AlgTask Class Reference

#include </builds/gaudi/Gaudi/GaudiHive/src/AlgTask.h>

Collaboration diagram for AlgTask:

Public Member Functions
	AlgTask (AvalancheSchedulerSvc *scheduler, ISvcLocator *svcLocator, IAlgExecStateSvc *aem, bool asynchronous)
void	operator() () const

Private Attributes
AvalancheSchedulerSvc *	m_scheduler
IAlgExecStateSvc *	m_aess
SmartIF< ISvcLocator >	m_serviceLocator
bool	m_asynchronous { false }

Detailed Description

Definition at line 35 of file AlgTask.h.

Constructor & Destructor Documentation

AlgTask()

AlgTask::AlgTask ( AvalancheSchedulerSvc *  scheduler, ISvcLocator *  svcLocator, IAlgExecStateSvc *  aem, bool  asynchronous  )

inline

Definition at line 37 of file AlgTask.h.

      : m_scheduler( scheduler ), m_aess( aem ), m_serviceLocator( svcLocator ), m_asynchronous( asynchronous ) {}

Member Function Documentation

operator()()

void AlgTask::operator() ( ) const

inline

Definition at line 40 of file AlgTask.h.

                          {
 
    SmartIF<IMessageSvc> messageSvc( m_serviceLocator );
    MsgStream            log( messageSvc, "AlgTask" );
 
    // Get task specification dynamically if it was not provided statically
    AvalancheSchedulerSvc::TaskSpec ts;
    log << MSG::DEBUG << "Getting taskspec for " << ( m_asynchronous ? "asynchronous" : "standard" ) << " algorithm"
        << endmsg;
    if ( !m_scheduler->next( ts, m_asynchronous ) ) {
      log << MSG::WARNING << "Missing specification while task is running" << endmsg;
      return;
    }
 
    EventContext& evtCtx   = *( ts.contextPtr );
    IAlgorithm*&  iAlgoPtr = ts.algPtr;
 
    Gaudi::Algorithm* this_algo = dynamic_cast<Gaudi::Algorithm*>( iAlgoPtr );
    if ( !this_algo ) { throw GaudiException( "Cast to Algorithm failed!", "AlgTask", StatusCode::FAILURE ); }
 
    bool eventfailed = false;
    Gaudi::Hive::setCurrentContext( evtCtx );
 
    // Get the IProperty interface of the ApplicationMgr to pass it to RetCodeGuard
    const SmartIF<IProperty> appmgr( m_serviceLocator );
 
    if ( !Gaudi::Concurrency::ThreadInitDone ) {
      log << MSG::DEBUG << "New thread detected: 0x" << std::hex << pthread_self() << std::dec
          << ". Doing thread local initialization." << endmsg;
      if ( SmartIF<IThreadPoolSvc> tps{ m_serviceLocator->service( "ThreadPoolSvc" ) } ) {
        tps->initThisThread();
      } else {
        log << MSG::ERROR << "Unable to get the ThreadPoolSvc to trigger thread local initialization" << endmsg;
        throw GaudiException( "Retrieval of ThreadPoolSvc failed", "AlgTask", StatusCode::FAILURE );
      }
    }
 
    // select the appropriate store
    this_algo->whiteboard()->selectStore( evtCtx.valid() ? evtCtx.slot() : 0 ).ignore();
    try {
      RetCodeGuard rcg( appmgr, Gaudi::ReturnCode::UnhandledException );
 
      if ( iAlgoPtr->sysExecute( evtCtx ).isFailure() ) {
        log << MSG::WARNING << "Execution of algorithm " << ts.algName << " failed" << endmsg;
        eventfailed = true;
      }
      rcg.ignore(); // disarm the guard
    } catch ( const GaudiException& Exception ) {
      log << MSG::FATAL << ".executeEvent(): Exception with tag=" << Exception.tag() << " thrown by " << ts.algName
          << endmsg;
      log << MSG::ERROR << Exception << endmsg;
      eventfailed = true;
    } catch ( const std::exception& Exception ) {
      log << MSG::FATAL << ".executeEvent(): Standard std::exception thrown by " << ts.algName << endmsg;
      log << MSG::ERROR << Exception.what() << endmsg;
      eventfailed = true;
    } catch ( ... ) {
      log << MSG::FATAL << ".executeEvent(): UNKNOWN Exception thrown by " << ts.algName << endmsg;
      eventfailed = true;
    }
 
    // A FAILURE in algorithm execution must be communicated to the framework
    m_aess->updateEventStatus( eventfailed, evtCtx );
 
    // Release algorithm
    m_scheduler->m_algResourcePool->releaseAlgorithm( ts.algName, iAlgoPtr ).ignore();
 
    // schedule a sign-off of the Algorithm execution
    m_scheduler->m_actionsQueue.push(
        [schdlr = this->m_scheduler, ts = std::move( ts )]() { return schdlr->signoff( ts ); } );
 
    Gaudi::Hive::setCurrentContextEvt( -1 );
  }

Member Data Documentation

m_aess

IAlgExecStateSvc* AlgTask::m_aess

private

Definition at line 117 of file AlgTask.h.

m_asynchronous

bool AlgTask::m_asynchronous { false }

private

Definition at line 120 of file AlgTask.h.

m_scheduler

AvalancheSchedulerSvc* AlgTask::m_scheduler

private

Definition at line 116 of file AlgTask.h.

m_serviceLocator

SmartIF<ISvcLocator> AlgTask::m_serviceLocator

private

Definition at line 118 of file AlgTask.h.

---

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

• GaudiHive/src/AlgTask.h