LVL1BS::CpmRoiByteStreamV2Tool Class Reference

Tool to perform ROB fragments to CPM TOB RoI and CPM TOB RoI to raw data conversions. More...

#include <CpmRoiByteStreamV2Tool.h>

Inheritance diagram for LVL1BS::CpmRoiByteStreamV2Tool:

Collaboration diagram for LVL1BS::CpmRoiByteStreamV2Tool:

Public Member Functions
	CpmRoiByteStreamV2Tool (const std::string &type, const std::string &name, const IInterface *parent)
virtual	~CpmRoiByteStreamV2Tool ()
virtual StatusCode	initialize () override
StatusCode	convert (const EventContext &ctx, const std::string &robFrags, DataVector< LVL1::CPMTobRoI > *roiCollection) const
	Convert ROB fragments to CPM RoIs.
StatusCode	convert (const IROBDataProviderSvc::VROBFRAG &robFrags, DataVector< LVL1::CPMTobRoI > *roiCollection) const
StatusCode	convert (const DataVector< LVL1::CPMTobRoI > *roiCollection) const
	Convert CPM RoI to bytestream.
const std::vector< uint32_t > &	sourceIDs (const std::string &sgKey) const
	Return reference to vector with all possible Source Identifiers.
ServiceHandle< StoreGateSvc > &	evtStore ()
	The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.
const ServiceHandle< StoreGateSvc > &	detStore () const
	The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.
virtual StatusCode	sysInitialize () override
	Perform system initialization for an algorithm.
virtual StatusCode	sysStart () override
	Handle START transition.
virtual std::vector< Gaudi::DataHandle * >	inputHandles () const override
	Return this algorithm's input handles.
virtual std::vector< Gaudi::DataHandle * >	outputHandles () const override
	Return this algorithm's output handles.
Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Property< T, V, H > &t)
void	updateVHKA (Gaudi::Details::PropertyBase &)
MsgStream &	msg () const
bool	msgLvl (const MSG::Level lvl) const

Static Public Member Functions
static const InterfaceID &	interfaceID ()
	AlgTool InterfaceID.

Protected Member Functions
void	renounceArray (SG::VarHandleKeyArray &handlesArray)
	remove all handles from I/O resolution
std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void >	renounce (T &h)
void	extraDeps_update_handler (Gaudi::Details::PropertyBase &ExtraDeps)
	Add StoreName to extra input/output deps as needed.

Private Types
typedef DataVector< LVL1::CPMTobRoI >	CpmRoiCollection
typedef std::map< uint32_t, const LVL1::CPMTobRoI * >	CpmRoiMap
typedef IROBDataProviderSvc::VROBFRAG::const_iterator	ROBIterator
typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType	ROBPointer
typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType	RODPointer
typedef ServiceHandle< StoreGateSvc >	StoreGateSvc_t

Private Member Functions
std::vector< uint32_t >	makeSourceIDs (bool roiDaq) const
void	setupCpmRoiMap (const CpmRoiCollection *roiCollection, CpmRoiMap &roiMap) const
	Set up CPM RoI map.
Gaudi::Details::PropertyBase &	declareGaudiProperty (Gaudi::Property< T, V, H > &hndl, const SG::VarHandleKeyType &)
	specialization for handling Gaudi::Property<SG::VarHandleKey>

Private Attributes
ServiceHandle< IByteStreamCnvSvc >	m_byteStreamCnvSvc { this, "ByteStreamCnvSvc", "ByteStreamCnvSvc" }
ServiceHandle< IROBDataProviderSvc >	m_robDataProvider
ToolHandle< LVL1BS::L1CaloErrorByteStreamTool >	m_errorTool
	Property: Error collection tool.
int	m_crateOffsetHw
	Property: Hardware crate number offset.
int	m_crateOffsetSw
	Property: Software crate number offset.
int	m_version
	Property: Sub_block header version.
int	m_dataFormat
	Property: Data compression format.
const int	m_crates
	Number of crates.
const int	m_modules
	Number of CPM modules per crate.
int	m_slinks
	Property: Number of slinks per crate when writing out bytestream.
int	m_crateMin
	Property: Minimum crate number when writing out bytestream.
int	m_crateMax
	Property: Maximum crate number when writing out bytestream.
std::vector< uint32_t >	m_sourceIDsProp
	Property: ROB source IDs.
std::vector< uint32_t >	m_sourceIDsRoIBProp
	Property: ROB source IDs for RoIB.
const eformat::SubDetector	m_subDetector
	Sub-detector type.
const L1CaloSrcIdMap	m_srcIdMap
	Source ID converter.
bool	m_isM7Format
StoreGateSvc_t	m_evtStore
	Pointer to StoreGate (event store by default).
StoreGateSvc_t	m_detStore
	Pointer to StoreGate (detector store by default).
std::vector< SG::VarHandleKeyArray * >	m_vhka
bool	m_varHandleArraysDeclared

Detailed Description

Tool to perform ROB fragments to CPM TOB RoI and CPM TOB RoI to raw data conversions.

Based on ROD document version X_xxx. <<== CHECK

Author

Peter Faulkner

Definition at line 47 of file CpmRoiByteStreamV2Tool.h.

Member Typedef Documentation

CpmRoiCollection

typedef DataVector<LVL1::CPMTobRoI> LVL1BS::CpmRoiByteStreamV2Tool::CpmRoiCollection

private

Definition at line 76 of file CpmRoiByteStreamV2Tool.h.

CpmRoiMap

typedef std::map<uint32_t, const LVL1::CPMTobRoI*> LVL1BS::CpmRoiByteStreamV2Tool::CpmRoiMap

private

Definition at line 77 of file CpmRoiByteStreamV2Tool.h.

ROBIterator

typedef IROBDataProviderSvc::VROBFRAG::const_iterator LVL1BS::CpmRoiByteStreamV2Tool::ROBIterator

private

Definition at line 78 of file CpmRoiByteStreamV2Tool.h.

ROBPointer

typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType LVL1BS::CpmRoiByteStreamV2Tool::ROBPointer

private

Definition at line 79 of file CpmRoiByteStreamV2Tool.h.

RODPointer

typedef OFFLINE_FRAGMENTS_NAMESPACE::PointerType LVL1BS::CpmRoiByteStreamV2Tool::RODPointer

private

Definition at line 80 of file CpmRoiByteStreamV2Tool.h.

StoreGateSvc_t

typedef ServiceHandle<StoreGateSvc> AthCommonDataStore< AthCommonMsg< AlgTool > >::StoreGateSvc_t

privateinherited

Definition at line 388 of file AthCommonDataStore.h.

Constructor & Destructor Documentation

CpmRoiByteStreamV2Tool()

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

Definition at line 40 of file CpmRoiByteStreamV2Tool.cxx.

    : AthAlgTool(type, name, parent),
      m_robDataProvider("ROBDataProviderSvc", name),
      m_errorTool("LVL1BS::L1CaloErrorByteStreamTool/L1CaloErrorByteStreamTool"),
      m_crates(4), m_modules(14),
      m_subDetector (eformat::TDAQ_CALO_CLUSTER_PROC_ROI)
{
    declareInterface<CpmRoiByteStreamV2Tool>(this);
 
    declareProperty("ErrorTool", m_errorTool,
                    "Tool to collect errors for monitoring");
    declareProperty("CrateOffsetHw",  m_crateOffsetHw = 8,
                    "Offset of CP crate numbers in bytestream");
    declareProperty("CrateOffsetSw",  m_crateOffsetSw = 0,
                    "Offset of CP crate numbers in RDOs");
 
    // Properties for reading bytestream only
    declareProperty("ROBSourceIDs",       m_sourceIDsProp,
                    "ROB fragment source identifiers");
    declareProperty("ROBSourceIDsRoIB",   m_sourceIDsRoIBProp,
                    "ROB fragment source identifiers for RoIBs");
 
    // Properties for writing bytestream only
    declareProperty("DataVersion",    m_version       = 2,
                    "Format version number in sub-block header");
    declareProperty("DataFormat",     m_dataFormat    = 1,
                    "Format identifier (0-1) in sub-block header");
    declareProperty("SlinksPerCrate", m_slinks        = 1,
                    "The number of S-Links per crate");
    declareProperty("CrateMin",       m_crateMin = 0,
                    "Minimum crate number, allows partial output");
    declareProperty("CrateMax",       m_crateMax = m_crates - 1,
                    "Maximum crate number, allows partial output");
 
    declareProperty("IsM7Format", m_isM7Format = false,
                    "Set it for M7 raw data");
 
}

~CpmRoiByteStreamV2Tool()

LVL1BS::CpmRoiByteStreamV2Tool::~CpmRoiByteStreamV2Tool ( )

virtual

Definition at line 83 of file CpmRoiByteStreamV2Tool.cxx.

{
}

Member Function Documentation

convert() [1/3]

StatusCode LVL1BS::CpmRoiByteStreamV2Tool::convert

(

const DataVector< LVL1::CPMTobRoI > *

roiCollection

)

const

Convert CPM RoI to bytestream.

Definition at line 334 of file CpmRoiByteStreamV2Tool.cxx.

{
    const bool debug = msgLvl(MSG::DEBUG);
    if (debug) msg(MSG::DEBUG);
 
    // Get the event assembler
    FullEventAssembler<L1CaloSrcIdMap>* fea = nullptr;
    ATH_CHECK( m_byteStreamCnvSvc->getFullEventAssembler (fea,
                                                          "CpmRoiByteStreamV2") );
    const uint16_t minorVersion = m_srcIdMap.minorVersion();
    fea->setRodMinorVersion(minorVersion);
 
    // Pointer to ROD data vector
 
    FullEventAssembler<L1CaloSrcIdMap>::RODDATA *theROD = 0;
 
    // Sub-block for neutral format
    CpmRoiSubBlockV2 subBlock;
 
    // Set up the container map
 
    // CPM RoI map
    CpmRoiMap roiMap;
    setupCpmRoiMap(roiCollection, roiMap);
 
    if (debug)
    {
        msg() << "Number of RoIs to be written = " << roiCollection->size()
              << " (collection), " << roiMap.size() << " (map)"
              << endmsg;
    }
    int count = 0;
    CpmRoiMap::const_iterator mapIter    = roiMap.begin();
    CpmRoiMap::const_iterator mapIterEnd = roiMap.end();
 
    // Loop over data
 
    const bool neutralFormat = m_dataFormat == L1CaloSubBlock::NEUTRAL;
    const int  modulesPerSlink = m_modules / m_slinks;
    for (int crate = m_crateMin; crate <= m_crateMax; ++crate)
    {
        const int hwCrate = crate + m_crateOffsetHw;
 
        // CPM modules are numbered 1 to m_modules
        for (int module = 1; module <= m_modules; ++module)
        {
            const int mod = module - 1;
 
            // Pack required number of modules per slink
 
            if (mod % modulesPerSlink == 0)
            {
                const int daqOrRoi = 1;
                const int slink = (m_slinks == 2) ? 2 * (mod / modulesPerSlink)
                                  : mod / modulesPerSlink;
                if (debug)
                {
                    msg() << "Treating crate " << hwCrate
                          << " slink " << slink << endmsg
                          << "Data Version/Format: " << m_version
                          << " " << m_dataFormat << endmsg;
                }
                const uint32_t rodIdCpm = m_srcIdMap.getRodID(hwCrate, slink, daqOrRoi,
                                          m_subDetector);
                theROD = fea->getRodData(rodIdCpm);
                if (neutralFormat)
                {
                    const L1CaloUserHeader userHeader;
                    theROD->push_back(userHeader.header());
                }
            }
            if (debug) msg() << "Module " << module << endmsg;
 
            // Create a sub-block (Neutral format only)
 
            if (neutralFormat)
            {
                subBlock.clear();
                subBlock.setRoiHeader(m_version, hwCrate, module);
            }
 
            // Find CPM RoIs for this module
 
            for (; mapIter != mapIterEnd; ++mapIter)
            {
                const LVL1::CPMTobRoI *const roi = mapIter->second;
                if (roi->crate() < crate)  continue;
                if (roi->crate() > crate)  break;
                if (roi->cpm()   < module) continue;
                if (roi->cpm()   > module) break;
                if (roi->energy() || roi->isolation())
                {
                    if (neutralFormat) subBlock.fillRoi(*roi);
                    else theROD->push_back(roi->roiWord());
                    ++count;
                }
            }
 
            // Pack and write the sub-block
 
            if (neutralFormat)
            {
                if ( !subBlock.pack())
                {
                    msg(MSG::ERROR) << "CPMTobRoI sub-block packing failed" << endmsg;
                    return StatusCode::FAILURE;
                }
                if (debug)
                {
                    msg() << "CPMTobRoI sub-block data words: "
                          << subBlock.dataWords() << endmsg;
                }
                subBlock.write(theROD);
            }
        }
    }
    if (debug)
    {
        msg() << "Number of RoIs written = " << count << endmsg;
    }
 
    if (debug) msg() << MSG::dec; // fill seems to leave it in hex
 
    return StatusCode::SUCCESS;
}

convert() [2/3]

StatusCode LVL1BS::CpmRoiByteStreamV2Tool::convert	(	const EventContext &	ctx,
		const std::string &	robFrags,
		DataVector< LVL1::CPMTobRoI > *	roiCollection ) const

Convert ROB fragments to CPM RoIs.

Definition at line 102 of file CpmRoiByteStreamV2Tool.cxx.

{
 const std::vector<uint32_t>& vID(sourceIDs(sgKey));
  // // get ROB fragments
  IROBDataProviderSvc::VROBFRAG robFrags;
  m_robDataProvider->getROBData(ctx, vID, robFrags, "CpmRoiByteStreamV2Tool");
  ATH_MSG_DEBUG("Number of ROB fragments:" << robFrags.size());
  return convert(robFrags, collection);
}

convert() [3/3]

StatusCode LVL1BS::CpmRoiByteStreamV2Tool::convert	(	const IROBDataProviderSvc::VROBFRAG &	robFrags,
		DataVector< LVL1::CPMTobRoI > *	roiCollection ) const

Definition at line 115 of file CpmRoiByteStreamV2Tool.cxx.

{
    const bool debug = msgLvl(MSG::DEBUG);
    if (debug) msg(MSG::DEBUG);
 
    // Sub-block for neutral format
    CpmRoiSubBlockV2 subBlock;
 
    // Loop over ROB fragments
 
    int robCount = 0;
    std::set<uint32_t> dupCheck;
    std::set<uint32_t> dupRoiCheck;
    ROBIterator rob    = robFrags.begin();
    ROBIterator robEnd = robFrags.end();
    for (; rob != robEnd; ++rob)
    {
 
        if (debug)
        {
            ++robCount;
            msg() << "Treating ROB fragment " << robCount << endmsg;
        }
 
        // Skip fragments with ROB status errors
 
        uint32_t robid = (*rob)->source_id();
        if ((*rob)->nstatus() > 0)
        {
            ROBPointer robData;
            (*rob)->status(robData);
            if (*robData != 0)
            {
                m_errorTool->robError(robid, *robData);
                if (debug) msg() << "ROB status error - skipping fragment" << endmsg;
                continue;
            }
        }
 
        // Skip duplicate fragments
 
        if (!dupCheck.insert(robid).second)
        {
            m_errorTool->rodError(robid, L1CaloSubBlock::ERROR_DUPLICATE_ROB);
            if (debug) msg() << "Skipping duplicate ROB fragment" << endmsg;
            continue;
        }
 
        // Unpack ROD data (slinks)
 
        RODPointer payloadBeg;
        RODPointer payload;
        RODPointer payloadEnd;
        (*rob)->rod_data(payloadBeg);
        payloadEnd = payloadBeg + (*rob)->rod_ndata();
        payload = payloadBeg;
        if (payload == payloadEnd)
        {
            if (debug) msg() << "ROB fragment empty" << endmsg;
            continue;
        }
 
        // Check identifier
        const uint32_t sourceID = (*rob)->rod_source_id();
        if (m_srcIdMap.getRobID(sourceID) != robid           ||
                m_srcIdMap.subDet(sourceID)   != m_subDetector   ||
                m_srcIdMap.daqOrRoi(sourceID) != 1               ||
                (m_srcIdMap.slink(sourceID) != 0 && m_srcIdMap.slink(sourceID) != 2) ||
                m_srcIdMap.crate(sourceID)    <  m_crateOffsetHw ||
                m_srcIdMap.crate(sourceID)    >= m_crateOffsetHw + m_crates)
        {
            m_errorTool->rodError(robid, L1CaloSubBlock::ERROR_ROD_ID);
            if (debug)
            {
                msg() << "Wrong source identifier in data: "
                      << MSG::hex << sourceID << MSG::dec << endmsg;
            }
            continue;
        }
 
        // Check minor version
        const int minorVersion = (*rob)->rod_version() & 0xffff;
        if (minorVersion <= m_srcIdMap.minorVersionPreLS1())
        {
            if (debug) msg() << "Skipping pre-LS1 data" << endmsg;
            continue;
        }
        const int rodCrate = m_srcIdMap.crate(sourceID);
        if (debug)
        {
            msg() << "Treating crate " << rodCrate
                  << " slink " << m_srcIdMap.slink(sourceID) << endmsg;
        }
 
        // First word may be User Header
        if (L1CaloUserHeader::isValid(*payload))
        {
            L1CaloUserHeader userHeader(*payload);
            userHeader.setVersion(minorVersion);
            const int headerWords = userHeader.words();
            if (headerWords != 1 )
            {
                m_errorTool->rodError(robid, L1CaloSubBlock::ERROR_USER_HEADER);
                if (debug) msg() << "Unexpected number of user header words: "
                                     << headerWords << endmsg;
                continue;
            }
            for (int i = 0; i < headerWords; ++i) ++payload;
        }
 
        // Loop over sub-blocks if there are any
 
        unsigned int rodErr = L1CaloSubBlock::ERROR_NONE;
        while (payload != payloadEnd)
        {
 
            if (L1CaloSubBlock::wordType(*payload) == L1CaloSubBlock::HEADER)
            {
                subBlock.clear();
                payload = subBlock.read(payload, payloadEnd);
                if (debug)
                {
                    msg() << "CPM RoI sub-block: Crate " << subBlock.crate()
                          << "  Module " << subBlock.module() << endmsg;
                }
                // Unpack sub-block
                if (subBlock.dataWords() && !subBlock.unpack())
                {
                    if (debug)
                    {
                        std::string errMsg(subBlock.unpackErrorMsg());
                        msg() << "CPM RoI sub-block unpacking failed: " << errMsg << endmsg;
                    }
                    rodErr = subBlock.unpackErrorCode();
                    break;
                }
                const int numChips = 8;
                const int numLocs  = 2;
                const int numTypes = 2;
                for (int chip = 0; chip < numChips; ++chip)
                {
                    for (int loc = 0; loc < numLocs; ++loc)
                    {
                        for (int type = 0; type < numTypes; ++type)
                        {
                            const LVL1::CPMTobRoI roi = subBlock.roi(chip, loc, type);
                            if (roi.energy() || roi.isolation())
                            {
                                roiCollection->push_back(new LVL1::CPMTobRoI(roi));
                            }
                        }
                    }
                }
            }
            else
            {
                // Just RoI word
                LVL1::CPMTobRoI roi;
                uint32_t roiWord = *payload;
                if (m_isM7Format) 
                    roiWord |= 0x80000000;
                
                if (roi.setRoiWord(roiWord))
                {
                    if (roi.crate() != rodCrate - m_crateOffsetHw)
                    {
                        if (debug) msg() << "Inconsistent RoI crate number: "
                                             << roi.crate() << endmsg;
                        rodErr = L1CaloSubBlock::ERROR_CRATE_NUMBER;
                        break;
                    }
                    if (roi.cpm() == 0 || roi.cpm() > m_modules)
                    {
                        if (debug) msg() << "Invalid CPM number: "
                                             << roi.cpm() << endmsg;
                        rodErr = L1CaloSubBlock::ERROR_MODULE_NUMBER;
                        break;
                    }
                    const uint32_t location = roiWord & 0xffff0000;
                    if (dupRoiCheck.insert(location).second)
                    {
                        if (roi.energy() || roi.isolation())
                        {
                            roiCollection->push_back(new LVL1::CPMTobRoI(roiWord));
                        }
                    }
                    else
                    {
                        if (debug) msg() << "Duplicate RoI word "
                                             << MSG::hex << roiWord << MSG::dec << endmsg;
                        rodErr = L1CaloSubBlock::ERROR_DUPLICATE_DATA;
                        break;
                    }
                }
                else
                {
                    if (debug) msg() << "Invalid RoI word "
                                         << MSG::hex << roiWord << MSG::dec << endmsg;
                    rodErr = L1CaloSubBlock::ERROR_ROI_TYPE;
                    break;
                }
                ++payload;
            }
        }
        if (rodErr != L1CaloSubBlock::ERROR_NONE)
            m_errorTool->rodError(robid, rodErr);
    }
    if (debug)
    {
        msg() << "Number of RoIs read = " << roiCollection->size() << endmsg;
    }
 
    return StatusCode::SUCCESS;
}

declareGaudiProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< AlgTool > >::declareGaudiProperty ( Gaudi::Property< T, V, H > & hndl, const SG::VarHandleKeyType &  )

inlineprivateinherited

specialization for handling Gaudi::Property<SG::VarHandleKey>

Definition at line 156 of file AthCommonDataStore.h.

  {
    return *AthCommonDataStore<PBASE>::declareProperty(hndl.name(),
                                                       hndl.value(), 
                                                       hndl.documentation());
 
  }

declareProperty()

Gaudi::Details::PropertyBase & AthCommonDataStore< AthCommonMsg< AlgTool > >::declareProperty ( Gaudi::Property< T, V, H > & t )

inlineinherited

Definition at line 145 of file AthCommonDataStore.h.

                                                                     {
    typedef typename SG::HandleClassifier<T>::type htype;
    return AthCommonDataStore<PBASE>::declareGaudiProperty(t, htype());
  }

detStore()

const ServiceHandle< StoreGateSvc > & AthCommonDataStore< AthCommonMsg< AlgTool > >::detStore ( ) const

inlineinherited

The standard StoreGateSvc/DetectorStore Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 95 of file AthCommonDataStore.h.

{ return m_detStore; }

evtStore()

ServiceHandle< StoreGateSvc > & AthCommonDataStore< AthCommonMsg< AlgTool > >::evtStore ( )

inlineinherited

The standard StoreGateSvc (event store) Returns (kind of) a pointer to the StoreGateSvc.

Definition at line 85 of file AthCommonDataStore.h.

{ return m_evtStore; }

extraDeps_update_handler()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::extraDeps_update_handler ( Gaudi::Details::PropertyBase & ExtraDeps )

protectedinherited

Add StoreName to extra input/output deps as needed.

use the logic of the VarHandleKey to parse the DataObjID keys supplied via the ExtraInputs and ExtraOuputs Properties to add the StoreName if it's not explicitly given

initialize()

StatusCode LVL1BS::CpmRoiByteStreamV2Tool::initialize ( )

overridevirtual

Definition at line 90 of file CpmRoiByteStreamV2Tool.cxx.

{
    ATH_MSG_INFO ("Initializing " << name());
 
    ATH_CHECK( m_errorTool.retrieve() );
    ATH_CHECK( m_byteStreamCnvSvc.retrieve() );
 
    return StatusCode::SUCCESS;
}

inputHandles()

virtual std::vector< Gaudi::DataHandle * > AthCommonDataStore< AthCommonMsg< AlgTool > >::inputHandles ( ) const

overridevirtualinherited

Return this algorithm's input handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

interfaceID()

const InterfaceID & LVL1BS::CpmRoiByteStreamV2Tool::interfaceID ( )

static

AlgTool InterfaceID.

Definition at line 33 of file CpmRoiByteStreamV2Tool.cxx.

{
    return IID_ICpmRoiByteStreamV2Tool;
}

makeSourceIDs()

std::vector< uint32_t > LVL1BS::CpmRoiByteStreamV2Tool::makeSourceIDs ( bool roiDaq ) const

private

Definition at line 463 of file CpmRoiByteStreamV2Tool.cxx.

{
  std::vector<uint32_t> sourceIDs;
 
  if (roiDaq) {
    sourceIDs = m_sourceIDsProp;
  }
  else {
    sourceIDs = m_sourceIDsRoIBProp;
  }
 
  if (sourceIDs.empty()) {
        const int maxCrates = m_crates + m_crateOffsetHw;
        const int maxSlinks = m_srcIdMap.maxSlinks();
        for (int hwCrate = m_crateOffsetHw; hwCrate < maxCrates; ++hwCrate)
        {
            for (int slink = 0; slink < maxSlinks; ++slink)
            {
                const int daqOrRoi = 1;
                const uint32_t rodId = m_srcIdMap.getRodID(hwCrate, slink, daqOrRoi,
                                       m_subDetector);
                const uint32_t robId = m_srcIdMap.getRobID(rodId);
                if (roiDaq)
                {
                    if (slink < 2) sourceIDs.push_back(robId);
                }
                else if (slink >= 2) sourceIDs.push_back(robId);
            }
        }
 
  }
  return sourceIDs;
}

msg()

MsgStream & AthCommonMsg< AlgTool >::msg ( ) const

inlineinherited

Definition at line 24 of file AthCommonMsg.h.

                                {
    return this->msgStream();
  }

msgLvl()

bool AthCommonMsg< AlgTool >::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Definition at line 30 of file AthCommonMsg.h.

                                               {
    return this->msgLevel(lvl);
  }

outputHandles()

virtual std::vector< Gaudi::DataHandle * > AthCommonDataStore< AthCommonMsg< AlgTool > >::outputHandles ( ) const

overridevirtualinherited

Return this algorithm's output handles.

We override this to include handle instances from key arrays if they have not yet been declared. See comments on updateVHKA.

renounce()

std::enable_if_t< std::is_void_v< std::result_of_t< decltype(&T::renounce)(T)> > &&!std::is_base_of_v< SG::VarHandleKeyArray, T > &&std::is_base_of_v< Gaudi::DataHandle, T >, void > AthCommonDataStore< AthCommonMsg< AlgTool > >::renounce ( T & h )

inlineprotectedinherited

Definition at line 380 of file AthCommonDataStore.h.

  {
    h.renounce();
    PBASE::renounce (h);
  }

renounceArray()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::renounceArray ( SG::VarHandleKeyArray & handlesArray )

inlineprotectedinherited

remove all handles from I/O resolution

Definition at line 364 of file AthCommonDataStore.h.

                                                          {
    handlesArray.renounce();
  }

setupCpmRoiMap()

void LVL1BS::CpmRoiByteStreamV2Tool::setupCpmRoiMap ( const CpmRoiCollection * roiCollection, CpmRoiMap & roiMap ) const

private

Set up CPM RoI map.

Definition at line 517 of file CpmRoiByteStreamV2Tool.cxx.

{
    roiMap.clear();
    if (roiCollection)
    {
        CpmRoiCollection::const_iterator pos  = roiCollection->begin();
        CpmRoiCollection::const_iterator pose = roiCollection->end();
        for (; pos != pose; ++pos)
        {
            const LVL1::CPMTobRoI *const roi = *pos;
            const int type = roi->type();
            const int crate = roi->crate();
            const int cpm = roi->cpm();
            const int chip = roi->chip();
            const int loc = roi->location() >> 2;
            const uint32_t key = (((((((crate << 4) | cpm) << 3) | chip) << 1) | loc) << 1) | type;
            roiMap.insert(std::make_pair(key, roi));
        }
    }
}

sourceIDs()

const std::vector< uint32_t > & LVL1BS::CpmRoiByteStreamV2Tool::sourceIDs

(

const std::string &

sgKey

)

const

Return reference to vector with all possible Source Identifiers.

Definition at line 497 of file CpmRoiByteStreamV2Tool.cxx.

{
    const std::string flag("RoIB");
    const std::string::size_type pos = sgKey.find(flag);
    const bool roiDaq =
        (pos == std::string::npos || pos != sgKey.length() - flag.length());
 
    if (roiDaq) {
      static const std::vector<uint32_t> sourceIDs = makeSourceIDs(roiDaq);
      return sourceIDs;
    }
    else {
      static const std::vector<uint32_t> sourceIDsRoIB = makeSourceIDs(roiDaq);
      return sourceIDsRoIB;
    }
}

sysInitialize()

virtual StatusCode AthCommonDataStore< AthCommonMsg< AlgTool > >::sysInitialize ( )

overridevirtualinherited

Perform system initialization for an algorithm.

We override this to declare all the elements of handle key arrays at the end of initialization. See comments on updateVHKA.

Reimplemented in asg::AsgMetadataTool, AthCheckedComponent< AthAlgTool >, AthCheckedComponent<::AthAlgTool >, and DerivationFramework::CfAthAlgTool.

sysStart()

virtual StatusCode AthCommonDataStore< AthCommonMsg< AlgTool > >::sysStart ( )

overridevirtualinherited

Handle START transition.

We override this in order to make sure that conditions handle keys can cache a pointer to the conditions container.

updateVHKA()

void AthCommonDataStore< AthCommonMsg< AlgTool > >::updateVHKA ( Gaudi::Details::PropertyBase & )

inlineinherited

Definition at line 308 of file AthCommonDataStore.h.

                                               {
    // debug() << "updateVHKA for property " << p.name() << " " << p.toString() 
    //         << "  size: " << m_vhka.size() << endmsg;
    for (auto &a : m_vhka) {
      std::vector<SG::VarHandleKey*> keys = a->keys();
      for (auto k : keys) {
        k->setOwner(this);
      }
    }
  }

Member Data Documentation

m_byteStreamCnvSvc

ServiceHandle<IByteStreamCnvSvc> LVL1BS::CpmRoiByteStreamV2Tool::m_byteStreamCnvSvc { this, "ByteStreamCnvSvc", "ByteStreamCnvSvc" }

private

Definition at line 73 of file CpmRoiByteStreamV2Tool.h.

{ this, "ByteStreamCnvSvc", "ByteStreamCnvSvc" };

m_crateMax

int LVL1BS::CpmRoiByteStreamV2Tool::m_crateMax

private

Property: Maximum crate number when writing out bytestream.

Definition at line 109 of file CpmRoiByteStreamV2Tool.h.

m_crateMin

int LVL1BS::CpmRoiByteStreamV2Tool::m_crateMin

private

Property: Minimum crate number when writing out bytestream.

Definition at line 107 of file CpmRoiByteStreamV2Tool.h.

m_crateOffsetHw

int LVL1BS::CpmRoiByteStreamV2Tool::m_crateOffsetHw

private

Property: Hardware crate number offset.

Definition at line 93 of file CpmRoiByteStreamV2Tool.h.

m_crateOffsetSw

int LVL1BS::CpmRoiByteStreamV2Tool::m_crateOffsetSw

private

Property: Software crate number offset.

Definition at line 95 of file CpmRoiByteStreamV2Tool.h.

m_crates

const int LVL1BS::CpmRoiByteStreamV2Tool::m_crates

private

Number of crates.

Definition at line 101 of file CpmRoiByteStreamV2Tool.h.

m_dataFormat

int LVL1BS::CpmRoiByteStreamV2Tool::m_dataFormat

private

Property: Data compression format.

Definition at line 99 of file CpmRoiByteStreamV2Tool.h.

m_detStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< AlgTool > >::m_detStore

privateinherited

Pointer to StoreGate (detector store by default).

Definition at line 393 of file AthCommonDataStore.h.

m_errorTool

ToolHandle<LVL1BS::L1CaloErrorByteStreamTool> LVL1BS::CpmRoiByteStreamV2Tool::m_errorTool

private

Property: Error collection tool.

Definition at line 90 of file CpmRoiByteStreamV2Tool.h.

m_evtStore

StoreGateSvc_t AthCommonDataStore< AthCommonMsg< AlgTool > >::m_evtStore

privateinherited

Pointer to StoreGate (event store by default).

Definition at line 390 of file AthCommonDataStore.h.

m_isM7Format

bool LVL1BS::CpmRoiByteStreamV2Tool::m_isM7Format

private

Definition at line 121 of file CpmRoiByteStreamV2Tool.h.

m_modules

const int LVL1BS::CpmRoiByteStreamV2Tool::m_modules

private

Number of CPM modules per crate.

Definition at line 103 of file CpmRoiByteStreamV2Tool.h.

m_robDataProvider

ServiceHandle<IROBDataProviderSvc> LVL1BS::CpmRoiByteStreamV2Tool::m_robDataProvider

private

Definition at line 88 of file CpmRoiByteStreamV2Tool.h.

m_slinks

int LVL1BS::CpmRoiByteStreamV2Tool::m_slinks

private

Property: Number of slinks per crate when writing out bytestream.

Definition at line 105 of file CpmRoiByteStreamV2Tool.h.

m_sourceIDsProp

std::vector<uint32_t> LVL1BS::CpmRoiByteStreamV2Tool::m_sourceIDsProp

private

Property: ROB source IDs.

Definition at line 111 of file CpmRoiByteStreamV2Tool.h.

m_sourceIDsRoIBProp

std::vector<uint32_t> LVL1BS::CpmRoiByteStreamV2Tool::m_sourceIDsRoIBProp

private

Property: ROB source IDs for RoIB.

Definition at line 113 of file CpmRoiByteStreamV2Tool.h.

m_srcIdMap

const L1CaloSrcIdMap LVL1BS::CpmRoiByteStreamV2Tool::m_srcIdMap

private

Source ID converter.

Definition at line 117 of file CpmRoiByteStreamV2Tool.h.

m_subDetector

const eformat::SubDetector LVL1BS::CpmRoiByteStreamV2Tool::m_subDetector

private

Sub-detector type.

Definition at line 115 of file CpmRoiByteStreamV2Tool.h.

m_varHandleArraysDeclared

bool AthCommonDataStore< AthCommonMsg< AlgTool > >::m_varHandleArraysDeclared

privateinherited

Definition at line 399 of file AthCommonDataStore.h.

m_version

int LVL1BS::CpmRoiByteStreamV2Tool::m_version

private

Property: Sub_block header version.

Definition at line 97 of file CpmRoiByteStreamV2Tool.h.

m_vhka

std::vector<SG::VarHandleKeyArray*> AthCommonDataStore< AthCommonMsg< AlgTool > >::m_vhka

privateinherited

Definition at line 398 of file AthCommonDataStore.h.

---

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

• CpmRoiByteStreamV2Tool.h
• CpmRoiByteStreamV2Tool.cxx