X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0f9e7b8886836bb988bac7570cdf9405e54d0ac4..b60aef4e2fea329ccaf96986006bdded72a61113:/src/instr/instr_msg_process.c diff --git a/src/instr/instr_msg_process.c b/src/instr/instr_msg_process.c index 9c4866ce2c..365651cb2e 100644 --- a/src/instr/instr_msg_process.c +++ b/src/instr/instr_msg_process.c @@ -20,7 +20,12 @@ void TRACE_msg_set_process_category(m_process_t process, const char *category, c char *instr_process_id (m_process_t proc, char *str, int len) { - snprintf (str, len, "%s-%d", MSG_process_get_name(proc), MSG_process_get_PID(proc)); + return instr_process_id_2 (MSG_process_get_name(proc), MSG_process_get_PID(proc), str, len); +} + +char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len) +{ + snprintf (str, len, "%s-%d", process_name, process_pid); return str; } @@ -50,7 +55,8 @@ void TRACE_msg_process_change_host(m_process_t process, m_host_t old_host, m_hos //set the state of this new container type = getType ("MSG_PROCESS_STATE", msg->type); - new_pajeSetState (MSG_get_clock(), msg, type, "executing"); + val_t value = getValueByName ("executing", type); + new_pajeSetState (MSG_get_clock(), msg, type, value); //end link msg = getContainer(instr_process_id(process, str, len)); @@ -59,18 +65,18 @@ void TRACE_msg_process_change_host(m_process_t process, m_host_t old_host, m_hos } } -void TRACE_msg_process_create (m_process_t process) +void TRACE_msg_process_create (const char *process_name, int process_pid, m_host_t host) { if (TRACE_msg_process_is_enabled()){ int len = INSTR_DEFAULT_STR_SIZE; char str[INSTR_DEFAULT_STR_SIZE]; - m_host_t host = MSG_process_get_host(process); container_t host_container = getContainer(host->name); - container_t msg = newContainer(instr_process_id(process, str, len), INSTR_MSG_PROCESS, host_container); + container_t msg = newContainer(instr_process_id_2(process_name, process_pid, str, len), INSTR_MSG_PROCESS, host_container); type_t type = getType ("MSG_PROCESS_STATE", msg->type); - new_pajeSetState (MSG_get_clock(), msg, type, "executing"); + val_t value = getValueByName ("executing", type); + new_pajeSetState (MSG_get_clock(), msg, type, value); } } @@ -93,7 +99,8 @@ void TRACE_msg_process_suspend(m_process_t process) container_t process_container = getContainer (instr_process_id(process, str, len)); type_t type = getType ("MSG_PROCESS_STATE", process_container->type); - new_pajePushState (MSG_get_clock(), process_container, type, "suspend"); + val_t value = getValueByName ("suspend", type); + new_pajePushState (MSG_get_clock(), process_container, type, value); } } @@ -117,7 +124,8 @@ void TRACE_msg_process_sleep_in(m_process_t process) container_t process_container = getContainer (instr_process_id(process, str, len)); type_t type = getType ("MSG_PROCESS_STATE", process_container->type); - new_pajePushState (MSG_get_clock(), process_container, type, "sleep"); + val_t value = getValueByName ("sleep", type); + new_pajePushState (MSG_get_clock(), process_container, type, value); } }