ByteStreamCnvSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef BYTESTREAMCNVSVC_BYTESTREAMCNVSVC_H
#define BYTESTREAMCNVSVC_BYTESTREAMCNVSVC_H
 
#include "ByteStreamCnvSvcBase/IByteStreamOutputSvc.h"
#include "ByteStreamCnvSvcBase/IByteStreamCnvSvc.h"
#include "ByteStreamCnvSvcBase/ByteStreamCnvSvcBase.h"
#include "ByteStreamCnvSvcBase/FullEventAssembler.h"
#include "ByteStreamCnvSvcBase/IByteStreamEventAccess.h"
#include "StoreGate/StoreGateSvc.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "GaudiKernel/ThreadLocalContext.h"
#include "GaudiKernel/ServiceHandle.h"
 
#include <map>
 
class FullEventAssemblerBase;

 
class ByteStreamCnvSvc : public extends<ByteStreamCnvSvcBase,
                                        IByteStreamCnvSvc, IByteStreamEventAccess> {
public:
   ByteStreamCnvSvc(const std::string& name, ISvcLocator* svc);

   virtual ~ByteStreamCnvSvc() = default;

   virtual StatusCode initialize() override;
   virtual StatusCode finalize() override;

   virtual StatusCode connectOutput(const std::string& t, const std::string& mode) override;
   virtual StatusCode connectOutput(const std::string& t) override;

   virtual StatusCode commitOutput(const std::string& outputConnection, bool b) override;

   virtual RawEventWrite* getRawEvent() override
   {
     return m_slots->m_rawEventWrite.get();
   }
 
protected:
   RawEventWrite* setRawEvent (std::unique_ptr<RawEventWrite> rawEventWrite);

   virtual FullEventAssemblerBase* findFullEventAssembler(const std::string& name) const override;
   virtual StatusCode storeFullEventAssembler(std::unique_ptr<FullEventAssemblerBase> fea, const std::string& name) override;
 
private:
   Gaudi::Property<std::string> m_ioSvcName{this, "ByteStreamOutputSvc", "", "ByteStream output service name"};

   Gaudi::Property<std::vector<std::string>> m_ioSvcNameList{this, "ByteStreamOutputSvcList", {}, "", "OrderedSet<T>"};

   Gaudi::Property<bool> m_fillTriggerBits{this, "FillTriggerBits", true, "Read in xTrigDecision and use it to fill Trigger bits in event header"};

   std::map<std::string, IByteStreamOutputSvc*> m_ioSvcMap;

   ServiceHandle<StoreGateSvc> m_evtStore{this, "EventStore", "StoreGateSvc"};

   Gaudi::Property<std::string> m_userType{this, "UserType", "RawEvent", "User type"};

   struct SlotData
   {
     std::unique_ptr<RawEventWrite> m_rawEventWrite;
     std::map<std::string, std::unique_ptr<FullEventAssemblerBase>> m_feaMap;
     std::vector<uint32_t> m_tagBuff;
     std::vector<uint32_t> m_l1Buff;
     std::vector<uint32_t> m_l2Buff;
     std::vector<uint32_t> m_efBuff;
 
     void clear()
     {
       m_rawEventWrite.reset();
       m_feaMap.clear();
       m_tagBuff.clear();
       m_l1Buff.clear();
       m_l2Buff.clear();
       m_efBuff.clear();
     }
   };
   SG::SlotSpecificObj<SlotData> m_slots;

   void writeFEA (SlotData& slot);
};
 
#endif // BYTESTREAMCNVSVC_BYTESTREAMCNVSVC_H