Gaudi Framework, version v20r2
	Generated: 18 Jul 2008

MinimalEventLoopMgr Class Reference

#include <MinimalEventLoopMgr.h>

Inheritance diagram for MinimalEventLoopMgr:

[legend]Collaboration diagram for MinimalEventLoopMgr:

[legend]List of all members.

---

Detailed Description

This is the default processing manager of the application manager.

This object handles the minimal requirements needed by the application manager. It also is capable of handling a bunch of algorithms and output streams. However, they list may as well be empty.

Author:

Markus Frank

Version:

1.0

Definition at line 28 of file MinimalEventLoopMgr.h.

Public Types
typedef std::list< IAlgorithm * >	ListAlg
	Creator friend class.
typedef std::list< std::string >	ListName
typedef std::vector< std::string >	VectorName
Public Member Functions
	MinimalEventLoopMgr (const std::string &nam, ISvcLocator *svcLoc)
	Standard Constructor.
virtual	~MinimalEventLoopMgr ()
	Standard Destructor.
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
	implementation of IInterface: queryInterface
virtual StatusCode	initialize ()
	implementation of IService::initalize
virtual StatusCode	start ()
	implementation of IService::start
virtual StatusCode	stop ()
	implementation of IService::stop
virtual StatusCode	finalize ()
	implementation of IService::finalize
virtual StatusCode	reinitialize ()
	implementation of IService::reinitialize
virtual StatusCode	restart ()
	implementation of IService::restart
virtual StatusCode	nextEvent (int maxevt)
	implementation of IEventProcessor::nextEvent
virtual StatusCode	executeEvent (void *par)
	implementation of IEventProcessor::executeEvent(void* par)
virtual StatusCode	executeRun (int maxevt)
	implementation of IEventProcessor::executeRun( )
virtual StatusCode	stopRun ()
	implementation of IEventProcessor::stopRun( )
void	topAlgHandler (Property &p)
	Top algorithm List handler.
StatusCode	decodeTopAlgs ()
	decodeTopAlgNameList & topAlgNameListHandler
void	outStreamHandler (Property &p)
	Output stream List handler.
StatusCode	decodeOutStreams ()
	decodeOutStreamNameList & outStreamNameListHandler
Protected Types
enum	State { OFFLINE, CONFIGURED, FINALIZED, INITIALIZED }
Protected Member Functions
template<class T>
T *	releaseInterface (T *iface)
	Helper to release interface pointer.
Protected Attributes
IAppMgrUI *	m_appMgrUI
	Reference to the IAppMgrUI interface of the application manager.
IIncidentSvc *	m_incidentSvc
	Reference to the indicent service.
ListAlg	m_topAlgList
	List of top level algorithms.
ListAlg	m_outStreamList
	List of output streams.
std::string	m_outStreamType
	Out Stream type.
StringArrayProperty	m_topAlgNames
	List of top level algorithms names.
StringArrayProperty	m_outStreamNames
	List of output stream names.
State	m_state
	State of the object.
bool	m_scheduledStop
	Scheduled stop of event processing.
IIncidentListener *	m_abortEventListener
	Instance of the incident listener waiting for AbortEvent.
bool	m_abortEvent
	Flag signalling that the event being processedhas to be aborted (skip all following top algs).
std::string	m_abortEventSource
	Source of the AbortEvent incident.

---

Member Typedef Documentation

typedef std::list<IAlgorithm*> MinimalEventLoopMgr::ListAlg

Creator friend class.

Definition at line 33 of file MinimalEventLoopMgr.h.

typedef std::list<std::string> MinimalEventLoopMgr::ListName

Definition at line 34 of file MinimalEventLoopMgr.h.

typedef std::vector<std::string> MinimalEventLoopMgr::VectorName

Definition at line 35 of file MinimalEventLoopMgr.h.

---

Member Enumeration Documentation

enum MinimalEventLoopMgr::State [protected]

Enumerator:

OFFLINE
CONFIGURED
FINALIZED
INITIALIZED

Definition at line 39 of file MinimalEventLoopMgr.h.

{ OFFLINE, CONFIGURED, FINALIZED, INITIALIZED };

---

Constructor & Destructor Documentation

MinimalEventLoopMgr::MinimalEventLoopMgr	(	const std::string &	nam,
		ISvcLocator *	svcLoc
	)

Standard Constructor.

Definition at line 81 of file MinimalEventLoopMgr.cpp.

References Service::declareProperty(), Property::declareUpdateHandler(), StatusCode::ignore(), IID_IAppMgrUI, m_abortEvent, m_abortEventListener, m_appMgrUI, m_incidentSvc, m_outStreamNames, m_outStreamType, m_scheduledStop, m_state, m_topAlgNames, OFFLINE, outStreamHandler(), IInterface::queryInterface(), and topAlgHandler().

: Service(nam, svcLoc)
{
  declareProperty("TopAlg",         m_topAlgNames );
  declareProperty("OutStream",      m_outStreamNames );
  declareProperty("OutStreamType",  m_outStreamType = "OutputStream");
  m_topAlgNames.declareUpdateHandler   ( &MinimalEventLoopMgr::topAlgHandler, this );
  m_outStreamNames.declareUpdateHandler( &MinimalEventLoopMgr::outStreamHandler, this );
  svcLoc->queryInterface(IID_IAppMgrUI, pp_cast<void>(&m_appMgrUI)).ignore();
  m_incidentSvc = 0;
  m_state = OFFLINE;
  m_scheduledStop = false;
  m_abortEventListener = 0;
  m_abortEvent = false;
}

MinimalEventLoopMgr::~MinimalEventLoopMgr

(

)

[virtual]

Standard Destructor.

Definition at line 100 of file MinimalEventLoopMgr.cpp.

References m_appMgrUI, m_incidentSvc, m_state, OFFLINE, and IInterface::release().

                                            {
  if( m_incidentSvc ) m_incidentSvc->release();
  if( m_appMgrUI ) m_appMgrUI->release();
  m_state = OFFLINE;
}

---

Member Function Documentation

template<class T>

T* MinimalEventLoopMgr::releaseInterface

(

T *

iface

)

[inline, protected]

Helper to release interface pointer.

Definition at line 75 of file MinimalEventLoopMgr.h.

Referenced by EventLoopMgr::finalize(), and finalize().

                                                    {
    if ( 0 != iface ) iface->release();
    return 0;
  }

StatusCode MinimalEventLoopMgr::queryInterface	(	const InterfaceID &	riid,
		void **	ppvInterface
	)			[virtual]

implementation of IInterface: queryInterface

Reimplemented from Service.

Definition at line 109 of file MinimalEventLoopMgr.cpp.

References Service::addRef(), IID_IAppMgrUI, IID_IEventProcessor, Service::queryInterface(), and StatusCode::SUCCESS.

                                                                                             {
  if ( riid == IID_IAppMgrUI )  {
    *ppvInterface = (IAppMgrUI*)this;
  }
  else if ( riid == IID_IEventProcessor )  {
    *ppvInterface = (IEventProcessor*)this;
  }
  else  {
    return Service::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}

StatusCode MinimalEventLoopMgr::initialize

(

)

[virtual]

implementation of IService::initalize

Reimplemented from Service.

Reimplemented in EventLoopMgr.

Definition at line 127 of file MinimalEventLoopMgr.cpp.

References IncidentType::AbortEvent, IIncidentSvc::addListener(), std::list< _Tp, _Alloc >::begin(), CONFIGURED, decodeOutStreams(), decodeTopAlgs(), std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::FAILURE, MSG::FATAL, IID_IProperty, Service::initialize(), INITIALIZED, StatusCode::isSuccess(), SmartIFBase< TYPE >::isValid(), m_abortEvent, m_abortEventListener, m_abortEventSource, m_appMgrUI, m_incidentSvc, m_outStreamList, m_outStreamNames, m_state, m_topAlgList, m_topAlgNames, Service::msgSvc(), Service::name(), ISvcLocator::service(), Service::serviceLocator(), Service::setProperty(), StatusCode::SUCCESS, and PropertyWithValue< TYPE >::value().

Referenced by EventLoopMgr::initialize().

                                              {

  MsgStream log(msgSvc(), name());

  if ( 0 == m_appMgrUI ) {
    return StatusCode::FAILURE;
  }

  StatusCode sc = Service::initialize();
  if ( !sc.isSuccess() )   {
    log << MSG::ERROR << "Failed to initialize Service Base class." << endreq;
    return StatusCode::FAILURE;
  }
  
  SmartIF<IProperty> prpMgr(IID_IProperty, serviceLocator());
  if ( ! prpMgr.isValid() )   {
    log << MSG::ERROR << "Error retrieving AppMgr interface IProperty." << endreq;
    return StatusCode::FAILURE;
  }
  else {
    if ( m_topAlgNames.value().size() == 0 )    {
      setProperty(prpMgr->getProperty("TopAlg")).ignore();
    }
    if ( m_outStreamNames.value().size() == 0 )   {
      setProperty(prpMgr->getProperty("OutStream")).ignore();
    }
  }

  // Get the references to the services that are needed by the ApplicationMgr itself
  sc = serviceLocator()->service("IncidentSvc", m_incidentSvc, true);
  if( !sc.isSuccess() )  {
    log << MSG::FATAL << "Error retrieving IncidentSvc." << endreq;
    return sc;
  }
  
  m_abortEventListener = new AbortEventListener(m_abortEvent,m_abortEventSource);
  m_incidentSvc->addListener(m_abortEventListener,IncidentType::AbortEvent);
  
  // The state is changed at this moment to allow decodeXXXX() to do something
  m_state = INITIALIZED;

  //--------------------------------------------------------------------------------------------
  // Create output streams. Do not initialize them yet.
  // The state is updated temporarily in order to enable the handler, which
  // is also triggered by a change to the "OutputStream" Property.
  //--------------------------------------------------------------------------------------------
  sc = decodeOutStreams();
  if ( !sc.isSuccess() )    {
    log << MSG::ERROR << "Failed to initialize Output streams." << endreq;
    m_state = CONFIGURED;
    return sc;
  }
  //--------------------------------------------------------------------------------------------
  // Create all needed Top Algorithms. Do not initialize them yet.
  // The state is updated temporarily in order to enable the handler, which
  // is also triggered by a change to the "TopAlg" Property.
  //--------------------------------------------------------------------------------------------
  sc = decodeTopAlgs();
  if ( !sc.isSuccess() )    {
    log << MSG::ERROR << "Failed to initialize Top Algorithms streams." << endreq;
    m_state = CONFIGURED;
    return sc;
  }

  ListAlg::iterator ita;
  // Initialize all the new TopAlgs. In fact Algorithms are protected against getting
  // initialized twice.
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysInitialize();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Algorithm: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  for (ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysInitialize();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Output Stream: " << (*ita)->name() << endreq;
      return sc;
    }
  }

  return StatusCode::SUCCESS;
}

StatusCode MinimalEventLoopMgr::start

(

)

[virtual]

implementation of IService::start

Reimplemented from Service.

Definition at line 214 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::isSuccess(), m_outStreamList, m_topAlgList, Service::msgSvc(), Service::name(), Service::start(), and StatusCode::SUCCESS.

                                         {

  StatusCode sc = Service::start();
  if ( ! sc.isSuccess() ) return sc;
  
  MsgStream log(msgSvc(), name());
  
  ListAlg::iterator ita;
  // Start all the new TopAlgs. In fact Algorithms are protected against getting
  // started twice.
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysStart();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Algorithm: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  for (ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysStart();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Output Stream: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  return StatusCode::SUCCESS;
}

StatusCode MinimalEventLoopMgr::stop

(

)

[virtual]

implementation of IService::stop

Reimplemented from Service.

Reimplemented in EventLoopMgr.

Definition at line 243 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::isSuccess(), m_outStreamList, m_topAlgList, Service::msgSvc(), Service::name(), Service::stop(), and StatusCode::SUCCESS.

Referenced by EventLoopMgr::stop().

                                        {

  StatusCode sc = StatusCode::SUCCESS;
  
  MsgStream log(msgSvc(), name());
  
  ListAlg::iterator ita;
  // Start all the new TopAlgs. In fact Algorithms are protected against getting
  // started twice.
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysStop();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Algorithm: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  for (ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysStop();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to initialize Output Stream: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  
  return Service::stop();
}

StatusCode MinimalEventLoopMgr::finalize

(

)

[virtual]

implementation of IService::finalize

Reimplemented from Service.

Reimplemented in EventLoopMgr.

Definition at line 326 of file MinimalEventLoopMgr.cpp.

References IncidentType::AbortEvent, std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), std::list< _Tp, _Alloc >::erase(), MSG::ERROR, Service::finalize(), FINALIZED, IID_IAlgManager, StatusCode::isSuccess(), m_abortEventListener, m_appMgrUI, m_incidentSvc, m_outStreamList, m_state, m_topAlgList, Service::msgSvc(), Service::name(), releaseInterface(), IIncidentSvc::removeListener(), Service::serviceLocator(), StatusCode::SUCCESS, and MSG::WARNING.

Referenced by EventLoopMgr::finalize().

                                            {
  MsgStream log( msgSvc(), name() );
  StatusCode sc = StatusCode::SUCCESS;
  // Call the finalize() method of all top algorithms
  ListAlg::iterator ita;
  for ( ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysFinalize();
    if( !sc.isSuccess() ) {
      log << MSG::WARNING << "Finalization of algorithm " << (*ita)->name() << " failed" << endreq;
    }
  }
  // Call the finalize() method of all Output streams
  for ( ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysFinalize();
    if( !sc.isSuccess() ) {
      log << MSG::WARNING << "Finalization of algorithm " << (*ita)->name() << " failed" << endreq;
    }
  }
  // release all top algorithms
  SmartIF<IAlgManager> algMan(IID_IAlgManager, serviceLocator());
  for ( ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    if (algMan->removeAlgorithm(*ita).isFailure()) {
      log << MSG::ERROR << "Problems removing Algorithm " << (*ita)->name()
          << endreq;
    }
    (*ita)->release();
  }
  m_topAlgList.erase(m_topAlgList.begin(), m_topAlgList.end() );

  // release all output streams
  for ( ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    (*ita)->release();
  }
  m_outStreamList.erase(m_outStreamList.begin(), m_outStreamList.end() );
  if ( sc.isSuccess() ) m_state = FINALIZED;
  
  m_incidentSvc->removeListener(m_abortEventListener,IncidentType::AbortEvent);
  m_abortEventListener = releaseInterface(m_abortEventListener);
  
  m_incidentSvc = releaseInterface(m_incidentSvc);
  m_appMgrUI = releaseInterface(m_appMgrUI);
  
  return Service::finalize();
}

StatusCode MinimalEventLoopMgr::reinitialize

(

)

[virtual]

implementation of IService::reinitialize

Reimplemented from Service.

Reimplemented in EventLoopMgr.

Definition at line 273 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::isSuccess(), m_outStreamList, m_topAlgList, Service::msgSvc(), Service::name(), and StatusCode::SUCCESS.

Referenced by EventLoopMgr::reinitialize().

                                             {
  MsgStream log( msgSvc(), name() );
  StatusCode sc = StatusCode::SUCCESS;
  ListAlg::iterator ita;

  // Renitialize all the TopAlgs.
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysReinitialize();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to reinitialize Algorithm: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  for (ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysReinitialize();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to reinitialize Output Stream: " << (*ita)->name() << endreq;
      return sc;
    }
  }

  return sc;
}

StatusCode MinimalEventLoopMgr::restart

(

)

[virtual]

implementation of IService::restart

Reimplemented from Service.

Definition at line 299 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::isSuccess(), m_outStreamList, m_topAlgList, Service::msgSvc(), Service::name(), and StatusCode::SUCCESS.

                                        {
  MsgStream log( msgSvc(), name() );
  StatusCode sc = StatusCode::SUCCESS;
  ListAlg::iterator ita;

  // Restart all the TopAlgs.
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysRestart();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to restart Algorithm: " << (*ita)->name() << endreq;
      return sc;
    }
  }
  for (ita = m_outStreamList.begin(); ita != m_outStreamList.end(); ita++ ) {
    sc = (*ita)->sysRestart();
    if( !sc.isSuccess() ) {
      log << MSG::ERROR << "Unable to restart Output Stream: " << (*ita)->name() << endreq;
      return sc;
    }
  }

  return sc;
}

StatusCode MinimalEventLoopMgr::nextEvent

(

int

maxevt

)

[virtual]

implementation of IEventProcessor::nextEvent

Implements IEventProcessor.

Reimplemented in EventLoopMgr.

Definition at line 374 of file MinimalEventLoopMgr.cpp.

References endreq(), MSG::ERROR, StatusCode::FAILURE, Service::msgSvc(), Service::name(), and System::typeinfoName().

Referenced by executeRun().

                                                            {
  MsgStream log(msgSvc(), name());
  log << MSG::ERROR << "This method cannot be called on an object of type " 
      << System::typeinfoName(typeid(*this)) << endreq;
  return StatusCode::FAILURE;
}

StatusCode MinimalEventLoopMgr::executeEvent

(

void *

par

)

[virtual]

implementation of IEventProcessor::executeEvent(void* par)

Implements IEventProcessor.

Reimplemented in EventLoopMgr.

Definition at line 425 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), MSG::DEBUG, std::list< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::FAILURE, MSG::FATAL, IID_IAlgManager, StatusCode::isSuccess(), SmartIFBase< TYPE >::isValid(), m_abortEvent, m_abortEventSource, m_outStreamList, m_topAlgList, Service::msgSvc(), Service::name(), Service::serviceLocator(), StatusCode::SUCCESS, GaudiException::tag(), MSG::WARNING, and std::exception::what().

Referenced by EventLoopMgr::executeEvent().

                                                               {
  bool eventfailed = false;
  
  // Call the resetExecuted() method of ALL "known" algorithms
  // (before we were reseting only the topalgs)
  SmartIF<IAlgManager> algMan(IID_IAlgManager, serviceLocator());
  if ( algMan.isValid() ) {
    const ListAlg& allAlgs = algMan->getAlgorithms() ;
    for( ListAlg::const_iterator ialg = allAlgs.begin() ; allAlgs.end() != ialg ; ++ialg ) { 
      if ( 0 != *ialg ) (*ialg)->resetExecuted();
    }
  } 

  // Call the execute() method of all top algorithms
  for (ListAlg::const_iterator ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    StatusCode sc(StatusCode::FAILURE);
    try {
      if (m_abortEvent){
        MsgStream log ( msgSvc() , name() );
        log << MSG::DEBUG << "AbortEvent incident fired by "
                          << m_abortEventSource << endreq;
        m_abortEvent = false;
        sc.ignore();
        break;
      }
      sc = (*ita)->sysExecute();
    } catch ( const GaudiException& Exception ) {
      MsgStream log ( msgSvc() , "MinimalEventLoopMgr.executeEvent()" );
      log << MSG::FATAL << " Exception with tag=" << Exception.tag()
          << " thrown by " << (*ita)->name() << endreq;
      log << MSG::ERROR << Exception << endreq;
    } catch ( const std::exception& Exception ) {
      MsgStream log ( msgSvc() , "MinimalEventLoopMgr.executeEvent()" );
      log << MSG::FATAL << " Standard std::exception thrown by " 
          << (*ita)->name() << endreq;
      log << MSG::ERROR << Exception.what()  << endreq;      
    } catch(...) {
      MsgStream log ( msgSvc() , "MinimalEventLoopMgr.executeEvent()" );
      log << MSG::FATAL << "UNKNOWN Exception thrown by " 
          << (*ita)->name() << endreq;
    }

    if( !sc.isSuccess() )  {
      MsgStream log( msgSvc(), name() );
      log << MSG::WARNING << "Execution of algorithm " << (*ita)->name() << " failed" << endreq;
      eventfailed = true;
    }
  }
  
  // Call the execute() method of all output streams
  for (ListAlg::const_iterator ito = m_outStreamList.begin(); ito != m_outStreamList.end(); ito++ ) {
    (*ito)->resetExecuted();
      StatusCode sc;
      sc = (*ito)->sysExecute();
    if( !sc.isSuccess() )  {
      MsgStream log( msgSvc(), name() );
      log << MSG::WARNING << "Execution of output stream " << (*ito)->name() << " failed" << endreq;
      eventfailed = true;
    }
  }

  // Check if there was an error processing current event
  if( eventfailed ){
    MsgStream log( msgSvc(), name() );
    log << MSG::ERROR << "Error processing event loop." << endreq;
    return StatusCode(StatusCode::FAILURE,true);
  }
  return StatusCode(StatusCode::SUCCESS,true);
}

StatusCode MinimalEventLoopMgr::executeRun

(

int

maxevt

)

[virtual]

implementation of IEventProcessor::executeRun( )

Implements IEventProcessor.

Reimplemented in EventLoopMgr.

Definition at line 384 of file MinimalEventLoopMgr.cpp.

References std::list< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::end(), endreq(), StatusCode::FAILURE, StatusCode::isSuccess(), m_topAlgList, Service::msgSvc(), Service::name(), nextEvent(), StatusCode::SUCCESS, and MSG::WARNING.

Referenced by EventLoopMgr::executeRun().

                                                       {
  StatusCode  sc;
  MsgStream log( msgSvc(), name() );
  ListAlg::iterator ita;
  bool eventfailed = false;

  // Call the beginRun() method of all top algorithms
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysBeginRun();
    if( !sc.isSuccess() ) {
      log << MSG::WARNING << "beginRun() of algorithm " << (*ita)->name() << " failed" << endreq;
      eventfailed = true;
    }
  }

  // Call now the nextEvent(...)
  sc = nextEvent(maxevt);
  if( !sc.isSuccess() ) {
    eventfailed = true;
  }

  // Call the endRun() method of all top algorithms
  for (ita = m_topAlgList.begin(); ita != m_topAlgList.end(); ita++ ) {
    sc = (*ita)->sysEndRun();
    if( !sc.isSuccess() ) {
      log << MSG::WARNING << "endRun() of algorithm " << (*ita)->name() << " failed" << endreq;
      eventfailed = true;
    }
  }

  if( eventfailed ){
    return StatusCode::FAILURE;
  }
  else {
    return StatusCode::SUCCESS;
  }
}

StatusCode MinimalEventLoopMgr::stopRun

(

)

[virtual]

implementation of IEventProcessor::stopRun( )

Implements IEventProcessor.

Definition at line 497 of file MinimalEventLoopMgr.cpp.

References m_scheduledStop, and StatusCode::SUCCESS.

                                        {
  m_scheduledStop = true;
  return StatusCode::SUCCESS;
}

void MinimalEventLoopMgr::topAlgHandler

(

Property &

p

)

Top algorithm List handler.

Definition at line 505 of file MinimalEventLoopMgr.cpp.

References decodeTopAlgs(), and StatusCode::FAILURE.

Referenced by MinimalEventLoopMgr().

                                                                  {
  if ( !(decodeTopAlgs( )).isSuccess() ) {
    throw GaudiException("Failed to initialize Top Algorithms streams.",
                         "MinimalEventLoopMgr::topAlgHandler", 
                         StatusCode::FAILURE);
  }
}

StatusCode MinimalEventLoopMgr::decodeTopAlgs

(

)

decodeTopAlgNameList & topAlgNameListHandler

Definition at line 516 of file MinimalEventLoopMgr.cpp.

References IInterface::addRef(), std::vector< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::clear(), CONFIGURED, MSG::DEBUG, std::vector< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::FAILURE, getGaudiThreadIDfromName(), IID_IAlgManager, INITIALIZED, StatusCode::isSuccess(), SmartIFBase< TYPE >::isValid(), m_state, m_topAlgList, m_topAlgNames, Service::msgSvc(), Service::name(), std::list< _Tp, _Alloc >::push_back(), Service::serviceLocator(), StatusCode::SUCCESS, and PropertyWithValue< TYPE >::value().

Referenced by initialize(), and topAlgHandler().

                                                 {
  StatusCode sc = StatusCode::SUCCESS;
  if ( CONFIGURED == m_state || INITIALIZED == m_state ) {
    SmartIF<IAlgManager> algMan(IID_IAlgManager, serviceLocator());
    MsgStream log(msgSvc(), name());
    if ( algMan.isValid() )   {
      // Reset the existing Top Algorithm List
      m_topAlgList.clear( );
      const std::vector<std::string>& algNames = m_topAlgNames.value( );
      for (VectorName::const_iterator it = algNames.begin(); it != algNames.end(); it++) {
        ListItem item(*it);
        // Got the type and name. Now creating the algorithm, avoiding duplicate creation.
        IAlgorithm* ialg;
        std::string item_name = item.name() + getGaudiThreadIDfromName(name()) ;
        sc = algMan->getAlgorithm( item_name, ialg );
        if ( sc.isSuccess( ) ) {
          log << MSG::DEBUG << "Top Algorithm " << item_name << " already exists" << endreq;
          ialg->addRef();  // increment reference count
        } 
        else {
          log << MSG::DEBUG << "Creating Top Algorithm " << item.type() << " with name " << item_name << endreq;
          sc = algMan->createAlgorithm( item.type(), item_name, ialg );
          if( !sc.isSuccess() ) {
            log << MSG::ERROR << "Unable to create Top Algorithm " << item.type() << " with name " << item_name << endreq;
            return sc;
          }
        }
        m_topAlgList.push_back(ialg);
      }
      return sc;
    }
    sc = StatusCode::FAILURE;
  }
  return sc;
}

void MinimalEventLoopMgr::outStreamHandler

(

Property &

p

)

Output stream List handler.

Definition at line 555 of file MinimalEventLoopMgr.cpp.

References decodeOutStreams(), and StatusCode::FAILURE.

Referenced by MinimalEventLoopMgr().

                                                                         {
  if ( !(decodeOutStreams( )).isSuccess() ) {
    throw GaudiException("Failed to initialize output streams.",
                         "MinimalEventLoopMgr::outStreamHandler", 
                         StatusCode::FAILURE);
  }
}

StatusCode MinimalEventLoopMgr::decodeOutStreams

(

)

decodeOutStreamNameList & outStreamNameListHandler

Definition at line 566 of file MinimalEventLoopMgr.cpp.

References std::vector< _Tp, _Alloc >::begin(), std::list< _Tp, _Alloc >::clear(), CONFIGURED, MSG::DEBUG, std::vector< _Tp, _Alloc >::end(), endreq(), MSG::ERROR, StatusCode::FAILURE, IID_IAlgManager, INITIALIZED, StatusCode::isSuccess(), SmartIFBase< TYPE >::isValid(), m_outStreamList, m_outStreamNames, m_outStreamType, m_state, Service::msgSvc(), Service::name(), std::list< _Tp, _Alloc >::push_back(), Service::serviceLocator(), StatusCode::SUCCESS, and PropertyWithValue< TYPE >::value().

Referenced by initialize(), and outStreamHandler().

                                                     {
  StatusCode sc = StatusCode::SUCCESS;
  if ( CONFIGURED == m_state || INITIALIZED == m_state ) {
    MsgStream log(msgSvc(), name());
    SmartIF<IAlgManager> algMan(IID_IAlgManager, serviceLocator());
    if ( algMan.isValid() )   {
      // Reset the existing Top Algorithm List
      m_outStreamList.clear();
      const std::vector<std::string>& algNames = m_outStreamNames.value( );
      for (VectorName::const_iterator it = algNames.begin(); it != algNames.end(); it++) {
        ListItem item(*it, m_outStreamType);
        IAlgorithm* ios;
        log << MSG::DEBUG << "Creating " << m_outStreamType <<  (*it) << endreq;
        sc = algMan->getAlgorithm( item.name(), ios );
        if ( sc.isSuccess( ) ) {
          log << MSG::DEBUG << "Output Stream " << item.name() << " already exists" << endreq;
        } 
        else {
          log << MSG::DEBUG << "Creating Output Stream " << (*it) << endreq;
          sc = algMan->createAlgorithm( item.type(), item.name(), ios );
          if( !sc.isSuccess() ) {
            log << MSG::ERROR << "Unable to create Output Stream " << (*it) << endreq;
            return sc;
          }
        }
        m_outStreamList.push_back( ios );
      }
     return sc;
    }
    sc = StatusCode::FAILURE;
  }
  return sc;
}

---

Member Data Documentation

IAppMgrUI* MinimalEventLoopMgr::m_appMgrUI [protected]

Reference to the IAppMgrUI interface of the application manager.

Definition at line 41 of file MinimalEventLoopMgr.h.

Referenced by finalize(), initialize(), MinimalEventLoopMgr(), and ~MinimalEventLoopMgr().

IIncidentSvc* MinimalEventLoopMgr::m_incidentSvc [protected]

Reference to the indicent service.

Definition at line 43 of file MinimalEventLoopMgr.h.

Referenced by EventLoopMgr::executeEvent(), finalize(), initialize(), MinimalEventLoopMgr(), EventLoopMgr::nextEvent(), EventLoopMgr::stop(), and ~MinimalEventLoopMgr().

ListAlg MinimalEventLoopMgr::m_topAlgList [protected]

List of top level algorithms.

Definition at line 45 of file MinimalEventLoopMgr.h.

Referenced by decodeTopAlgs(), executeEvent(), executeRun(), finalize(), initialize(), reinitialize(), restart(), start(), and stop().

ListAlg MinimalEventLoopMgr::m_outStreamList [protected]

List of output streams.

Definition at line 47 of file MinimalEventLoopMgr.h.

Referenced by decodeOutStreams(), executeEvent(), finalize(), initialize(), reinitialize(), restart(), start(), and stop().

std::string MinimalEventLoopMgr::m_outStreamType [protected]

Out Stream type.

Definition at line 49 of file MinimalEventLoopMgr.h.

Referenced by decodeOutStreams(), and MinimalEventLoopMgr().

StringArrayProperty MinimalEventLoopMgr::m_topAlgNames [protected]

List of top level algorithms names.

Definition at line 51 of file MinimalEventLoopMgr.h.

Referenced by decodeTopAlgs(), initialize(), and MinimalEventLoopMgr().

StringArrayProperty MinimalEventLoopMgr::m_outStreamNames [protected]

List of output stream names.

Definition at line 53 of file MinimalEventLoopMgr.h.

Referenced by decodeOutStreams(), initialize(), and MinimalEventLoopMgr().

State MinimalEventLoopMgr::m_state [protected]

State of the object.

Reimplemented from Service.

Definition at line 55 of file MinimalEventLoopMgr.h.

Referenced by decodeOutStreams(), decodeTopAlgs(), finalize(), initialize(), MinimalEventLoopMgr(), and ~MinimalEventLoopMgr().

bool MinimalEventLoopMgr::m_scheduledStop [protected]

Scheduled stop of event processing.

Definition at line 57 of file MinimalEventLoopMgr.h.

Referenced by EventLoopMgr::executeEvent(), MinimalEventLoopMgr(), EventLoopMgr::nextEvent(), and stopRun().

IIncidentListener* MinimalEventLoopMgr::m_abortEventListener [protected]

Instance of the incident listener waiting for AbortEvent.

Definition at line 59 of file MinimalEventLoopMgr.h.

Referenced by finalize(), initialize(), and MinimalEventLoopMgr().

bool MinimalEventLoopMgr::m_abortEvent [protected]

Flag signalling that the event being processedhas to be aborted (skip all following top algs).

Definition at line 62 of file MinimalEventLoopMgr.h.

Referenced by executeEvent(), initialize(), and MinimalEventLoopMgr().

std::string MinimalEventLoopMgr::m_abortEventSource [protected]

Source of the AbortEvent incident.

Definition at line 64 of file MinimalEventLoopMgr.h.

Referenced by executeEvent(), and initialize().

---

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

• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r2/GaudiKernel/v25r2/GaudiKernel/MinimalEventLoopMgr.h
• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r2/GaudiKernel/v25r2/src/Lib/MinimalEventLoopMgr.cpp

---