source: XIOS/dev/dev_trunk_graph/src/filter/pass_through_filter.cpp @ 2019

#include "pass_through_filter.hpp"
#include "workflow_graph.hpp"
#include <algorithm>

namespace xios
{
  CPassThroughFilter::CPassThroughFilter(CGarbageCollector& gc)
    : CFilter(gc, 1, this)
  { /* Nothing to do */ }

  CDataPacketPtr CPassThroughFilter::apply(std::vector<CDataPacketPtr> data)
  {
    buildWorkflowGraph(data);
    return data[0];
  }

  void CPassThroughFilter::buildWorkflowGraph(std::vector<CDataPacketPtr> data)
  {
    if(this->graphEnabled)
    {
      this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
      
      if(!data[0]->graphPackage) 
      {
        data[0]->graphPackage = new CGraphDataPackage;
        data[0]->graphPackage->fromFilter = -1;
      }
          
      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
      
      CWorkflowGraph::addNode("Pass through filter", 2, false, 1, data[0]);
      CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
      data[0]->graphPackage->fromFilter = this->graphPackage->filterId;
        
    } 
  }


} // namespace xios