Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
further untangle the msg_process creation by using a default value for auto_restart
[simgrid.git] / src / msg / msg_process.cpp
index e8cb1c5bd76788a1c3dcdef558ce560c8a37b1ef..1c366886bbdfc044cbe4a96aebf4857b885a68ff 100644 (file)
@@ -51,12 +51,9 @@ void MSG_process_cleanup_from_SIMIX(smx_actor_t smx_actor)
 
 /* This function creates a MSG process. It has the prototype enforced by SIMIX_function_register_process_create */
 smx_actor_t MSG_process_create_from_SIMIX(const char* name, std::function<void()> code, void* data, sg_host_t host,
-                                          xbt_dict_t properties, int auto_restart, smx_actor_t parent_process)
+                                          xbt_dict_t properties, smx_actor_t parent_process)
 {
   msg_process_t p = MSG_process_create_with_environment(name, std::move(code), data, host, properties);
-  if (p) {
-    MSG_process_auto_restart_set(p,auto_restart);
-  }
   return p;
 }
 
@@ -140,17 +137,14 @@ msg_process_t MSG_process_create_with_environment(
   xbt_assert(code != nullptr && host != nullptr, "Invalid parameters: host and code params must not be nullptr");
   MsgActorExt* msgExt = new MsgActorExt(data);
 
-  /* Let's create the process: SIMIX may decide to start it right now,
-   * even before returning the flow control to us */
-  msg_process_t process = simcall_process_create(name, std::move(code), msgExt, host, properties, 0);
+  msg_process_t process = simcall_process_create(name, std::move(code), msgExt, host, properties);
 
   if (!process) { /* Undo everything */
     delete msgExt;
     return nullptr;
   }
-  else {
-    simcall_process_on_exit(process,(int_f_pvoid_pvoid_t)TRACE_msg_process_kill,process);
-  }
+
+  simcall_process_on_exit(process, (int_f_pvoid_pvoid_t)TRACE_msg_process_kill, process);
   return process;
 }