AlgTask< T > Class Template Reference

#include <src/AlgTask.h>

Inheritance diagram for AlgTask< T >:

Collaboration diagram for AlgTask< T >:

Public Member Functions
	AlgTask (AvalancheSchedulerSvc *scheduler, ISvcLocator *svcLocator, IAlgExecStateSvc *aem)
	AlgTask (AvalancheSchedulerSvc::TaskSpec &&ts, AvalancheSchedulerSvc *scheduler, ISvcLocator *svcLocator, IAlgExecStateSvc *aem)
T *	execute () override
void	operator() ()

Private Attributes
AvalancheSchedulerSvc::TaskSpec	m_ts
AvalancheSchedulerSvc *	m_scheduler
IAlgExecStateSvc *	m_aess
SmartIF< ISvcLocator >	m_serviceLocator

Detailed Description

template<class T>
class AlgTask< T >

Definition at line 37 of file AlgTask.h.

Constructor & Destructor Documentation

AlgTask() [1/2]

template<class T>

AlgTask< T >::AlgTask ( AvalancheSchedulerSvc *  scheduler, ISvcLocator *  svcLocator, IAlgExecStateSvc *  aem  )

inline

Definition at line 39 of file AlgTask.h.

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

AlgTask() [2/2]

template<class T>

AlgTask< T >::AlgTask ( AvalancheSchedulerSvc::TaskSpec &&  ts, AvalancheSchedulerSvc *  scheduler, ISvcLocator *  svcLocator, IAlgExecStateSvc *  aem  )

inline

Definition at line 42 of file AlgTask.h.

      : m_ts( std::move( ts ) ), m_scheduler( scheduler ), m_aess( aem ), m_serviceLocator( svcLocator ){};

Member Function Documentation

execute()

template<class T>

T* AlgTask< T >::execute ( )

inlineoverride

Definition at line 46 of file AlgTask.h.

                        {

    SmartIF<IMessageSvc> messageSvc( m_serviceLocator );
    MsgStream            log( messageSvc, "AlgTask" );

    // Get task specification dynamically if it was not provided statically
    if ( !m_ts.algPtr )
      if ( !m_scheduler->m_scheduledQueue.try_pop( m_ts ) ) {
        log << MSG::WARNING << "Specification not complete or void while task is running" << endmsg;
        return nullptr;
      }

    EventContext& evtCtx   = *( m_ts.contextPtr );
    IAlgorithm*&  iAlgoPtr = m_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 ( UNLIKELY( iAlgoPtr->sysExecute( evtCtx ).isFailure() ) ) {
        log << MSG::WARNING << "Execution of algorithm " << m_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 " << m_ts.algName
          << endmsg;
      log << MSG::ERROR << Exception << endmsg;
      eventfailed = true;
    } catch ( const std::exception& Exception ) {
      log << MSG::FATAL << ".executeEvent(): Standard std::exception thrown by " << m_ts.algName << endmsg;
      log << MSG::ERROR << Exception.what() << endmsg;
      eventfailed = true;
    } catch ( ... ) {
      log << MSG::FATAL << ".executeEvent(): UNKNOWN Exception thrown by " << m_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( m_ts.algName, iAlgoPtr ).ignore();

    // schedule a sign-off of the Algorithm execution
    m_scheduler->m_actionsQueue.push(
        [schdlr = this->m_scheduler, ts = std::move( this->m_ts )]() { return schdlr->signoff( ts ); } );

    Gaudi::Hive::setCurrentContextEvt( -1 );

    return nullptr;
  }

operator()()

template<class T>

void AlgTask< T >::operator() ( )

inline

Definition at line 120 of file AlgTask.h.

{ execute(); };

Member Data Documentation

m_aess

template<class T>

IAlgExecStateSvc* AlgTask< T >::m_aess

private

Definition at line 125 of file AlgTask.h.

m_scheduler

template<class T>

AvalancheSchedulerSvc* AlgTask< T >::m_scheduler

private

Definition at line 124 of file AlgTask.h.

m_serviceLocator

template<class T>

SmartIF<ISvcLocator> AlgTask< T >::m_serviceLocator

private

Definition at line 126 of file AlgTask.h.

m_ts

template<class T>

AvalancheSchedulerSvc::TaskSpec AlgTask< T >::m_ts

private

Definition at line 120 of file AlgTask.h.

---

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

• GaudiHive/src/AlgTask.h