Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
More aid_t.
authorArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Tue, 20 Apr 2021 07:19:32 +0000 (09:19 +0200)
committerArnaud Giersch <arnaud.giersch@univ-fcomte.fr>
Tue, 20 Apr 2021 09:01:33 +0000 (11:01 +0200)
src/smpi/internals/smpi_replay.cpp
src/smpi/mpi/smpi_win.cpp

index 0965e9e..f37bebe 100644 (file)
@@ -480,7 +480,7 @@ void RecvAction::kernel(simgrid::xbt::ReplayAction&)
 
   TRACE_smpi_comm_out(get_pid());
   if (is_recv && not TRACE_smpi_view_internals()) {
-    int src_traced = MPI_COMM_WORLD->group()->actor(status.MPI_SOURCE);
+    aid_t src_traced = MPI_COMM_WORLD->group()->actor(status.MPI_SOURCE);
     TRACE_smpi_recv(src_traced, get_pid(), args.tag);
   }
 }
index 3005236..fa51e44 100644 (file)
@@ -672,7 +672,7 @@ int Win::finish_comms(int rank){
   // because we only wait for requests that we are responsible for.
   // Also use the process id here since the request itself returns from src()
   // and dst() the process id, NOT the rank (which only exists in the context of a communicator).
-  int proc_id = comm_->group()->actor(rank);
+  aid_t proc_id = comm_->group()->actor(rank);
   auto it     = std::stable_partition(begin(requests_), end(requests_), [proc_id](const MPI_Request& req) {
     return (req == MPI_REQUEST_NULL || (req->src() != proc_id && req->dst() != proc_id));
   });