Changeset 2547 for XIOS3/trunk/src/buffer_client.hpp

Timestamp:

08/29/23 17:24:04 (9 months ago)

Author:

ymipsl

Message:

Major update :

• New method to lock and unlock one-sided windows (window_dynamic) to avoid network overhead
• Introducing multithreading on server sided to manage more efficiently dead-lock occuring (similar to co-routine which will be available and implemented in futur c++ standard), based on c++ threads
• Suprression of old "attached mode" which is replaced by online writer and reder filters

YM

File:

• XIOS3/trunk/src/buffer_client.hpp (modified) (6 diffs)

XIOS3/trunk/src/buffer_client.hpp

@@ -7 +7 @@
 #include "mpi.hpp"
 #include "cxios.hpp"
+#include "window_dynamic.hpp"
 
 namespace xios
@@ -15 +16 @@
       static size_t maxRequestSize;
 
-      CClientBuffer(MPI_Comm intercomm, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize);
+      CClientBuffer(MPI_Comm intercomm, int serverRank, StdSize bufferSize, bool hasWindows);
       ~CClientBuffer();
 //      void createWindows(MPI_Comm oneSidedComm) ;
@@ -28 +29 @@
       StdSize remain(void);
       MPI_Aint getWinAddress(int numWindows) ;
+      MPI_Aint getWinBufferAddress(int numWindows) ;
       void infoBuffer(void) ;
       bool isNotifiedFinalized(void) ;
@@ -33 +35 @@
       void fixBufferSize(size_t bufferSize) { newBufferSize_=bufferSize ; isGrowableBuffer_=false ; resizingBufferStep_=1 ;}
       void fixBuffer(void) { isGrowableBuffer_=false ;}
-      void attachWindows(vector<MPI_Win>& windows) ;
+      void attachWindows(MPI_Comm& winComm) ;
       bool isAttachedWindows(void) { return isAttachedWindows_ ;}
     private:
@@ -58 +60 @@
       StdSize maxEventSize;
       StdSize bufferSize;
-      const StdSize estimatedMaxEventSize;
       bool isFinalized_=false ;
 
@@ -69 +70 @@
       CBufferOut* retBuffer;
       const MPI_Comm interComm;
-      std::vector<MPI_Win> windows_ ;
-      bool hasWindows=false ;
+      std::vector<CWindowDynamic*> windows_ ;
+      bool hasWindows_=false ;
       bool isAttachedWindows_=false ;
       double latency_=0 ;