RecMuCTPIByteStreamCnv.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/ROBData.h"
 
#include "AthenaKernel/StorableConversions.h"
 
// Trigger include(s):
#include "TrigT1Result/MuCTPI_RIO.h"
 
// Local include(s):
#include "RecMuCTPIByteStreamCnv.h"

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

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

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

StatusCode RecMuCTPIByteStreamCnv::createObj( IOpaqueAddress* pAddr, DataObject*& pObj ) {
 
  MsgStream log( msgSvc(), "RecMuCTPIByteStreamCnv" );
  log << MSG::DEBUG << "executing createObj()" << 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() );
 
  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() == 0 ) {    
    // This is a hack - in early data the rob id of the MuCTPI was
    // wrong, i.e. 0x76000b
    uint32_t newRobId = robId;
    newRobId |= 0x00000b;
    vID[0] = ( newRobId );
    m_robDataProvider->getROBData(ctx, vID, robFrags );
    // size check
    if ( robFrags.size() != 1 ) {
      log << MSG::WARNING << " Number of ROB fragments for source ROB ID " << MSG::hex << newRobId << " (ROD ID " 
          << m_srcIdMap.getRodID() << MSG::dec << ") is " << robFrags.size() << endmsg;
      MuCTPI_RIO * result = new MuCTPI_RIO;
      pObj = SG::asStorable( result ) ;
      return StatusCode::SUCCESS;
    }
  }
 
  IROBDataProviderSvc::VROBFRAG::const_iterator it = robFrags.begin();
  MuCTPI_RIO* result{};
  // Convert to Object
  auto sc =  m_tool->convert( ROBData( *it ).getROBFragment(), result ) ;
  if (sc.isFailure()){
    log << MSG::ERROR<<"RecMuCTPIByteStreamCnv::createObj failed."<<endmsg;
    delete result; //object new'ed in convert
    return sc;
  }
  pObj = SG::asStorable( result ) ;
  
  return StatusCode::SUCCESS;
}