#include <eFexByteStreamTool.h>

Inheritance diagram for eFexByteStreamTool:

Collaboration diagram for eFexByteStreamTool:

Classes
class	MonitoredLogging
	Create a class to override logging interface in underlying decoder tool. More...

Public Member Functions
	eFexByteStreamTool (const std::string &type, const std::string &name, const IInterface *parent)
virtual	~eFexByteStreamTool () override=default
virtual StatusCode	initialize () override
virtual StatusCode	convertFromBS (const std::vector< const OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment * > &vrobf, const EventContext &eventContext) const override
	BS->xAOD conversion.
virtual StatusCode	convertToBS (std::vector< OFFLINE_FRAGMENTS_NAMESPACE_WRITE::ROBFragment * > &vrobf, const EventContext &eventContext) override
	xAOD->BS conversion
virtual const std::vector< uint32_t > &	robIds () const override
	Declare ROB IDs for conversion.

Private Attributes
ToolHandle< GenericMonitoringTool >	m_monTool {this,"MonTool","","Monitoring tool"}
Gaudi::Property< std::vector< uint32_t > >	m_robIds {this, "ROBIDs", {}, "List of ROB IDs required for conversion to/from xAOD RoI"}
SG::WriteHandleKey< xAOD::eFexEMRoIContainer >	m_eEMWriteKey
SG::WriteHandleKey< xAOD::eFexTauRoIContainer >	m_eTAUWriteKey
SG::WriteHandleKey< xAOD::eFexEMRoIContainer >	m_eEMxWriteKey
SG::WriteHandleKey< xAOD::eFexTauRoIContainer >	m_eTAUxWriteKey
SG::WriteHandleKey< xAOD::eFexEMRoIContainer >	m_eEMSliceWriteKey
SG::WriteHandleKey< xAOD::eFexTauRoIContainer >	m_eTAUSliceWriteKey
SG::WriteHandleKey< xAOD::eFexTowerContainer >	m_eTowerWriteKey
SG::ReadHandleKey< xAOD::eFexEMRoIContainer >	m_eEMReadKey
SG::ReadHandleKey< xAOD::eFexTauRoIContainer >	m_eTAUReadKey
std::unique_ptr< L1CaloBsDecoderRun3 >	m_decoder

Detailed Description

Definition at line 40 of file eFexByteStreamTool.h.

Constructor & Destructor Documentation

◆ eFexByteStreamTool()

eFexByteStreamTool::eFexByteStreamTool	(	const std::string &	type,
		const std::string &	name,
		const IInterface *	parent )

Definition at line 45 of file eFexByteStreamTool.cxx.

48 : base_class(type, name, parent) {}

◆ ~eFexByteStreamTool()

virtual eFexByteStreamTool::~eFexByteStreamTool ( )

overridevirtualdefault

Member Function Documentation

◆ convertFromBS()

StatusCode eFexByteStreamTool::convertFromBS	(	const std::vector< const OFFLINE_FRAGMENTS_NAMESPACE::ROBFragment * > &	vrobf,
		const EventContext &	eventContext ) const

overridevirtual

BS->xAOD conversion.

Definition at line 97 of file eFexByteStreamTool.cxx.

                                                                                                               {
 
    // indices are source (tob or xtob) and bool for in/out of time
    std::map<std::pair<L1CaloRdoFexTob::TobSource,bool>,SG::WriteHandle<xAOD::eFexEMRoIContainer>> eContainers;
    std::map<std::pair<L1CaloRdoFexTob::TobSource,bool>,SG::WriteHandle<xAOD::eFexTauRoIContainer>> tContainers;
 
    bool multislice=false;
 
    if (!m_eEMWriteKey.empty()) {
        ATH_CHECK(StatusCode(addContainer<xAOD::eFexEMRoIContainer, xAOD::eFexEMRoIAuxContainer>(
                eContainers, L1CaloRdoFexTob::TobSource::EfexTob, false, m_eEMWriteKey, ctx)));
    }
    if (!m_eTAUWriteKey.empty()) {
        ATH_CHECK(StatusCode(addContainer<xAOD::eFexTauRoIContainer, xAOD::eFexTauRoIAuxContainer>(
                tContainers, L1CaloRdoFexTob::TobSource::EfexTob, false, m_eTAUWriteKey, ctx)));
    }
    if (!m_eEMxWriteKey.empty()) {
        ATH_CHECK( StatusCode(addContainer<xAOD::eFexEMRoIContainer,xAOD::eFexEMRoIAuxContainer>(
                eContainers,L1CaloRdoFexTob::TobSource::EfexXtob,false,m_eEMxWriteKey,ctx)) );
    }
    if (!m_eTAUxWriteKey.empty()) {
        ATH_CHECK( StatusCode(addContainer<xAOD::eFexTauRoIContainer,xAOD::eFexTauRoIAuxContainer>(
                tContainers,L1CaloRdoFexTob::TobSource::EfexXtob,false,m_eTAUxWriteKey,ctx)) );
    }
    if (!m_eEMSliceWriteKey.empty()) {
        ATH_CHECK( StatusCode(addContainer<xAOD::eFexEMRoIContainer,xAOD::eFexEMRoIAuxContainer>(
                eContainers,L1CaloRdoFexTob::TobSource::EfexXtob,true,m_eEMSliceWriteKey,ctx)) );
        multislice=true;
    }
    if (!m_eTAUSliceWriteKey.empty()) {
        ATH_CHECK( StatusCode(addContainer<xAOD::eFexTauRoIContainer,xAOD::eFexTauRoIAuxContainer>(
                tContainers,L1CaloRdoFexTob::TobSource::EfexXtob,true,m_eTAUSliceWriteKey,ctx)) );
        multislice=true;
    }
 
 
    SG::WriteHandle<xAOD::eFexTowerContainer> eTowers;
    if(!m_eTowerWriteKey.empty()) {
        eTowers = SG::WriteHandle<xAOD::eFexTowerContainer>(m_eTowerWriteKey,ctx);
        ATH_CHECK( eTowers.record(std::make_unique<xAOD::eFexTowerContainer>(),std::make_unique<xAOD::eFexTowerAuxContainer>()) );
    }
 
    std::list<L1CaloRdoRodInfo> rodInfos;
    std::list<L1CaloRdoEfexTob> efexTobs;
    std::list<L1CaloRdoEfexTower> efexTowers;
    L1CaloBsDecoderRun3& decoder = *m_decoder;
    std::map<std::tuple<int,int,int,int,int>,size_t> towerMap; // maps {crate,module,fpga,eta,phi} onto index in vector
    for (const ROBF* rob : vrobf) {
        // Iterate over ROD words and decode
        ATH_MSG_DEBUG("Decoding " << rob->rod_ndata() << " ROD words from ROB 0x" << std::hex << rob->rob_source_id() << std::dec);
        L1CaloBsDecoderUtil::decodeRodInfo( rob, rodInfos );
 
        if(rob->rod_ndata()==0) continue;
 
        CxxUtils::span data{rob->rod_data(), rob->rod_ndata()};
        auto lastRod = rodInfos.end(); lastRod--;
 
        if ( (rob->rob_source_id() >> 16) == eformat::TDAQ_CALO_FEAT_EXTRACT_DAQ && !m_eTowerWriteKey.empty() ) {
            // decoding raw input data
            // tower et counts should be in order: PS, L1, L2, L3, Had
            // towers with all et counts 0 will still be zero-suppressed
            efexTowers.clear();
            decoder.decodeEfexData(data.begin(), data.end(), efexTowers, lastRod );
            for(auto& t : efexTowers) {
                if (t.getLayer() != 0) continue; // do hadronic in next loop
                towerMap[std::make_tuple(t.getCrate(),t.getModule(),t.getFpgaNumber(),t.getRegion().getEtaIndex(),t.getRegion().getPhiIndex())] = eTowers->size();
                eTowers->push_back( std::make_unique<xAOD::eFexTower>() );
                // in bytestream cell orders are L2,PS,L1,L3 so reorder to usual PS,L1,L2,L3 order
                std::vector<uint16_t> counts(11,xAOD::eFexTower::c_missingCountCode);
                counts[0] = t.getSupercells().at(4);
                for(size_t idx = 0;idx<4;idx++) {
                    counts[idx+1] = t.getSupercells().at(idx+5); // L1
                    counts[idx+5] = t.getSupercells().at(idx); // L2
                }
                counts[9] = t.getSupercells().at(9);
 
                eTowers->back()->initialize(t.getRegion().getEtaIndex()*0.1 + 0.05,2.*ROOT::Math::Pi()*(0.5 + t.getRegion().getPhiIndex() - 64*(t.getRegion().getPhiIndex()>=32))/64,
                                        counts,
                                        t.getModule() + t.getCrate()*12,
                                        t.getFpgaNumber(),
                                        t.getFlag(),0 /* hadronic status flag */);
            }
 
            for(auto& t : efexTowers) {
                if (t.getLayer() == 0) continue; // do hadronic towers now ... add to existing towers
                size_t idx = eTowers->size();
                if(auto itr = towerMap.find({t.getCrate(), t.getModule(), t.getFpgaNumber(),t.getRegion().getEtaIndex(),t.getRegion().getPhiIndex()}); itr != towerMap.end()) {
                    idx = itr->second;
                } else {
                    // possible that ecal tower was zero-suppressed but hcal has energy, so create such a tower
                    towerMap[std::make_tuple(t.getCrate(),t.getModule(),t.getFpgaNumber(),t.getRegion().getEtaIndex(),t.getRegion().getPhiIndex())] = eTowers->size();
                    eTowers->push_back( std::make_unique<xAOD::eFexTower>() );
                    eTowers->back()->initialize(t.getRegion().getEtaIndex()*0.1 + 0.05,2.*ROOT::Math::Pi()*(0.5 + t.getRegion().getPhiIndex() - 64*(t.getRegion().getPhiIndex()>=32))/64,
                                                std::vector<uint16_t>(11,xAOD::eFexTower::c_missingCountCode),
                                                t.getModule() + t.getCrate()*12,t.getFpgaNumber(),0,t.getFlag());
                }
                auto tower = eTowers->at(idx);
                tower->setHad_status(t.getFlag());
                auto et_count = tower->et_count();
                et_count.at(10) = t.getValue();
                tower->setEt_count(et_count);
            }
 
 
 
        } else if ( (rob->rob_source_id() >> 16) == eformat::TDAQ_CALO_FEAT_EXTRACT_ROI ) {
            // decoding tobs
            efexTobs.clear();
            decoder.decodeEfexTobs(data.begin(), data.end(), efexTobs, lastRod);
 
            for (const L1CaloRdoEfexTob &tob: efexTobs) {
                // loop over slices ... create separate tobs for each, where there's a word defined
                for (size_t slice = 0; slice < tob.numSlices(); slice++) {
                    if (!multislice && int(slice) != tob.getL1aPos())
                        continue; // ignore out-of-time slices if multiSlice option = false
                    if (tob.getWord0(slice) == 0) continue; // this tob isn't in this slice
                    if (tob.getTobType() == L1CaloRdoFexTob::TobType::EM) {
                        auto cont = eContainers.find({tob.getTobSource(), int(slice) != tob.getL1aPos()});
                        if (cont == eContainers.end()) continue; // not writing this tob collection
                        cont->second->push_back(std::make_unique<xAOD::eFexEMRoI>());
                        if (tob.getTobSource() == L1CaloRdoFexTob::TobSource::EfexTob) {
                            cont->second->back()->initialize(tob.getModule(), tob.getCrate(), tob.getWord0(slice));
                        } else {
                            cont->second->back()->initialize(tob.getWord0(slice), tob.getWord1(slice));
                        }
                    } else if (tob.getTobType() == L1CaloRdoFexTob::TobType::Tau) {
                        auto cont = tContainers.find({tob.getTobSource(), int(slice) != tob.getL1aPos()});
                        if (cont == tContainers.end()) continue; // not writing this tob collection
                        cont->second->push_back(std::make_unique<xAOD::eFexTauRoI>());
                        if (tob.getTobSource() == L1CaloRdoFexTob::TobSource::EfexTob) {
                            cont->second->back()->initialize(tob.getModule(), tob.getCrate(), tob.getWord0(slice));
                        } else {
                            cont->second->back()->initialize(tob.getWord0(slice), tob.getWord1(slice));
                        }
                    }
                } // timeslice loop
            } // tob loop
        } // tob data if block
    } // fragment loop
 
    if(msgLevel(MSG::DEBUG)) {
        std::stringstream msg;
        for (auto&[k, v]: eContainers) {
            msg << v->size() << " " << (k.second ? "out-of-time " : "in-time ") << "eg" <<
                (k.first == L1CaloRdoFexTob::TobSource::EfexTob ? "" : "x") << "TOB, ";
        }
        for (auto&[k, v]: tContainers) {
            msg << v->size() << " " << (k.second ? "out-of-time " : "in-time ") << "tau" <<
                (k.first == L1CaloRdoFexTob::TobSource::EfexTob ? "" : "x") << "TOB, ";
        }
        ATH_MSG_DEBUG("Decoded: " << msg.str());
        if (!m_eTowerWriteKey.empty()) {
            ATH_MSG_DEBUG("Decoded: " << eTowers->size() << " eTowers");
        }
    }
    // this is how to print the in-time em xTOBs:
//    for(const auto& tob : *(eContainers[{L1CaloRdoFexTob::TobSource::EfexXtob,false}])) {
//        std::cout << tob->eFexNumber() << "." << tob->fpga() << ": " << tob->fpgaEta() << " " << tob->fpgaPhi() << " " << tob->et() << " " << tob->etXTOB() << " " << tob->etTOB() << " " << std::endl;
//    }
 
    return StatusCode::SUCCESS;
}

◆ convertToBS()

StatusCode eFexByteStreamTool::convertToBS	(	std::vector< OFFLINE_FRAGMENTS_NAMESPACE_WRITE::ROBFragment * > &	vrobf,
		const EventContext &	eventContext )

overridevirtual

xAOD->BS conversion

Definition at line 260 of file eFexByteStreamTool.cxx.

                                                                                                                           {
    // not supported yet
    return StatusCode::FAILURE;
}

◆ initialize()

StatusCode eFexByteStreamTool::initialize ( )

overridevirtual

Definition at line 50 of file eFexByteStreamTool.cxx.

                                          {
 
    // Initialise eEM data handle keys
    ATH_CHECK(m_eEMReadKey.initialize(!m_eEMReadKey.empty()));
    ATH_CHECK(m_eEMWriteKey.initialize(!m_eEMWriteKey.empty()));
 
    // Initialise eTAU data handle keys
    ATH_CHECK(m_eTAUReadKey.initialize(!m_eTAUReadKey.empty()));
    ATH_CHECK(m_eTAUWriteKey.initialize(!m_eTAUWriteKey.empty()));
 
    // write keys for xTOBs
    ATH_CHECK(m_eEMxWriteKey.initialize(!m_eEMxWriteKey.empty()));
    ATH_CHECK(m_eTAUxWriteKey.initialize(!m_eTAUxWriteKey.empty()));
 
    // multislice TOBs
    ATH_CHECK(m_eEMSliceWriteKey.initialize(!m_eEMSliceWriteKey.empty()));
    ATH_CHECK(m_eTAUSliceWriteKey.initialize(!m_eTAUSliceWriteKey.empty()));
 
    // Initialize eTower handle key
    ATH_CHECK(m_eTowerWriteKey.initialize(!m_eTowerWriteKey.empty()));
 
    m_decoder = std::make_unique<L1CaloBsDecoderRun3>();
 
    // Initialize monitoring tool if not empty
    if (!m_monTool.empty()) {
        ATH_CHECK(m_monTool.retrieve());
        m_decoder->setLogger( std::make_unique<MonitoredLogging>(m_monTool) );
        ATH_MSG_INFO("Logging errors to " << m_monTool.name() << " monitoring tool");
    }
 
 
    return StatusCode::SUCCESS;
}

◆ robIds()

virtual const std::vector< uint32_t > & eFexByteStreamTool::robIds ( ) const

inlineoverridevirtual

Declare ROB IDs for conversion.

Definition at line 56 of file eFexByteStreamTool.h.

                                                                   {
            return m_robIds.value();
        }

Member Data Documentation

◆ m_decoder

std::unique_ptr<L1CaloBsDecoderRun3> eFexByteStreamTool::m_decoder

private

Definition at line 107 of file eFexByteStreamTool.h.

◆ m_eEMReadKey

SG::ReadHandleKey<xAOD::eFexEMRoIContainer> eFexByteStreamTool::m_eEMReadKey

private

Initial value:

{

this, "eEMContainerReadKey", "", "Read handle key to eEM (x)TOB container for conversion to ByteStream"}

Definition at line 98 of file eFexByteStreamTool.h.

98 {

99 this, "eEMContainerReadKey", "", "Read handle key to eEM (x)TOB container for conversion to ByteStream"};

◆ m_eEMSliceWriteKey

SG::WriteHandleKey<xAOD::eFexEMRoIContainer> eFexByteStreamTool::m_eEMSliceWriteKey

private

Initial value:

{

this, "eEMSliceContainerWriteKey", "", "Write handle key to eEM TOB out-of-time container for conversion from ByteStream"}

Definition at line 89 of file eFexByteStreamTool.h.

89 {

90 this, "eEMSliceContainerWriteKey", "", "Write handle key to eEM TOB out-of-time container for conversion from ByteStream"};

◆ m_eEMWriteKey

SG::WriteHandleKey<xAOD::eFexEMRoIContainer> eFexByteStreamTool::m_eEMWriteKey

private

Initial value:

{

this, "eEMContainerWriteKey", "", "Write handle key to eEM TOB container for conversion from ByteStream"}

Definition at line 79 of file eFexByteStreamTool.h.

79 {

80 this, "eEMContainerWriteKey", "", "Write handle key to eEM TOB container for conversion from ByteStream"};

◆ m_eEMxWriteKey

SG::WriteHandleKey<xAOD::eFexEMRoIContainer> eFexByteStreamTool::m_eEMxWriteKey

private

Initial value:

{

this, "eEMxContainerWriteKey", "", "Write handle key to eEM xTOB container for conversion from ByteStream"}

Definition at line 83 of file eFexByteStreamTool.h.

83 {

84 this, "eEMxContainerWriteKey", "", "Write handle key to eEM xTOB container for conversion from ByteStream"};

◆ m_eTAUReadKey

SG::ReadHandleKey<xAOD::eFexTauRoIContainer> eFexByteStreamTool::m_eTAUReadKey

private

Initial value:

{

this, "eTAUContainerReadKey", "", "Read handle key to eTAU (x)TOB container for conversion to ByteStream"}

Definition at line 100 of file eFexByteStreamTool.h.

100 {

101 this, "eTAUContainerReadKey", "", "Read handle key to eTAU (x)TOB container for conversion to ByteStream"};

◆ m_eTAUSliceWriteKey

SG::WriteHandleKey<xAOD::eFexTauRoIContainer> eFexByteStreamTool::m_eTAUSliceWriteKey

private

Initial value:

{

this, "eTAUSliceContainerWriteKey", "", "Write handle key to eTAU TOB out-of-time container for conversion from ByteStream"}

Definition at line 91 of file eFexByteStreamTool.h.

91 {

92 this, "eTAUSliceContainerWriteKey", "", "Write handle key to eTAU TOB out-of-time container for conversion from ByteStream"};

◆ m_eTAUWriteKey

SG::WriteHandleKey<xAOD::eFexTauRoIContainer> eFexByteStreamTool::m_eTAUWriteKey

private

Initial value:

{

this, "eTAUContainerWriteKey", "", "Write handle key to eTAU TOB container for conversion from ByteStream"}

Definition at line 81 of file eFexByteStreamTool.h.

81 {

82 this, "eTAUContainerWriteKey", "", "Write handle key to eTAU TOB container for conversion from ByteStream"};

◆ m_eTAUxWriteKey

SG::WriteHandleKey<xAOD::eFexTauRoIContainer> eFexByteStreamTool::m_eTAUxWriteKey

private

Initial value:

{

this, "eTAUxContainerWriteKey", "", "Write handle key to eTAU xTOB container for conversion from ByteStream"}

Definition at line 85 of file eFexByteStreamTool.h.

85 {

86 this, "eTAUxContainerWriteKey", "", "Write handle key to eTAU xTOB container for conversion from ByteStream"};

◆ m_eTowerWriteKey

SG::WriteHandleKey<xAOD::eFexTowerContainer> eFexByteStreamTool::m_eTowerWriteKey

private

Initial value:

{

this, "eTowerContainerWriteKey", "", "Write handle key to ETower container for conversion from ByteStream"}

Definition at line 94 of file eFexByteStreamTool.h.

94 {

95 this, "eTowerContainerWriteKey", "", "Write handle key to ETower container for conversion from ByteStream"};

◆ m_monTool

ToolHandle<GenericMonitoringTool> eFexByteStreamTool::m_monTool {this,"MonTool","","Monitoring tool"}

private

Definition at line 61 of file eFexByteStreamTool.h.

61{this,"MonTool","","Monitoring tool"};

◆ m_robIds

Gaudi::Property<std::vector<uint32_t> > eFexByteStreamTool::m_robIds {this, "ROBIDs", {}, "List of ROB IDs required for conversion to/from xAOD RoI"}

private

Definition at line 74 of file eFexByteStreamTool.h.

74{this, "ROBIDs", {}, "List of ROB IDs required for conversion to/from xAOD RoI"};

The documentation for this class was generated from the following files:

Classes

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ eFexByteStreamTool()

◆ ~eFexByteStreamTool()

Member Function Documentation

◆ convertFromBS()

◆ convertToBS()

◆ initialize()

◆ robIds()

Member Data Documentation

◆ m_decoder

◆ m_eEMReadKey

◆ m_eEMSliceWriteKey

◆ m_eEMWriteKey

◆ m_eEMxWriteKey

◆ m_eTAUReadKey

◆ m_eTAUSliceWriteKey

◆ m_eTAUWriteKey

◆ m_eTAUxWriteKey

◆ m_eTowerWriteKey

◆ m_monTool

◆ m_robIds