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

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

@@ -14 +14 @@
       static size_t maxRequestSize;
 
-      CClientBuffer(MPI_Comm intercomm, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize, StdSize maxBufferedEvents);
+      CClientBuffer(MPI_Comm intercomm, vector<MPI_Win>& windows, int clientRank, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize);
       ~CClientBuffer();
-
+//      void createWindows(MPI_Comm oneSidedComm) ;
+      void freeWindows(void) ;
+      void lockBuffer(void) ;
+      void unlockBuffer(void) ;
+      
       bool isBufferFree(StdSize size);
-      CBufferOut* getBuffer(StdSize size);
-      bool checkBuffer(void);
+      CBufferOut* getBuffer(size_t timeLine, StdSize size);
+      bool checkBuffer(bool send=false);
       bool hasPendingRequest(void);
       StdSize remain(void);
-
+      MPI_Aint getWinAddress(int numWindows) ;
+      void infoBuffer(void) ;
+      bool isNotifiedFinalized(void) ;
     private:
       char* buffer[2];
-
+      char* bufferHeader[2];
+      size_t* firstTimeLine[2] ;
+      size_t* bufferCount[2] ;
+      size_t* control[2] ;
+      size_t* finalize[2] ;
+      bool winState[2] ;
       int current;
 
       StdSize count;
-      StdSize bufferedEvents;
       StdSize maxEventSize;
-      const StdSize maxBufferedEvents;
       const StdSize bufferSize;
       const StdSize estimatedMaxEventSize;
@@ -37 +46 @@
 
       const int serverRank;
+      const int clientRank_;
       bool pending;
 
@@ -43 +53 @@
       CBufferOut* retBuffer;
       const MPI_Comm interComm;
+      std::vector<MPI_Win> windows_ ;
+      bool hasWindows ;
+      static const int headerSize=4*sizeof(size_t);
   };
 }