ByteStreamMergeOutputSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef BYTESTREAMCNVSVC_BYTESTREAMMERGEOUTPUTSVC_H
#define BYTESTREAMCNVSVC_BYTESTREAMMERGEOUTPUTSVC_H

 
#include "AthenaBaseComps/AthService.h"
#include "ByteStreamCnvSvcBase/IByteStreamInputSvc.h"
#include "ByteStreamCnvSvcBase/IByteStreamOutputSvc.h"
#include "GaudiKernel/ServiceHandle.h"

class ByteStreamMergeOutputSvc : public extends<AthService, IByteStreamOutputSvc> {
public:
   ByteStreamMergeOutputSvc(const std::string& name, ISvcLocator* svcloc);

   virtual ~ByteStreamMergeOutputSvc() = default;
 
   virtual StatusCode initialize() override;
   virtual bool putEvent(const RawEvent* re) override;
   virtual bool putEvent(const RawEvent* re, const EventContext& ctx) override;
 
private:
   uint32_t reducedROBid(uint32_t);
 
   ServiceHandle<IByteStreamInputSvc> m_inSvc{this, "ByteStreamInputSvc", {}};
   ServiceHandle<IByteStreamOutputSvc> m_outSvc{this, "ByteStreamOutputSvc", {}};
 
   Gaudi::Property<std::string> m_bsOutputStreamName{this, "BSOutputStreamName", {}, "stream name for multiple output"};
   Gaudi::Property<bool> m_overwriteHeader{this, "overWriteHeader", false};
};
 
#endif // BYTESTREAMCNVSVC_BYTESTREAMMERGEOUTPUTSVC_H