AlgoExecutionTask Class Reference

#include <src/AlgoExecutionTask.h>

Inheritance diagram for AlgoExecutionTask:

Collaboration diagram for AlgoExecutionTask:

Public Member Functions
	AlgoExecutionTask (IAlgorithm *algorithm, unsigned int algoIndex, ISvcLocator *svcLocator, ForwardSchedulerSvc *schedSvc)
virtual tbb::task *	execute ()

Private Attributes
SmartIF< IAlgorithm >	m_algorithm
const unsigned int	m_algoIndex
SmartIF< ForwardSchedulerSvc >	m_schedSvc
SmartIF< ISvcLocator >	m_serviceLocator

Detailed Description

Definition at line 14 of file AlgoExecutionTask.h.

Constructor & Destructor Documentation

AlgoExecutionTask::AlgoExecutionTask ( IAlgorithm *  algorithm, unsigned int  algoIndex, ISvcLocator *  svcLocator, ForwardSchedulerSvc *  schedSvc  )

inline

Definition at line 16 of file AlgoExecutionTask.h.

                                                  :
    m_algorithm(algorithm),
    m_algoIndex(algoIndex),
    m_schedSvc(schedSvc),
    m_serviceLocator(svcLocator){};

Member Function Documentation

tbb::task * AlgoExecutionTask::execute ( )

virtual

Definition at line 14 of file AlgoExecutionTask.cpp.

                                    {

  Algorithm* this_algo = dynamic_cast<Algorithm*>(m_algorithm.get());  
   if (!this_algo){
     throw GaudiException ("Cast to Algorithm failed!","AlgoExecutionTask",StatusCode::FAILURE);
   }

  bool eventfailed=false;
  EventContext* eventContext = this_algo->getContext();
  //  eventContext->m_thread_id = pthread_self();
  Gaudi::Hive::setCurrentContext( eventContext );

  m_schedSvc->addAlg(this_algo, eventContext, pthread_self());

  // Get the IProperty interface of the ApplicationMgr to pass it to RetCodeGuard
  const SmartIF<IProperty> appmgr(m_serviceLocator);
  
  SmartIF<IMessageSvc> messageSvc (m_serviceLocator);
  MsgStream log(messageSvc, "AlgoExecutionTask");

  StatusCode sc(StatusCode::FAILURE);
  try {
    RetCodeGuard rcg(appmgr, Gaudi::ReturnCode::UnhandledException);
    sc = m_algorithm->sysExecute();
    if (UNLIKELY(!sc.isSuccess()))  {
      log << MSG::WARNING << "Execution of algorithm " << m_algorithm->name() << " 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_algorithm->name() << endmsg;
    log << MSG::ERROR << Exception << endmsg;
  } catch ( const std::exception& Exception ) {
    log << MSG::FATAL << ".executeEvent(): Standard std::exception thrown by "
            << m_algorithm->name() << endmsg;
    log << MSG::ERROR <<  Exception.what()  << endmsg;
  } catch(...) {
    log << MSG::FATAL << ".executeEvent(): UNKNOWN Exception thrown by "
            << m_algorithm->name() << endmsg;
  }  

  // Commit all DataHandles
  this_algo->commitHandles();

  // DP it is important to propagate the failure of an event.
  // We need to stop execution when this happens so that execute run can 
  // then receive the FAILURE
  eventContext->setFail(eventfailed);
  
  // Push in the scheduler queue an action to be performed 
  auto action_promote2Executed = std::bind(&ForwardSchedulerSvc::promoteToExecuted,
                                           m_schedSvc, 
                                           m_algoIndex, 
                                           eventContext->slot(),
                                           m_algorithm);

  m_schedSvc->m_actionsQueue.push(action_promote2Executed);    

  m_schedSvc->delAlg(this_algo);

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

  return nullptr;
}

Member Data Documentation

const unsigned int AlgoExecutionTask::m_algoIndex

private

Definition at line 27 of file AlgoExecutionTask.h.

SmartIF<IAlgorithm> AlgoExecutionTask::m_algorithm

private

Definition at line 26 of file AlgoExecutionTask.h.

SmartIF<ForwardSchedulerSvc> AlgoExecutionTask::m_schedSvc

private

Definition at line 29 of file AlgoExecutionTask.h.

SmartIF<ISvcLocator> AlgoExecutionTask::m_serviceLocator

private

Definition at line 30 of file AlgoExecutionTask.h.

---

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

• GaudiHive/src/AlgoExecutionTask.h
• GaudiHive/src/AlgoExecutionTask.cpp