DataFlowManager.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_DATAFLOWMANAGER_H
#define GAUDIHIVE_DATAFLOWMANAGER_H

// FW includes
#include "GaudiKernel/IAlgorithm.h"
#include <GaudiKernel/SmartIF.h>

// boost
#include "boost/dynamic_bitset.hpp"

// std includes
#include <list>
#include <vector>
#include <string>
#include <unordered_map>

class DataFlowManager{

public:

  typedef boost::dynamic_bitset<> dependency_bitset;

  typedef std::vector<std::vector<std::string>> algosDependenciesCollection;  
  DataFlowManager(const std::list<IAlgorithm*>& /*algos*/):
                  m_dataObjectsCatalog(0){};

  DataFlowManager(algosDependenciesCollection algoDependencies);

  bool canAlgorithmRun(unsigned int iAlgo);

  void updateDataObjectsCatalog(const std::vector<std::string>& newProducts);

  void reset();
  
  std::vector<std::string> content() const;

  std::vector<std::string> dataDependencies(unsigned int iAlgo) const;

private:
  dependency_bitset m_dataObjectsCatalog;
  static std::vector< dependency_bitset > m_algosRequirements; 
  static std::vector<std::string> m_productName_vec;
  static std::unordered_map<std::string,long int> m_productName_index_map;  
  inline long int productName2index(const std::string& productName){return m_productName_index_map.count(productName)>0 ? m_productName_index_map[productName]: -1 ;};
  inline std::string& index2productName(const unsigned int i){return m_productName_vec[i];};

};

#endif