ByteStreamRDP_OutputSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef BYTESTREAMRDP_OUTPUTSVC_H
#define BYTESTREAMRDP_OUTPUTSVC_H
 
#include "ByteStreamData/RawEvent.h" 
#include "ByteStreamCnvSvcBase/IByteStreamOutputSvc.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "AthenaBaseComps/AthService.h"
#include "GaudiKernel/ServiceHandle.h"
 
class IROBDataProviderSvc;
 
class ByteStreamRDP_OutputSvc: public extends<AthService, IByteStreamOutputSvc> {
public:
   ByteStreamRDP_OutputSvc(const std::string& name, ISvcLocator* svcloc);
 
   virtual StatusCode initialize() override;
 
   virtual bool putEvent(const RawEvent* re) override;
   virtual bool putEvent(const RawEvent* re, const EventContext& ctx) override;
 
private: // data
   struct EventCache {
      void releaseEvent() {
         this->rawEvent.reset();
         this->dataBuffer.reset();
      }
      std::unique_ptr<RawEvent> rawEvent {nullptr}; 
      std::unique_ptr<uint32_t[]> dataBuffer {nullptr}; 
   };
   SG::SlotSpecificObj<EventCache> m_eventsCache; 
 
   ServiceHandle<IROBDataProviderSvc> m_robProvider {
      this, "ROBDataProviderSvc", "ROBDataProviderSvc", "ROB data provider"};
   Gaudi::Property<std::string> m_bsOutputStreamName {
      this, "BSOutputStreamName", "", "Stream name for multiple output"};
};
 
#endif