HLTResultMTByteStreamCnv.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2019 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef TRIGHLTRESULTBYTESTREAM_HLTResultMTByteStreamCnv_H
#define TRIGHLTRESULTBYTESTREAM_HLTResultMTByteStreamCnv_H
 
// Athena includes
#include "AthenaBaseComps/AthMessaging.h"
#include "AthenaKernel/SlotSpecificObj.h"
#include "ByteStreamCnvSvcBase/IByteStreamEventAccess.h"
#include "ByteStreamData/RawEvent.h"
 
// Gaudi includes
#include "GaudiKernel/Converter.h"
 
namespace HLT {
  class HLTResultMTByteStreamCnv : public Converter, public AthMessaging {
  public:
    HLTResultMTByteStreamCnv(ISvcLocator* svcLoc);
    virtual ~HLTResultMTByteStreamCnv();
 
    // ------------------------- Converter methods -----------------------------
    virtual StatusCode initialize() override;
    virtual StatusCode finalize() override;

    virtual StatusCode createObj(IOpaqueAddress* pAddr, DataObject*& pObj) override;
    virtual StatusCode createRep(DataObject* pObj, IOpaqueAddress*& pAddr) override;
 
    // ------------------------- Converter definition helpers ------------------
    static long storageType();
    static const CLID& classID();
 
    long repSvcType() const override { return i_repSvcType(); } 
 
  private:
    ServiceHandle<IByteStreamEventAccess> m_ByteStreamEventAccess;

    struct Cache {
      std::unique_ptr<uint32_t[]> streamTagData;
      std::vector<std::unique_ptr<OFFLINE_FRAGMENTS_NAMESPACE_WRITE::ROBFragment>> robFragments;
      ~Cache() {clear();}
      void clear() {
        streamTagData.reset();
        for (auto& ptr : robFragments) ptr.reset();
        robFragments.clear();
      }
    };
    SG::SlotSpecificObj<Cache> m_cache;
  };
} // namespace HLT
 
#endif // TRIGHLTRESULTBYTESTREAM_HLTResultMTByteStreamCnv_H