pid_to_process(Pid) -> pid_to_process(&Pid)

Author: KronicDeth

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_empty_list_arguments.rs

@@ -34,7 +34,7 @@ fn without_loaded_module_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_empty_list_arguments/with_loaded_module.rs

@@ -34,7 +34,7 @@ fn without_exported_function_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_empty_list_arguments/with_loaded_module/with_exported_function.rs

@@ -31,7 +31,7 @@ fn with_arity_when_run_exits_normal() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));
@@ -79,7 +79,7 @@ fn without_arity_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_non_empty_proper_list_arguments.rs

@@ -36,7 +36,7 @@ fn without_loaded_module_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_non_empty_proper_list_arguments/with_loaded_module.rs

@@ -37,7 +37,7 @@ fn without_exported_function_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_non_empty_proper_list_arguments/with_loaded_module/with_exported_function.rs

@@ -40,7 +40,7 @@ fn without_arity_when_run_exits_undef() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/otp/erlang/spawn_3/test/with_atom_module/with_atom_function/with_non_empty_proper_list_arguments/with_loaded_module/with_exported_function/with_arity.rs

@@ -32,7 +32,7 @@ fn with_valid_arguments_when_run_exits_normal() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));
@@ -81,7 +81,7 @@ fn without_valid_arguments_when_run_exits() {
 
     assert_eq!(run_queue_length_after, run_queue_length_before + 1);
 
-    let arc_process = pid_to_process(child_pid_pid).unwrap();
+    let arc_process = pid_to_process(&child_pid_pid).unwrap();
 
     assert!(arc_scheduler.run_through(&arc_process));
     assert!(!arc_scheduler.run_through(&arc_process));

lumen_runtime/src/registry.rs

@@ -34,10 +34,10 @@ pub fn names(process_control_block: &ProcessControlBlock) -> exception::Result {
     Ok(acc)
 }
 
-pub fn pid_to_process(pid: Pid) -> Option<Arc<ProcessControlBlock>> {
+pub fn pid_to_process(pid: &Pid) -> Option<Arc<ProcessControlBlock>> {
     RW_LOCK_WEAK_PROCESS_CONTROL_BLOCK_BY_PID
         .read()
-        .get(&pid)
+        .get(pid)
         .and_then(|weak_process| weak_process.clone().upgrade())
 }
 
@@ -48,7 +48,7 @@ pub fn pid_to_self_or_process(
     if process_arc.pid() == pid {
         Some(process_arc.clone())
     } else {
-        pid_to_process(pid)
+        pid_to_process(&pid)
     }
 }
 

lumen_runtime/src/send.rs

@@ -65,7 +65,7 @@ pub fn send(
 
                 Ok(Sent::Sent)
             } else {
-                match pid_to_process(destination_pid) {
+                match pid_to_process(&destination_pid) {
                     Some(destination_arc_process_control_block) => {
                         if destination_arc_process_control_block.send_from_other(message)? {
                             let scheduler_id = destination_arc_process_control_block