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

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

@@ -2 +2 @@
 #include "functor_type.hpp"
 #include "calendar_util.hpp"
+#include "workflow_graph.hpp"
 
 namespace xios
@@ -28 +29 @@
 //    , nextOperationDate(initDate + opFreq + this->samplingOffset)
     , isFirstOperation(true)
+    , graphCycleCompleted(true)
   {
   }
 
+  void CTemporalFilter::buildWorkflowGraph(std::vector<CDataPacketPtr> data)
+  {
+    if(this->graphEnabled )
+    {
+      if(!data[0]->graphPackage)
+      {
+        data[0]->graphPackage = new CGraphDataPackage;
+      }
+      
+      if(graphCycleCompleted)
+      {  
+        this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
+        CWorkflowGraph::addNode("Temporal filter", 3, false, 0, data[0]);
+        graphCycleCompleted = false;
+      }
+      
+      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
+      
+      CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
+      data[0]->graphPackage->fromFilter = this->graphPackage->filterId;
+      this->graphPackage->sourceFilterIds.push_back(data[0]->graphPackage->fromFilter); 
+      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
+    }
+
+  }
   CDataPacketPtr CTemporalFilter::apply(std::vector<CDataPacketPtr> data)
   {
+    buildWorkflowGraph(data);
+  
     CDataPacketPtr packet;
 
@@ -43 +74 @@
       {
         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);
@@ -75 +105 @@
           packet->data.resize(tmpData.numElements());
           packet->data = tmpData;
+          packet->graphPackage = data[0]->graphPackage;
         }
         else
@@ -80 +111 @@
 
         isFirstOperation = false;
-//        nextOperationDate = initDate + samplingFreq + nbOperationDates*opFreq - samplingFreq + offsetMonth + offsetAllButMonth;
-      }
+        graphCycleCompleted = true;
+     }
     }