TrigCostDataStore.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2021 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGCOSTMONITOR_TRIGCOSTDATASTORE_H
#define TRIGCOSTMONITOR_TRIGCOSTDATASTORE_H 1
 
#include <tbb/concurrent_hash_map.h>
#include <tbb/concurrent_vector.h>
 
#include "TrigCostMonitor/AlgorithmIdentifier.h"
 
#include "TrigTimeAlgs/TrigTimeStamp.h"
 
#include "GaudiKernel/EventContext.h"
#include "AthViews/View.h"

template<typename PAYLOAD>
class TrigCostDataStore {
  public:

  TrigCostDataStore() : m_store() {}

  ~TrigCostDataStore() {}

  StatusCode initialize(size_t nSlots);

  StatusCode insert(const AlgorithmIdentifier& ai, const PAYLOAD& payload,
                    MsgStream& msg);

  template<typename ENTRY>
  StatusCode push_back(const AlgorithmIdentifier& ai, ENTRY&& entry,
                       MsgStream& msg);

  StatusCode retrieve(const AlgorithmIdentifier& ai, 
    typename tbb::concurrent_hash_map<AlgorithmIdentifier, PAYLOAD, AlgorithmIdentifierHashCompare>::const_accessor& payload,
    MsgStream& msg) const;

  StatusCode clear(const EventContext& context, MsgStream& msg);

  StatusCode getIterators(const EventContext& context, MsgStream& msg, 
    typename tbb::concurrent_hash_map< AlgorithmIdentifier, PAYLOAD, AlgorithmIdentifierHashCompare>::const_iterator& begin, 
    typename tbb::concurrent_hash_map< AlgorithmIdentifier, PAYLOAD, AlgorithmIdentifierHashCompare>::const_iterator& end);
 
  private:

  StatusCode checkSlot(const size_t slot, MsgStream& msg) const;
 
  std::vector< tbb::concurrent_hash_map< AlgorithmIdentifier, PAYLOAD, AlgorithmIdentifierHashCompare> > m_store; 
};
 
#include "TrigCostDataStore.icc"
 
#endif // TRIGCOSTMONITOR_TRIGCOSTDATASTORE_H