The test calls for RoI data access for each RoI returned bunch of quantiries are checked, RoI et, actual RoI span, and cells count. More...

Inheritance diagram for AskForRoI:

Collaboration diagram for AskForRoI:

Public Member Functions
	AskForRoI (const EventContext &context, const ServiceHandle< ITrigCaloDataAccessSvc > &svc, const TrigRoiDescriptor &roi)
	~AskForRoI ()
StatusCode	request (LArTT_Selector< LArCellCont > &sel) const
StatusCode	request (CaloConstCellContainer &c) const
void	firstCall () override
	a method that will be called to obtain first results from the service It should set the reference quantities
bool	callAndCompare () const override
	a function that performs request, and compares the results obtained with the result of the first execution When result differ this function is supposed to return false, otherwise true
bool	run (size_t nrepeats)
	runs the stress test by invoking it the firstCall and then repetitively the callAndCompare
bool	msgLvl (const MSG::Level lvl) const
	Test the output level.
MsgStream &	msg () const
	The standard message stream.
MsgStream &	msg (const MSG::Level lvl) const
	The standard message stream.
void	setLevel (MSG::Level lvl)
	Change the current logging level.

Static Public Member Functions
static bool	launchTests (size_t nrepeats, const std::vector< ParallelCallTest * > &tests)
	Method to run launch number of tests in parallel (increasing the stress of the calle) It has a potential that also the "first" calls can be launched in parallel and thus be the worse case compared to a situation when the first calls are invoked sequentially while further calls in parallel.

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

Private Attributes
const EventContext &	m_context
const ServiceHandle< ITrigCaloDataAccessSvc > &	m_svc
const TrigRoiDescriptor	m_roi
LArTT_Selector< LArCellCont >	m_selRef
CaloConstCellContainer *	m_colRef
StatusCode	m_statusRef
double	m_etSumRef = 0
size_t	m_countRef = 0
double	m_minEtaRef = 100
double	m_maxEtaRef = -100
double	m_minPhiRef = 100
double	m_maxPhiRef = -100
std::string	m_nm
	Message source name.
boost::thread_specific_ptr< MsgStream >	m_msg_tls
	MsgStream instance (a std::cout like with print-out levels)
std::atomic< IMessageSvc * >	m_imsg { nullptr }
	MessageSvc pointer.
std::atomic< MSG::Level >	m_lvl { MSG::NIL }
	Current logging level.
std::atomic_flag m_initialized	ATLAS_THREAD_SAFE = ATOMIC_FLAG_INIT
	Messaging initialized (initMessaging)

Detailed Description

The test calls for RoI data access for each RoI returned bunch of quantiries are checked, RoI et, actual RoI span, and cells count.

Definition at line 30 of file TestCaloDataAccess.cxx.

Constructor & Destructor Documentation

◆ AskForRoI()

AskForRoI::AskForRoI	(	const EventContext &	context,
		const ServiceHandle< ITrigCaloDataAccessSvc > &	svc,
		const TrigRoiDescriptor &	roi )

inline

Definition at line 32 of file TestCaloDataAccess.cxx.

    : AthMessaging ("TestCaloDataAccess"),
      m_context( context ),
      m_svc( svc ),
      m_roi ( roi ) {
    m_colRef = new CaloConstCellContainer(SG::VIEW_ELEMENTS);
  }

◆ ~AskForRoI()

AskForRoI::~AskForRoI ( )

inline

Definition at line 41 of file TestCaloDataAccess.cxx.

               {
    if ( m_colRef ) { m_colRef->clear(); delete m_colRef; }
  }

Member Function Documentation

◆ callAndCompare()

bool AskForRoI::callAndCompare ( ) const

inlineoverridevirtual

a function that performs request, and compares the results obtained with the result of the first execution When result differ this function is supposed to return false, otherwise true

Implements ParallelCallTest.

Definition at line 108 of file TestCaloDataAccess.cxx.

                                       {
 
    Gaudi::Hive::setCurrentContext (m_context);
    LArTT_Selector<LArCellCont> sel;
    CaloConstCellContainer col(SG::VIEW_ELEMENTS);
    double etSum  = 0;      
    size_t count = 0;
    double minEta = 100;
    double maxEta = -100;
    double minPhi = 100;
    double maxPhi = -100;
    StatusCode status;
    if ( m_roi.isFullscan() ) {
      status = request( col );      
      status.ignore();
      
      for ( const auto cell : col ) {
    if ( !cell ) continue;
    etSum  += cell->et();
    count ++;
    minEta  = std::min( minEta, cell->eta() );
    maxEta  = std::max( maxEta, cell->eta() );
    minPhi  = std::min( minPhi, cell->phi() );
    maxPhi  = std::max( maxPhi, cell->phi() );
      }
    } else {
      
      status = request( sel );      
      status.ignore();
      
      for ( const auto cell : sel ) {
    etSum  += cell->et();
    count ++;
    minEta  = std::min( minEta, cell->eta() );
    maxEta  = std::max( maxEta, cell->eta() );
    minPhi  = std::min( minPhi, cell->phi() );
    maxPhi  = std::max( maxPhi, cell->phi() );
      }
      std::cout << "callAndCompare : " << m_context << " " << count << " " << etSum << " " << minEta << " " << maxEta << " " << minPhi << " " << maxPhi << " " << " " << m_minEtaRef << " " << m_maxEtaRef << " " << m_minPhiRef << " " << m_maxPhiRef << " " << m_etSumRef << " " << m_countRef << std::endl;
    }
 
    DIFF( "RoI mask", status.getCode(), m_statusRef.getCode() );
    DIFF( "RoI count ", count , m_countRef );
    DIFF( "RoI etSum ", etSum , m_etSumRef );
    DIFF( "RoI minEta", minEta, m_minEtaRef );
    DIFF( "RoI maxEta", maxEta, m_maxEtaRef );
    DIFF( "RoI minPhi", minPhi, m_minPhiRef );
    DIFF( "RoI maxPhi", maxPhi, m_maxPhiRef );
    
    bool checkStatus = m_statusRef == status
      and m_countRef == count
      and m_etSumRef == etSum 
      and m_minEtaRef == minEta
      and m_maxEtaRef == maxEta
      and m_minPhiRef == minPhi
      and m_maxPhiRef == maxPhi;
 
    if ( checkStatus == false ) {
      
      // iterate over two slectors and compare cell by cell
      for ( LArTT_Selector<LArCellCont>::const_iterator refIter = m_selRef.begin(), thisIter = sel.begin(); 
        refIter != m_selRef.end() and thisIter != sel.end(); ++refIter, ++thisIter ) {   
    const LArCell* refCell = *refIter;
    const LArCell* thisCell = *thisIter;
    if ( thisCell->et() != refCell->et() ) {
      ATH_MSG_WARNING( "eta/phi/et Reference cell " << refCell->eta() << "/" << refCell->phi() << "/" << refCell->et() 
                           <<    " differ from the one in this request " << thisCell->eta() << "/" << thisCell->phi() << "/" << thisCell->et() );
    }
      }
    }
 
    return checkStatus;
  }

◆ firstCall()

void AskForRoI::firstCall ( )

inlineoverridevirtual

a method that will be called to obtain first results from the service It should set the reference quantities

Implements ParallelCallTest.

Definition at line 68 of file TestCaloDataAccess.cxx.

                            { 
    Gaudi::Hive::setCurrentContext (m_context);
    if ( m_roi.isFullscan() ) {
      struct timeval t1{},t2{};
      gettimeofday(&t1,NULL);
      m_statusRef = request( *m_colRef );
      m_statusRef.ignore(); 
      gettimeofday(&t2,NULL);
      
      for ( const auto cell : *m_colRef ) {
    if ( !cell ) continue;
    m_etSumRef += cell->et();
    m_countRef ++;
    m_minEtaRef = std::min( m_minEtaRef, cell->eta() );
    m_maxEtaRef = std::max( m_maxEtaRef, cell->eta() );
    m_minPhiRef = std::min( m_minPhiRef, cell->phi() );
    m_maxPhiRef = std::max( m_maxPhiRef, cell->phi() );
      }
      std::cout << "t lFC : " << m_context << " " << m_etSumRef << " " << t1.tv_sec << " " << t1.tv_usec << " " << t2.tv_sec << " " << t2.tv_usec << " " << ((t2.tv_sec-t1.tv_sec)*1e6+(t2.tv_usec-t1.tv_usec) )*1e-6 << std::endl;
      
    } else {
      
      struct timeval t1{},t2{};
      gettimeofday(&t1,NULL);
      m_statusRef = request( m_selRef );
      m_statusRef.ignore();
      gettimeofday(&t2,NULL);
      
      for ( const auto cell : m_selRef ) {
    m_etSumRef += cell->et();
    m_countRef ++;
    m_minEtaRef = std::min( m_minEtaRef, cell->eta() );
    m_maxEtaRef = std::max( m_maxEtaRef, cell->eta() );
    m_minPhiRef = std::min( m_minPhiRef, cell->phi() );
    m_maxPhiRef = std::max( m_maxPhiRef, cell->phi() );
      }
      std::cout << "t RoI : " << m_context << " " << m_etSumRef << " " << t1.tv_sec << " " << t1.tv_usec << " " << t2.tv_sec << " " << t2.tv_usec << " " << ((t2.tv_sec-t1.tv_sec)*1e6+(t2.tv_usec-t1.tv_usec) )*1e-6 << std::endl;
    }
  }

◆ 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();
  // If user did not set an explicit level, set a default
  if (m_lvl == MSG::NIL) {
    m_lvl = m_imsg ?
      static_cast<MSG::Level>( m_imsg.load()->outputLevel(m_nm) ) :
      MSG::INFO;
  }
}

◆ launchTests()

bool ParallelCallTest::launchTests	(	size_t	nrepeats,
		const std::vector< ParallelCallTest * > &	tests )

staticinherited

Method to run launch number of tests in parallel (increasing the stress of the calle) It has a potential that also the "first" calls can be launched in parallel and thus be the worse case compared to a situation when the first calls are invoked sequentially while further calls in parallel.

Definition at line 83 of file ParallelCallTest.cxx.

                                                                                               {
  // Suppress undefined behavior warning resulting from a tbb bug.
  // /cvmfs/atlas-nightlies.cern.ch/repo/sw/master/sw/lcg/releases/LCG_88/tbb/44_20160413/x86_64-slc6-gcc62-dbg/include/tbb/parallel_reduce.h:177:32: runtime error: member call on address 0x2aab14047b40 which does not point to an object of type 'task'
  //0x2aab14047b40: note: object has invalid vptr
  //    00 00 00 00  00 00 00 00 00 00 00 00  00 00 00 00 00 00 00 00  00 00 00 00 00 0
  // cf. https://github.com/RcppCore/RcppParallel/issues/36
  RedirStderr redir;
 
  //std::vector<ParallelCallTest*> tests( testList.begin(), testList.end() );
  return  tbb::parallel_reduce( tbb::blocked_range< std::vector<ParallelCallTest*>::const_iterator >( tests.begin(), tests.end() ),
                true, // initial value
                [&]( tbb::blocked_range< std::vector<ParallelCallTest*>::const_iterator > groupOfTests, bool statusSoFar ) -> bool {
                  bool success = true;
                  for ( auto test : groupOfTests ) {
                    success = test->run( nrepeats ) and success;
                  }
                  return statusSoFar and success;
                },
                []( bool allCallsStatus, bool thisCallStatus ) -> bool { // result accumulation
                  return allCallsStatus and thisCallStatus; 
                } );    
}

◆ 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 163 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 178 of file AthMessaging.h.

179{ return msg() << lvl; }

AthMessaging::msg

MsgStream & msg() const

The standard message stream.

Definition AthMessaging.h:163

◆ 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_lvl <= lvl) {
    msg() << lvl;
    return true;
  } else {
    return false;
  }
}

◆ request() [1/2]

StatusCode AskForRoI::request ( CaloConstCellContainer & c ) const

inline

Definition at line 57 of file TestCaloDataAccess.cxx.

                                                        {
    if ( m_roi.isFullscan() ){
      return m_svc->loadFullCollections( m_context, c );
    }
    else{
      std::cout << "wrong RoI descriptor used for FS" << std::endl;
      return StatusCode::FAILURE;
    }
  }

◆ request() [2/2]

StatusCode AskForRoI::request ( LArTT_Selector< LArCellCont > & sel ) const

inline

Definition at line 45 of file TestCaloDataAccess.cxx.

                                                               {
    if ( m_roi.isFullscan() ){
      std::cout << "wrong RoI descriptor used for RoI" << std::endl;
      return StatusCode::FAILURE;
    }
    else{
      // keep this for test reasons
      //usleep (5000);
      return m_svc->loadCollections( m_context, m_roi, TTEM, 2, sel );    
    }
  }

◆ run()

bool ParallelCallTest::run ( size_t nrepeats )

inherited

runs the stress test by invoking it the firstCall and then repetitively the callAndCompare

nrepeats times (>=1) A single failure of the callAndCompare would result in the whole execution failed

Definition at line 69 of file ParallelCallTest.cxx.

                                            {    
  firstCall();
  
  return  tbb::parallel_reduce( tbb::blocked_range<int>( 0, nrepeats, 1 ),
                true, // initial value
                [&]( tbb::blocked_range<int>, bool statusSoFar ) -> bool {
                  return callAndCompare() and statusSoFar;
                },
                []( bool allCallsStatus, bool thisCallStatus ) -> bool { // result accumulation
                  return allCallsStatus and thisCallStatus; 
                } );
}

◆ 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;
}

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_colRef

CaloConstCellContainer* AskForRoI::m_colRef

private

Definition at line 188 of file TestCaloDataAccess.cxx.

◆ m_context

const EventContext& AskForRoI::m_context

private

Definition at line 183 of file TestCaloDataAccess.cxx.

◆ m_countRef

size_t AskForRoI::m_countRef = 0

private

Definition at line 191 of file TestCaloDataAccess.cxx.

◆ m_etSumRef

double AskForRoI::m_etSumRef = 0

private

Definition at line 190 of file TestCaloDataAccess.cxx.

◆ m_imsg

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

mutableprivateinherited

MessageSvc pointer.

Definition at line 135 of file AthMessaging.h.

135{ nullptr };

◆ m_lvl

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

mutableprivateinherited

Current logging level.

Definition at line 138 of file AthMessaging.h.

138{ MSG::NIL };

◆ m_maxEtaRef

double AskForRoI::m_maxEtaRef = -100

private

Definition at line 193 of file TestCaloDataAccess.cxx.

◆ m_maxPhiRef

double AskForRoI::m_maxPhiRef = -100

private

Definition at line 195 of file TestCaloDataAccess.cxx.

◆ m_minEtaRef

double AskForRoI::m_minEtaRef = 100

private

Definition at line 192 of file TestCaloDataAccess.cxx.

◆ m_minPhiRef

double AskForRoI::m_minPhiRef = 100

private

Definition at line 194 of file TestCaloDataAccess.cxx.

◆ 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_roi

const TrigRoiDescriptor AskForRoI::m_roi

private

Definition at line 185 of file TestCaloDataAccess.cxx.

◆ m_selRef

LArTT_Selector<LArCellCont> AskForRoI::m_selRef

private

Definition at line 187 of file TestCaloDataAccess.cxx.

◆ m_statusRef

StatusCode AskForRoI::m_statusRef

private

Definition at line 189 of file TestCaloDataAccess.cxx.

◆ m_svc

const ServiceHandle<ITrigCaloDataAccessSvc>& AskForRoI::m_svc

private

Definition at line 184 of file TestCaloDataAccess.cxx.

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

TestCaloDataAccess.cxx

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ AskForRoI()

◆ ~AskForRoI()

Member Function Documentation

◆ callAndCompare()

◆ firstCall()

◆ initMessaging()

◆ launchTests()

◆ msg() [1/2]

◆ msg() [2/2]

◆ msgLvl()

◆ request() [1/2]

◆ request() [2/2]

◆ run()

◆ setLevel()

Member Data Documentation

◆ ATLAS_THREAD_SAFE

◆ m_colRef

◆ m_context

◆ m_countRef

◆ m_etSumRef

◆ m_imsg

◆ m_lvl

◆ m_maxEtaRef

◆ m_maxPhiRef

◆ m_minEtaRef

◆ m_minPhiRef

◆ m_msg_tls

◆ m_nm

◆ m_roi

◆ m_selRef

◆ m_statusRef

◆ m_svc