ByteStreamCnvSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 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();
 
   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:
   std::string m_ioSvcName;
 
   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;
 
   std::string m_userType;
 
   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