X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/19b3962253112b19308537bc2400de141c119d99..4bd1f48f0bf1ad1703be680ec2a38d626c6a2668:/src/msg/instr_msg_process.cpp diff --git a/src/msg/instr_msg_process.cpp b/src/msg/instr_msg_process.cpp index 9d695b55a1..9b5fc3b618 100644 --- a/src/msg/instr_msg_process.cpp +++ b/src/msg/instr_msg_process.cpp @@ -12,7 +12,7 @@ XBT_LOG_NEW_DEFAULT_SUBCATEGORY (instr_msg_process, instr, "MSG process"); char *instr_process_id (msg_process_t proc, char *str, int len) { - return instr_process_id_2 (proc->cname(), proc->pid(), str, len); + return instr_process_id_2(proc->getCname(), proc->getPid(), str, len); } char *instr_process_id_2 (const char *process_name, int process_pid, char *str, int len) @@ -24,7 +24,7 @@ char *instr_process_id_2 (const char *process_name, int process_pid, char *str, /* * Instrumentation functions to trace MSG processes (msg_process_t) */ -void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, msg_host_t new_host) +void TRACE_msg_process_change_host(msg_process_t process, msg_host_t new_host) { if (TRACE_msg_process_is_enabled()){ static long long int counter = 0; @@ -37,8 +37,8 @@ void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, m //start link container_t msg = PJ_container_get (instr_process_id(process, str, len)); - type_t type = PJ_type_get ("MSG_PROCESS_LINK", PJ_type_get_root()); - new StartLinkEvent (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key); + simgrid::instr::Type* type = PJ_type_get("MSG_PROCESS_LINK", PJ_type_get_root()); + new simgrid::instr::StartLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key); //destroy existing container of this process TRACE_msg_process_destroy (MSG_process_get_name (process), MSG_process_get_PID (process)); @@ -49,7 +49,7 @@ void TRACE_msg_process_change_host(msg_process_t process, msg_host_t old_host, m //end link msg = PJ_container_get(instr_process_id(process, str, len)); type = PJ_type_get ("MSG_PROCESS_LINK", PJ_type_get_root()); - new EndLinkEvent (MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key); + new simgrid::instr::EndLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, msg, "M", key); } } @@ -59,8 +59,9 @@ void TRACE_msg_process_create (const char *process_name, int process_pid, msg_ho int len = INSTR_DEFAULT_STR_SIZE; char str[INSTR_DEFAULT_STR_SIZE]; - container_t host_container = PJ_container_get(host->cname()); - PJ_container_new(instr_process_id_2(process_name, process_pid, str, len), INSTR_MSG_PROCESS, host_container); + container_t host_container = PJ_container_get(host->getCname()); + PJ_container_new(instr_process_id_2(process_name, process_pid, str, len), simgrid::instr::INSTR_MSG_PROCESS, + host_container); } } @@ -82,7 +83,7 @@ void TRACE_msg_process_kill(smx_process_exit_status_t status, msg_process_t proc { if (TRACE_msg_process_is_enabled() && status==SMX_EXIT_FAILURE){ //kill means that this process no longer exists, let's destroy it - TRACE_msg_process_destroy(process->cname(), process->pid()); + TRACE_msg_process_destroy(process->getCname(), process->getPid()); } } @@ -93,9 +94,9 @@ void TRACE_msg_process_suspend(msg_process_t process) char str[INSTR_DEFAULT_STR_SIZE]; container_t process_container = PJ_container_get (instr_process_id(process, str, len)); - type_t type = PJ_type_get ("MSG_PROCESS_STATE", process_container->type); - val_t value = PJ_value_get ("suspend", type); - new PushStateEvent (MSG_get_clock(), process_container, type, value); + simgrid::instr::Type* type = PJ_type_get("MSG_PROCESS_STATE", process_container->type_); + simgrid::instr::Value* val = simgrid::instr::Value::get("suspend", type); + new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val); } } @@ -106,8 +107,8 @@ void TRACE_msg_process_resume(msg_process_t process) char str[INSTR_DEFAULT_STR_SIZE]; container_t process_container = PJ_container_get (instr_process_id(process, str, len)); - type_t type = PJ_type_get ("MSG_PROCESS_STATE", process_container->type); - new PopStateEvent (MSG_get_clock(), process_container, type); + simgrid::instr::Type* type = PJ_type_get("MSG_PROCESS_STATE", process_container->type_); + new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type); } } @@ -118,9 +119,9 @@ void TRACE_msg_process_sleep_in(msg_process_t process) char str[INSTR_DEFAULT_STR_SIZE]; container_t process_container = PJ_container_get (instr_process_id(process, str, len)); - type_t type = PJ_type_get ("MSG_PROCESS_STATE", process_container->type); - val_t value = PJ_value_get ("sleep", type); - new PushStateEvent (MSG_get_clock(), process_container, type, value); + simgrid::instr::Type* type = PJ_type_get("MSG_PROCESS_STATE", process_container->type_); + simgrid::instr::Value* val = simgrid::instr::Value::get("sleep", type); + new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val); } } @@ -131,7 +132,7 @@ void TRACE_msg_process_sleep_out(msg_process_t process) char str[INSTR_DEFAULT_STR_SIZE]; container_t process_container = PJ_container_get (instr_process_id(process, str, len)); - type_t type = PJ_type_get ("MSG_PROCESS_STATE", process_container->type); - new PopStateEvent (MSG_get_clock(), process_container, type); + simgrid::instr::Type* type = PJ_type_get("MSG_PROCESS_STATE", process_container->type_); + new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type); } }