Changeset 2143 for XIOS/dev/dev_ym/XIOS_COUPLING/src/filter/pass_through_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/pass_through_filter.cpp (modified) (2 diffs)

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

@@ -1 +1 @@
 #include "pass_through_filter.hpp"
+#include "workflow_graph.hpp"
+#include <algorithm>
 
 namespace xios
@@ -9 +11 @@
   CDataPacketPtr CPassThroughFilter::apply(std::vector<CDataPacketPtr> data)
   {
+    buildWorkflowGraph(data);
     return data[0];
   }
+
+  void CPassThroughFilter::buildWorkflowGraph(std::vector<CDataPacketPtr> data)
+  {
+    if(this->graphEnabled)
+    {
+      if(data[0]->graphPackage && data[0]->graphPackage->currentField->getId() == this->graphPackage->inFields[0]->getId())
+      {
+        std::cout<<"PASS THROUGH FILTER OMITTED "<<this<<std::endl;
+        return;
+      }
+      this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
+      
+      if(!data[0]->graphPackage) 
+      {
+        data[0]->graphPackage = new CGraphDataPackage;
+        data[0]->graphPackage->fromFilter = -1;
+        data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+      }
+
+      for(int i=0; i<this->graphPackage->filterId; i++)
+      {
+        if(CXios::isClient 
+          &&  (*CWorkflowGraph::vectorOfNodes_)[i].label_field_id == this->label_field_id  
+          && (*CWorkflowGraph::vectorOfNodes_)[i].timestamp == data[0]->timestamp
+          && (*CWorkflowGraph::vectorOfNodes_)[i].filter_name == "Pass through filter" )
+        {
+          data[0]->graphPackage->fromFilter = i;
+          return;
+        }  
+      }
+      
+      CWorkflowGraph::addNode("Pass through filter", 2, false, 1, data[0]);
+      if(CXios::isClient) (*CWorkflowGraph::vectorOfNodes_)[this->graphPackage->filterId].label_field_id = this->label_field_id;
+      CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
+      
+      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
+      
+      data[0]->graphPackage->fromFilter = this->graphPackage->filterId;
+        
+    } 
+  }
+
+
 } // namespace xios