Changeset 1686 for XIOS/dev/dev_olga/src/filter/store_filter.cpp

Timestamp:

07/31/19 13:51:01 (5 years ago)

Author:

yushan

Message:

backup for trunk with graph

File:

• XIOS/dev/dev_olga/src/filter/store_filter.cpp (modified) (4 diffs)

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

@@ -3 +3 @@
 #include "grid.hpp"
 #include "timer.hpp"
+#include "file.hpp"
 
 namespace xios
@@ -21 +22 @@
       ERROR("CStoreFilter::CStoreFilter(CContext* context, CGrid* grid)",
             "Impossible to construct a store filter without providing a grid.");
-//    filterId = InvalidableObject::count;
-//    InvalidableObject::count++;
   }
 
@@ -78 +77 @@
   template CDataPacket::StatusCode CStoreFilter::getData<7>(Time timestamp, CArray<double, 7>& data);
 
+  void CStoreFilter::buildGraph(std::vector<CDataPacketPtr> data)
+  {
+    bool building_graph = this->tag ? data[0]->timestamp >= this->start_graph && data[0]->timestamp <= this->end_graph : false;
+
+    if(building_graph)
+    {
+      this->filterID = InvalidableObject::filterIdGenerator++;
+      int edgeID = InvalidableObject::edgeIdGenerator++;
+
+      CWorkflowGraph::allocNodeEdge();
+ 
+      CWorkflowGraph::addNode(this->filterID, "Store Filter", 7, 0, 1, data[0]);
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].distance = ++(data[0]->distance);
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].attributes = this->field->record4graphXiosAttributes();
+      if(this->field->file) (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].attributes += "</br>file attributes : </br>" +this->field->file->record4graphXiosAttributes();
+
+      // if(CXios::isClient) std::cout<<"CStoreFilter::apply filter tag = "<<this->tag<<std::endl;
+
+      if(CXios::isClient && CWorkflowGraph::build_begin) 
+      {
+        CWorkflowGraph::addEdge(edgeID, this->filterID, data[0]);;
+        (*CWorkflowGraph::mapFilters_ptr_with_info)[data[0]->src_filterID].filter_filled = 0;
+      }
+      else CWorkflowGraph::build_begin = true;
+    }
+  }
+
   void CStoreFilter::onInputReady(std::vector<CDataPacketPtr> data)
   {
+    buildGraph(data);
 
     CDataPacketPtr packet;
@@ -128 +155 @@
     packets.erase(packets.begin(), packets.lower_bound(timestamp));
   }
-
-  int CStoreFilter::getFilterId(void)
-  {
-    return filterId;
-  }
-
 } // namespace xios