TrigByteStreamCnvSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGBYTESTREAMCNVSVC_H
#define TRIGBYTESTREAMCNVSVC_H
 
#include "ByteStreamCnvSvcBase/ByteStreamCnvSvcBase.h"
#include "ByteStreamCnvSvcBase/IByteStreamCnvSvc.h"
#include "AthenaMonitoringKernel/Monitored.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "EFInterfaceSvc.h"
 
// Forward declarations
class StoreGateSvc;
class IROBDataProviderSvc;

class TrigByteStreamCnvSvc : public extends<ByteStreamCnvSvcBase,
                                            IByteStreamCnvSvc, IByteStreamEventAccess> {
public:
  TrigByteStreamCnvSvc(const std::string& name, ISvcLocator* svcLoc);
  virtual ~TrigByteStreamCnvSvc();
 
  // ------------------------- IService methods --------------------------------
  virtual StatusCode initialize() override;
  virtual StatusCode finalize() override;
 
  // ------------------------- IConversionSvc methods --------------------------
  virtual StatusCode connectOutput(const std::string& outputFile) override;
  StatusCode connectOutput(const std::string& outputFile, const EventContext& eventContext);
  virtual StatusCode connectOutput(const std::string& outputFile, const std::string& openMode) override;
  virtual StatusCode commitOutput(const std::string& outputFile, bool do_commit) override;
  StatusCode commitOutput(const std::string& outputFile, bool do_commit, const EventContext& eventContext);
 
  // ------------------------- IByteStreamEventAccess methods ------------------
  virtual RawEventWrite* getRawEvent() override;
  RawEventWrite* getRawEvent(const EventContext& eventContext) const;
 
protected:
   // ------------------------- IByteStreamCnvSvc methods ------------------
   virtual FullEventAssemblerBase* findFullEventAssembler(const std::string& name) const override;
   virtual StatusCode storeFullEventAssembler(std::unique_ptr<FullEventAssemblerBase> fea, const std::string& name) override;
 
private:
  // ------------------------- Helper methods ----------------------------------
  RawEventWrite* setRawEvent(std::unique_ptr<RawEventWrite>&& rawEventWrite, const EventContext& eventContext);
  void clearRawEvent(const EventContext& eventContext);
  void printRawEvent(const EventContext& eventContext) const;
  void monitorRawEvent(const std::unique_ptr<uint32_t[]>& rawEventPtr) const;
  const EventContext* currentContext() const;
 
  // ------------------------- Service / Tool handles --------------------------
  ServiceHandle<StoreGateSvc> m_evtStore {this, "EventStore", "StoreGateSvc"};
  ServiceHandle<IROBDataProviderSvc> m_robDataProviderSvc {this, "ROBDataProvider", "ROBDataProviderSvc"};
  ServiceHandle<EFInterfaceSvc> m_efInterfaceSvc {this, "EFInterfaceSvc", "", "Online service managing EF interface with Dataflow"};
  ToolHandle<GenericMonitoringTool> m_monTool {this, "MonTool", "" , "Monitoring tool"};
 
  // ------------------------- Other private members ---------------------------
  SG::SlotSpecificObj<std::unique_ptr<RawEventWrite>> m_rawEventWriteCache;
  bool m_hasEFInterface{false}; 
};
 
#endif // TRIGBYTESTREAMCNVSVC_H