X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fc727903530d55d5d3f903a8213c7cb8a3273c7a..babdd699215108cc2d305e593f7e07a0fd5bf548:/src/msg/msg_process.c diff --git a/src/msg/msg_process.c b/src/msg/msg_process.c index 6e9a904896..2c03e8d345 100644 --- a/src/msg/msg_process.c +++ b/src/msg/msg_process.c @@ -51,6 +51,12 @@ void MSG_process_cleanup_from_SIMIX(smx_process_t smx_proc) msg_global->process_data_cleanup(msg_proc->data); } + // remove the process from its virtual machine + if (msg_proc->vm) { + int pos = xbt_dynar_search(msg_proc->vm->processes,&smx_proc); + xbt_dynar_remove_at(msg_proc->vm->processes,pos, NULL); + } + // free the MSG process xbt_free(msg_proc); } @@ -63,8 +69,9 @@ void MSG_process_create_from_SIMIX(smx_process_t* process, const char *name, { m_host_t host = MSG_get_host_by_name(hostname); m_process_t p = MSG_process_create_with_environment(name, code, data, - host, kill_time, argc, argv, + host, argc, argv, properties); + MSG_process_set_kill_time(p,kill_time); *((m_process_t*) process) = p; } @@ -79,7 +86,7 @@ m_process_t MSG_process_create(const char *name, xbt_main_func_t code, void *data, m_host_t host) { - return MSG_process_create_with_environment(name, code, data, host, -1, -1, + return MSG_process_create_with_environment(name, code, data, host, -1, NULL, NULL); } @@ -113,7 +120,7 @@ m_process_t MSG_process_create_with_arguments(const char *name, void *data, m_host_t host, int argc, char **argv) { - return MSG_process_create_with_environment(name, code, data, host, -1.0, + return MSG_process_create_with_environment(name, code, data, host, argc, argv, NULL); } @@ -136,7 +143,6 @@ m_process_t MSG_process_create_with_arguments(const char *name, object. It is for user-level information and can be NULL. It can be retrieved with the function \ref MSG_process_get_data. * \param host the location where the new process is executed. - * \param kill_time the time when the process is killed. * \param argc first argument passed to \a code * \param argv second argument passed to \a code * \param properties list a properties defined for this process @@ -146,7 +152,6 @@ m_process_t MSG_process_create_with_arguments(const char *name, m_process_t MSG_process_create_with_environment(const char *name, xbt_main_func_t code, void *data, m_host_t host, - double kill_time, int argc, char **argv, xbt_dict_t properties) { @@ -176,7 +181,7 @@ m_process_t MSG_process_create_with_environment(const char *name, /* Let's create the process: SIMIX may decide to start it right now, * even before returning the flow control to us */ - simcall_process_create(&process, name, code, simdata, SIMIX_host_get_name(host->smx_host), kill_time, + simcall_process_create(&process, name, code, simdata, SIMIX_host_get_name(host->smx_host), -1, argc, argv, properties); if (!process) { @@ -315,6 +320,18 @@ xbt_dynar_t MSG_processes_as_dynar(void) { return SIMIX_processes_as_dynar(); } +/** \ingroup m_process_management + * \brief Set the kill time of a process. + * + * \param process a process + * \param kill_time the time when the process is killed. + */ +MSG_error_t MSG_process_set_kill_time(m_process_t process, double kill_time) +{ + simcall_process_set_kill_time(process,kill_time); + return MSG_OK; +} + /** \ingroup m_process_management * \brief Returns the process ID of \a process. *