X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/611d822b02f836d7abe031cced6adc4281ef4356..895710d49f77179d9893bc76b3e31b69fae638af:/src/smpi/bindings/smpi_pmpi.cpp diff --git a/src/smpi/bindings/smpi_pmpi.cpp b/src/smpi/bindings/smpi_pmpi.cpp index 10a3936550..b6dfc7e916 100644 --- a/src/smpi/bindings/smpi_pmpi.cpp +++ b/src/smpi/bindings/smpi_pmpi.cpp @@ -28,7 +28,7 @@ void TRACE_smpi_set_category(const char *category) int PMPI_Init(int *argc, char ***argv) { - xbt_assert(simgrid::s4u::Engine::isInitialized(), + xbt_assert(simgrid::s4u::Engine::is_initialized(), "Your MPI program was not properly initialized. The easiest is to use smpirun to start it."); // PMPI_Init is called only once per SMPI process int already_init; @@ -36,11 +36,12 @@ int PMPI_Init(int *argc, char ***argv) if(already_init == 0){ simgrid::smpi::Process::init(argc, argv); smpi_process()->mark_as_initialized(); - int rank = simgrid::s4u::this_actor::getPid(); + int rank = simgrid::s4u::this_actor::get_pid(); TRACE_smpi_init(rank); TRACE_smpi_comm_in(rank, __func__, new simgrid::instr::NoOpTIData("init")); TRACE_smpi_comm_out(rank); TRACE_smpi_computing_init(rank); + TRACE_smpi_sleeping_init(rank); smpi_bench_begin(); } @@ -52,7 +53,7 @@ int PMPI_Init(int *argc, char ***argv) int PMPI_Finalize() { smpi_bench_end(); - int rank = simgrid::s4u::this_actor::getPid(); + int rank = simgrid::s4u::this_actor::get_pid(); TRACE_smpi_comm_in(rank, __func__, new simgrid::instr::NoOpTIData("finalize")); smpi_process()->finalize(); @@ -108,7 +109,7 @@ int PMPI_Is_thread_main(int *flag) if (flag == nullptr) { return MPI_ERR_ARG; } else { - *flag = simgrid::s4u::this_actor::getPid() == + *flag = simgrid::s4u::this_actor::get_pid() == 1; // FIXME: I don't think this is correct: This just returns true if the process ID is 1, // regardless of whether this process called MPI_Thread_Init() or not. return MPI_SUCCESS; @@ -120,7 +121,7 @@ int PMPI_Abort(MPI_Comm /*comm*/, int /*errorcode*/) smpi_bench_end(); // FIXME: should kill all processes in comm instead smx_actor_t process = SIMIX_process_self(); - simgrid::simix::kernelImmediate([process] { SIMIX_process_kill(process, process); }); + simgrid::simix::simcall([process] { SIMIX_process_kill(process, process); }); return MPI_SUCCESS; }