Changeset 2524

Timestamp:

06/23/23 16:22:08 (19 months ago)

Author:

jderouillat

Message:

Replace MPI probing on intercommunicator by probing on intracommunicator for one_sided transport_protocol

Location:

XIOS3/branches/xios-3.0-beta/src/transport

Files:

• one_sided_client_buffer.cpp (modified) (4 diffs)
• one_sided_client_buffer.hpp (modified) (1 diff)
• one_sided_context_server.cpp (modified) (1 diff)

XIOS3/branches/xios-3.0-beta/src/transport/one_sided_client_buffer.cpp

@@ -8 +8 @@
   extern CLogType logProtocol;
 
-  COneSidedClientBuffer::COneSidedClientBuffer(MPI_Comm& interComm, int serverRank, MPI_Comm& commSelf, MPI_Comm& interCommMerged, int intraServerRank) : interComm_(interComm), serverRank_(serverRank)
+  COneSidedClientBuffer::COneSidedClientBuffer(MPI_Comm& interComm, int serverRank, MPI_Comm& commSelf, MPI_Comm& interCommMerged, int intraServerRank) : interComm_(interComm), serverRank_(serverRank), interCommMerged_(interCommMerged), intraServerRank_(intraServerRank)
   {
     
@@ -261 +261 @@
     }
     if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").resume() ;
-    MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, serverRank_, 20, interComm_, &request.mpiRequest ) ;
+    MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_, &request.mpiRequest ) ;
     if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").suspend() ;
     info(logProtocol)<<outStr.str()<<endl ;
@@ -272 +272 @@
     request.buffer = new CBufferOut(sizeof(EVENT_BUFFER_RESIZE)+sizeof(timeline)+sizeof(size)) ; 
     *(request.buffer)<<EVENT_BUFFER_RESIZE<<timeline<<size ;
-    MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, serverRank_, 20, interComm_, &request.mpiRequest ) ;
+    MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_, &request.mpiRequest ) ;
     requests_.push_back(request) ;
   }
@@ -280 +280 @@
     MPI_Aint controlAddr ;
     MPI_Get_address(control_, &controlAddr) ;
-    MPI_Send(&controlAddr, 1, MPI_AINT, serverRank_, 20, interComm_) ;
+    MPI_Send(&controlAddr, 1, MPI_AINT, intraServerRank_, 20, interCommMerged_) ;
   }
 

XIOS3/branches/xios-3.0-beta/src/transport/one_sided_client_buffer.hpp

@@ -182 +182 @@
       int serverRank_ ;
 
+      MPI_Comm interCommMerged_; 
+      int intraServerRank_ ;
+
       std::list<CBuffer*> buffers_ ;
       std::list<SBloc> blocs_ ;

XIOS3/branches/xios-3.0-beta/src/transport/one_sided_context_server.cpp

@@ -98 +98 @@
     {
       traceOff();
-      MPI_Iprobe(MPI_ANY_SOURCE, 20,interComm, &flag, &status);
+      MPI_Iprobe(MPI_ANY_SOURCE, 20,interCommMerged_, &flag, &status);
       traceOn();
       if (flag==true)
       {
-        requests_.push_back(CRequest(interComm, status)) ;
+        requests_.push_back(CRequest(interCommMerged_, status)) ;
         if (requests_.back().test()) 
         {