X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/cd077da6be23eb5a0682927d41d8fb104b846aea..8976bfbf1b73e13049d914169c672eabf7b63164:/src/msg/instr_msg_task.cpp diff --git a/src/msg/instr_msg_task.cpp b/src/msg/instr_msg_task.cpp index 39f0254631..7a146ac018 100644 --- a/src/msg/instr_msg_task.cpp +++ b/src/msg/instr_msg_task.cpp @@ -50,9 +50,9 @@ void TRACE_msg_task_execute_start(msg_task_t task) if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->pushEvent(MSG_get_clock(), process_container, "task_execute"); } } @@ -62,8 +62,9 @@ void TRACE_msg_task_execute_end(msg_task_t task) if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->popEvent(MSG_get_clock(), process_container); } } @@ -84,9 +85,9 @@ void TRACE_msg_task_get_start() if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->pushEvent(MSG_get_clock(), process_container, "receive"); } } @@ -96,13 +97,14 @@ void TRACE_msg_task_get_end(double start_time, msg_task_t task) if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->popEvent(MSG_get_clock(), process_container); 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(), simgrid::instr::Container::getRootContainer(), type, - process_container, "SR", key); + simgrid::instr::LinkType* link = + static_cast(simgrid::instr::Type::getRootType()->byName("MSG_PROCESS_TASK_LINK")); + link->endEvent(MSG_get_clock(), simgrid::instr::Container::getRootContainer(), process_container, "SR", key); } } @@ -113,14 +115,14 @@ int TRACE_msg_task_put_start(msg_task_t task) if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->pushEvent(MSG_get_clock(), process_container, "send"); 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(), simgrid::instr::Container::getRootContainer(), type, - process_container, "SR", key); + simgrid::instr::LinkType* link = + static_cast(simgrid::instr::Type::getRootType()->byName("MSG_PROCESS_TASK_LINK")); + link->startEvent(MSG_get_clock(), simgrid::instr::Container::getRootContainer(), process_container, "SR", key); } return 1; @@ -132,7 +134,8 @@ void TRACE_msg_task_put_end() if (TRACE_msg_process_is_enabled()){ 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); + simgrid::instr::StateType* state = + static_cast(process_container->type_->byName("MSG_PROCESS_STATE")); + state->popEvent(MSG_get_clock(), process_container); } }