TileMuRcvContByteStreamCnv.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
// Gaudi includes
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/StatusCode.h"
#include "GaudiKernel/DataObject.h"
#include "GaudiKernel/IRegistry.h"
#include "GaudiKernel/IToolSvc.h"
 
// Athena includes
#include "AthenaKernel/errorcheck.h"
 
#include "ByteStreamCnvSvcBase/IByteStreamCnvSvc.h"
#include "ByteStreamCnvSvcBase/ByteStreamCnvSvcBase.h"
#include "ByteStreamCnvSvcBase/ByteStreamAddress.h"
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
#include "ByteStreamData/RawEvent.h"
 
#include "StoreGate/StoreClearedIncident.h"
#include "AthenaKernel/CLASS_DEF.h"
 
// Tile includes
#include "TileByteStream/TileMuRcvContByteStreamCnv.h"
#include "TileByteStream/TileMuRcvContByteStreamTool.h"
#include "TileByteStream/TileROD_Decoder.h"
 
 
#include <string> 
 
 
TileMuRcvContByteStreamCnv::TileMuRcvContByteStreamCnv(ISvcLocator* svcloc)
  : AthConstConverter(storageType(), classID(),svcloc, "TileMuRcvContByteStreamCnv")
  , m_tool("TileMuRcvContByteStreamTool")
  , m_byteStreamCnvSvc("ByteStreamCnvSvc", name())
  , m_storeGate("StoreGateSvc", name())
  , m_robSvc("ROBDataProviderSvc", name())
  , m_decoder("TileROD_Decoder")
{
}
 
CLID TileMuRcvContByteStreamCnv::classID(){
  return ClassID_traits<TileMuonReceiverContainer>::ID();
}
 
long TileMuRcvContByteStreamCnv::storageType() {
  return ByteStreamAddress::storageType();
}
 
StatusCode TileMuRcvContByteStreamCnv::initialize()
{
  ATH_CHECK(Converter::initialize());
 
  ATH_MSG_DEBUG(" initialize ");
 
  // Get ByteStreamCnvSvc
  ATH_CHECK( m_byteStreamCnvSvc.retrieve() );
 
  // retrieve Tool
  ATH_CHECK( m_decoder.retrieve() );
 
  ATH_CHECK( m_tool.retrieve() );
 
  ATH_CHECK( m_robSvc.retrieve() );
 
  ATH_CHECK( m_storeGate.retrieve() );
 
  return StatusCode::SUCCESS ;
}
 
 
StatusCode TileMuRcvContByteStreamCnv::createObjConst(IOpaqueAddress* pAddr, DataObject*& pObj) const
{
 
  ATH_MSG_DEBUG( " Executing createObj method" );
 
  ByteStreamAddress* pRE_Addr{};
  ATH_CHECK( (pRE_Addr = dynamic_cast<ByteStreamAddress*>(pAddr)) != nullptr );
 
  const EventContext& ctx = pRE_Addr->getEventContext();
  const RawEvent* re = m_robSvc->getEvent(ctx);
  if (!re) {
    ATH_MSG_ERROR( "Could not get raw event from ByteStreamInputSvc" );
    return StatusCode::FAILURE;
  }
 
  auto cont = std::make_unique<TileMuonReceiverContainer>();
 
  StatusCode sc=m_decoder->convertTMDBDecision(re,cont.get());
  if (sc!=StatusCode::SUCCESS) {
    ATH_MSG_WARNING( "Conversion tool returned an error. TileMuonReceiverContainer might be empty." );
  }
 
  pObj = SG::asStorable( std::move(cont) );
 
  return StatusCode::SUCCESS;
}
 
StatusCode TileMuRcvContByteStreamCnv::createRepConst(DataObject* pObj, IOpaqueAddress*& pAddr) const
{
  ATH_MSG_DEBUG( " Executing createRep method" );
 
  // get Full Event Assembler
  FullEventAssembler<TileHid2RESrcID>* fea = 0;
  std::string key("Tile");
 
  ATH_CHECK( m_byteStreamCnvSvc->getFullEventAssembler(fea, key) );
 
  // create TileMuonReceiverContainer
  //
  TileMuonReceiverContainer* muRcvCont(0);
  SG::fromStorable(pObj, muRcvCont);
  if(!muRcvCont){
    ATH_MSG_ERROR( " Can not cast to TileMuonReceiverContainer " );
    return StatusCode::FAILURE;
  }
 
  std::string name = pObj->registry()->name();
  ByteStreamAddress* addr = new ByteStreamAddress(classID(), name, "");
 
  pAddr = addr;
 
  // call TileMuRcvContByteStreamTool
  ATH_CHECK( m_tool->convert(muRcvCont,fea) );
 
  return StatusCode::SUCCESS;
}
 
StatusCode TileMuRcvContByteStreamCnv::finalize()
{
  return Converter::finalize();
}