Changeset 1686 for XIOS/dev/dev_olga/src/filter/file_writer_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/file_writer_filter.cpp (modified) (5 diffs)

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

@@ -4 +4 @@
 #include "utils.hpp"
 #include "workflow_graph.hpp"
+#include "graphviz.hpp"
 
 namespace xios
 {
-  CFileWriterFilter::CFileWriterFilter(CGarbageCollector& gc, CField* field, bool buildWorkflowGraph /* =false */)
+  CFileWriterFilter::CFileWriterFilter(CGarbageCollector& gc, CField* field)
     : CInputPin(gc, 1)
     , field(field)
@@ -14 +15 @@
       ERROR("CFileWriterFilter::CFileWriterFilter(CField* field)",
             "The field cannot be null.");
-    if (buildWorkflowGraph)
+  }
+
+  void CFileWriterFilter::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)
     {
-      filterId = InvalidableObject::count;
-      InvalidableObject::count++;
+      this->filterID = InvalidableObject::filterIdGenerator++;
+      int edgeID = InvalidableObject::edgeIdGenerator++;
+
+      CWorkflowGraph::allocNodeEdge();
+      StdString namestring = to_string(this->field->name);
+      namestring.erase(0, 6);
+      namestring.erase(namestring.length()-1, 1);
+
+      CWorkflowGraph::addNode(this->filterID, namestring + "\\n("+this->field->file->getId()+".nc)", 6, 0, 1, data[0]);
+
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].attributes = this->field->record4graphXiosAttributes();
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].attributes += "</br>file attributes : </br>" +this->field->file->record4graphXiosAttributes();
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].clusterID =1;
+      (*CWorkflowGraph::mapFilters_ptr_with_info)[this->filterID].distance = ++(data[0]->distance);
+
+      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;
     }
   }
@@ -23 +51 @@
   void CFileWriterFilter::onInputReady(std::vector<CDataPacketPtr> data)
   {
+    buildGraph(data);
+    
     const bool detectMissingValue = ( !field->default_value.isEmpty() &&
                                ( (!field->detect_missing_value.isEmpty() || field->detect_missing_value == true)
@@ -41 +71 @@
 
     field->sendUpdateData(dataArray);
-
   }
 
@@ -53 +82 @@
     return true;
   }
-
-  int CFileWriterFilter::getFilterId(void)
-  {
-    return filterId;
-  }
-
 } // namespace xios