TrigByteStreamInputSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2020 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGBYTESTREAMINPUTSVC_H
#define TRIGBYTESTREAMINPUTSVC_H
 
#include "ByteStreamCnvSvc/ByteStreamInputSvc.h"
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
#include "ByteStreamData/RawEvent.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "AthenaMonitoringKernel/Monitored.h"
#include <memory.h>
 
// Forward declarations
class StoreGateSvc;
 
class TrigByteStreamInputSvc : public ByteStreamInputSvc {
public:
  TrigByteStreamInputSvc(const std::string& name, ISvcLocator* svcLoc);
  virtual ~TrigByteStreamInputSvc();
 
  // -------------------------- IInterface methods -----------------------------
  virtual StatusCode queryInterface(const InterfaceID& riid, void** ppvInterface) override;
 
  // ------------------------- Service methods --------------------------------
  virtual StatusCode initialize() override;
  virtual StatusCode finalize() override;
 
  // ------------------------- ByteStreamInputSvc methods ----------------------
  virtual const RawEvent* nextEvent() override;
  virtual const RawEvent* previousEvent() override;
  virtual const RawEvent* currentEvent() const override;
 
private:
  // ------------------------- Service handles ---------------------------------
  ServiceHandle<IROBDataProviderSvc> m_robDataProviderSvc {this, "ROBDataProvider", "ROBDataProviderSvc"};
  ServiceHandle<StoreGateSvc> m_evtStore {this, "EventStore", "StoreGateSvc"};
  ToolHandle<GenericMonitoringTool> m_monTool {this, "MonTool", "" , "Monitoring tool"};
 
  // ------------------------- Properties --------------------------------------
  Gaudi::Property<int> m_checkCTPFragmentModuleID {this, "CheckCTPFragmentModuleID", -1,
    "After reading a new event, assert we can retrieve the CTP fragment with Module ID given by this property, "
    "and that has no errors. A value <0 disables the check."};
 
  // ------------------------- Private data members ----------------------------
  struct EventCache {
    ~EventCache() = default;
    void releaseEvent();
    std::unique_ptr<RawEvent> fullEventFragment {nullptr}; 
    std::unique_ptr<uint32_t[]> rawData {nullptr}; 
  };
 
  SG::SlotSpecificObj<EventCache> m_eventsCache; 
  uint16_t m_maxLB{0}; 
};
 
#endif // TRIGBYTESTREAMINPUTSVC_H