TagInfoMgr.h

Go to the documentation of this file.

//Dear emacs, this is -*-c++-*-
/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef EVENTINFOMGT_TAGINFOMGR_H
#define EVENTINFOMGT_TAGINFOMGR_H
 
//<<<<<< INCLUDES                                                       >>>>>>
 
#include "EventInfoMgt/ITagInfoMgr.h"
#include "AthenaBaseComps/AthService.h"
#include "GaudiKernel/Service.h"
#include "GaudiKernel/ServiceHandle.h"
#include "GaudiKernel/ToolHandle.h"
#include "AthenaKernel/IOVRange.h"
#include "AthenaKernel/IIOVDbSvc.h"
#include "GaudiKernel/MsgStream.h"
#include "EventInfo/TagInfo.h"
#include "IOVDbMetaDataTools/IIOVDbMetaDataTool.h"
 
#include <map>
#include <set>
#include <shared_mutex>
 
//<<<<<< PUBLIC TYPES                                                   >>>>>>
 
class StoreGateSvc;
class CondAttrListCollection;
 
//<<<<<< CLASS DECLARATIONS                                             >>>>>>
 
class TagInfoMgr : virtual public AthService,
                   virtual public ITagInfoMgr,
                   virtual public IIncidentListener
{
public:
 
    TagInfoMgr(const std::string &name,ISvcLocator *pSvcLocator);
    ~TagInfoMgr();
 
 
    virtual StatusCode   initialize() override;
    virtual StatusCode   start() override;
    virtual StatusCode   finalize() override;
  
    virtual StatusCode   queryInterface( const InterfaceID& riid, void** ppvInterface ) override;
 
 
    virtual StatusCode   addTag(const std::string& tagName, 
                              const std::string& tagValue) override;
 
    virtual StatusCode   removeTagFromInput(const std::string& tagName) override;
 
    virtual std::string  findTag(const std::string & name) const override final;
 
    virtual std::string  findInputTag(const std::string& name) const override final;
 
    virtual NameTagPairVec getInputTags() const override final;
 
    virtual std::string  dumpTagInfoToStr() const override final;
 
    virtual void         printTags(MsgStream& log) const override final;
 
    virtual void         addListener(Listener* listener) override final;
 
    virtual void         removeListener(Listener* listener) override final;
   
 
    void                 handle(const Incident& incident) override final;
 
    StatusCode           updateTagInfo();
 
    void                 notifyListeners() const;
 
 
    // Private methods:
private:
    template <class TYPE> class SvcFactory;  
    friend class SvcFactory<TagInfoMgr>;
 
    TagInfoMgr();
    TagInfoMgr(const TagInfoMgr&);
    TagInfoMgr &operator=(const TagInfoMgr&);
    StatusCode getRunNumber (unsigned int& runNumber);
  
    // Private data:
private:
 
 
 
    StatusCode fillTagInfo(const CondAttrListCollection* tagInfoCond);
    StatusCode fillMetaData(const CondAttrListCollection* tagInfoCond);
 
    Gaudi::Property<std::map<std::string,std::string> >
        m_extraTagValuePairs { this, "ExtraTagValuePairs", {}, "key/value pairs to be added", "mapMergeNoReplace<T,T>" };
 
    std::map<std::string,std::string> m_extraTagValuePairsViaInterface;
 
    std::set<std::string>          m_tagsToBeRemoved;
 
    ServiceHandle<StoreGateSvc>    m_storeGate { this, "StoreGateSvc", "StoreGateSvc" };
 
    ServiceHandle<StoreGateSvc>    m_detStore { this, "DetectorStore", "DetectorStore" };
 
    ServiceHandle<IIOVDbSvc>       m_iovDbSvc { this, "IOVDbSvc", "IOVDbSvc" };
 
    PublicToolHandle<IIOVDbMetaDataTool> m_metaDataTool { this, "IOVDbMetaDataTool", "IOVDbMetaDataTool" };
 
    bool                           m_isFirstBeginRun { true };
 
    EventIDBase::number_type       m_conditionsRun { EventIDBase::UNDEFNUM };
 
    EventIDBase::number_type       m_currentRun { EventIDBase::UNDEFNUM };
 
    IOVRange                       m_lastIOVRange { IOVRange(IOVTime(), IOVTime()) };
 
    TagInfo                        m_tagInfo;
 
    std::set< Listener* >          m_listeners;
 
    mutable std::shared_mutex      m_mutex   ATLAS_THREAD_SAFE;
};
 
 
//<<<<<< INLINE PUBLIC FUNCTIONS                                        >>>>>>
//<<<<<< INLINE MEMBER FUNCTIONS                                        >>>>>>
 
#endif // EVENTINFOMGT_TAGINFOMGR_H