Changeset 2019 for XIOS/dev/dev_trunk_graph/src/context_server.hpp

Timestamp:

01/22/21 12:00:29 (3 years ago)

Author:

yushan

Message:

Graph intermedia commit to a tmp branch

File:

• XIOS/dev/dev_trunk_graph/src/context_server.hpp (modified) (6 diffs)

XIOS/dev/dev_trunk_graph/src/context_server.hpp

@@ -5 +5 @@
 #include "buffer_server.hpp"
 #include "mpi.hpp"
+#include "event_scheduler.hpp"
 
 namespace xios
 {
   class CContext ;
+  class CContextClient;
 
   class CContextServer
@@ -19 +21 @@
     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 +28 @@
     void setPendingEvent(void) ;
     bool hasPendingEvent(void) ;
-
+    bool isAttachedModeEnabled() const;
+    void releaseBuffers(void) ;
+    void notifyClientsFinalize(void) ;
+    
     MPI_Comm intraComm ;
     int intraCommSize ;
@@ -33 +39 @@
     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 +56 @@
     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 ;
+
+    void setAssociatedClient(CContextClient* associatedClient) {associatedClient_=associatedClient ;}
+    CContextClient* getAssociatedClient(void) { return associatedClient_ ;}
 
     ~CContextServer() ;
@@ -50 +68 @@
     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.
+      CEventScheduler* eventScheduler_ ;
+      bool isProcessingEvent_ ;
+      CContextClient* associatedClient_ ;
   } ;