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

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

@@ -7 +7 @@
 #include "field.hpp"
 #include "grid.hpp"
+#include "workflow_graph.hpp"
 
 namespace xios
@@ -12 +13 @@
   CClientToServerStoreFilter::CClientToServerStoreFilter(CGarbageCollector& gc, CField* field, CContextClient* client)
     : CInputPin(gc, 1)
-    , field_(field), client_(client)
+    , field_(field), client_(client), graphEnabled(false)
   {
     if (!field)
@@ -21 +22 @@
   void CClientToServerStoreFilter::onInputReady(std::vector<CDataPacketPtr> data)
   {
+    buildWorkflowGraph(data);
+
     CTimer::get("Field : send data").resume();
     CEventClient event(field_->getType(), CField::EVENT_ID_UPDATE_DATA);
@@ -27 +30 @@
     field_->getSentGrid()->getClientToServerConnector(client_)->transfer(data[0]->data, client_, event, message) ;
     CTimer::get("Field : send data").suspend();
+  }
+
+  void CClientToServerStoreFilter::buildWorkflowGraph(std::vector<CDataPacketPtr> data)
+  {
+    if(this->graphEnabled)
+    {
+      this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
+      if(!data[0]->graphPackage) data[0]->graphPackage = new CGraphDataPackage;
+      
+      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
+      
+      CWorkflowGraph::addNode("Client to Server Store filter", 6, true, 1, data[0]);
+     
+      CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
+      // flux can be redirected to other filters. So don't change the 'from' parameter
+      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
+    }
   }