Changeset 2482 for XIOS3/dev/XIOS_ATTACHED/src/node/field.hpp

Timestamp:

03/28/23 16:42:11 (15 months ago)

Author:

ymipsl

Message:

First guess in supression of attached mode replaced by online reader and write filters

YM

File:

• XIOS3/dev/XIOS_ATTACHED/src/node/field.hpp (modified) (9 diffs)

XIOS3/dev/XIOS_ATTACHED/src/node/field.hpp

@@ -28 +28 @@
 #include "client_to_server_store_filter.hpp"
 #include "file_reader_source_filter.hpp"
+#include "client_online_reader_filter.hpp"
 
 
@@ -56 +57 @@
    class CSourceFilter;
    class CServerToClientFilter;
+   class CGridRedistributeFilter;
    ///--------------------------------------------------------------
 
@@ -199 +201 @@
         void checkForLateDataFromCoupler(void) ;
 
-        void checkIfMustAutoTrigger(void); // ym obsolete
-        void autoTriggerIfNeeded(void); //ym obsolete
         void triggerLateField(void) ;
 
@@ -237 +237 @@
         void connectToFileReader(CGarbageCollector& gc) ;
         void connectToServerToClient(CGarbageCollector& gc) ;
+        void connectToOnlineWriter(CGarbageCollector& gc) ;
+        void connectToOnlineReader(CGarbageCollector& gc) ;
 
         void setContextClientDataBufferSize(map<CContextClient*,map<int,size_t>>& bufferSize, 
@@ -267 +269 @@
          CGrid*  grid_=nullptr;
          CGrid* getGrid(void) { return grid_; } 
+         void setGrid(CGrid* grid) { grid_=grid; } 
       
       private:
@@ -327 +330 @@
         
       private:
-         CContextClient* client;
+         CContextClient* client_;
       public:
          void setContextClient(CContextClient* newContextClient);
-         CContextClient* getContextClient(void) {return client;}
+         CContextClient* getContextClient(void) {return client_;}
 
       private:
@@ -372 +375 @@
          std::shared_ptr<COutputPin> selfReferenceFilter; // probably redondant with inputFilter
 
-         //! The source filter for data provided by the client
-//         std::shared_ptr<CSourceFilter> clientSourceFilter; // obsolete to remove
  
          //! The source filter for data provided by the model to enter the client workflow
@@ -393 +394 @@
          std::shared_ptr<CFileReaderSourceFilter> fileReaderSourceFilter_;
 
-         //! The source filter for data provided by the server
-//         std::shared_ptr<CSourceFilter> serverSourceFilter; // obsolete to remove
-        
          //! The terminal filter which send data to server for writing
          std::shared_ptr<CClientToServerStoreFilter> clientToServerStoreFilter_;
@@ -405 +403 @@
          std::shared_ptr<CServerToClientStoreFilter> serverToClientStoreFilter_;
 
+         //! the filter to redistribute data before to call the fileWriterStoreFilter
+         std::shared_ptr<CGridRedistributeFilter>  redistributeFilter_ ;
+
+          //! the filter to connect to online reader
+         std::shared_ptr<CClientOnlineReaderFilter>  clientOnlineReaderFilter_ ;
 
    }; // class CField