DataFlowManager.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_DATAFLOWMANAGER_H
#define GAUDIHIVE_DATAFLOWMANAGER_H

// FW includes
#include "GaudiKernel/DataObjID.h"
#include "GaudiKernel/IAlgorithm.h"
#include "GaudiKernel/SmartIF.h"

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

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

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