Changeset 1757 for XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/context_server.hpp

Timestamp:

10/18/19 14:55:57 (5 years ago)

Author:

ymipsl

Message:

Implement one sided communication in client/server protocol to avoid dead-lock when some buffer are full.

YM

File:

• XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/context_server.hpp (modified) (5 diffs)

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

@@ -19 +19 @@
     bool listenPendingRequest(MPI_Status& status) ;
     void checkPendingRequest(void) ;
+    void getBufferFromClient(size_t timeLine) ;
     void processRequest(int rank, char* buff,int count) ;
     void processEvents(void) ;
@@ -25 +26 @@
     void setPendingEvent(void) ;
     bool hasPendingEvent(void) ;
-
+    bool isAttachedModeEnabled() const;
+    void releaseBuffers(void) ;
+    void notifyClientsFinalize(void) ;
+    
     MPI_Comm intraComm ;
     int intraCommSize ;
@@ -33 +37 @@
     int commSize ;
 
+    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,MPI_Request> pendingRequest ;
     map<int,char*> bufferRequest ;
@@ -44 +54 @@
     bool pendingEvent ;
     bool scheduled  ;    /*!< event of current timeline is alreading scheduled ? */
+    bool attachedMode ;  //! true if attached mode is enabled otherwise false
+    bool pureOneSided ; //!< if true, client will communicated with servers only trough one sided communication. Otherwise the hybrid mode P2P /One sided is used.
+         
     size_t hashId ;
 
@@ -50 +63 @@
     private:
       std::map<int, StdSize> mapBufferSize_;
+      vector<MPI_Win> windows ; //! one sided mpi windows to expose client buffers to servers ; No memory will be attached on server side.
+
   } ;