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

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

@@ -4 +4 @@
 #include "utils.hpp"
 #include "workflow_graph.hpp"
+#include "graphviz.hpp"
+
+using namespace ep_lib;
 
 namespace xios
@@ -14 +17 @@
       ERROR("CFileWriterFilter::CFileWriterFilter(CField* field)",
             "The field cannot be null.");
-    if (buildWorkflowGraph)
-    {
-      filterId = InvalidableObject::count;
-      InvalidableObject::count++;
-    }
   }
 
   void CFileWriterFilter::onInputReady(std::vector<CDataPacketPtr> data)
   {
+    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] = "File Writer Filter";
+
+      if(CXios::isClient) std::cout<<"CFileWriterFilter::apply filter tag = "<<this->tag<<std::endl;
+
+      if(CXios::isClient) 
+      {
+        StdString str = this->output_field_id +" ts=" + to_string(data[0]->timestamp);
+        // 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);  
+      }
+    }
+    
     const bool detectMissingValue = ( !field->default_value.isEmpty() &&
                                ( (!field->detect_missing_value.isEmpty() || field->detect_missing_value == true)
@@ -41 +59 @@
 
     field->sendUpdateData(dataArray);
+    
+    
+    
   }
 
@@ -53 +74 @@
   }
 
-  int CFileWriterFilter::getFilterId(void)
-  {
-    return filterId;
-  }
+
 
 } // namespace xios