Changeset 1677 for XIOS/dev/dev_trunk_omp/src/filter/store_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/store_filter.cpp (modified) (2 diffs)

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

@@ -90 +90 @@
   void CStoreFilter::onInputReady(std::vector<CDataPacketPtr> data)
   {
+    if(CXios::isClient) std::cout<<"CStoreFilter onInputReady"<<std::endl;
+
+    if(this->tag)
+    {
+      this->filterID = InvalidableObject::filterIdGenerator++;
+
+      if(CWorkflowGraph::mapFieldToFilters_ptr==0) CWorkflowGraph::mapFieldToFilters_ptr = new std::unordered_map <StdString, vector <int> >;
+      if(CWorkflowGraph::mapFilters_ptr==0) CWorkflowGraph::mapFilters_ptr = new std::unordered_map <int, StdString>;
+
+      (*CWorkflowGraph::mapFilters_ptr)[this->filterID] = "Store Filter";
+
+      if(CXios::isClient) std::cout<<"CStoreFilter::apply filter tag = "<<this->tag<<std::endl;
+
+      if(CXios::isClient) 
+      {
+        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);  
+      }
+    }
+
+
 
     CDataPacketPtr packet;
@@ -139 +161 @@
   }
 
-  int CStoreFilter::getFilterId(void)
-  {
-    return filterId;
-  }
 
 } // namespace xios