source: XIOS/dev/dev_trunk_omp/src/workflow_graph.cpp @ 1677

#include "workflow_graph.hpp"

namespace xios
{

  std::unordered_map <StdString, vector <int > > *CWorkflowGraph::mapFieldToFilters_ptr = 0;
  #pragma omp threadprivate(CWorkflowGraph::mapFieldToFilters_ptr)

  std::unordered_map <int, StdString> *CWorkflowGraph::mapFilters_ptr = 0;
  #pragma omp threadprivate(CWorkflowGraph::mapFilters_ptr)

  std::unordered_map <int,vector<Time> > *CWorkflowGraph::mapFilterTimestamps_ptr = 0;
  #pragma omp threadprivate(CWorkflowGraph::mapFilterTimestamps_ptr)

  set<Time>  *CWorkflowGraph::timestamps_ptr = 0;
  #pragma omp threadprivate(CWorkflowGraph::timestamps_ptr)

  vector <StdString> CWorkflowGraph::filters;
  vector <StdString> CWorkflowGraph::fields;
  vector <pair<int, int> > CWorkflowGraph::fieldsToFilters;

  CWorkflowGraph::CWorkflowGraph()
  { }

  /*!
   * Reorganize information collected by XIOS for visualization.
   */
  void CWorkflowGraph::buildStaticWorkflow()
  TRY
  {
    
    if(mapFilters_ptr==0 || mapFieldToFilters_ptr==0) 
      std::cout<<"No graph information provided"<<std::endl;

    else // Create a list of filters (graph nodes)
    {
      size_t filterIdx = 0;
      filters.resize(mapFilters_ptr->size());
      fieldsToFilters.clear();
      fields.clear();
      for (auto it=mapFilters_ptr->begin(); it != mapFilters_ptr->end(); it++)
      {
        filters[it->first]=it->second;
      }

      // Create a list of fields and their filter connectivity (graph edges and edge-to-node connectivity)
      for (auto it=mapFieldToFilters_ptr->begin(); it != mapFieldToFilters_ptr->end(); it++)
      {
        for (size_t i = 0; i < (it->second.size() - 1); i+=2)
        {
          fieldsToFilters.push_back(make_pair(it->second[i],it->second[i+1]));
          fields.push_back(it->first);
        }
      }
    }
  }
  CATCH


  void CWorkflowGraph::showStaticWorkflow()
  TRY
  {
    if(mapFilters_ptr!=0 && !mapFilters_ptr->empty())
    for (auto it=mapFilters_ptr->begin(); it != mapFilters_ptr->end(); it++)
    {
      std::cout<<"mapFilters_ptr["<<it->first<<"]="<<it->second<<std::endl;
    }
    else std::cout<<"mapFilters_ptr empty"<<std::endl;

    if(mapFieldToFilters_ptr!=0 && !mapFieldToFilters_ptr->empty())
    for (auto it=mapFieldToFilters_ptr->begin(); it != mapFieldToFilters_ptr->end(); it++)
    {
      for (size_t i = 0; i < it->second.size(); i++)
      {
        std::cout<<"mapFieldToFilters_ptr["<<it->first<<"]["<<i<<"] = "<<it->second[i]<<std::endl;
      }
    }
    else std::cout<<"mapFieldToFilters_ptr empty"<<mapFieldToFilters_ptr<<std::endl;

    /*if(mapFilterTimestamps_ptr!=0 && !mapFilterTimestamps_ptr->empty())
    for (auto it=mapFilterTimestamps_ptr->begin(); it != mapFilterTimestamps_ptr->end(); it++)
    {
      for (size_t i = 0; i < it->second.size(); i++)
      {
        std::cout<<"mapFilterTimestamps_ptr["<<it->first<<"]["<<i<<"] = "<<it->second[i]<<std::endl;
      }
    }
    else std::cout<<"mapFilterTimestamps_ptr empty"<<std::endl;

    if(timestamps_ptr!=0 && !timestamps_ptr->empty())
    for (auto it=timestamps_ptr->begin(); it != timestamps_ptr->end(); it++)
    {
      std::cout<<"timestamps_ptr = "<<*it<<std::endl;
    }
    else std::cout<<"timestamps_ptr empty"<<std::endl;
*/
  }
  CATCH

}