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"
#include "GaudiKernel/DataObjID.h"

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

// std includes
#include <list>
#include <vector>
#include <set>
#include <unordered_set>
#include <unordered_map>

class DataFlowManager{

public:

  typedef boost::dynamic_bitset<> dependency_bitset;

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

  DataFlowManager(algosDependenciesCollection algoDependencies);

  bool canAlgorithmRun(unsigned int iAlgo);

  void updateDataObjectsCatalog(const DataObjIDColl& newProducts);

  void reset();
  
  DataObjIDColl content() const;

  DataObjIDColl dataDependencies(unsigned int iAlgo) const;

private:
  DataObjIDColl m_fc;

  dependency_bitset m_dataObjectsCatalog;
  static std::vector< dependency_bitset > m_algosRequirements; 
  static std::vector<DataObjID> m_productName_vec;
  typedef DataObjID productName_t;

  static std::unordered_map<productName_t,long int,DataObjID_Hasher> m_productName_index_map;  
  inline long int productName2index(const productName_t& productName){return m_productName_index_map.count(productName)>0 ? m_productName_index_map[productName]: -1 ;};
  inline DataObjID& index2productName(const unsigned int i){return m_productName_vec[i];};

};

#endif