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, EventContext *ctx, ISvcLocator *svcLocator, 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
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 21 of file IOBoundAlgTask.h.

Constructor & Destructor Documentation

IOBoundAlgTask::IOBoundAlgTask ( IAlgorithm *  algorithm, EventContext *  ctx, ISvcLocator *  svcLocator, IAlgExecStateSvc *  aem  )

inline

Definition at line 24 of file IOBoundAlgTask.h.

      : m_algorithm( algorithm ), m_evtCtx( ctx ), m_aess( aem ), m_serviceLocator( svcLocator )
  {
  }

IOBoundAlgTask::~IOBoundAlgTask ( )

inlineoverride

Definition at line 29 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 );

  // TODO reproduce the commented out functionality in a different service
  // 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" );

  // select the appropriate store
  this_algo->whiteboard()->selectStore( m_evtCtx->valid() ? m_evtCtx->slot() : 0 ).ignore();

  StatusCode sc( StatusCode::FAILURE );
  try {
    RetCodeGuard rcg( appmgr, Gaudi::ReturnCode::UnhandledException );
    log << MSG::DEBUG << "Starting execution of algorithm " << m_algorithm->name() << endmsg;
    m_aess->algExecState( ialg, *m_evtCtx ).setState( AlgExecState::State::Executing );
    sc = m_algorithm->sysExecute( *m_evtCtx );
    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 ).setState( AlgExecState::State::Done, sc );
  m_aess->updateEventStatus( eventfailed, *m_evtCtx );

  // TODO reproduce the commented out functionality in a different service
  // m_schedSvc->delAlg(this_algo);

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

  return sc;
}

Member Data Documentation

IAlgExecStateSvc* IOBoundAlgTask::m_aess

private

Definition at line 36 of file IOBoundAlgTask.h.

SmartIF<IAlgorithm> IOBoundAlgTask::m_algorithm

private

Definition at line 34 of file IOBoundAlgTask.h.

EventContext* IOBoundAlgTask::m_evtCtx

private

Definition at line 35 of file IOBoundAlgTask.h.

SmartIF<ISvcLocator> IOBoundAlgTask::m_serviceLocator

private

Definition at line 37 of file IOBoundAlgTask.h.

---

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

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