Changeset 2246 for XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.hpp

Timestamp:

10/11/21 14:41:56 (3 years ago)

Author:

ymipsl

Message:

• Update of the tranfer protocol using one sided communication
• Introduce MPI_Improb/MPI_mrecv to listen incomming request
• Introducing latency when looping over managers

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.hpp (modified) (2 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.hpp

@@ -19 +19 @@
     bool eventLoop(bool enableEventsProcessing = true);
     void listen(void) ;
-    bool listenPendingRequest(MPI_Status& status) ;
+//    bool listenPendingRequest(MPI_Status& status) ;
+    bool listenPendingRequest(MPI_Message &message, MPI_Status& status) ;
+    void checkPendingProbe(void) ;
     void checkPendingRequest(void) ;
     void getBufferFromClient(size_t timeLine) ;
@@ -42 +44 @@
     MPI_Comm interCommMerged; //!< Communicator of the client group + server group (intraCommunicator) needed for one sided communication.
 
-    MPI_Comm commSelf; //!< Communicator of the server alone. Needed to create a new communicator between 1 proc client and 1 proc server for one sided communication
-
     map<int,CServerBuffer*> buffers ;
     map<int,size_t> lastTimeLine ; //!< last event time line for a processed request
     map<int,size_t>::iterator itLastTimeLine ; //!< iterator on lastTimeLine
+    map<int, list<std::pair<MPI_Message,MPI_Status> > > pendingProbe;
     map<int,MPI_Request> pendingRequest ;
     map<int,char*> bufferRequest ;