TileDigitsContByteStreamCnv.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
// Gaudi includes
#include "GaudiKernel/StatusCode.h"
#include "GaudiKernel/DataObject.h"
 
// Athena includes 
#include "AthenaKernel/StorableConversions.h"
#include "AthenaKernel/errorcheck.h"
 
#include "ByteStreamCnvSvcBase/IByteStreamCnvSvc.h"
#include "ByteStreamCnvSvcBase/ByteStreamCnvSvcBase.h" 
#include "ByteStreamCnvSvcBase/ByteStreamAddress.h" 
#include "ByteStreamCnvSvcBase/ROBDataProviderSvc.h"
#include "ByteStreamData/RawEvent.h" 
 
#include "StoreGate/StoreClearedIncident.h"
#include "AthenaKernel/CLASS_DEF.h"
 
 
// Tile includes
#include "TileByteStream/TileDigitsContByteStreamCnv.h"
#include "TileByteStream/TileDigitsContByteStreamTool.h"
#include "TileByteStream/TileROD_Decoder.h"
#include "TileByteStream/TileHid2RESrcID.h"
#include "TileEvent/TileDigitsContainer.h"
#include "TileCalibBlobObjs/TileCalibUtils.h"
 
#include <vector> 
#include <string> 
#include <stdint.h>
 
 
TileDigitsContByteStreamCnv::TileDigitsContByteStreamCnv(ISvcLocator* svcloc) 
  : AthConstConverter(storageType(), classID(), svcloc, "TileDigitsContByteStreamCnv")
  , m_tool("TileDigitsContByteStreamTool")
  , m_byteStreamCnvSvc("ByteStreamCnvSvc", name())
  , m_robSvc("ROBDataProviderSvc", name())
  , m_decoder("TileROD_Decoder")
  , m_hid2re(0)
{
}
 
CLID TileDigitsContByteStreamCnv::classID(){ return ClassID_traits<TileDigitsContainer>::ID();}
 
long TileDigitsContByteStreamCnv::storageType() { return ByteStreamAddress::storageType(); }
 
StatusCode TileDigitsContByteStreamCnv::initialize() {
  
  ATH_CHECK(Converter::initialize());
 
  ATH_MSG_DEBUG(" initialize ");
 
  // Get ByteStreamCnvSvc
  ATH_CHECK( m_byteStreamCnvSvc.retrieve() );
 
  // retrieve Tool
  ATH_CHECK( m_decoder.retrieve() );
  m_hid2re = m_decoder->getHid2re();
 
  ATH_CHECK( m_tool.retrieve() );
 
  ATH_CHECK( m_robSvc.retrieve() );
 
  
  return StatusCode::SUCCESS;
}
 
StatusCode TileDigitsContByteStreamCnv::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 std::string containerName(*(pRE_Addr->par()));
  bool isTMDB(containerName == std::string("MuRcvDigitsCnt"));
  bool isFELIX(containerName == std::string("TileDigitsFlxCnt"));
  uint32_t newrob = 0x0;
 
 
  std::vector<uint32_t> robid(1);
  robid[0] = 0;
  std::vector<const ROBDataProviderSvc::ROBF*> robf;
 
  TileMutableDigitsContainer* cont = m_queue.get (true);
  ATH_CHECK( cont->status() );
    
  // iterate over all collections in a container and fill them
  //
  for (IdentifierHash hash : cont->GetAllCurrentHashes()) {
    TileDigitsCollection* digitsCollection = cont->indexFindPtr (hash);
    digitsCollection->clear();
    TileDigitsCollection::ID collID = digitsCollection->identify();
      
    // find ROB
    if (isTMDB) {
      newrob = m_hid2re->getRobFromTileMuRcvFragID(collID);
    } else if (isFELIX) {
      newrob = m_hid2re->getRobFromFragID(collID + TileCalibUtils::FELIX_FRAGID_OFFSET);
    } else {
      newrob = m_hid2re->getRobFromFragID(collID);
    }
 
    if (newrob != robid[0]) {
      robid[0] = newrob;
      robf.clear();
      m_robSvc->getROBData(ctx, robid, robf);
    }
      
    if (robf.size() > 0 ) {
      if (isTMDB) {// reid for TMDB 0x5x010x
        ATH_MSG_DEBUG(" Decoding TMDB digits in ROD fragment ");
        m_decoder->fillCollection_TileMuRcv_Digi(robf[0], *digitsCollection);
      }else if (isFELIX) {
        ATH_MSG_DEBUG(" Decoding FELIX digits in ROD fragment ");
        m_decoder->fillCollection_FELIX_Digi(robf[0], *digitsCollection);
      } else {
        m_decoder->fillCollection(robf[0], *digitsCollection);
      }
    } else {
      uint32_t status = TileROD_Decoder::NO_ROB;
      digitsCollection->setFragBCID(0xDEAD | (status<<16));
      ATH_MSG_DEBUG( "Status for " << ((isTMDB)?"TMDB ":"") << "drawer 0x" << MSG::hex << collID << " in Digi frag is 0x" << status << MSG::dec);
    }
 
 
  }
 
  ATH_MSG_DEBUG( "Creating digits container: " << containerName );
 
  TileDigitsContainer* basecont = cont;
  pObj = SG::asStorable( basecont ) ;
 
 
  return StatusCode::SUCCESS;  
}
 
 
StatusCode TileDigitsContByteStreamCnv::createRepConst(DataObject* pObj, IOpaqueAddress*& pAddr) const
{
  // convert TileDigitsContainer in the container into ByteStream
 
  ATH_MSG_DEBUG(" Executing createRep method ");
 
  // uint32_t runnum = re->header()->specific_part()->run_no(); 
 
  // get Full Event Assembler
  FullEventAssembler<TileHid2RESrcID>* fea = 0;
  std::string key("Tile");
  ATH_CHECK( m_byteStreamCnvSvc->getFullEventAssembler(fea, key) );
 
  // create TileDigitsContainer
  TileDigitsContainer* digicont(0) ; 
  SG::fromStorable(pObj, digicont ); 
 
  if(!digicont){
    ATH_MSG_ERROR(" Can not cast to TileDigitsContainer ");
   return StatusCode::FAILURE;    
  } 
 
  std::string name = pObj->registry()->name(); 
 
  ByteStreamAddress* addr = new ByteStreamAddress(classID(), name, ""); 
 
  pAddr = addr; 
 
  // call TileDigitsContByteStreamTool
 
  return m_tool->convert(digicont, fea);
}
 
StatusCode TileDigitsContByteStreamCnv::finalize()
{
  return Converter::finalize(); 
}