MuCTPIByteStreamCnv.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 "ByteStreamCnvSvcBase/ByteStreamAddress.h"
#include "ByteStreamData/RawEvent.h"
#include "ByteStreamData/ROBData.h"
 
#include "AthenaKernel/StorableConversions.h"
 
// Trigger include(s):
#include "TrigT1Result/MuCTPI_RDO.h"
 
// Local include(s):
#include "MuCTPIByteStreamCnv.h"
#include "MuCTPIByteStreamTool.h"
 
// Hack for early data, where CTP and MuCTPI were plugged into the
// same ROS PC
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
#  include "CTPByteStreamTool.h"
#  include "RecCTPByteStreamTool.h"
#  include "TrigT1Result/CTP_RDO.h"
#  include "TrigT1Result/CTP_RIO.h"
#endif

MuCTPIByteStreamCnv::MuCTPIByteStreamCnv( ISvcLocator* svcloc )
  : Converter( storageType(), classID(), svcloc ),
    m_tool( "MuCTPIByteStreamTool" ),
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
    m_ctp_tool( "CTPByteStreamTool" ),
    m_ctp_rec_tool( "RecCTPByteStreamTool" ),
    m_storeGate( "StoreGateSvc", "MuCTPIByteStreamCnv" ),
#endif
    m_robDataProvider( "ROBDataProviderSvc", "MuCTPIByteStreamCnv" ),
    m_ByteStreamEventAccess( "ByteStreamCnvSvc", "MuCTPIByteStreamCnv" ) {
 
}

const CLID& MuCTPIByteStreamCnv::classID() {
 
  return ClassID_traits<MuCTPI_RDO>::ID();
 
}
 
long MuCTPIByteStreamCnv::storageType() {
  return ByteStreamAddress::storageType();
}

StatusCode MuCTPIByteStreamCnv::initialize() {
 
  //
  // Initialise the base class:
  //
  ATH_CHECK(  Converter::initialize() );
 
  MsgStream log( msgSvc(), "MuCTPIByteStreamCnv" );
  log << MSG::DEBUG << "MuCTPIByteStreamCnv in initialize() " << endmsg;
 
  //
  // Get ByteStreamCnvSvc:
  //
  ATH_CHECK(  m_ByteStreamEventAccess.retrieve() );
 
  //
  // Get MuCTPIByteStreamTool:
  //
  ATH_CHECK(  m_tool.retrieve() );
  log << MSG::DEBUG << "Connected to MuCTPIByteStreamTool" << endmsg;
 
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
  //
  // Get CTPByteStreamTool:
  //
  ATH_CHECK( m_ctp_tool.retrieve() );
  log << MSG::DEBUG << "Connected to CTPByteStreamTool" << endmsg;
 
  //
  // Get RecCTPByteStreamTool:
  //
  ATH_CHECK(  m_ctp_rec_tool.retrieve() );
  log << MSG::DEBUG << "Connected to RecCTPByteStreamTool" << endmsg;
#endif
 
  //
  // Get ROBDataProvider:
  //
  if( m_robDataProvider.retrieve().isFailure() ) {
    log << MSG::WARNING << "Can't get ROBDataProviderSvc" << endmsg;
    // return is disabled for Write BS which does not requre ROBDataProviderSvc
  } else {
    log << MSG::DEBUG << "Connected to ROBDataProviderSvc" << endmsg;
  }
 
  return StatusCode::SUCCESS;
}

StatusCode MuCTPIByteStreamCnv::createObj( IOpaqueAddress* pAddr, DataObject*& pObj ) {
 
  MsgStream log( msgSvc(), "MuCTPIByteStreamCnv" );
  log << MSG::DEBUG << "createObj() called" << endmsg;
 
  ByteStreamAddress *pBS_Addr;
  pBS_Addr = dynamic_cast< ByteStreamAddress* >( pAddr );
  if ( !pBS_Addr ) {
    log << MSG::ERROR << " Can not 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() );
 
  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(Gaudi::Hive::currentContext(), vID, robFrags );
 
  //
  // Size check:
  //
  if( robFrags.size() == 0 ) {
    
    // This is a hack - for some time CTP and MUCTPI were plugged in
    // the same ROB of the same ROS PC ...
    // 0x76000b : MUCTPI
    // 0x76000a : CTP
    // Note that the MUCTPI ROBID must come first, cos further down we
    // just use the first element of robFrags to create the RDO
    vID[0] = ( robId | 0x00000b );
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
    vID.push_back( robId | 0x00000a );
#endif
    m_robDataProvider->getROBData(Gaudi::Hive::currentContext(), vID, robFrags );
 
    if( robFrags.size() == 0 ) {
      // yet another temporary hack!!! - for some time the ROB ID was 0!
      vID[0] = 0x00000b;
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
      vID[1] = 0x00000a;
#endif
      m_robDataProvider->getROBData(Gaudi::Hive::currentContext(),  vID, robFrags );
      
      if( robFrags.size() == 0 ) {
        log << MSG::WARNING << "No MuCTPI ROB fragments found!" << endmsg;
 
        MuCTPI_RDO* result = new MuCTPI_RDO;
        pObj = SG::asStorable( result );
        return StatusCode::SUCCESS;
      }
    }
  }
 
  IROBDataProviderSvc::VROBFRAG::const_iterator it = robFrags.begin();
  MuCTPI_RDO* result = 0;
  StatusCode sc = m_tool->convert( ROBData( *it ).getROBFragment(), result );
  if( sc.isFailure() ) {
    log << MSG::ERROR << " Failed to create Objects: " << *( pBS_Addr->par() ) << endmsg;
    if (result!=0){
      delete result;
      result=0;
    }
    return sc;
  }
  pObj = SG::asStorable( result ) ;
 
#ifdef CTP_MUCTPI_HAVE_SAME_ROS
  // If CTP and MuCTPI send to the same ROS, the MuCTPI ROS, we get
  // the CTP fragment in the MuCTPI ROS fragment. In order to be able
  // to produce a CTP_RDO, we call the CTP ByteStream AlgTool from
  // here whenever we think we have a CTP fragment.
 
  if( robFrags.size() > 1 ) {
 
    ++it;
    if( it != robFrags.end() ) {
    
      CTP_RDO* ctp_result = 0;
      CTP_RIO* ctp_rio_result = 0;
 
      ATH_CHECK(  m_ctp_tool->convert( ROBData( *it ).getROBFragment(), ctp_result ) );
 
      SG::asStorable( ctp_result ) ;
      ATH_CHECK(  m_storeGate->record( ctp_result, "CTP_RDO" ) );
 
      ATH_CHECK(  m_ctp_rec_tool->convert( ROBData( *it ).getROBFragment(), ctp_rio_result, log ) );
 
      SG::asStorable( ctp_rio_result ) ;
      ATH_CHECK(  m_storeGate->record( ctp_rio_result, "CTP_RIO" ) );
    }
 
  }
#endif
 
  return sc;
}

StatusCode MuCTPIByteStreamCnv::createRep( DataObject* pObj, IOpaqueAddress*& pAddr ) {
 
  MsgStream log( msgSvc(), "MuCTPIByteStreamCnv" );
  log << MSG::DEBUG << "createRep() called" << endmsg;
 
  RawEventWrite* re = m_ByteStreamEventAccess->getRawEvent();
 
  MuCTPI_RDO* result;
  if( ! SG::fromStorable( pObj, result ) ) {
    log << MSG::ERROR << " Cannot cast to MuCTPI_RDO" << endmsg;
    return StatusCode::FAILURE;
  }
 
  ByteStreamAddress* addr = new ByteStreamAddress( classID(), pObj->registry()->name(), "" );
 
  pAddr = addr;
 
  // Convert to ByteStream
  return m_tool->convert( result, re );
}