RecMuCTPIByteStreamCnv.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2021 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" ) {
 
}

const 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;
  pBS_Addr = dynamic_cast< ByteStreamAddress* >( pAddr );
  if ( !pBS_Addr ) {
    log << MSG::ERROR << " Cannot cast to ByteStreamAddress " << endmsg ;
    return StatusCode::FAILURE;
  }
 
  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(Gaudi::Hive::currentContext(), 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(Gaudi::Hive::currentContext(), 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
  ATH_CHECK(  m_tool->convert( ROBData( *it ).getROBFragment(), result ) );
  pObj = SG::asStorable( result ) ;
  
  return StatusCode::SUCCESS;
}