Changeset 2143 for XIOS/dev/dev_ym/XIOS_COUPLING/src/filter/file_writer_store_filter.cpp

Timestamp:

06/04/21 11:54:38 (3 years ago)

Author:

yushan

Message:

Big commit on graph functionality. Add buildWorkflowGraph function for filters

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/filter/file_writer_store_filter.cpp (modified) (3 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/filter/file_writer_store_filter.cpp

@@ -4 +4 @@
 #include "file.hpp"
 #include "context.hpp"
+#include "workflow_graph.hpp"
 
 namespace xios
@@ -9 +10 @@
   CFileWriterStoreFilter::CFileWriterStoreFilter(CGarbageCollector& gc, CField* field)
     : CInputPin(gc, 1)
-    , field_(field)
+    , field_(field), graphEnabled(false)
 
   {
@@ -67 +68 @@
       }  
       nstep_ = file_->getDataOutput()->writeFieldData(field_, fieldData, lastWrite_,currentWrite, nstep_);
+      if(this->graphEnabled)
+      {
+        
+        this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
+        if(!data[0]->graphPackage) data[0]->graphPackage = new CGraphDataPackage;
+        data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+        std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
+      
+        CWorkflowGraph::addNode("File Writer Store filter", 5, true, 1, data[0]);
+      
+        CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
+        data[0]->graphPackage->fromFilter = this->graphPackage->filterId;
+
+
+      }
     }