RecCTPByteStreamCnv.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
 
// Gaudi/Athena include(s):
#include "GaudiKernel/MsgStream.h"
#include "ByteStreamCnvSvcBase/ByteStreamAddress.h"
#include "ByteStreamData/RawEvent.h"
#include "ByteStreamData/ROBData.h"
 
#include "AthenaKernel/StorableConversions.h"
 
// Trigger include(s):
#include "TrigT1Result/CTP_RIO.h"
 
// Local include(s):
#include "RecCTPByteStreamCnv.h"

RecCTPByteStreamCnv::RecCTPByteStreamCnv( ISvcLocator* svcloc )
  : Converter( storageType(), classID(), svcloc ),
    m_tool( "RecCTPByteStreamTool" ),
    m_robDataProvider( "ROBDataProviderSvc", "RecCTPByteStreamCnv" ) {
 
}

CLID RecCTPByteStreamCnv::classID() {
 
  return ClassID_traits< CTP_RIO >::ID();
 
}
 
long RecCTPByteStreamCnv::storageType() {
  return ByteStreamAddress::storageType();
}

StatusCode RecCTPByteStreamCnv::initialize() {
 
  //
  // Initialise the base class:
  //
  ATH_CHECK( Converter::initialize() );
 
  MsgStream log( msgSvc(), "RecCTPByteStreamCnv" );
  log << MSG::DEBUG << "RecCTPByteStreamCnv in initialize()" << endmsg;
 
  //
  // Get RecCTPByteStreamTool:
  //
  ATH_CHECK(  m_tool.retrieve() );
  log << MSG::DEBUG << "Connected to RecCTPByteStreamTool" << endmsg;
 
  //
  // Get ROBDataProvider:
  //
  ATH_CHECK( m_robDataProvider.retrieve() );
  log << MSG::DEBUG << "Connected to ROBDataProviderSvc" << endmsg;
 
  return StatusCode::SUCCESS;
}

StatusCode RecCTPByteStreamCnv::createObj( IOpaqueAddress* pAddr, DataObject*& pObj ) {
 
  MsgStream log( msgSvc(), "RecCTPByteStreamCnv" );
  log << MSG::DEBUG << "RecCTPByteStreamCnv::createObj() called" << endmsg;
 
  ByteStreamAddress* pBS_Addr{};
  ATH_CHECK( (pBS_Addr = dynamic_cast<ByteStreamAddress*>(pAddr)) != nullptr );
 
  const EventContext& ctx = pBS_Addr->getEventContext();
 
  log << MSG::DEBUG << " Creating Objects: " << *( pBS_Addr->par() ) << endmsg;
 
  //
  // Get SourceID:
  //
  const uint32_t robId = m_srcIdMap.getRobID( m_srcIdMap.getRodID() );
 
  log << MSG::DEBUG << "expected ROB sub-detector ID: " << std::hex 
      << robId << std::dec << endmsg;  
 
  std::vector< uint32_t > vID;
  vID.push_back( robId );
 
  // get ROB fragment
  IROBDataProviderSvc::VROBFRAG robFrags;
  m_robDataProvider->getROBData(ctx, vID, robFrags );
 
  // size check
  if ( robFrags.size() != 1 ) {
    log << MSG::WARNING << " Number of ROB fragments for source ID 0x" << MSG::hex << robId
        << " is " << robFrags.size() << endmsg;
 
    CTP_RIO* result = new CTP_RIO;
    pObj = SG::asStorable( result ) ;
    return StatusCode::SUCCESS;
  }
 
  IROBDataProviderSvc::VROBFRAG::const_iterator it = robFrags.begin();
  CTP_RIO * result = 0;
 
  ATH_CHECK(  m_tool->convert( ROBData( *it ).getROBFragment(), result ) );
  pObj = SG::asStorable( result );
 
  return StatusCode::SUCCESS;
}