Changeset 2547 for XIOS3/trunk/src/transport/legacy_context_client.hpp

Timestamp:

08/29/23 17:24:04 (10 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/transport/legacy_context_client.hpp (modified) (4 diffs)

XIOS3/trunk/src/transport/legacy_context_client.hpp

@@ -11 +11 @@
 #include "registry.hpp"
 #include "context_client.hpp"
+#include "window_dynamic.hpp"
 
 namespace xios
@@ -48 +49 @@
       void getBuffers(const size_t timeLine, const list<int>& serverList, const list<int>& sizeList, list<CBufferOut*>& retBuffers);
       void newBuffer(int rank);
-      void checkAttachWindows(CClientBuffer* buffer , int rank) ;
+      bool checkAttachWindows(CClientBuffer* buffer , int rank, map<int,MPI_Request>& attachList) ;
       bool checkBuffers(list<int>& ranks);
       bool checkBuffers(void);
       void callGlobalEventLoop() ;
+      void yield(void) ;
+      void synchronize(void) ;
       bool havePendingRequests(list<int>& ranks) ;
       void setGrowableBuffer(void) { isGrowableBuffer_=true;}
@@ -76 +79 @@
 
       std::map<int, MPI_Comm> winComm_ ; //! Window communicators
-      std::map<int, std::vector<MPI_Win> >windows_ ; //! one sided mpi windows to expose client buffers to servers == windows[nbServers][2]
+      std::map<int, std::vector<CWindowDynamic*> >windows_ ; //! one sided mpi windows to expose client buffers to servers == windows[nbServers][2]
       bool isGrowableBuffer_ = true ;
 
@@ -82 +85 @@
 
       bool locked_ = false ; //!< The context client is locked to avoid recursive checkBuffer
+      shared_ptr<CEventScheduler> eventScheduler_ ;
   };
 }