Changeset 2406 for XIOS3/trunk/src/node/context.hpp

Timestamp:

09/20/22 16:37:37 (21 months ago)

Author:

ymipsl

Message:

Refactor management of client context and server context.
YM

File:

• XIOS3/trunk/src/node/context.hpp (modified) (4 diffs)

XIOS3/trunk/src/node/context.hpp

@@ -160 +160 @@
          // Distribute files (in write mode) among secondary-server pools according to the estimated data flux
          void distributeFiles(const std::vector<CFile*>& files);
-         void distributeFileOverBandwith(const std::vector<CFile*>& files) ;
-         void distributeFileOverMemoryBandwith(const std::vector<CFile*>& files) ;
+         void distributeFileOverOne(const vector<CFile*>& files) ; //!< Distribute files over one single server (no distribution)
+         void distributeFileOverBandwith(const std::vector<CFile*>& files) ; //!< Distribute files overs servers to balance the I/O bandwith
+         void distributeFileOverMemoryBandwith(const std::vector<CFile*>& files) ; //!< Distribute files overs servers to minimize the memory consumption
          
+       public:
          // Send context close definition
-         void sendCloseDefinition(void);
-       public:
          void sendCloseDefinition(CContextClient* client) ;
        private:
@@ -223 +223 @@
        public:  
         void freeComms(void);                  //!< Free internally allcoated communicators
-        void releaseClientBuffers(void);       //! Deallocate buffers allocated by clientContexts
 
          // dispatch event
@@ -309 +308 @@
          bool hasServer;
 
-         CContextServer* server;    //!< Concrete context server
-         CContextClient* client;    //!< Concrete contex client
+      private:
          std::vector<CContextServer*> serverPrimServer;
          std::vector<CContextClient*> clientPrimServer;
@@ -321 +319 @@
         std::string defaultWriterId ;
         std::string defaultGathererId ;
+
+        std::vector<CContextClient*> writerClientOut_ ;
+        std::vector<CContextServer*> writerServerOut_ ;
+        std::vector<CContextClient*> writerClientIn_ ;
+        std::vector<CContextServer*> writerServerIn_ ;
+
+        std::vector<CContextClient*> readerClientOut_ ;
+        std::vector<CContextServer*> readerServerOut_ ;
+        std::vector<CContextClient*> readerClientIn_ ;
+        std::vector<CContextServer*> readerServerIn_ ;
+
 
         std::map<std::string, CContextClient*> clients_ ;