1 #ifndef GAUDIHIVE_DATAFLOWMANAGER_H 2 #define GAUDIHIVE_DATAFLOWMANAGER_H 10 #include "boost/dynamic_bitset.hpp" 15 #include <unordered_map> 16 #include <unordered_set> 73 return m_productName_index_map.
count( productName ) > 0 ? m_productName_index_map[productName] : -1;
boost::dynamic_bitset dependency_bitset
Type holding the dependencies for one single algorithm.
The DataFlowManager takes care of keeping track of the dependencies of the algorithms in terms of dat...
void updateDataObjectsCatalog(const DataObjIDColl &newProducts)
Update the catalog of available products in the slot.
DataObjIDColl dataDependencies(unsigned int iAlgo) const
Get the dependencies of a single algo;.
static std::vector< DataObjID > m_productName_vec
Track the products, assigning an index to them. Static since the same for all events.
DataObjIDColl content() const
Get the content of the catalog.
static std::unordered_map< productName_t, long int, DataObjID_Hasher > m_productName_index_map
static std::vector< dependency_bitset > m_algosRequirements
Requirements of algos. Static since the same for all events.
DataObjID & index2productName(const unsigned int i)
Simple helper method to convert an index to a product name.
long int productName2index(const productName_t &productName)
Simple helper method to convert the product name into an index.
std::vector< DataObjIDColl > algosDependenciesCollection
void reset()
Reset to default values.
dependency_bitset m_dataObjectsCatalog
Catalog of the products in the whiteboard.
DataObjID productName_t
Track the products, assigning an index to them. Static since the same for all events.
DataFlowManager(const std::list< IAlgorithm * > &)
Constructor.
bool canAlgorithmRun(unsigned int iAlgo)
Needed data products are available.