X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f409d6f711ba652a6fd78e185791cf7870b6765d..b372d23d3d8818b4547ef207f43b45709298a002:/src/instr/instr_platform.cpp diff --git a/src/instr/instr_platform.cpp b/src/instr/instr_platform.cpp index 287d5315a6..c8936419b4 100644 --- a/src/instr/instr_platform.cpp +++ b/src/instr/instr_platform.cpp @@ -465,31 +465,33 @@ void define_callbacks() }); s4u::Actor::on_wake_up.connect( [](s4u::Actor const& actor) { Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->pop_event(); }); - s4u::Exec::on_start.connect([](simgrid::s4u::Actor const& actor, s4u::Exec const&) { - Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->push_event("execute"); + s4u::Exec::on_start.connect([](s4u::Exec const&) { + Container::by_name(instr_pid(*s4u::Actor::self()))->get_state("ACTOR_STATE")->push_event("execute"); }); - s4u::Exec::on_completion.connect([](s4u::Actor const& actor, s4u::Exec const&) { - Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->pop_event(); + s4u::Exec::on_completion.connect([](s4u::Exec const&) { + Container::by_name(instr_pid(*s4u::Actor::self()))->get_state("ACTOR_STATE")->pop_event(); }); - s4u::Comm::on_sender_start.connect([](s4u::Actor const& actor) { - Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->push_event("send"); + s4u::Comm::on_start.connect([](s4u::Comm const&, bool is_sender) { + Container::by_name(instr_pid(*s4u::Actor::self())) + ->get_state("ACTOR_STATE") + ->push_event(is_sender ? "send" : "receive"); }); - s4u::Comm::on_receiver_start.connect([](s4u::Actor const& actor) { - Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->push_event("receive"); + s4u::Comm::on_completion.connect([](s4u::Comm const&) { + Container::by_name(instr_pid(*s4u::Actor::self()))->get_state("ACTOR_STATE")->pop_event(); }); - s4u::Comm::on_completion.connect( - [](s4u::Actor const& actor) { Container::by_name(instr_pid(actor))->get_state("ACTOR_STATE")->pop_event(); }); s4u::Actor::on_host_change.connect(on_actor_host_change); } if (TRACE_smpi_is_enabled() && TRACE_smpi_is_computing()) { - s4u::Exec::on_start.connect([](simgrid::s4u::Actor const& actor, s4u::Exec const& exec) { - Container::by_name(std::string("rank-") + std::to_string(actor.get_pid())) + s4u::Exec::on_start.connect([](s4u::Exec const& exec) { + Container::by_name(std::string("rank-") + std::to_string(s4u::Actor::self()->get_pid())) ->get_state("MPI_STATE") ->push_event("computing", new CpuTIData("compute", exec.get_cost())); }); - s4u::Exec::on_completion.connect([](s4u::Actor const& actor, s4u::Exec const&) { - Container::by_name(std::string("rank-") + std::to_string(actor.get_pid()))->get_state("MPI_STATE")->pop_event(); + s4u::Exec::on_completion.connect([](s4u::Exec const&) { + Container::by_name(std::string("rank-") + std::to_string(s4u::Actor::self()->get_pid())) + ->get_state("MPI_STATE") + ->pop_event(); }); }