JepReadByteStreamV1V2Cnv.icc

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
 
#include <vector>
#include <stdint.h>
 
#include "ByteStreamCnvSvcBase/ByteStreamAddress.h"
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
 
#include "ByteStreamData/RawEvent.h"
#include "ByteStreamData/ROBData.h"
 
#include "AthContainers/DataVector.h"
 
#include "GaudiKernel/DataObject.h"
#include "GaudiKernel/IOpaqueAddress.h"
#include "GaudiKernel/IRegistry.h"
#include "GaudiKernel/ISvcLocator.h"
#include "GaudiKernel/StatusCode.h"
 
#include "AthenaKernel/ClassID_traits.h"
#include "AthenaKernel/StorableConversions.h"
#include "AthenaKernel/errorcheck.h"
 
#include "JepByteStreamV1Tool.h"
#include "JepByteStreamV2Tool.h"
 
namespace LVL1BS {
 
template <typename Container>
JepReadByteStreamV1V2Cnv<Container>::JepReadByteStreamV1V2Cnv( ISvcLocator* svcloc )
    : AthConstConverter( storageType(), classID(), svcloc, "JepReadByteStreamV1V2Cnv" ),
      m_tool1("LVL1BS::JepByteStreamV1Tool/JepByteStreamV1Tool"),
      m_tool2("LVL1BS::JepByteStreamV2Tool/JepByteStreamV2Tool"),
      m_robDataProvider("ROBDataProviderSvc", name())
{
}
 
template <typename Container>
JepReadByteStreamV1V2Cnv<Container>::~JepReadByteStreamV1V2Cnv()
{
}
 
// CLID
 
template <typename Container>
CLID JepReadByteStreamV1V2Cnv<Container>::classID()
{
  return ClassID_traits<Container>::ID();
}
 
template <typename Container>
long JepReadByteStreamV1V2Cnv<Container>::storageType()
{
  return ByteStreamAddress::storageType();
}
 
//  Init method gets all necessary services etc.
 
 
template <typename Container>
StatusCode JepReadByteStreamV1V2Cnv<Container>::initialize()
{
  ATH_CHECK( Converter::initialize() );
  ATH_CHECK( m_tool1.retrieve() );
  ATH_CHECK( m_tool2.retrieve() );
  ATH_CHECK( m_robDataProvider.retrieve() );
 
  return StatusCode::SUCCESS;
}
 
// createObj should create the RDO from bytestream.
 
template <typename Container>
StatusCode JepReadByteStreamV1V2Cnv<Container>::createObjConst ( IOpaqueAddress* pAddr,
                                                                 DataObject*& pObj ) const
{
  ByteStreamAddress* pBS_Addr{};
  ATH_CHECK( (pBS_Addr = dynamic_cast<ByteStreamAddress*>(pAddr)) != nullptr );
 
  const EventContext& ctx = pBS_Addr->getEventContext();
  const std::string nm = *( pBS_Addr->par() );
 
  ATH_MSG_DEBUG( " Creating Objects " << nm );
 
  // get SourceIDs
  const std::vector<uint32_t>& vID1(m_tool1->sourceIDs());
  const std::vector<uint32_t>& vID2(m_tool2->sourceIDs());
 
  // get ROB fragments
  IROBDataProviderSvc::VROBFRAG robFrags1;
  m_robDataProvider->getROBData(ctx, vID1, robFrags1 );
  IROBDataProviderSvc::VROBFRAG robFrags2;
  m_robDataProvider->getROBData(ctx, vID2, robFrags2 );
 
  // size check
  auto collection = std::make_unique<Container>();
  ATH_MSG_DEBUG( " Number of ROB fragments is " << robFrags1.size()
                 << ", " << robFrags2.size() );
 
  if (robFrags1.size() == 0 && robFrags2.size() == 0) {
    pObj = SG::asStorable(std::move(collection)) ;
    return StatusCode::SUCCESS;
  }
 
  // Pre-LS1 data
  if (robFrags1.size() > 0) {
    ATH_CHECK( m_tool1->convert(nm, robFrags1, collection.get()) );
  }
  // Post-LS1 data
  if (robFrags2.size() > 0) {
    ATH_CHECK( m_tool2->convert(nm, robFrags2, collection.get()) );
  }
 
  pObj = SG::asStorable(std::move(collection));
 
  return StatusCode::SUCCESS;
}
 
} // end namespace