ROBDataProviderSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2021 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef BYTESTREAMCNVSVCBASE_ROBDATAPROVIDERSVC_H
#define BYTESTREAMCNVSVCBASE_ROBDATAPROVIDERSVC_H
 
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
#include "ByteStreamData/RawEvent.h"
#include "eformat/SourceIdentifier.h"
#include "AthenaBaseComps/AthService.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include <vector>
#include <map>
#include <memory>
 
class ROBDataProviderSvc :  public extends<AthService, IROBDataProviderSvc> {
 
public:
   typedef OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment ROBF;
 
   ROBDataProviderSvc(const std::string& name, ISvcLocator* svcloc);
 
   virtual StatusCode initialize() override;
 
   virtual void addROBData(const EventContext& context, const std::vector<uint32_t>& robIds, const std::string_view callerName="UNKNOWN") override;
 
   virtual void setNextEvent(const EventContext& context, const std::vector<OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment>& result) override;
 
   virtual void setNextEvent(const EventContext& context, const RawEvent* re) override;
 
   virtual void getROBData(const EventContext& context, const std::vector<uint32_t>& robIds, VROBFRAG& robFragments, 
               const std::string_view callerName="UNKNOWN") override;
 
   virtual const RawEvent* getEvent(const EventContext& context) override;
 
   virtual void setEventStatus(const EventContext& context, uint32_t status) override;
 
   virtual uint32_t getEventStatus(const EventContext& context) override;
 
   virtual void processCachedROBs(const EventContext& context, 
                  const std::function< void(const ROBF* )>& fn ) const override;
 
   virtual bool isEventComplete(const EventContext& /*context*/) const override { return true; }
   virtual int collectCompleteEventData(const EventContext& /*context*/, const std::string_view /*callerName*/ ) override {  return 0; }
 
protected:
   //typedef std::vector<ROBF*> VROBF;
 
   typedef std::map<uint32_t, std::unique_ptr<const ROBF>, std::less<uint32_t> > ROBMAP;
 
  struct EventCache {
    const RawEvent* event = 0;
    uint32_t eventStatus = 0;    
    uint32_t currentLvl1ID = 0;    
    ROBMAP robmap;
 
  };
  SG::SlotSpecificObj<EventCache> m_eventsCache;
 
   typedef SimpleProperty< std::vector< std::pair<int, int> > > ArrayPairIntProperty;
   ArrayPairIntProperty  m_filterRobWithStatus; // filter with full ROB SourceID
   ArrayPairIntProperty  m_filterSubDetWithStatus;  // filter with Sub Det ID
 
   typedef std::map<uint32_t, std::vector<uint32_t> > FilterRobMap;
   FilterRobMap          m_filterRobMap;
   typedef std::map<eformat::SubDetector, std::vector<uint32_t> > FilterSubDetMap;
   FilterSubDetMap       m_filterSubDetMap;
   bool filterRobWithStatus(const ROBF* rob);
 
   BooleanProperty m_filterEmptyROB;
   bool m_maskL2EFModuleID = false;    
 
private:
  static void robmapClear(ROBMAP& toclear);
};
 
#endif