Changeset 2492

Timestamp:

04/21/23 20:45:21 (14 months ago)

Author:

ymipsl

Message:

Better writer attached mode, new CClientOnlineWriterFilter class that embed subfilters
YM

Location:

XIOS3/dev/XIOS_ATTACHED/src

Files:

• filter/client_online_reader_filter.hpp (modified) (2 diffs)
• filter/client_online_writer_filter.cpp (added)
• filter/client_online_writer_filter.hpp (added)
• node/field.cpp (modified) (2 diffs)
• node/field.hpp (modified) (3 diffs)

XIOS3/dev/XIOS_ATTACHED/src/filter/client_online_reader_filter.hpp

@@ -1 @@
-#ifndef __XIOS_ONLINE_READER_FILTER__
-#define __XIOS_ONLINE_READER_FILTER__
+#ifndef __XIOS_CLIENT_ONLINE_READER_FILTER__
+#define __XIOS_CLIENT_ONLINE_READER_FILTER__
 
 #include <map>
@@ -62 +62 @@
 } // namespace xios
 
-#endif // __XIOS_ONLINE_READER_FILTER__
+#endif // __XIOS_CLIENT_ONLINE_READER_FILTER__

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

@@ -803 +803 @@
   } 
 
+/*
   void CField::connectToOnlineWriter(CGarbageCollector& gc)
   {
@@ -826 +827 @@
     }
   } 
+*/
+  void CField::connectToOnlineWriter(CGarbageCollector& gc)
+  {
+    // insert temporal filter before sending to files
+    clientOnlineWriterFilter_ = std::shared_ptr<CClientOnlineWriterFilter>(new CClientOnlineWriterFilter(gc,this)) ;
+    getTemporalDataFilter(gc, fileOut_->output_freq)->connectOutput(clientOnlineReaderFilter_, 0);
+   
+    const bool buildGraph_ = !build_workflow_graph.isEmpty() && build_workflow_graph == true ;
+  
+    if(buildGraph_) 
+    {
+      // to do
+    }
+  } 
 
   void CField::connectToOnlineReader(CGarbageCollector& gc)

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

@@ -29 +29 @@
 #include "file_reader_source_filter.hpp"
 #include "client_online_reader_filter.hpp"
+#include "client_online_writer_filter.hpp"
 
 
@@ -403 +404 @@
          std::shared_ptr<CServerToClientStoreFilter> serverToClientStoreFilter_;
 
-         //! the filter to redistribute data before to call the fileWriterStoreFilter
+         //! the filter to redistribute data before to call the fileWriterStoreFilter ==> to remove
          std::shared_ptr<CGridRedistributeFilter>  redistributeFilter_ ;
 
@@ -409 +410 @@
          std::shared_ptr<CClientOnlineReaderFilter>  clientOnlineReaderFilter_ ;
 
+          //! the filter to connect to online writer
+         std::shared_ptr<CClientOnlineWriterFilter>  clientOnlineWriterFilter_ ;
+
+
    }; // class CField