#include <CTP_Decoder.h>

Inheritance diagram for CTP_Decoder:

Collaboration diagram for CTP_Decoder:

Public Member Functions
	CTP_Decoder ()
	Helper class to decode the CTP data fragment. More...

void	setRDO (const CTP_RDO *rdo)
	Set RDO and fill internal variables from the data object. More...

const CTP_RDO *	getRDO () const
	Accessor function to retrieve pointer to RDO object. More...

const std::vector< CTP_BC > &	getBunchCrossings ()
	Get vector reference of bunch-crossing data of the current event. More...

const CTP_BC &	getBunchCrossing (unsigned int pos)
	Get data of a single bunch-crossing. More...

bool	checkTrigger (unsigned int itemNo, unsigned int bcPos)
	Test the LVL1 trigger result for a certain trigger item. More...

bool	checkTriggerAfterPrescale (unsigned int itemNo, unsigned int bcPos)
	Test the LVL1 trigger result after pre-scale factors are applied, before the final trigger decision, which includes the trigger masks, is taken. More...

std::vector< unsigned int >	getAllTriggers (unsigned int bcPos)
	Function to obtain a vector with the numbers of the trigger items that fired for the current event. More...

void	dumpData () const
	Helper to dump data for debugging. More...

bool	msgLvl (const MSG::Level lvl) const
	Test the output level. More...

MsgStream &	msg () const
	The standard message stream. More...

MsgStream &	msg (const MSG::Level lvl) const
	The standard message stream. More...

void	setLevel (MSG::Level lvl)
	Change the current logging level. More...

Private Member Functions
void	initMessaging () const
	Initialize our message level and MessageSvc. More...

Private Attributes
const CTP_RDO *	m_rdo {nullptr}
	The RDO member. More...

std::vector< CTP_BC >	m_BCs
	Vector of BCs for the current event. More...

std::string	m_nm
	Message source name. More...

boost::thread_specific_ptr< MsgStream >	m_msg_tls
	MsgStream instance (a std::cout like with print-out levels) More...

std::atomic< IMessageSvc * >	m_imsg { nullptr }
	MessageSvc pointer. More...

std::atomic< MSG::Level >	m_lvl { MSG::NIL }
	Current logging level. More...

std::atomic_flag m_initialized	ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT
	Messaging initialized (initMessaging) More...

Detailed Description

Definition at line 141 of file CTP_Decoder.h.

Constructor & Destructor Documentation

◆ CTP_Decoder()

CTP_Decoder::CTP_Decoder ( )

Helper class to decode the CTP data fragment.

Date: 2007-07-10 14:58:38

   The CTP ROD data fragment contains the LVL1 trigger
   inputs (160 PITs), and the final trigger result in three
   stages, before pre-scale factors, after pre-scale
   factors, and after veto (dead-time, busy). All of these
   trigger bits can be stored for a number of
   bunch-crossings (BCs), up to 63, where the L1A can be
   almost anywhere within this window. 

   In addition, the GPS time-stamp of the LVL1 trigger
   decision is stored as part of the data fragment.

See also: CTP_RDO

Author: David Berge berge.nosp@m.@cer.nosp@m.n.ch; Eleanor Dobson elean.nosp@m.or.d.nosp@m.obson.nosp@m.@cer.nosp@m.n.ch

Version: $ $ Default constructor

Definition at line 15 of file CTP_Decoder.cxx.

                          :
   AthMessaging(Athena::getMessageSvc(), "CTP_Decoder")
 {
 }

Member Function Documentation

◆ checkTrigger()

bool CTP_Decoder::checkTrigger	(	unsigned int	itemNo,
		unsigned int	bcPos
	)

Test the LVL1 trigger result for a certain trigger item.

Parameters

itemNo	The trigger item that shall be tested
bcPos	The bunch-crossing in the readout window that is to be checked

Returns: A boolean value is returned indicating whether or not the trigger item has fired for a given event

Definition at line 143 of file CTP_Decoder.cxx.

 {
   if(pos >= m_BCs.size()) {
     ATH_MSG_WARNING("Trying to access bunch crossing no "
                   << pos << ", but in the event are only " << m_BCs.size());
     return false;
   }
   if(itemNo >= getBunchCrossing(pos).getTAV().size()) {
     ATH_MSG_WARNING("Checking item no " << itemNo
                     << ", which is more than the maximum : "
                     << getBunchCrossing(pos).getTAV().size());
   }
   return getBunchCrossing(pos).getTAV().test(itemNo);
 }

◆ checkTriggerAfterPrescale()

bool CTP_Decoder::checkTriggerAfterPrescale	(	unsigned int	itemNo,
		unsigned int	bcPos
	)

Test the LVL1 trigger result after pre-scale factors are applied, before the final trigger decision, which includes the trigger masks, is taken.

Here one sees all triggers of an event, irrespective of the trigger mask.

Parameters

itemNo	The trigger item that shall be tested
bcPos	The bunch-crossing in the readout window that is to be checked

Returns: A boolean value is returned indicating whether or not the trigger item is on before the veto step for a given event

Definition at line 158 of file CTP_Decoder.cxx.

                                                                                 {
    if(pos >= m_BCs.size()) {
      ATH_MSG_WARNING("Trying to access bunch crossing no "
                    << pos << ", but in the event are only " << m_BCs.size());
      return false;
    }
    if(itemNo >= getBunchCrossing(pos).getTAP().size()) {
      ATH_MSG_WARNING("Checking item no " << itemNo
                      << ", which is more than the maximum : "
                      << getBunchCrossing(pos).getTAP().size());
    }
    return getBunchCrossing(pos).getTAP().test(itemNo);
 }

◆ dumpData()

void CTP_Decoder::dumpData ( ) const

Helper to dump data for debugging.

Definition at line 107 of file CTP_Decoder.cxx.

 {
    unsigned int nBunches = m_rdo->getNumberOfBunches();
    unsigned int vecSize = m_BCs.size();
   
    if(nBunches == 0) {
       ATH_MSG_DEBUG("CTP_RDO empty");
       return;
    }
   
    if(nBunches != vecSize) {
      ATH_MSG_ERROR("mismatch: " << nBunches << " bunches, but vector size is " << vecSize);
    }
   
    if( msgLvl(MSG::DEBUG) ){
       msg() << MSG::DEBUG << "=================================================" << endmsg;
       msg() << MSG::DEBUG << "Event dump" << endmsg;
       msg() << MSG::DEBUG << "Time " << m_rdo->getTimeSec() << "s "
             << std::setw(10) << std::setiosflags(std::ios_base::right) << std::setfill(' ')
             << m_rdo->getTimeNanoSec() << std::resetiosflags(std::ios_base::right)
             << "ns" << endmsg;
       msg() << MSG::DEBUG << "Number of bunches: " <<  nBunches
             << " (BC vector size " << vecSize << ")" << endmsg;
       msg() << MSG::DEBUG << "L1A position: " << m_rdo->getL1AcceptBunchPosition() << endmsg;
    }
    
    for(unsigned int i = 0; i<vecSize; ++i) {
       ATH_MSG_DEBUG("Now dumping BC " << i);
       m_BCs[i].dumpData(msg());
    }
  
    ATH_MSG_DEBUG("=================================================");
 }

◆ getAllTriggers()

std::vector< unsigned int > CTP_Decoder::getAllTriggers ( unsigned int bcPos )

Function to obtain a vector with the numbers of the trigger items that fired for the current event.

Parameters

bcPos The bunch-crossing in the readout window that is to be used

Returns: A vector<unsigned int> with the list of trigger items that fired in the event (trigger-item numbers run from 1 to 256 for run-I and from 1 to 512 for run-II).

Definition at line 174 of file CTP_Decoder.cxx.

                                                                     {
    if(pos >= m_BCs.size()) {
       ATH_MSG_WARNING("Trying to access bunch crossing no "
                       << pos << ", but in the event are only " << m_BCs.size());
       return std::vector<unsigned int>();
    }
    std::vector<unsigned int> triggers;
    const CTP_BC& bc = getBunchCrossing(pos);
    if(bc.getTAV().any()) {
       for(unsigned int i = 0; i < bc.getTAV().size() ; ++i) {
          if(bc.getTAV().test(i)) {
             triggers.push_back(i+1);
          }
       }  
    }
    return triggers;
 }

◆ getBunchCrossing()

const CTP_BC& CTP_Decoder::getBunchCrossing ( unsigned int pos )

inline

Get data of a single bunch-crossing.

Definition at line 184 of file CTP_Decoder.h.

                                                    {
     return m_BCs[pos];
   }

◆ getBunchCrossings()

const std::vector<CTP_BC>& CTP_Decoder::getBunchCrossings ( )

inline

Get vector reference of bunch-crossing data of the current event.

Definition at line 180 of file CTP_Decoder.h.

                                                {
     return m_BCs;
   }

◆ getRDO()

const CTP_RDO* CTP_Decoder::getRDO ( ) const

inline

Accessor function to retrieve pointer to RDO object.

Definition at line 176 of file CTP_Decoder.h.

                                 {
     return m_rdo;
   }

◆ initMessaging()

void AthMessaging::initMessaging ( ) const

privateinherited

Initialize our message level and MessageSvc.

This method should only be called once.

Definition at line 39 of file AthMessaging.cxx.

 {
   m_imsg = Athena::getMessageSvc();
   m_lvl = m_imsg ?
     static_cast<MSG::Level>( m_imsg.load()->outputLevel(m_nm) ) :
     MSG::INFO;
 }

◆ msg() [1/2]

MsgStream & AthMessaging::msg ( ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 164 of file AthMessaging.h.

 {
   MsgStream* ms = m_msg_tls.get();
   if (!ms) {
     if (!m_initialized.test_and_set()) initMessaging();
     ms = new MsgStream(m_imsg,m_nm);
     m_msg_tls.reset( ms );
   }
  
   ms->setLevel (m_lvl);
   return *ms;
 }

◆ msg() [2/2]

MsgStream & AthMessaging::msg ( const MSG::Level lvl ) const

inlineinherited

The standard message stream.

Returns a reference to the default message stream May not be invoked before sysInitialize() has been invoked.

Definition at line 179 of file AthMessaging.h.

180 { return msg() << lvl; }

◆ msgLvl()

bool AthMessaging::msgLvl ( const MSG::Level lvl ) const

inlineinherited

Test the output level.

Parameters

lvl	The message level to test against

Returns: boolean Indicating if messages at given level will be printed

Return values

true	Messages at level "lvl" will be printed

Definition at line 151 of file AthMessaging.h.

 {
   if (!m_initialized.test_and_set()) initMessaging();
   if (m_lvl <= lvl) {
     msg() << lvl;
     return true;
   } else {
     return false;
   }
 }

◆ setLevel()

void AthMessaging::setLevel ( MSG::Level lvl )

inherited

Change the current logging level.

Use this rather than msg().setLevel() for proper operation with MT.

Definition at line 28 of file AthMessaging.cxx.

 {
   m_lvl = lvl;
 }

◆ setRDO()

void CTP_Decoder::setRDO ( const CTP_RDO * rdo )

Set RDO and fill internal variables from the data object.

Definition at line 20 of file CTP_Decoder.cxx.

 {
    m_rdo = rdo;
    unsigned int ctpVersionNumber = m_rdo->getCTPVersionNumber();
    CTPdataformatVersion ctpVersion(ctpVersionNumber);
   
    unsigned int nBunches = rdo->getNumberOfBunches();
    ATH_MSG_DEBUG("setRDO> #bunches: " << nBunches << ", ctp version (found in RDO): " << ctpVersionNumber);
    ATH_MSG_VERBOSE(ctpVersion.dump());
  
    m_BCs.clear();
    m_BCs.resize(nBunches);
    for (CTP_BC& bc : m_BCs) {
       bc.setCTPVersion(ctpVersionNumber);
    }
   
    //std::vector<uint32_t> PITs = rdo->getPITWords();
    //std::vector<uint32_t> FPIs = rdo->getFPIWords();
    const std::vector<uint32_t> & TIPs = rdo->getTIPWords();
    const std::vector<uint32_t> & TBPs = rdo->getTBPWords();
    const std::vector<uint32_t> & TAPs = rdo->getTAPWords();
    const std::vector<uint32_t> & TAVs = rdo->getTAVWords();
   
    if( nBunches * ctpVersion.getTIPwords() != TIPs.size() ) {
      ATH_MSG_FATAL("Expected " << nBunches * ctpVersion.getTIPwords() << " TIP words, but TIP vector has size " << TIPs.size());
    } else {
      ATH_MSG_DEBUG(TIPs.size() << " TIP words as expected");
    }
    if( nBunches * ctpVersion.getTBPwords() != TBPs.size() ) {
      ATH_MSG_FATAL(nBunches * ctpVersion.getTBPwords() << " TBP words, but TBP vector has size " << TBPs.size());
    } else {
      ATH_MSG_DEBUG(TBPs.size() << " TBP words as expected");
    }
    if( nBunches * ctpVersion.getTAPwords() != TAPs.size() ) {
      ATH_MSG_FATAL(nBunches * ctpVersion.getTAPwords() << " TAP words, but TAP vector has size " << TAPs.size());
    } else {
      ATH_MSG_DEBUG(TAPs.size() << " TAP words as expected");
    }
    if( nBunches * ctpVersion.getTAVwords() != TAVs.size() ) {
      ATH_MSG_FATAL(nBunches * ctpVersion.getTAVwords() << " TAV words, but TAV vector has size " << TAVs.size());
    } else {
      ATH_MSG_DEBUG(TAVs.size() << " TAV words as expected");
    }
   
  
    for(unsigned int i = 0 ; i < nBunches ; ++i) {
  
       ATH_MSG_DEBUG(i << " from CTP_RDO to internal bitsets");
  
       for(unsigned int tip = 0; tip < ctpVersion.getTIPwords(); ++tip) {
          unsigned int index = i*ctpVersion.getTIPwords() + tip;
          if(index >= TIPs.size()) {
             ATH_MSG_FATAL("Invalid TIP position " << index);
             return;
          }
          m_BCs[i].setTIPWord(TIPs[index],tip); //sets m_tip
       }
     
       for(unsigned int tbp = 0; tbp < ctpVersion.getTBPwords(); ++tbp) {
          unsigned int index = i * ctpVersion.getTBPwords() + tbp;
          if(index >= TBPs.size()) {
             ATH_MSG_FATAL("Invalid TBP position " << index);
             return;
          }
          m_BCs[i].setTBPWord(TBPs[index],tbp); //sets m_tbp
       }
     
       for(unsigned int tap = 0; tap < ctpVersion.getTAPwords(); ++tap) {
          unsigned int index = i * ctpVersion.getTAPwords() + tap;
          if(index >= TAPs.size()) {
             ATH_MSG_FATAL("Invalid TAP position " << index);
             return;
          }
          m_BCs[i].setTAPWord(TAPs[index],tap); //sets m_tap
       }
     
       for(unsigned int tav = 0; tav < ctpVersion.getTAVwords(); ++tav) {
          unsigned int index = i * ctpVersion.getTAVwords() + tav;
          if(index >= TAVs.size()) {
             ATH_MSG_FATAL("Invalid TAV position " << index);
             return;
          }
          m_BCs[i].setTAVWord(TAVs[index],tav); //set m_tav
       }
    }
 }

Member Data Documentation

◆ ATLAS_THREAD_SAFE

std::atomic_flag m_initialized AthMessaging::ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT

mutableprivateinherited

Messaging initialized (initMessaging)

Definition at line 141 of file AthMessaging.h.

◆ m_BCs

std::vector<CTP_BC> CTP_Decoder::m_BCs

private

Vector of BCs for the current event.

Definition at line 225 of file CTP_Decoder.h.

◆ m_imsg

std::atomic<IMessageSvc*> AthMessaging::m_imsg { nullptr }

mutableprivateinherited

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

◆ m_lvl

std::atomic<MSG::Level> AthMessaging::m_lvl { MSG::NIL }

mutableprivateinherited

Current logging level.

Definition at line 138 of file AthMessaging.h.

◆ m_msg_tls

boost::thread_specific_ptr<MsgStream> AthMessaging::m_msg_tls

mutableprivateinherited

MsgStream instance (a std::cout like with print-out levels)

Definition at line 132 of file AthMessaging.h.

◆ m_nm

std::string AthMessaging::m_nm

privateinherited

Message source name.

Definition at line 129 of file AthMessaging.h.

◆ m_rdo

const CTP_RDO* CTP_Decoder::m_rdo {nullptr}

private

The RDO member.

Definition at line 223 of file CTP_Decoder.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ CTP_Decoder()

Member Function Documentation

◆ checkTrigger()

◆ checkTriggerAfterPrescale()

◆ dumpData()

◆ getAllTriggers()

◆ getBunchCrossing()

◆ getBunchCrossings()

◆ getRDO()

◆ initMessaging()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ setLevel()

◆ setRDO()

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_BCs

◆ m_imsg

◆ m_lvl

◆ m_msg_tls

◆ m_nm

◆ m_rdo