Changeset 1677 for XIOS/dev/dev_trunk_omp/src/filter/pass_through_filter.cpp

Timestamp:

06/25/19 16:14:54 (5 years ago)

Author:

yushan

Message:

MARK: Dynamic workflow graph developement. Branch up to date with trunk @1663.

File:

• XIOS/dev/dev_trunk_omp/src/filter/pass_through_filter.cpp (modified) (2 diffs)

XIOS/dev/dev_trunk_omp/src/filter/pass_through_filter.cpp

@@ -1 +1 @@
 #include "pass_through_filter.hpp"
+#include "workflow_graph.hpp"
 
 namespace xios
@@ -5 +6 @@
   CPassThroughFilter::CPassThroughFilter(CGarbageCollector& gc, bool buildWorkflowGraph /*= false*/)
     : CFilter(gc, 1, this, buildWorkflowGraph)
-  { /* Nothing to do */ }
+  { 
+  }
 
   CDataPacketPtr CPassThroughFilter::apply(std::vector<CDataPacketPtr> data)
   {
+        if(this->tag)
+    {
+      std::cout<<"CPassThroughFilter::apply tag = "<<this->tag<<std::endl;
+      this->filterID = InvalidableObject::filterIdGenerator++;
+      if(CWorkflowGraph::mapFilters_ptr==0) CWorkflowGraph::mapFilters_ptr = new std::unordered_map <int, StdString>;
+
+      (*CWorkflowGraph::mapFilters_ptr)[this->filterID] = "Pass Through Filter";
+
+      if(CWorkflowGraph::mapFieldToFilters_ptr==0) CWorkflowGraph::mapFieldToFilters_ptr = new std::unordered_map <StdString, vector <int> >;
+      
+      StdString str = data[0]->fieldID + " ts=" + to_string(data[0]->timestamp);
+      (*CWorkflowGraph::mapFieldToFilters_ptr)[str].push_back(data[0]->src_filterID);
+      (*CWorkflowGraph::mapFieldToFilters_ptr)[str].push_back(this->filterID);
+      data[0]->src_filterID=this->filterID;
+
+    }
+    
+    data[0]->fieldID = this->output_field_id;
+    
+
     return data[0];
   }
+
 } // namespace xios