MdtRawDataMonAlg.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2023 CERN for the benefit of the ATLAS collaboration
*/
 
// Package : MdtRawDataMonAlg
// Authors:   N. Benekos(Illinois)
//            A. Cortes (Illinois)
//            G. Dedes (MPI)
//            Orin Harris (University of Washington)
//            Justin Griffiths (University of Washington)
//            M. Biglietti (INFN - Roma Tre)
// Oct. 2007
//
// DESCRIPTION:
// Subject: MDT-->Offline Muon Data Quality
 
#include "MdtRawDataMonAlg.h"
 
#include "AnalysisTriggerEvent/LVL1_ROI.h"
#include "AthenaMonitoring/AthenaMonManager.h"
#include "GaudiKernel/MsgStream.h"
#include "MdtCalibFitters/MTStraightLine.h"
#include "MdtHistCoder.h"
#include "MuonCalibIdentifier/MuonFixedId.h"
#include "MuonChamberIDSelector.h"
#include "MuonDQAUtils/MuonChamberNameConverter.h"
#include "MuonDQAUtils/MuonChambersRange.h"
#include "MuonDQAUtils/MuonDQAHistMap.h"
#include "MuonIdHelpers/MdtIdHelper.h"
#include "MuonRIO_OnTrack/MdtDriftCircleOnTrack.h"
#include "MuonReadoutGeometry/MuonDetectorManager.h"
#include "MuonReadoutGeometry/MuonStation.h"
#include "MuonSegment/MuonSegment.h"
#include "TrkEventPrimitives/FitQuality.h"
#include "TrkTrack/Track.h"
#include "TrkTrack/TrackCollection.h"
#include "xAODMuon/Muon.h"
#include "xAODTracking/TrackParticle.h"
#include "xAODTracking/TrackParticleContainer.h"
#include "xAODTracking/TrackingPrimitives.h"
 
// root includes
#include <TH2F.h>
 
#include <array>
#include <cmath>
#include <memory>
#include <sstream>
 
namespace {
    // the tube number of a tube in a tubeLayer in encoded in the GeoSerialIdentifier (modulo maxNTubesPerLayer)
    constexpr unsigned int maxNTubesPerLayer = MdtIdHelper::maxNTubesPerLayer;
}  // namespace
 
struct MDTOverviewHistogramStruct {
    std::vector<float> mdt_tube_x_barrel;
    std::vector<float> mdt_tube_y_barrel;
    std::vector<float> mdt_tube_z_barrel;
    std::vector<float> mdt_tube_perp_barrel;
 
    std::vector<float> mdt_tube_x_ovl;
    std::vector<float> mdt_tube_y_ovl;
    std::vector<float> mdt_tube_z_ovl;
    std::vector<float> mdt_tube_perp_ovl;
 
    std::vector<float> mdt_tube_x_endcap;
    std::vector<float> mdt_tube_y_endcap;
    std::vector<float> mdt_tube_z_endcap;
    std::vector<float> mdt_tube_perp_endcap;
 
    std::vector<float> adc_mon_nosel;
    std::vector<float> tdc_mon_nosel;
    std::vector<float> tdc_mon;
    std::vector<float> adc_mon;
    std::vector<int> noiseBurst;
 
    std::vector<float> tdc_mon_noiseBurst;
    std::vector<float> adc_mon_noiseBurst;
    std::vector<float> adc_mon_noiseBurst_notNoisy;
    std::vector<float> tdc_mon_noiseBurst_adcCut;
 
    std::vector<float> tdc_mon_adcCut;
};
 
struct MDTSummaryHistogramStruct {
    std::vector<int> sector;
    std::vector<int> stationEta;
    std::vector<float> adc_mon;
    std::vector<float> tdc_mon;
    std::vector<float> tdc_mon_nb2;
    std::vector<float> adc_mon_nb2;
    std::vector<float> tdc_mon_nb1;
    std::vector<float> adc_mon_nb1;
    std::vector<float> adc_mon_adccut;
    std::vector<float> tdc_mon_adccut;
    std::vector<int> x_mon;
    std::vector<int> y_mon;
    std::vector<int> x_mon_noise;
    std::vector<int> y_mon_noise;
    std::vector<float> tdc_mon_nb3;
    std::vector<int> x_bin_perML;
    std::vector<int> y_bin_perML;
    std::vector<int> bin_byLayer_x;
    std::vector<int> bin_byLayer_y;
    std::vector<float> tdc_mon_rpc;
    std::vector<float> tdc_mon_tgc;
    std::vector<int> biny_vslb;
    std::vector<int> biny_vslb_bycrate;
    std::vector<int> biny_vslb_bycrate_bis_bee;
    std::vector<int> biny_vslb_bycrate_ontrack;
    std::vector<int> biny_vslb_bycrate_bis_bee_ontrack;
};
 
struct MDTSegmentHistogramStruct {
    std::vector<float> adc_segs_mon;
    std::vector<float> tdc_segs_mon;
    std::vector<int> x_segs_mon;
    std::vector<int> y_segs_mon;
};
// *********************************************************************
// Public Methods
// *********************************************************************
 
MdtRawDataMonAlg::MdtRawDataMonAlg(const std::string& name, ISvcLocator* pSvcLocator) : AthMonitorAlgorithm(name, pSvcLocator) {}
 
MdtRawDataMonAlg::~MdtRawDataMonAlg() = default;
/*---------------------------------------------------------*/
StatusCode MdtRawDataMonAlg::initialize()
/*---------------------------------------------------------*/
{
    // init message stream
    ATH_MSG_DEBUG("initialize MdtRawDataMonAlg");
 
    ATH_MSG_DEBUG("******************");
    ATH_MSG_DEBUG("doMdtESD: " << m_doMdtESD);
    ATH_MSG_DEBUG("******************");
 
    // MuonDetectorManager from the conditions store
    ATH_CHECK(m_DetectorManagerKey.initialize());
    ATH_CHECK(detStore()->retrieve(m_detMgr));
 
    ATH_CHECK(m_idHelperSvc.retrieve());
 
    if (m_maskNoisyTubes)
        m_masked_tubes = std::make_unique<MDTNoisyTubes>();
    else
        m_masked_tubes = std::make_unique<MDTNoisyTubes>(false);
    mdtchamberId();
 
    ATH_CHECK(m_l1RoiKey.initialize(SG::AllowEmpty));
    ATH_CHECK(m_muonKey.initialize());
    ATH_CHECK(m_segm_type.initialize());
    ATH_CHECK(m_key_mdt.initialize());
    ATH_CHECK(m_key_rpc.initialize());
    ATH_CHECK(m_eventInfo.initialize());
    ATH_CHECK(m_muon_type.initialize());
    m_BMGid = m_idHelperSvc->mdtIdHelper().stationNameIndex("BMG");
    if (m_BMGid != -1) {
        ATH_MSG_DEBUG("Processing configuration for layouts with BMG chambers.");
        m_BMGpresent = true;
        // MuonDetectorManager from the Detector Store
        const MuonGM::MuonDetectorManager* MuonDetMgrDS{nullptr};
        ATH_CHECK(detStore()->retrieve(MuonDetMgrDS));
 
        for (int phi = 6; phi < 8; phi++) {                 // phi sectors
            for (int eta = 1; eta < 4; eta++) {             // eta sectors
                for (int side = -1; side < 2; side += 2) {  // side
                    if (!MuonDetMgrDS->getMuonStation("BMG", side * eta, phi)) continue;
                    for (int roe = 1; roe <= (MuonDetMgrDS->getMuonStation("BMG", side * eta, phi))->nMuonReadoutElements();
                         roe++) {  // iterate on readout elemets
                        const MuonGM::MdtReadoutElement* mdtRE = dynamic_cast<const MuonGM::MdtReadoutElement*>(
                            (MuonDetMgrDS->getMuonStation("BMG", side * eta, phi))->getMuonReadoutElement(roe));  // has to be an MDT
                        if (mdtRE) initDeadChannels(mdtRE);
                    }
                }
            }
        }
    }
 
    /* It seems as if a bunch of histograms are created below on the heap
     * Then these are filled in the binMdtFooBar methods
     * Later these are passed onto relevant methods of MDTChamber where internals are filled
     * The original histograms are transient and not needed past initialize here
     * The logic is a little too convoluted but left as is
     */
    unsigned int counter{0};
    std::string s{""}, xAxis{""};
 
    // Create Inner/Middle/Outer/Extra histograms per BA/BC/EA/EC
    std::vector<std::string> ecap{"BA", "BC", "EA", "EC"};
    std::vector<std::string> layer{"Inner", "Middle", "Outer", "Extra"};
    std::vector<std::unique_ptr<TH2F>> mdtHitsPerMultiLayerLumi;
    mdtHitsPerMultiLayerLumi.reserve(ecap.size() * layer.size());
 
    for (const auto& iecap : ecap) {
        for (const auto& ilayer : layer) {
            s = "NumberOfHitsIn" + iecap + ilayer + "PerMultiLayer_ADCCut";
            mdtHitsPerMultiLayerLumi.push_back(std::make_unique<TH2F>(s.c_str(), s.c_str(), 1, 0, 1, 1, 0, 1));
            xAxis = iecap.substr(0, 1) + ilayer.substr(0, 1) + iecap.substr(1, 1);
            ATH_CHECK(binMdtRegional(mdtHitsPerMultiLayerLumi[counter].get(), xAxis));
            counter++;
        }  // end of iecap
    }      // end of ilayer
    counter = 0;
 
    // Create Barrel/EndCap histrograms here
    std::vector<std::string> mdtHitsBE{"Barrel", "EndCap"};
    std::vector<std::unique_ptr<TH2F>> mdtHitsPerChamberIMOLumi;
    mdtHitsPerChamberIMOLumi.reserve(mdtHitsBE.size());
 
    for (const auto& imdt : mdtHitsBE) {
        s = "NumberOfHits" + imdt;
        mdtHitsPerChamberIMOLumi.push_back(std::make_unique<TH2F>(s.c_str(), s.c_str(), 1, 0, 1, 1, 0, 1));
        ATH_CHECK(binMdtGlobal(mdtHitsPerChamberIMOLumi[counter].get(), imdt.at(0)));
        counter++;
    }  // end of imdt
    counter = 0;
 
    // Create Inner/Middle/Outer histograms here
    std::vector<std::unique_ptr<TH2F>> mdtHitsPerMLByLayer;
    mdtHitsPerMLByLayer.reserve(layer.size() - 1);
 
    for (const auto& ilayer : layer) {
        if (ilayer == "Extra") continue;
        s = "NumberOfHitsInMDT" + ilayer + "_ADCCut";
        mdtHitsPerMLByLayer.push_back(std::make_unique<TH2F>(s.c_str(), s.c_str(), 1, 0, 1, 1, 0, 1));
    }  // end of ilayer
    ATH_CHECK(binMdtGlobal_byLayer(mdtHitsPerMLByLayer[0].get(), mdtHitsPerMLByLayer[1].get(), mdtHitsPerMLByLayer[2].get()));
 
    for (std::vector<Identifier>::const_iterator itr = m_chambersId.begin(); itr != m_chambersId.end(); ++itr, ++counter) {
        std::string hardware_name =
            convertChamberName(m_idHelperSvc->mdtIdHelper().stationName(*itr), m_idHelperSvc->mdtIdHelper().stationEta(*itr),
                               m_idHelperSvc->mdtIdHelper().stationPhi(*itr), "MDT");
        // Skip Chambers That Do NOT Exist
        if (hardware_name == "BML6A13" || hardware_name == "BML6C13") continue;
        std::unique_ptr<MDTChamber>& chamber = m_hist_hash_list[m_chambersIdHash.at(counter)];
        chamber = std::make_unique<MDTChamber>(hardware_name);
 
        chamber->SetMDTHitsPerChamber_IMO_Bin(mdtHitsPerChamberIMOLumi[chamber->GetBarrelEndcapEnum()].get());
        chamber->SetMDTHitsPerML_byLayer_Bins(
            mdtHitsPerMultiLayerLumi[chamber->GetRegionEnum() * layer.size() + chamber->GetLayerEnum()].get(),
            mdtHitsPerMLByLayer[(chamber->GetLayerEnum() < 3 ? chamber->GetLayerEnum() : 0)].get());
 
        m_tubesperchamber_map[hardware_name] = GetTubeMax(*itr, hardware_name);  // total number of tubes in chamber
    }
 
    ATH_MSG_DEBUG(" end of initialize ");
    return AthMonitorAlgorithm::initialize();
}
 
/*----------------------------------------------------------------------------------*/
StatusCode MdtRawDataMonAlg::fillHistograms(const EventContext& ctx) const
/*----------------------------------------------------------------------------------*/
{
    int lumiblock = -1;
    SG::ReadHandle<xAOD::EventInfo> evt(m_eventInfo, ctx);
    lumiblock = evt->lumiBlock();
 
    ATH_MSG_DEBUG("MdtRawDataMonAlg::MDT RawData Monitoring Histograms being filled");
 
    // Making an histo to store the Run3 geo flag
    auto run3geo = Monitored::Scalar<int>("run3geo", m_do_run3Geometry);
    auto firstEvent = Monitored::Scalar<int>("firstEvent", (int)(m_firstEvent));
    fill("MdtMonitor", run3geo, firstEvent);
    m_firstEvent = 0;
 
    // Retrieve the LVL1 Muon RoIs:
    bool trig_BARREL = false;
    bool trig_ENDCAP = false;
    if (!m_l1RoiKey.empty()) {
        SG::ReadHandle<xAOD::MuonRoIContainer> muonRoIs(m_l1RoiKey, ctx);
        if (!muonRoIs.isValid()) { ATH_MSG_ERROR("evtStore() does not contain muon L1 ROI Collection with name " << m_l1RoiKey); }
        // DEV still needed ? does not compile
        if (muonRoIs.isPresent() && muonRoIs.isValid()) {
            ATH_MSG_VERBOSE("Retrieved LVL1MuonRoIs object with key: " << m_l1RoiKey.key());
            trig_BARREL = std::any_of(muonRoIs->begin(), muonRoIs->end(),
                                      [](const auto& i) { return i->getSource() == xAOD::MuonRoI::RoISource::Barrel; });
            trig_ENDCAP = std::any_of(muonRoIs->begin(), muonRoIs->end(),
                                      [](const auto& i) { return i->getSource() == xAOD::MuonRoI::RoISource::Endcap; });
        }
    }
 
    // declare MDT stuff
    SG::ReadHandle<Muon::MdtPrepDataContainer> mdt_container(m_key_mdt, ctx);
    if (!mdt_container.isValid()) {
        ATH_MSG_ERROR("evtStore() does not contain mdt prd Collection with name " << m_key_mdt);
        return StatusCode::FAILURE;
    }
 
    ATH_MSG_DEBUG("****** mdtContainer->size() : " << mdt_container->size());
 
    int nColl = 0;         // Number of MDT chambers with hits
    int nColl_ADCCut = 0;  // Number of MDT chambers with hits above ADC cut
    int nPrd = 0;          // Total number of MDT prd digits
    int nPrdcut = 0;       // Total number of MDT prd digits with a cut on ADC>50.
 
    // declare RPC stuff
    SG::ReadHandle<Muon::RpcPrepDataContainer> rpc_container(m_key_rpc, ctx);
    if (!rpc_container.isValid()) {
        ATH_MSG_ERROR("evtStore() does not contain rpc prd Collection with name " << m_key_rpc);
        return StatusCode::FAILURE;
    }
 
    ATH_MSG_DEBUG("****** rpc->size() : " << rpc_container->size());
 
    Muon::RpcPrepDataContainer::const_iterator containerIt;
 
    float Nhitsrpc = 0;
    for (containerIt = rpc_container->begin(); containerIt != rpc_container->end(); ++containerIt) {
        for (Muon::RpcPrepDataCollection::const_iterator rpcPrd = (*containerIt)->begin(); rpcPrd != (*containerIt)->end(); ++rpcPrd) {
            ++Nhitsrpc;
        }
    }
    float Nhitsmdt = 0;
    bool isNoiseBurstCandidate = false;
    Muon::MdtPrepDataContainer::const_iterator MdtcontainerIt;
    for (MdtcontainerIt = mdt_container->begin(); MdtcontainerIt != mdt_container->end(); ++MdtcontainerIt) {
        for (Muon::MdtPrepDataCollection::const_iterator mdtCollection = (*MdtcontainerIt)->begin();
             mdtCollection != (*MdtcontainerIt)->end(); ++mdtCollection) {
            ++Nhitsmdt;
        }
    }
 
    if (Nhitsmdt > m_HighOccThreshold) isNoiseBurstCandidate = true;
    std::string type = "MDT";
    std::string hardware_name;
 
    std::map<std::string, int> evnt_hitsperchamber_map;
    std::set<std::string> chambers_from_tracks;
 
    if (m_doMdtESD == true) {
        // DEV this shouls be done in some other way, in AthenaMonManager there is
        //  Gaudi::Property<std::string> m_environmentStr {this,"Environment","user"}; ///< Environment string pulled from the job option
        //  and converted to enum
        // commented out for the time being
        //     if(m_environment == AthenaMonManager::tier0 || m_environment == AthenaMonManager::tier0ESD || m_environment ==
        //     AthenaMonManager::online) {
        if (true) {  // DEV to be updated
 
            SG::ReadHandle<xAOD::TrackParticleContainer> muons(m_muon_type, ctx);
 
            // ATH_CHECK(muons.isValid());
 
            for (const auto* const mu : *muons) {
                // add quality selection here
                if (mu) {
                    const Trk::Track* trk = mu->track();
                    // this work only if tp are available
                    if (!trk) continue;
 
                    uint8_t ntri_eta = 0;
                    uint8_t n_phi = 0;
                    mu->summaryValue(ntri_eta, xAOD::numberOfTriggerEtaLayers);
                    mu->summaryValue(n_phi, xAOD::numberOfPhiLayers);
                    if (ntri_eta + n_phi == 0) continue;
 
                    for (const Trk::MeasurementBase* hit : *trk->measurementsOnTrack()) {
                        const Trk::RIO_OnTrack* rot_from_track = dynamic_cast<const Trk::RIO_OnTrack*>(hit);
                        if (!rot_from_track) continue;
                        Identifier rotId = rot_from_track->identify();
                        if (!m_idHelperSvc->isMdt(rotId)) continue;
                        IdentifierHash mdt_idHash;
                        MDTChamber* mdt_chamber = nullptr;
                        m_idHelperSvc->mdtIdHelper().get_module_hash(rotId, mdt_idHash);
                        ATH_CHECK(getChamber(mdt_idHash, mdt_chamber));
                        std::string mdt_chambername = mdt_chamber->getName();
                        chambers_from_tracks.insert(mdt_chambername);
                    }
                }
            }
 
            MDTOverviewHistogramStruct overviewPlots;
            auto summaryPlots = std::make_unique<std::array<MDTSummaryHistogramStruct, 4096>>();
            // loop in MdtPrepDataContainer
            std::vector<std::string> v_hit_in_chamber_allphi;
            std::map<std::string, std::vector<std::string>> v_hit_in_chamber;
            for (Muon::MdtPrepDataContainer::const_iterator containerIt = mdt_container->begin(); containerIt != mdt_container->end();
                 ++containerIt) {
                if (containerIt == mdt_container->end() || containerIt->empty()) continue;  // check if there are counts
                nColl++;
 
                bool isHit_above_ADCCut = false;
                // loop over hits
                for (const auto* mdtCollection : **containerIt) {
                    nPrd++;
 
                    float adc = mdtCollection->adc();
                    hardware_name = getChamberName(mdtCollection);
 
                    if (hardware_name.substr(0, 3) == "BMG") adc /= m_adcScale;
                    if (adc > m_ADCCut) {
                        nPrdcut++;
                        isHit_above_ADCCut = true;
                        if (m_do_mdtchamberstatphislice) {
                            std::string phi = hardware_name.substr(hardware_name.length() - 2);
                            v_hit_in_chamber[phi].push_back(hardware_name);
                        }
                        v_hit_in_chamber_allphi.push_back(hardware_name);
                    }
                    fillMDTOverviewVects(mdtCollection, isNoiseBurstCandidate, overviewPlots);
                    //=======================================================================
                    //=======================================================================
                    //=======================================================================
                    ATH_CHECK(fillMDTSummaryVects(mdtCollection, chambers_from_tracks, isNoiseBurstCandidate, trig_BARREL, trig_ENDCAP,
                                                  summaryPlots.get()));
                    //=======================================================================
                    //=======================================================================
                    //=======================================================================
                    if (m_doChamberHists) { ATH_CHECK(fillMDTHistograms(mdtCollection)); }
 
                    std::map<std::string, int>::iterator iter_hitsperchamber = evnt_hitsperchamber_map.find(hardware_name);
                    if (iter_hitsperchamber == evnt_hitsperchamber_map.end()) {
                        evnt_hitsperchamber_map.insert(make_pair(hardware_name, 1));
                    } else {
                        iter_hitsperchamber->second += 1;
                    }
 
                }  // for loop over hits mdtcollection
                nColl_ADCCut += isHit_above_ADCCut;
            }  // loop in MdtPrepDataContainer
            if (m_do_mdtchamberstatphislice) {
                for (const auto& phiitem : v_hit_in_chamber) {
                    auto hit_in_chamber = Monitored::Collection("hits_phi_" + phiitem.first, phiitem.second);
                    fill("MdtMonitor", hit_in_chamber);
                }
            }
            auto hit_in_chamber_allphi = Monitored::Collection("hits_allphi", v_hit_in_chamber_allphi);
            fill("MdtMonitor", hit_in_chamber_allphi);
 
            fillMDTOverviewHistograms(overviewPlots);
            ATH_CHECK(fillMDTSummaryHistograms(summaryPlots.get(), lumiblock));
 
            int nHighOccChambers = 0;
            for (const auto& iterstat : evnt_hitsperchamber_map) {
                const auto iter_tubesperchamber = m_tubesperchamber_map.find(iterstat.first);
                if (ATH_UNLIKELY(iter_tubesperchamber == m_tubesperchamber_map.end())) {  // indicates software error
                    ATH_MSG_ERROR("Unable to find chamber " << iterstat.first);
                    continue;
                }
                float nTubes = iter_tubesperchamber->second;
                float hits = iterstat.second;
                float occ = hits / nTubes;
                if (occ > 0.1) nHighOccChambers++;
            }
 
            auto nHighOccChambers_mon = Monitored::Scalar<float>("nHighOccChambers_mon", nHighOccChambers);
 
            auto nPrd_mon = Monitored::Scalar<int>("nPrd_mon", nPrd);
            auto nPrdcut_mon = Monitored::Scalar<int>("nPrdcut_mon", nPrdcut);
            auto Nhitsrpc_mon = Monitored::Scalar<int>("Nhitsrpc_mon", Nhitsrpc);
            auto nColl_mon = Monitored::Scalar<int>("nColl_mon", nColl);
            auto nColl_ADCCut_mon = Monitored::Scalar<int>("nColl_ADCCut_mon", nColl_ADCCut);
 
            fill("MdtMonitor", nHighOccChambers_mon, nPrd_mon, Nhitsrpc_mon, nPrdcut_mon, nColl_mon, nColl_ADCCut_mon);
 
            //        if (m_mdtglobalhitstime) m_mdtglobalhitstime->Fill(m_time - m_firstTime);
 
        }  // m_environment == AthenaMonManager::tier0 || m_environment == AthenaMonManager::tier0ESD
    }      // m_doMdtESD==true
 
    for (const auto& key : m_segm_type) {
        SG::ReadHandle<Trk::SegmentCollection> segms(key, ctx);
        if (!segms.isValid()) {
            ATH_MSG_ERROR("evtStore() does not contain mdt segms Collection with name " << key);
            return StatusCode::FAILURE;
        }
 
        MDTSegmentHistogramStruct segsPlots[4][4][16];  // [region][layer][phi]
 
        ATH_CHECK(handleEvent_effCalc_fillVects(segms.cptr(), segsPlots));
 
        ATH_CHECK(fillMDTSegmentHistograms(segsPlots));
    }
    return StatusCode::SUCCESS;
}
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 
void MdtRawDataMonAlg::fillMDTOverviewVects(const Muon::MdtPrepData* mdtCollection, bool& isNoiseBurstCandidate,
                                            MDTOverviewHistogramStruct& vects) const {
    Identifier digcoll_id = mdtCollection->identify();
 
    std::string hardware_name = getChamberName(mdtCollection);
    bool isNoisy = m_masked_tubes->isNoisy(mdtCollection);
 
    // MuonDetectorManager from the conditions store
    SG::ReadCondHandle<MuonGM::MuonDetectorManager> DetectorManagerHandle{m_DetectorManagerKey};
    const MuonGM::MuonDetectorManager* MuonDetMgr = DetectorManagerHandle.cptr();
    if (!MuonDetMgr) {
        ATH_MSG_ERROR("Null pointer to the read MuonDetectorManager conditions object");
        return;
    }
 
    const MuonGM::MdtReadoutElement* pReadoutElementMDT = MuonDetMgr->getMdtReadoutElement(digcoll_id);
    const Amg::Vector3D mdtgPos = pReadoutElementMDT->tubePos(digcoll_id);  // global position of the wire
    float mdt_tube_eta = mdtgPos.eta();
 
    float tdc = mdtCollection->tdc() * 25.0 / 32.0;
    // Note: the BMG is digitized with 200ps which is not same as other MDT chambers with 25/32=781.25ps
    if (hardware_name.substr(0, 3) == "BMG") tdc = mdtCollection->tdc() * 0.2;
 
    float adc = mdtCollection->adc();
    if (hardware_name.substr(0, 3) == "BMG") adc /= m_adcScale;
 
    if (adc > m_ADCCut) {
        // barrel
        if (std::abs(mdt_tube_eta) > 0. && std::abs(mdt_tube_eta) < 0.9) {
            vects.mdt_tube_x_barrel.push_back(mdtgPos.x());
            vects.mdt_tube_y_barrel.push_back(mdtgPos.y());
            vects.mdt_tube_z_barrel.push_back(mdtgPos.z());
            vects.mdt_tube_perp_barrel.push_back(mdtgPos.perp());
        }
        // OverLap -->Fill MDT Global RZ and YX
        if (std::abs(mdt_tube_eta) > 0.9 && std::abs(mdt_tube_eta) < 1.2) {
            vects.mdt_tube_x_ovl.push_back(mdtgPos.x());
            vects.mdt_tube_y_ovl.push_back(mdtgPos.y());
            vects.mdt_tube_z_ovl.push_back(mdtgPos.z());
            vects.mdt_tube_perp_ovl.push_back(mdtgPos.perp());
        }
        // EndCap -->Fill MDT Global RZ and YX
        if (std::abs(mdt_tube_eta) > 1.2 && std::abs(mdt_tube_eta) < 2.7) {
            vects.mdt_tube_x_endcap.push_back(mdtgPos.x());
            vects.mdt_tube_y_endcap.push_back(mdtgPos.y());
            vects.mdt_tube_z_endcap.push_back(mdtgPos.z());
            vects.mdt_tube_perp_endcap.push_back(mdtgPos.perp());
        }
    }
 
    vects.adc_mon_nosel.push_back(adc);
    vects.tdc_mon_nosel.push_back(tdc);
    if (!isNoisy && adc > 0) {
        vects.tdc_mon.push_back(tdc);
        vects.adc_mon.push_back(adc);
    }
 
    vects.noiseBurst.push_back((int)isNoiseBurstCandidate);
    if (isNoiseBurstCandidate) {
        vects.tdc_mon_noiseBurst.push_back(tdc);
        vects.adc_mon_noiseBurst.push_back(adc);
        if (!isNoisy) { vects.adc_mon_noiseBurst_notNoisy.push_back(adc); }
        if (adc > m_ADCCut) { vects.tdc_mon_noiseBurst_adcCut.push_back(tdc); }
    }
 
    if (adc > m_ADCCut) { vects.tdc_mon_adcCut.push_back(tdc); }
}
 
void MdtRawDataMonAlg::fillMDTOverviewHistograms(const MDTOverviewHistogramStruct& vects) const {
    auto mdt_tube_x_barrel = Monitored::Collection("mdt_tube_x_barrel", vects.mdt_tube_x_barrel);
    auto mdt_tube_y_barrel = Monitored::Collection("mdt_tube_y_barrel", vects.mdt_tube_y_barrel);
    auto mdt_tube_z_barrel = Monitored::Collection("mdt_tube_z_barrel", vects.mdt_tube_z_barrel);
    auto mdt_tube_perp_barrel = Monitored::Collection("mdt_tube_perp_barrel", vects.mdt_tube_perp_barrel);
    fill("MdtMonitor", mdt_tube_z_barrel, mdt_tube_perp_barrel, mdt_tube_x_barrel, mdt_tube_y_barrel);
 
    auto mdt_tube_x_ovl = Monitored::Collection("mdt_tube_x_ovl", vects.mdt_tube_x_ovl);
    auto mdt_tube_y_ovl = Monitored::Collection("mdt_tube_y_ovl", vects.mdt_tube_y_ovl);
    auto mdt_tube_z_ovl = Monitored::Collection("mdt_tube_z_ovl", vects.mdt_tube_z_ovl);
    auto mdt_tube_perp_ovl = Monitored::Collection("mdt_tube_perp_ovl", vects.mdt_tube_perp_ovl);
    fill("MdtMonitor", mdt_tube_z_ovl, mdt_tube_perp_ovl, mdt_tube_x_ovl, mdt_tube_y_ovl);
 
    auto mdt_tube_x_endcap = Monitored::Collection("mdt_tube_x_endcap", vects.mdt_tube_x_endcap);
    auto mdt_tube_y_endcap = Monitored::Collection("mdt_tube_y_endcap", vects.mdt_tube_y_endcap);
    auto mdt_tube_z_endcap = Monitored::Collection("mdt_tube_z_endcap", vects.mdt_tube_z_endcap);
    auto mdt_tube_perp_endcap = Monitored::Collection("mdt_tube_perp_endcap", vects.mdt_tube_perp_endcap);
    fill("MdtMonitor", mdt_tube_z_endcap, mdt_tube_perp_endcap, mdt_tube_x_endcap, mdt_tube_y_endcap);
 
    auto adc_mon_nosel = Monitored::Collection("adc_mon_nosel", vects.adc_mon_nosel);
    auto tdc_mon_nosel = Monitored::Collection("tdc_mon_nosel", vects.tdc_mon_nosel);
    auto noiseBurst = Monitored::Collection("noiseBurst", vects.noiseBurst);
    fill("MdtMonitor", adc_mon_nosel, tdc_mon_nosel, noiseBurst);
 
    auto tdc_mon = Monitored::Collection("tdc_mon", vects.tdc_mon);
    auto adc_mon = Monitored::Collection("adc_mon", vects.adc_mon);
    fill("MdtMonitor", tdc_mon, adc_mon);
 
    auto adc_mon_noiseBurst_notNoisy = Monitored::Collection("adc_mon_noiseBurst_notNoisy", vects.adc_mon_noiseBurst_notNoisy);
    fill("MdtMonitor", adc_mon_noiseBurst_notNoisy);
 
    auto tdc_mon_noiseBurst_adcCut = Monitored::Collection("tdc_mon_noiseBurst_adcCut", vects.tdc_mon_noiseBurst_adcCut);
    fill("MdtMonitor", tdc_mon_noiseBurst_adcCut);
 
    auto tdc_mon_adcCut = Monitored::Collection("tdc_mon_adcCut", vects.tdc_mon_adcCut);
    fill("MdtMonitor", tdc_mon_adcCut);
}
 
StatusCode MdtRawDataMonAlg::fillMDTSummaryVects(const Muon::MdtPrepData* mdtCollection, const std::set<std::string>& chambers_from_tracks,
                                                 bool& isNoiseBurstCandidate, bool trig_barrel, bool trig_endcap,
                                                 std::array<MDTSummaryHistogramStruct, 4096>* vects) const {
    StatusCode sc = StatusCode::SUCCESS;
    Identifier digcoll_id = (mdtCollection)->identify();
    IdentifierHash digcoll_idHash = (mdtCollection)->collectionHash();
 
    MDTChamber* chamber{nullptr};
    ATH_CHECK(getChamber(digcoll_idHash, chamber));
    bool isNoisy = m_masked_tubes->isNoisy(mdtCollection);
 
    std::string region[4] = {"BA", "BC", "EA", "EC"};
    std::string layer[4] = {"Inner", "Middle", "Outer", "Extra"};
    std::string crate[4] = {"01", "02", "03", "04"};
    //  std::string slayer[4]={"inner","middle","outer","extra"};
 
    //  int ibarrel = chamber->GetBarrelEndcapEnum();
    int iregion = chamber->GetRegionEnum();
    int ilayer = chamber->GetLayerEnum();
    int icrate = chamber->GetCrate();
    //
    int stationPhi = chamber->GetStationPhi();
    std::string chambername = chamber->getName();
    int thisStationEta = chamber->GetStationEta();
 
    int crate_region = iregion;
    // correct readout crate info for BEE,BIS7/8
    if (chambername.substr(0, 3) == "BEE" || (chambername.substr(0, 3) == "BIS" && (thisStationEta == 7 || thisStationEta == 8))) {
        if (iregion == 0) crate_region = 2;
        if (iregion == 1) crate_region = 3;
    }
 
    uint16_t v = MdtHistCoder::encode(iregion, ilayer, stationPhi, crate_region, icrate - 1);
    std::array<MDTSummaryHistogramStruct, 4096>& array = *(vects);
    auto& thisVects = array[v];
 
    bool is_on_track = false;
    for (const auto& ch : chambers_from_tracks) {
        if (chambername == ch) is_on_track = true;
    }
 
    bool isBIM = (chambername.at(2) == 'M');
    float tdc = mdtCollection->tdc() * 25.0 / 32.0;
    // Note: the BMG is digitized with 200ps which is not same as other MDT chambers with 25/32=781.25ps
    if (chambername.substr(0, 3) == "BMG") tdc = mdtCollection->tdc() * 0.2;
    float adc = mdtCollection->adc();
    if (chambername.substr(0, 3) == "BMG") adc /= m_adcScale;
 
    thisVects.sector.push_back(stationPhi + iregion * 16);  // here valgrind complains
 
    //  mdtoccvslb_summaryPerSector->Fill(lumiblock,  stationPhi+iregion*16  );
    // MDTBA/Overview/Hits
    // iregion = BA/BC/EA/EC --> 4
    // ilayer = //inner, middle, outer, extra --> 4
    // stationPhi --> 16  ====> 256
    // std::string mon="MDTHits_ADCCut_"+region[iregion]+"_Mon_"+layer[ilayer]+"_Phi_"+std::to_string(stationPhi+1);;
    //  int mlayer_n = m_mdtIdHelper->multilayer(digcoll_id);
    int mlayer_n = m_idHelperSvc->mdtIdHelper().multilayer(digcoll_id);
 
    if (!isNoisy && adc > 0) {
        thisVects.adc_mon.push_back(adc);
        thisVects.tdc_mon.push_back(tdc);
        if (isNoiseBurstCandidate) {
            thisVects.tdc_mon_nb2.push_back(tdc);
            thisVects.adc_mon_nb2.push_back(adc);
        }
    }
 
    if (!isNoisy) {
        //    fill(MDT_regionGroup, adc_mon);
        if (isNoiseBurstCandidate) {
            thisVects.tdc_mon_nb1.push_back(tdc);
            thisVects.adc_mon_nb1.push_back(adc);
        }
    }
    if (adc > m_ADCCut && !isNoisy) {
        thisVects.adc_mon_adccut.push_back(adc);
        thisVects.tdc_mon_adccut.push_back(tdc);
        int thisStationEta = chamber->GetStationEta();
        thisVects.stationEta.push_back(thisStationEta);
 
        int binx = chamber->GetMDTHitsPerChamber_IMO_BinX();
        if (iregion < 2)
            binx = binx - 9;
        else
            binx = binx - 7;
        int biny = chamber->GetMDTHitsPerChamber_IMO_BinY();
 
        std::string varx = " ";
        std::string vary = " ";
        std::string varx_noise = " ";
        std::string vary_noise = " ";
        if (iregion < 2) {
            varx = "x_mon_barrel";
            vary = "y_mon_barrel";
            varx_noise = "x_mon_barrel_noise";
            vary_noise = "y_mon_barrel_noise";
        } else {
            varx = "x_mon_endcap";
            vary = "y_mon_endcap";
            varx_noise = "x_mon_endcap_noise";
            vary_noise = "y_mon_endcap_noise";
        }
 
        thisVects.x_mon.push_back(binx);
        thisVects.y_mon.push_back(biny - 1);
        if (isNoiseBurstCandidate) {
            thisVects.x_mon_noise.push_back(binx);
            thisVects.y_mon_noise.push_back(biny - 1);
            thisVects.tdc_mon_nb3.push_back(tdc);
        }
 
        thisVects.x_bin_perML.push_back(chamber->GetMDTHitsPerML_Binx() - 1);  // get the right bin!!!!
        int biny_ml = 0;
        if (mlayer_n == 1)
            biny_ml = chamber->GetMDTHitsPerML_m1_Biny();
        else if (mlayer_n == 2)
            biny_ml = chamber->GetMDTHitsPerML_m2_Biny();
        thisVects.y_bin_perML.push_back(biny_ml - 1);
 
        if (layer[ilayer] != "Extra") {
            thisVects.bin_byLayer_x.push_back(chamber->GetMDTHitsPerML_byLayer_BinX() - 1);
            thisVects.bin_byLayer_y.push_back(chamber->GetMDTHitsPerML_byLayer_BinY(mlayer_n) - 1);
        }
        if (trig_barrel) { thisVects.tdc_mon_rpc.push_back(tdc); }
        if (trig_endcap) { thisVects.tdc_mon_tgc.push_back(tdc); }
 
        // Fill occupancy vs. Lumiblock
        thisVects.biny_vslb.push_back(get_bin_for_LB_hist(iregion, ilayer, stationPhi, thisStationEta, isBIM));
        if (chambername.substr(0, 3) == "BEE" || (chambername.substr(0, 3) == "BIS" && (thisStationEta == 7 || thisStationEta == 8))) {
            thisVects.biny_vslb_bycrate_bis_bee.push_back(
                get_bin_for_LB_crate_hist(crate_region, icrate, stationPhi + 1, thisStationEta, chambername));
        } else {
            thisVects.biny_vslb_bycrate.push_back(
                get_bin_for_LB_crate_hist(crate_region, icrate, stationPhi + 1, thisStationEta, chambername));
        }
 
        if (is_on_track) {
            if (chambername.substr(0, 3) == "BEE" || (chambername.substr(0, 3) == "BIS" && (thisStationEta == 7 || thisStationEta == 8))) {
                thisVects.biny_vslb_bycrate_bis_bee_ontrack.push_back(
                    get_bin_for_LB_crate_hist(crate_region, icrate, stationPhi + 1, thisStationEta, chambername));
            } else {
                thisVects.biny_vslb_bycrate_ontrack.push_back(
                    get_bin_for_LB_crate_hist(crate_region, icrate, stationPhi + 1, thisStationEta, chambername));
            }
        }
    }
 
    return sc;
}
 
StatusCode MdtRawDataMonAlg::fillMDTSummaryHistograms(std::array<MDTSummaryHistogramStruct, 4096>* vects, int lb) const {
    std::string region[4] = {"BA", "BC", "EA", "EC"};
    std::string layer[4] = {"Inner", "Middle", "Outer", "Extra"};
    std::string crate[4] = {"01", "02", "03", "04"};
    //  std::string slayer[4]={"inner","middle","outer","extra"};
 
    auto lb_mon = Monitored::Scalar<int>("lb_mon", lb);
 
    for (int iregion = 0; iregion < 4; ++iregion) {
        std::string MDT_regionGroup = "MDT_regionGroup" + region[iregion];  // MDTXX/Overview
        for (int crate_region = 0; crate_region < 4; ++crate_region) {
            std::string MDT_regionGroup_bycrate = "MDT_regionGroup_bycrate" + region[crate_region];  // MDTXX/Overview
            for (int ilayer = 0; ilayer < 4; ++ilayer) {
                for (int stationPhi = 0; stationPhi < 16; ++stationPhi) {
                    for (int icrate = 0; icrate < 4; ++icrate) {
                        uint16_t v = MdtHistCoder::encode(iregion, ilayer, stationPhi, crate_region, icrate);
 
                        std::array<MDTSummaryHistogramStruct, 4096>& array = *(vects);
                        auto& thisVects = array[v];
 
                        auto sector = Monitored::Collection("sector", thisVects.sector);
 
                        fill("MdtMonitor", lb_mon, sector);
 
                        auto stationEta = Monitored::Collection(
                            "stEta_" + region[iregion] + "_" + layer[ilayer] + "_phi" + std::to_string(stationPhi + 1),
                            thisVects.stationEta);
 
                        if (m_do_mdtChamberHits) { fill(MDT_regionGroup, stationEta); }
 
                        auto adc_mon = Monitored::Collection("adc_mon", thisVects.adc_mon);
                        auto tdc_mon = Monitored::Collection("tdc_mon", thisVects.tdc_mon);
 
                        auto tdc_mon_nb2 = Monitored::Collection("tdc_mon_nb2", thisVects.tdc_mon_nb2);
                        auto adc_mon_nb2 = Monitored::Collection("adc_mon_nb2", thisVects.adc_mon_nb2);
 
                        auto tdc_mon_nb1 = Monitored::Collection("tdc_mon_nb1", thisVects.tdc_mon_nb1);
                        auto adc_mon_nb1 = Monitored::Collection("adc_mon_nb1", thisVects.adc_mon_nb1);
 
                        auto adc_mon_adccut = Monitored::Collection("adc_mon_adccut", thisVects.adc_mon_adccut);
 
                        auto tdc_mon_adccut = Monitored::Collection("tdc_mon_adccut", thisVects.tdc_mon_adccut);
 
                        std::string varx = iregion < 2 ? "x_mon_barrel" : "x_mon_endcap";
                        std::string vary = iregion < 2 ? "y_mon_barrel" : "y_mon_endcap";
                        std::string varx_noise = iregion < 2 ? "x_mon_barrel_noise" : "x_mon_endcap_noise";
                        std::string vary_noise = iregion < 2 ? "y_mon_barrel_noise" : "y_mon_endcap_noise";
 
                        auto x_mon = Monitored::Collection(varx, thisVects.x_mon);
                        auto y_mon = Monitored::Collection(vary, thisVects.y_mon);
                        auto x_mon_noise = Monitored::Collection(varx_noise, thisVects.x_mon_noise);
                        auto y_mon_noise = Monitored::Collection(vary_noise, thisVects.y_mon_noise);
                        fill("MdtMonitor", x_mon, y_mon, x_mon_noise, y_mon_noise);
                        auto tdc_mon_nb3 = Monitored::Collection("tdc_mon_nb3", thisVects.tdc_mon_nb3);
 
                        varx = "x_mon_" + region[iregion] + "_" + layer[ilayer];
                        vary = "y_mon_" + region[iregion] + "_" + layer[ilayer];
 
                        auto x_bin_perML = Monitored::Collection(varx, thisVects.x_bin_perML);  // get the right bin!!!!
                        auto y_bin_perML = Monitored::Collection(vary, thisVects.y_bin_perML);
 
                        if (layer[ilayer] != "Extra") {
                            varx = "x_mon_" + layer[ilayer];
                            vary = "y_mon_" + layer[ilayer];
                            auto bin_byLayer_x = Monitored::Collection(varx, thisVects.bin_byLayer_x);
                            auto bin_byLayer_y = Monitored::Collection(vary, thisVects.bin_byLayer_y);
 
                            fill("MdtMonitor", bin_byLayer_x, bin_byLayer_y);
                        }
 
                        auto tdc_mon_rpc = Monitored::Collection("tdc_mon_rpc", thisVects.tdc_mon_rpc);
                        auto tdc_mon_tgc = Monitored::Collection("tdc_mon_tgc", thisVects.tdc_mon_tgc);
 
                        auto biny_name = "y_mon_bin_" + region[iregion] + "_" + layer[ilayer];
                        if (layer[ilayer] == "Extra" || layer[ilayer] == "Outer")
                            biny_name = "y_mon_bin_" + region[iregion] + "_OuterPlusExtra";
 
                        auto biny_var = Monitored::Collection(biny_name, thisVects.biny_vslb);
 
                        std::vector<int> sum_biny_vslb_bycrate;
                        sum_biny_vslb_bycrate.reserve(thisVects.biny_vslb_bycrate.size() + thisVects.biny_vslb_bycrate_bis_bee.size());
                        sum_biny_vslb_bycrate.insert(sum_biny_vslb_bycrate.end(), thisVects.biny_vslb_bycrate_bis_bee.begin(),
                                                     thisVects.biny_vslb_bycrate_bis_bee.end());
                        sum_biny_vslb_bycrate.insert(sum_biny_vslb_bycrate.end(), thisVects.biny_vslb_bycrate.begin(),
                                                     thisVects.biny_vslb_bycrate.end());
 
                        auto biny_name_bycrate = "y_mon_bin_bycrate_" + region[crate_region] + "_" + crate[icrate];
                        auto biny_var_bycrate = Monitored::Collection(biny_name_bycrate, sum_biny_vslb_bycrate);
 
                        std::vector<int> sum_biny_vslb_bycrate_ontrack;
                        sum_biny_vslb_bycrate_ontrack.reserve(thisVects.biny_vslb_bycrate_ontrack.size() +
                                                              thisVects.biny_vslb_bycrate_bis_bee_ontrack.size());
                        sum_biny_vslb_bycrate_ontrack.insert(sum_biny_vslb_bycrate_ontrack.end(),
                                                             thisVects.biny_vslb_bycrate_bis_bee_ontrack.begin(),
                                                             thisVects.biny_vslb_bycrate_bis_bee_ontrack.end());
                        sum_biny_vslb_bycrate_ontrack.insert(sum_biny_vslb_bycrate_ontrack.end(),
                                                             thisVects.biny_vslb_bycrate_ontrack.begin(),
                                                             thisVects.biny_vslb_bycrate_ontrack.end());
 
                        auto biny_name_bycrate_ontrack = "y_mon_bin_bycrate_ontrack_" + region[crate_region] + "_" + crate[icrate];
                        auto biny_var_bycrate_ontrack = Monitored::Collection(biny_name_bycrate_ontrack, sum_biny_vslb_bycrate_ontrack);
 
                        fill(MDT_regionGroup, adc_mon, tdc_mon, tdc_mon_nb2, adc_mon_nb2, tdc_mon_adccut, adc_mon_adccut, tdc_mon_adccut,
                             adc_mon_adccut, tdc_mon_nb3, x_bin_perML, y_bin_perML, tdc_mon_rpc, tdc_mon_tgc, biny_var, lb_mon, biny_var);
 
                        fill(MDT_regionGroup_bycrate, lb_mon, biny_var_bycrate, biny_var_bycrate_ontrack);
                    }
                }
            }
        }
    }
 
    return StatusCode::SUCCESS;
}
 
StatusCode MdtRawDataMonAlg::fillMDTHistograms(const Muon::MdtPrepData* mdtCollection) const {
    // fill chamber by chamber histos
    StatusCode sc = StatusCode::SUCCESS;
    Identifier digcoll_id = (mdtCollection)->identify();
    IdentifierHash digcoll_idHash = (mdtCollection)->collectionHash();
 
    MDTChamber* chamber{nullptr};
    ATH_CHECK(getChamber(digcoll_idHash, chamber));
 
    std::string hardware_name = chamber->getName();
    //
 
    //      //convert layer numbering from 1->4 to 1->8
    //      //check if we are in 2nd multilayer
    //      //then add 4 if large chamber, 3 if small chamber
    int mdtlayer = m_idHelperSvc->mdtIdHelper().tubeLayer(digcoll_id);
    if (m_idHelperSvc->mdtIdHelper().multilayer(digcoll_id) == 2) {
        if (hardware_name.at(1) == 'I' && hardware_name.at(3) != '8')
            mdtlayer += 4;
        else
            mdtlayer += 3;
    }
 
    int mdttube = m_idHelperSvc->mdtIdHelper().tube(digcoll_id) + (mdtlayer - 1) * cachedTubeMax(digcoll_id);
 
    ChamberTubeNumberCorrection(mdttube, hardware_name, m_idHelperSvc->mdtIdHelper().tube(digcoll_id), mdtlayer - 1);
    bool isNoisy = m_masked_tubes->isNoisy(mdtCollection);
 
    float tdc = mdtCollection->tdc() * 25.0 / 32.0;
    // Note: the BMG is digitized with 200ps which is not same as other MDT chambers with 25/32=781.25ps
    if (hardware_name.substr(0, 3) == "BMG") tdc = mdtCollection->tdc() * 0.2;
    float adc = mdtCollection->adc();
    if (hardware_name.substr(0, 3) == "BMG") adc /= m_adcScale;
 
    int iregion = chamber->GetRegionEnum();
 
    int mezz = mezzmdt(digcoll_id);
 
    std::string monPerCh = "MdtMonPerChamber";
    if (iregion == 0) monPerCh += "BA";
    if (iregion == 1) monPerCh += "BC";
    if (iregion == 2) monPerCh += "EA";
    if (iregion == 3) monPerCh += "EC";
 
    int mdtMultLayer = m_idHelperSvc->mdtIdHelper().multilayer(digcoll_id);
 
    auto tdc_perch = Monitored::Scalar<float>("tdc_perch_" + hardware_name, tdc);
    auto adc_perch = Monitored::Scalar<float>("adc_perch_" + hardware_name, adc);
    auto layer_perch = Monitored::Scalar<int>("layer_perch_" + hardware_name, mdtlayer);
    auto tube_perch = Monitored::Scalar<int>("tube_perch_" + hardware_name, mdttube);
    auto mezz_perch = Monitored::Scalar<int>("mezz_perch_" + hardware_name, mezz);
    auto ml1_adccut = Monitored::Scalar<int>("ml1_adccut", (int)(adc > m_ADCCut && !isNoisy && mdtMultLayer == 1));
    auto ml2_adccut = Monitored::Scalar<int>("ml2_adccut", (int)(adc > m_ADCCut && !isNoisy && mdtMultLayer == 2));
    auto adccut_nonoise = Monitored::Scalar<int>("adccut_nonoise", (int)(adc > m_ADCCut && !isNoisy));
    auto adccut = Monitored::Scalar<int>("adccut", (int)(adc > m_ADCCut));
 
    fill(monPerCh, tdc_perch, adc_perch, layer_perch, tube_perch, mezz_perch, ml1_adccut, ml2_adccut, adccut_nonoise, adccut);
 
    return sc;
}
 
// Code for measuring tube efficiencies and tdc/adc based on hits along segments
// Strategy:
// First loop over hits along segments and store hits
// Identify the MLs affected for each segment
// Loop over the tubes in the affected MLs and identify tubes traversed by segment vector (these represent the denom in the efficiency calc)
// Find traversed tubes that also have a hit along the segment (these represent the num in the efficiency calc)
// Details:
//        * To avoid double-counting hits (for tdc/adc fills) due to overlapping segments, use a set called store_ROTs
//        * To avoid double-counting hits (for eff calc) due to overlapping segments, use a set called store_effTubes
//        * The above 2 sets need not have the same size, because in the latter case some tubes are missed because they are slightly too
//          far away from the segment vector -- these tubes are simply excluded from the eff calc.
//          Additionally the latter case is complicated because for overlapping traversed tubes,
//          we must preference the ones that are part of a segment that records a hit in those tubes
StatusCode MdtRawDataMonAlg::handleEvent_effCalc_fillVects(const Trk::SegmentCollection* segms,
                                                           MDTSegmentHistogramStruct (&vects)[4][4][16]) const {
    std::string type = "MDT";
    const MdtIdHelper& id_helper = m_idHelperSvc->mdtIdHelper();
    std::set<monAlg::TubeTraversedBySegment, monAlg::TubeTraversedBySegment_cmp> store_effTubes;
    std::set<Identifier> store_ROTs;
 
    // MuonDetectorManager from the conditions store
 
    SG::ReadCondHandle<MuonGM::MuonDetectorManager> DetectorManagerHandle{m_DetectorManagerKey};
    const MuonGM::MuonDetectorManager* MuonDetMgr = DetectorManagerHandle.cptr();
    if (!MuonDetMgr) {
        ATH_MSG_ERROR("Null pointer to the read MuonDetectorManager conditions object");
        return StatusCode::FAILURE;
    }
 
    // LOOP OVER SEGMENTS
    for (const Trk::Segment* trk_seg : *segms) {
        const Muon::MuonSegment* segment = dynamic_cast<const Muon::MuonSegment*>(trk_seg);
        if (!segment) {
            ATH_MSG_DEBUG("no pointer to segment!!!");
            break;
        }
        if (segment->numberOfContainedROTs() < std::max(0lu, m_nb_hits.value()) ||
            segment->fitQuality()->chiSquared() / segment->fitQuality()->doubleNumberDoF() > m_chi2_cut) {
            continue;
        }
 
    std::vector<Identifier> ROTs_chamber;
    std::vector<int> ROTs_tube;
    std::vector<int> ROTs_L;
    std::vector<int> ROTs_ML;
        for (unsigned int irot = 0; irot < segment->numberOfContainedROTs(); irot++) {
            const Trk::RIO_OnTrack* rot = segment->rioOnTrack(irot);
            const Muon::MdtDriftCircleOnTrack* mrot = dynamic_cast<const Muon::MdtDriftCircleOnTrack*>(rot);
            if (!mrot) continue;
            Identifier tmpid = rot->identify();
            // This information needs to be stored fully for each segment (for calculations below), so deal with these duplicates later
            // (otherwise we may not check a traversed ML for a differently pointing overlapping segment, for example)
 
            IdentifierHash idHash{0};
            MDTChamber* chamber = nullptr;
            id_helper.get_module_hash(tmpid, idHash);
            ATH_CHECK(getChamber(idHash, chamber));
            const std::string& chambername = chamber->getName();
            float adc = mrot->prepRawData()->adc();
 
            if (m_idHelperSvc->hasHPTDC(tmpid)) adc /= m_adcScale;
 
            if (store_ROTs.count(tmpid)) { continue; }
            store_ROTs.insert(tmpid);
 
            double tdc = mrot->prepRawData()->tdc() * 25.0 / 32.0;
            // Note: the BMG is digitized with 200ps which is not same as other MDT chambers with 25/32=781.25ps
            if (m_idHelperSvc->hasHPTDC(tmpid)) tdc = mrot->prepRawData()->tdc() * 0.2;
            int iregion = chamber->GetRegionEnum();
            int ilayer = chamber->GetLayerEnum();
            int statphi = chamber->GetStationPhi();
 
            auto& thisVects = vects[iregion][ilayer][statphi];
            thisVects.adc_segs_mon.push_back(adc);
 
            if (adc > m_ADCCut) {  // This is somewhat redundant because this is usual cut for segment-reconstruction, but that's OK
 
                thisVects.tdc_segs_mon.push_back(tdc);
 
                int binx = chamber->GetMDTHitsPerChamber_IMO_BinX();
                if (iregion < 2)
                    binx = binx - 9;
                else
                    binx = binx - 7;
                int biny = chamber->GetMDTHitsPerChamber_IMO_BinY();
                thisVects.x_segs_mon.push_back(binx);
                thisVects.y_segs_mon.push_back(biny - 1);
 
            }  // adc cut
 
            int mdtMultLayer = m_idHelperSvc->mdtIdHelper().multilayer(tmpid);
            auto adc_perch = Monitored::Scalar<float>("adc_segs_perch_" + chambername, adc);
            auto adc_ml1 = Monitored::Scalar<int>("adc_ml1", (int)(mdtMultLayer == 1));
            auto adc_ml2 = Monitored::Scalar<int>("adc_ml2", (int)(mdtMultLayer == 2));
 
            std::string monPerCh = "MdtMonPerChamber";
            if (iregion == 0)
                monPerCh += "BA";
            else if (iregion == 1)
                monPerCh += "BC";
            else if (iregion == 2)
                monPerCh += "EA";
            else if (iregion == 3)
                monPerCh += "EC";
        
        ROTs_chamber.push_back(tmpid);
        ROTs_ML.push_back(mdtMultLayer);
        ROTs_tube.push_back(m_idHelperSvc->mdtIdHelper().tube(tmpid));
        ROTs_L.push_back(m_idHelperSvc->mdtIdHelper().tubeLayer(tmpid));
 
 
            fill(monPerCh, adc_perch, adc_ml1, adc_ml2);
        }
        // Finished gathering hits used in segment
 
        if (m_doChamberHists) {
            // Find unique chambers (since above we stored one chamber for every tube)
            // Also store the MLs affected by the ROTs, since we don't necessarily want to look for traversed tubes in entire chamber
        std::vector<Identifier> unique_chambers;
        std::vector<std::vector<int>> unique_chambers_ML;
        
        for (unsigned i = 0; i < ROTs_chamber.size(); i++) {
          bool isUnique = true;
          for (unsigned j = 0; j < unique_chambers.size(); j++) {
        if (getChamberName(ROTs_chamber.at(i)) == getChamberName(unique_chambers.at(j))) {
          isUnique = false;
          if (!AinB(ROTs_ML.at(i), unique_chambers_ML.at(j))) unique_chambers_ML.at(j).push_back(ROTs_ML.at(i));
          break;
        }
          }
          if (isUnique) {
        unique_chambers.push_back(ROTs_chamber.at(i));
        std::vector<int> tmp_ML;
        tmp_ML.push_back(ROTs_ML.at(i));
        unique_chambers_ML.push_back(tmp_ML);
          }
        }
            // Done finding unique chambers
            // Loop over the unique chambers
            // Here we store the tubes in each chamber that were traversed by the segment
            std::vector<Identifier> traversed_station_id;
        std::vector<int> traversed_tube;
        std::vector<int> traversed_L;
        std::vector<int> traversed_ML;
 
            for (const Identifier& station_id : unique_chambers) {
                const std::string hardware_name = getChamberName(station_id);
                // SEGMENT track
                const MuonGM::MdtReadoutElement* detEl = MuonDetMgr->getMdtReadoutElement(station_id);
                const Amg::Transform3D& gToStation = detEl->GlobalToAmdbLRSTransform();
                const Amg::Vector3D segPosL = gToStation * segment->globalPosition();
                const Amg::Vector3D segDirL = gToStation.linear() * segment->globalDirection();
        MuonCalib::MTStraightLine segment_track =
          MuonCalib::MTStraightLine(segPosL, segDirL, Amg::Vector3D(0, 0, 0), Amg::Vector3D(0, 0, 0));
        
                // Loop over tubes in chamber, find those along segment
                for (int ML : {1, 2}) {
 
                    Identifier newId = id_helper.channelID(station_id, ML, 1, 1);
                    const MuonGM::MdtReadoutElement* MdtRoEl = MuonDetMgr->getMdtReadoutElement(newId);
                    int tubeMax = cachedTubeMax(newId);
                    int tubeLayerMax = cachedTubeLayerMax(newId);
                    CorrectTubeMax(hardware_name, tubeMax);
                    CorrectLayerMax(hardware_name, tubeLayerMax);
 
                    int tubeMin = id_helper.tubeMin(newId);
                    int tubeLayerMin = id_helper.tubeLayerMin(newId);
                    for (int i_tube = tubeMin; i_tube <= tubeMax; ++i_tube) {
                        for (int i_layer = tubeLayerMin; i_layer <= tubeLayerMax; ++i_layer) {
                            Identifier tubeId = id_helper.channelID(newId, ML, i_layer, i_tube);
                            
                if (m_BMGpresent && m_idHelperSvc->mdtIdHelper().stationName(newId) == m_BMGid) {
                                std::map<Identifier, std::set<Identifier>>::const_iterator myIt = m_DeadChannels.find(MdtRoEl->identify());
                                if (myIt != m_DeadChannels.end()) {
                                    if (myIt->second.count(tubeId)) {
                                        ATH_MSG_DEBUG("Skipping tube with identifier " << m_idHelperSvc->toString(tubeId));
                                        continue;
                                    }
                                }
                            }
             
                            Amg::Vector3D TubePos = MdtRoEl->GlobalToAmdbLRSCoords(MdtRoEl->tubePos(tubeId));
                Amg::Vector3D tube_position = Amg::Vector3D(TubePos.x(), TubePos.y(), TubePos.z());
                            static const Amg::Vector3D tube_direction{1, 0, 0};
                MuonCalib::MTStraightLine tube_track =
                  MuonCalib::MTStraightLine(tube_position, tube_direction, Amg::Vector3D(0, 0, 0), Amg::Vector3D(0, 0, 0));
                double distance = std::abs(segment_track.signDistFrom(tube_track));
 
                            if (distance < (MdtRoEl->innerTubeRadius())) { 
                                traversed_tube.push_back(i_tube);
                                traversed_L.push_back(i_layer);
                                traversed_ML.push_back(ML);
                traversed_station_id.push_back(station_id); 
                }
 
                        }
                    }
                }
            }
 
            // Done looping over the unqiue chambers
 
            // Loop over traversed tubes that were stored above
            // Here we fill the DRvsDT/DRvsSegD histos, as well is unique hits and traversed tubes to calculate efficiencies
        if (traversed_tube.size() <  20) {  // quality cut here -- 20 traversed tubes is ridiculous and generates low efficiencies (these
                       // are due to non-pointing segments)
 
          for (unsigned k = 0; k < traversed_tube.size(); k++) {
 
          std::string hardware_name = getChamberName(traversed_station_id.at(k));
 
                    // GET HISTS
                    IdentifierHash idHash{0};
                    id_helper.get_module_hash(traversed_station_id.at(k), idHash);
 
                    MDTChamber* chamber{nullptr};
                    ATH_CHECK(getChamber(idHash, chamber));
 
            bool hit_flag = false;
                    for (unsigned j = 0; j < ROTs_tube.size(); j++) {
              if ((getChamberName(ROTs_chamber.at(j)) == hardware_name) && (traversed_tube.at(k) == ROTs_tube.at(j)) &&
              (traversed_L.at(k) == ROTs_L.at(j)) &&
              (traversed_ML.at(k) == ROTs_ML.at(j))) {  // found traversed tube with hit used in segment
            hit_flag = true;
            break;
              }
                    }
 
            const Identifier& trav_id = traversed_station_id.at(k);
                    Identifier newId = id_helper.channelID(trav_id, traversed_ML.at(k), 1, 1);
 
 
            int tubeLayerMax = cachedTubeLayerMax(newId);
                    id_helper.get_module_hash(newId, idHash);
            CorrectLayerMax(hardware_name, tubeLayerMax);  // ChamberTubeNumberCorrection handles the tubeMax problem
                    
 
            int mdtlayer = ((traversed_L.at(k) - 1) + (traversed_ML.at(k) - 1) * tubeLayerMax);
                    int ibin = traversed_tube.at(k) + mdtlayer * cachedTubeMax(newId);
 
            
                    ChamberTubeNumberCorrection(ibin, hardware_name, traversed_tube.at(k), mdtlayer);
                    // Store info for eff calc
                    // (Here we make sure we are removing duplicates from overlapping segments by using sets)
            std::set<monAlg::TubeTraversedBySegment, monAlg::TubeTraversedBySegment_cmp>::iterator it;
            monAlg::TubeTraversedBySegment tmp_effTube = monAlg::TubeTraversedBySegment(hardware_name, ibin, hit_flag, idHash);
            monAlg::TubeTraversedBySegment tmp_effTube_Hit = monAlg::TubeTraversedBySegment(hardware_name, ibin, true, idHash);
            monAlg::TubeTraversedBySegment tmp_effTube_noHit = monAlg::TubeTraversedBySegment(hardware_name, ibin, false, idHash);
                    it = store_effTubes.find(tmp_effTube_Hit);
                    if (hit_flag || (it == store_effTubes.end()))
              store_effTubes.insert(tmp_effTube);  // Insert if w/hit, but if w/o hit then only insert if no already stored w/ h
 
            it = store_effTubes.find(tmp_effTube_noHit);
                    if (hit_flag && (it != store_effTubes.end()))
                        store_effTubes.erase(it);  // If w/ hit, and the same tube is stored w/o hit, remove duplicate w/o hit
                }
            }
            // Done looping over traversed tubes
 
        }  // m_doChamberHists
    }
 
    // Fill effentries/effcounts hists for efficiency calculation
    if (m_doChamberHists) {  // Don't perform this block if not doing chamber by chamber hists
        for (const monAlg::TubeTraversedBySegment& it : store_effTubes) {
            // GET HISTS
            MDTChamber* chamber{nullptr};
            ATH_CHECK(getChamber(it.idHash, chamber));
            int tubebin = it.tubeBin;
 
            int iregion = chamber->GetRegionEnum();
            std::string monPerCh = "MdtMonPerChamber";
            if (iregion == 0) monPerCh += "BA";
            if (iregion == 1) monPerCh += "BC";
            if (iregion == 2) monPerCh += "EA";
            if (iregion == 3) monPerCh += "EC";
 
            std::string chambername = chamber->getName();
            auto tube_perch_segs = Monitored::Scalar<int>("tube_perch_segs_" + chambername, tubebin);
            auto hitcut = Monitored::Scalar<int>("hitcut", (int)(it.isHit));
 
            fill(monPerCh, tube_perch_segs, hitcut);
        }
    }
    return StatusCode::SUCCESS;
    
}
 
StatusCode MdtRawDataMonAlg::fillMDTSegmentHistograms(const MDTSegmentHistogramStruct (&vects)[4][4][16]) const {
    std::string region[4] = {"BA", "BC", "EA", "EC"};
    std::string layer[4] = {"Inner", "Middle", "Outer", "Extra"};
 
    for (int iregion = 0; iregion < 4; ++iregion) {
        std::string MDT_regionGroup = "MDT_regionGroup" + region[iregion];  // MDTXX/Overview, 4 gruppi
        for (int ilayer = 0; ilayer < 4; ++ilayer) {
            for (int stationPhi = 0; stationPhi < 16; ++stationPhi) {
                const auto& thisVects = vects[iregion][ilayer][stationPhi];
 
                auto adc_segs_mon = Monitored::Collection("adc_segs_mon", thisVects.adc_segs_mon);
                auto adc_segs_overall_mon = Monitored::Collection("adc_segs_overall_mon", thisVects.adc_segs_mon);
                std::string tdc_var = "tdc_segs_" + region[iregion] + "_" + layer[ilayer] + "_phi" + std::to_string(stationPhi + 1);
                auto tdc_segs_mon = Monitored::Collection(tdc_var, thisVects.tdc_segs_mon);
                if (m_do_mdttdccut_sector) fill(MDT_regionGroup, tdc_segs_mon);
 
                auto tdc_segs_overall_mon = Monitored::Collection("tdc_segs_overall_mon", thisVects.tdc_segs_mon);
                auto tdc_segs_region_mon = Monitored::Collection("tdc_segs_region_mon", thisVects.tdc_segs_mon);
 
                fill(MDT_regionGroup, adc_segs_mon, tdc_segs_region_mon);
 
                std::string varx = iregion < 2 ? "x_segs_mon_barrel" : "x_segs_mon_endcap";
                std::string vary = iregion < 2 ? "y_segs_mon_barrel" : "y_segs_mon_endcap";
                auto x_segs_mon = Monitored::Collection(varx, thisVects.x_segs_mon);
                auto y_segs_mon = Monitored::Collection(vary, thisVects.y_segs_mon);
 
                fill("MdtMonitor", tdc_segs_overall_mon, adc_segs_overall_mon, x_segs_mon, y_segs_mon);
            }
        }
    }
    return StatusCode::SUCCESS;
}
 
void MdtRawDataMonAlg::initDeadChannels(const MuonGM::MdtReadoutElement* mydetEl) {
    PVConstLink cv = mydetEl->getMaterialGeom();  // it is "Multilayer"
    int nGrandchildren = cv->getNChildVols();
    if (nGrandchildren <= 0) return;
 
    Identifier detElId = mydetEl->identify();
 
    std::set<Identifier>& deadTubes = m_DeadChannels[detElId];
 
    for (int layer = 1; layer <= mydetEl->getNLayers(); ++layer) {
        for (int tube = 1; tube <= mydetEl->getNtubesperlayer(); ++tube) {
            bool tubefound = false;
            for (unsigned int kk = 0; kk < cv->getNChildVols(); ++kk) {
                int tubegeo = cv->getIdOfChildVol(kk) % maxNTubesPerLayer;
                int layergeo = (cv->getIdOfChildVol(kk) - tubegeo) / maxNTubesPerLayer;
                if (tubegeo == tube && layergeo == layer) {
                    tubefound = true;
                    break;
                }
                if (layergeo > layer) break;  // don't loop any longer if you cannot find tube anyway anymore
            }
            if (!tubefound) {
                Identifier deadTubeId = m_idHelperSvc->mdtIdHelper().channelID(detElId, mydetEl->getMultilayer(), layer, tube);
                deadTubes.insert(deadTubeId);
                ATH_MSG_VERBOSE("adding dead tube " << m_idHelperSvc->toString(deadTubeId));
            }
        }
    }
}