ROBDataProviderSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 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 "Gaudi/Property.h"
#include <vector>
#include <map>
#include <memory>
 
class ROBDataProviderSvc :  public extends<AthService, IROBDataProviderSvc> {
 
public:
   using ROBF = OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment;

   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;

   using ROBMAP = std::map<uint32_t, std::unique_ptr<const ROBF>, std::less<uint32_t>>;
 
  struct EventCache {
    const RawEvent* event = nullptr;
    uint32_t eventStatus = 0;
    uint32_t currentLvl1ID = 0;    
    ROBMAP robmap;
 
  };
  SG::SlotSpecificObj<EventCache> m_eventsCache;

   using ArrayPairIntType = std::vector<std::pair<int, int>>;
   Gaudi::Property<ArrayPairIntType> m_filterRobWithStatus{
      this, "filterRobWithStatus", {}, "ROB IDs and status words to filter (full ROB SourceID)"};
   Gaudi::Property<ArrayPairIntType> m_filterSubDetWithStatus{
      this, "filterSubDetWithStatus", {}, "Sub-detector IDs and status words to filter"};

   using FilterRobMap = std::map<uint32_t, std::vector<uint32_t>>;
   FilterRobMap          m_filterRobMap;
   using FilterSubDetMap = std::map<eformat::SubDetector, std::vector<uint32_t>>;
   FilterSubDetMap       m_filterSubDetMap;
   bool filterRobWithStatus(const ROBF* rob);

   Gaudi::Property<bool> m_filterEmptyROB{this, "filterEmptyROB", false, "Filter out empty ROB fragments"};
   bool m_maskL2EFModuleID = false;    
 
private:
  static void robmapClear(ROBMAP& toclear);
};
 
#endif