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

#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)
    {
      if(data[0]->graphPackage->currentField->getId() == this->graphPackage->inFields[0]->getId())
      {
        std::cout<<"PASS THROUGH FILTER OMITTED "<<this<<std::endl;
        std::cout<<data[0]->graphPackage->currentField->getId()<< "-------"<< this->graphPackage->inFields[0]->getId()<<std::endl;
        return;
      }
      this->graphPackage->filterId = CWorkflowGraph::getNodeSize();
      
      if(!data[0]->graphPackage) 
      {
        data[0]->graphPackage = new CGraphDataPackage;
        data[0]->graphPackage->fromFilter = -1;
      }
      
      CWorkflowGraph::addNode("Pass through filter", 2, false, 1, data[0]);
      data[0]->graphPackage->currentField = this->graphPackage->inFields[0];
      std::rotate(this->graphPackage->inFields.begin(), this->graphPackage->inFields.begin() + 1, this->graphPackage->inFields.end());
      
      CWorkflowGraph::addEdge(data[0]->graphPackage->fromFilter, this->graphPackage->filterId, data[0]);
      data[0]->graphPackage->fromFilter = this->graphPackage->filterId;
        
    } 
  }


} // namespace xios