Changeset 1677 for XIOS/dev/dev_trunk_omp/src/filter/temporal_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/temporal_filter.cpp (modified) (4 diffs)

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

@@ -2 +2 @@
 #include "functor_type.hpp"
 #include "calendar_util.hpp"
+#include "workflow_graph.hpp"
 
 namespace xios
@@ -32 +33 @@
   CDataPacketPtr CTemporalFilter::apply(std::vector<CDataPacketPtr> data)
   {
+   
+    if(this->tag)
+    {
+      if(this->filterIDoutputs.size()==0) this->filterID = InvalidableObject::filterIdGenerator++;
+      
+
+      std::cout<<"CTemporalFilter::apply filter tag = "<<this->tag<<std::endl;
+
+      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);
+       
+    
+      if(CWorkflowGraph::mapFilters_ptr==0) CWorkflowGraph::mapFilters_ptr = new std::unordered_map <int, StdString>;
+
+      if(this->filterIDoutputs.size()==0) (*CWorkflowGraph::mapFilters_ptr)[this->filterID] = "Temporal Filter";  
+
+      this->filterIDoutputs.push_back(data[0]->src_filterID); 
+    }
+    
+    
     CDataPacketPtr packet;
 
@@ -42 +66 @@
       {
         usePacket = (data[0]->date >= nextSamplingDate);
-//        outputResult = (data[0]->date + samplingFreq > nextOperationDate);
         outputResult = (data[0]->date  > initDate + nbOperationDates*opFreq - samplingFreq + offsetMonth + offsetAllButMonth);
         copyLess = (isInstantOperation && usePacket && outputResult);
@@ -79 +102 @@
 
         isFirstOperation = false;
-//        nextOperationDate = initDate + samplingFreq + nbOperationDates*opFreq - samplingFreq + offsetMonth + offsetAllButMonth;
+        if(this->tag) packet->src_filterID=this->filterID;
+        packet->fieldID = this->output_field_id;
+        if(this->tag) this->filterIDoutputs.clear();
       }
     }