MDT_RawDataProviderTool.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#include "MDT_RawDataProviderTool.h"
 
#include "ByteStreamCnvSvcBase/IROBDataProviderSvc.h"
#include "MuonRDO/MdtCsmContainer.h"
#include "MuonReadoutGeometry/MuonDetectorManager.h"
 
 
StatusCode Muon::MDT_RawDataProviderTool::initialize() {
    ATH_MSG_VERBOSE("Starting init");
 
    ATH_MSG_VERBOSE("Getting m_robDataProvider");
 
    // Get ROBDataProviderSvc
    ATH_CHECK(m_robDataProvider.retrieve());
    ATH_CHECK(m_idHelperSvc.retrieve());
 
    ATH_MSG_VERBOSE("Getting m_decoder");
 
    // Retrieve decoder
    ATH_CHECK(m_decoder.retrieve());
    m_maxhashtoUse = m_idHelperSvc->mdtIdHelper().stationNameIndex("BME") != -1 ? m_idHelperSvc->mdtIdHelper().detectorElement_hash_max()
                                                                                : m_idHelperSvc->mdtIdHelper().module_hash_max();
 
    ATH_CHECK(m_rdoContainerKey.initialize());
    ATH_CHECK(m_readKey.initialize());
    ATH_CHECK(m_rdoContainerCacheKey.initialize(!m_rdoContainerCacheKey.key().empty()));
 
    ATH_MSG_DEBUG("initialize() successful in " << name());
    return StatusCode::SUCCESS;
}
 
StatusCode Muon::MDT_RawDataProviderTool::convertIntoContainer(const ROBFragmentList & vecRobs,
                                                               const EventContext& ctx) const {
    
    ATH_MSG_VERBOSE("convert(): " << vecRobs.size() << " ROBFragments.");
 
    SG::WriteHandle rdoContainerHandle(m_rdoContainerKey, ctx);
 
    MdtCsmContainer* rdoContainer = nullptr;
 
    // here we have two paths. The first one we do not use an external cache, so just create
    // the MDT CSM container and record it. For the second path, we create the container
    // by passing in the container cache key so that the container is linked with the event
    // wide cache.
    const bool externalCacheRDO = !m_rdoContainerCacheKey.key().empty();
    if (!externalCacheRDO) {
        // without the cache we just record the container
        ATH_CHECK(rdoContainerHandle.record(std::make_unique<MdtCsmContainer>(m_maxhashtoUse)));
        ATH_MSG_DEBUG("Created container");
        rdoContainer = rdoContainerHandle.ptr();
    } else {
        // use the cache to get the container
        SG::UpdateHandle update(m_rdoContainerCacheKey, ctx);
        ATH_CHECK(update.isValid());
        ATH_CHECK(rdoContainerHandle.record(std::make_unique<MdtCsmContainer>(update.ptr())));
        ATH_MSG_DEBUG("Created container using cache for " << m_rdoContainerCacheKey.key());
        rdoContainer = rdoContainerHandle.ptr();
    }
 
    // this should never happen, but since we dereference the pointer we should check it first
    if (!rdoContainer) {
        ATH_MSG_ERROR("MdtCsmContainer is null, cannot convert MDT raw data");
        return StatusCode::FAILURE;
    }
 
 
    ATH_MSG_VERBOSE("convert(): " << vecRobs.size() << " ROBFragments.");
 
    for (const OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment* frag : vecRobs) {
        // convert only if data payload is delivered
        if (frag->rod_ndata() != 0) {
            m_decoder->fillCollections(*frag, *rdoContainer).ignore();
        } else {
            ATH_MSG_DEBUG(" ROB " << MSG::hex << frag->source_id() << " is delivered with an empty payload" );
            // store the error condition into the StatusCode and continue
        }
    }
    // in presence of errors return FAILURE
    ATH_MSG_DEBUG("After processing numColls=" << rdoContainer->numberOfCollections());
    return StatusCode::SUCCESS;
}
 
StatusCode Muon::MDT_RawDataProviderTool::convert(
    const EventContext& ctx) const  // call decoding function using list of all detector ROBId's
{
 
    const MuonMDT_CablingMap* readCdo{};
    ATH_CHECK(SG::get(readCdo, m_readKey, ctx));
    return convert(readCdo->getAllROBId(), ctx);
}
 
StatusCode Muon::MDT_RawDataProviderTool::convert(const std::vector<IdentifierHash>& HashVec, const EventContext& ctx) const {
    const MuonMDT_CablingMap* readCdo{};
    ATH_CHECK(SG::get(readCdo, m_readKey, ctx));
    return convert(readCdo->getROBId(HashVec, msgStream()), ctx);
}
 
StatusCode Muon::MDT_RawDataProviderTool::convert(const std::vector<uint32_t>& robIds, 
                                                  const EventContext& ctx) const {
    ROBFragmentList vecOfRobf;
    m_robDataProvider->getROBData(ctx, robIds, vecOfRobf);
    return convertIntoContainer(vecOfRobf, ctx);  // using the old one
}