Changeset 1757 for XIOS/dev/dev_ym/XIOS_ONE_SIDED/src/buffer_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/buffer_server.hpp (modified) (3 diffs)

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

@@ -12 +12 @@
   {
     public:
-      CServerBuffer(StdSize bufSize) ;
+      CServerBuffer(vector<MPI_Win>& windows, vector<MPI_Aint>& winAddress, int windowsRank, StdSize bufSize) ;
       ~CServerBuffer() ;
 
@@ -18 +18 @@
       void* getBuffer(size_t count) ;
       void freeBuffer(size_t count) ;
-
+      void createWindows(MPI_Comm oneSidedComm) ;
+      bool freeWindows(void) ;
+      bool getBufferFromClient(size_t timeLine, char* & buffer, size_t& count) ;
+      bool isBufferEmpty(void) ;
+      void updateCurrentWindows(void) ;
+      void lockBuffer(void) ;
+      void unlockBuffer(void) ;
+      void notifyClientFinalize(void) ;
     private:
       char* buffer;
@@ -25 +32 @@
       size_t end;
       size_t size;
+      size_t used ;  // count of element occupied
+      std::vector<MPI_Win> windows_ ;
+      std::vector<MPI_Aint> winAddress_ ;
+
+      int currentWindows ;
+      bool hasWindows ;
+      int windowsRank_ ;
   };
 }