X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d2d824f563b6a7cc2fb7c8d618c893c8084ab334..172a73b13fe909117c7fbf3d69d4ce5e87efdbc6:/src/msg/instr_msg_task.cpp diff --git a/src/msg/instr_msg_task.cpp b/src/msg/instr_msg_task.cpp index 369aa77244..8d2f0782cf 100644 --- a/src/msg/instr_msg_task.cpp +++ b/src/msg/instr_msg_task.cpp @@ -49,13 +49,10 @@ void TRACE_msg_task_execute_start(msg_task_t task) XBT_DEBUG("EXEC,in %p, %lld, %s", task, task->counter, task->category); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); - simgrid::instr::Value* val = simgrid::instr::Value::byName("task_execute", type); - new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* state = process_container->type_->byName("MSG_PROCESS_STATE"); + simgrid::instr::Value* val = state->getEntityValue("task_execute"); + new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, state, val); } } @@ -64,11 +61,8 @@ void TRACE_msg_task_execute_end(msg_task_t task) XBT_DEBUG("EXEC,out %p, %lld, %s", task, task->counter, task->category); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* type = process_container->type_->byName("MSG_PROCESS_STATE"); new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type); } } @@ -89,13 +83,10 @@ void TRACE_msg_task_get_start() XBT_DEBUG("GET,in"); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); - simgrid::instr::Value* val = simgrid::instr::Value::byName("receive", type); - new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* state = process_container->type_->byName("MSG_PROCESS_STATE"); + simgrid::instr::Value* val = state->getEntityValue("receive"); + new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, state, val); } } @@ -104,16 +95,12 @@ void TRACE_msg_task_get_end(double start_time, msg_task_t task) XBT_DEBUG("GET,out %p, %lld, %s", task, task->counter, task->category); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* type = process_container->type_->byName("MSG_PROCESS_STATE"); new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type); - char key[INSTR_DEFAULT_STR_SIZE]; - snprintf (key, INSTR_DEFAULT_STR_SIZE, "p%lld", task->counter); - type = PJ_type_get_root()->getChild("MSG_PROCESS_TASK_LINK"); + std::string key = std::string("p") + std::to_string(task->counter); + type = simgrid::instr::Type::getRootType()->byName("MSG_PROCESS_TASK_LINK"); new simgrid::instr::EndLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, process_container, "SR", key); } } @@ -124,17 +111,13 @@ int TRACE_msg_task_put_start(msg_task_t task) XBT_DEBUG("PUT,in %p, %lld, %s", task, task->counter, task->category); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); - simgrid::instr::Value* val = simgrid::instr::Value::byName("send", type); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* type = process_container->type_->byName("MSG_PROCESS_STATE"); + simgrid::instr::Value* val = type->getEntityValue("send"); new simgrid::instr::PushStateEvent(MSG_get_clock(), process_container, type, val); - char key[INSTR_DEFAULT_STR_SIZE]; - snprintf (key, INSTR_DEFAULT_STR_SIZE, "p%lld", task->counter); - type = PJ_type_get_root()->getChild("MSG_PROCESS_TASK_LINK"); + std::string key = std::string("p") + std::to_string(task->counter); + type = simgrid::instr::Type::getRootType()->byName("MSG_PROCESS_TASK_LINK"); new simgrid::instr::StartLinkEvent(MSG_get_clock(), PJ_container_get_root(), type, process_container, "SR", key); } @@ -146,11 +129,8 @@ void TRACE_msg_task_put_end() XBT_DEBUG("PUT,out"); if (TRACE_msg_process_is_enabled()){ - int len = INSTR_DEFAULT_STR_SIZE; - char str[INSTR_DEFAULT_STR_SIZE]; - - container_t process_container = PJ_container_get (instr_process_id(MSG_process_self(), str, len)); - simgrid::instr::Type* type = process_container->type_->getChild("MSG_PROCESS_STATE"); + container_t process_container = simgrid::instr::Container::byName(instr_process_id(MSG_process_self())); + simgrid::instr::Type* type = process_container->type_->byName("MSG_PROCESS_STATE"); new simgrid::instr::PopStateEvent(MSG_get_clock(), process_container, type); } }