IOBoundAlgTask Class Reference

Wrapper around I/O-bound Gaudi-algorithms. More...

#include <GaudiHive/src/IOBoundAlgTask.h>

Inheritance diagram for IOBoundAlgTask:

Collaboration diagram for IOBoundAlgTask:

Public Member Functions
	IOBoundAlgTask (IAlgorithm *algorithm, unsigned int algoIndex, EventContext *ctx, ISvcLocator *svcLocator, ForwardSchedulerSvc *schedSvc, IAlgExecStateSvc *aem)
	~IOBoundAlgTask () override
virtual StatusCode	execute () override
Public Member Functions inherited from IAlgTask
virtual	~IAlgTask ()=default

Private Attributes
SmartIF< IAlgorithm >	m_algorithm
EventContext *	m_evtCtx
const unsigned int	m_algoIndex
SmartIF< ForwardSchedulerSvc >	m_schedSvc
IAlgExecStateSvc *	m_aess
SmartIF< ISvcLocator >	m_serviceLocator

Detailed Description

Wrapper around I/O-bound Gaudi-algorithms.

It may also cover the accelerator-targeted algorithms. It must be used to prepare algorithms before sending them to I/O-bound scheduler.

Author

Illya Shapoval

Version

1.0

Definition at line 23 of file IOBoundAlgTask.h.

Constructor & Destructor Documentation

IOBoundAlgTask::IOBoundAlgTask ( IAlgorithm *  algorithm, unsigned int  algoIndex, EventContext *  ctx, ISvcLocator *  svcLocator, ForwardSchedulerSvc *  schedSvc, IAlgExecStateSvc *  aem  )

inline

Definition at line 25 of file IOBoundAlgTask.h.

                                       :
    m_algorithm(algorithm),
    m_evtCtx(ctx),
    m_algoIndex(algoIndex),
    m_schedSvc(schedSvc),
    m_aess(aem),
    m_serviceLocator(svcLocator) {}

IOBoundAlgTask::~IOBoundAlgTask ( )

inlineoverride

Definition at line 38 of file IOBoundAlgTask.h.

{}

Member Function Documentation

StatusCode IOBoundAlgTask::execute ( )

overridevirtual

Implements IAlgTask.

Definition at line 13 of file IOBoundAlgTask.cpp.

                                   {

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

  bool eventfailed=false;
  Gaudi::Hive::setCurrentContext( m_evtCtx );

  m_schedSvc->addAlg(this_algo, m_evtCtx, 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, "AccelAlgoExecutionTask");

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

  // 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
  m_aess->algExecState(ialg,*m_evtCtx).setExecuted(true);
  m_aess->algExecState(ialg,*m_evtCtx).setExecStatus(sc);
  m_aess->updateEventStatus(eventfailed,*m_evtCtx);


  // Push in the scheduler queue an action to be performed
  auto action_promote2Executed = std::bind(&ForwardSchedulerSvc::promoteToAsyncExecuted,
                                           m_schedSvc,
                                           m_algoIndex,
                                           m_evtCtx->slot(),
                                           m_algorithm,
                                           m_evtCtx);

  // TODO Expose a method to push actions in IScheduler?
  m_schedSvc->m_actionsQueue.push(action_promote2Executed);

  m_schedSvc->delAlg(this_algo);

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

  return sc;
}

Member Data Documentation

IAlgExecStateSvc* IOBoundAlgTask::m_aess

private

Definition at line 48 of file IOBoundAlgTask.h.

const unsigned int IOBoundAlgTask::m_algoIndex

private

Definition at line 45 of file IOBoundAlgTask.h.

SmartIF<IAlgorithm> IOBoundAlgTask::m_algorithm

private

Definition at line 43 of file IOBoundAlgTask.h.

EventContext* IOBoundAlgTask::m_evtCtx

private

Definition at line 44 of file IOBoundAlgTask.h.

SmartIF<ForwardSchedulerSvc> IOBoundAlgTask::m_schedSvc

private

Definition at line 47 of file IOBoundAlgTask.h.

SmartIF<ISvcLocator> IOBoundAlgTask::m_serviceLocator

private

Definition at line 49 of file IOBoundAlgTask.h.

---

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

• GaudiHive/src/IOBoundAlgTask.h
• GaudiHive/src/IOBoundAlgTask.cpp