MinimalEventLoopMgr Class Reference

This is the default processing manager of the application manager. More...

#include </builds/gaudi/Gaudi/GaudiKernel/include/GaudiKernel/MinimalEventLoopMgr.h>

Inheritance diagram for MinimalEventLoopMgr:

Collaboration diagram for MinimalEventLoopMgr:

Classes
class	AbortEventListener

Public Types
typedef std::vector< SmartIF< IAlgorithm > >	ListAlg
Public Types inherited from extends< Service, IEventProcessor >
using	base_class
	Typedef to this class.
using	extend_interfaces_base
	Typedef to the base of this class.
Public Types inherited from Service
using	Factory = Gaudi::PluginService::Factory<IService*( const std::string&, ISvcLocator* )>
Public Types inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
using	PropertyHolderImpl
	Typedef used to refer to this class from derived classes, as in.
Public Types inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
using	base_class
Public Types inherited from extend_interfaces< Interfaces... >
using	ext_iids
	take union of the ext_iids of all Interfaces...

Public Member Functions
	MinimalEventLoopMgr (const std::string &nam, ISvcLocator *svcLoc)
	Standard Constructor.
	MinimalEventLoopMgr (const MinimalEventLoopMgr &)=delete
	No copy allowed.
MinimalEventLoopMgr &	operator= (const MinimalEventLoopMgr &)=delete
	No copy allowed.
StatusCode	initialize () override
	implementation of IService::initialize
StatusCode	start () override
	implementation of IService::start
StatusCode	stop () override
	implementation of IService::stop
StatusCode	finalize () override
	implementation of IService::finalize
StatusCode	reinitialize () override
	implementation of IService::reinitialize
StatusCode	restart () override
	implementation of IService::restart
EventContext	createEventContext () override
	implementation of IEventProcessor::createEventContext()
StatusCode	nextEvent (int maxevt) override
	implementation of IEventProcessor::nextEvent
StatusCode	executeEvent (EventContext &&ctx) override
	implementation of IEventProcessor::executeEvent(EventContext&&)
StatusCode	executeRun (int maxevt) override
	implementation of IEventProcessor::executeRun( )
StatusCode	stopRun () override
	implementation of IEventProcessor::stopRun( )
void	topAlgHandler (Gaudi::Details::PropertyBase &p)
	Top algorithm List handler.
StatusCode	decodeTopAlgs ()
	decodeTopAlgNameList & topAlgNameListHandler
void	outStreamHandler (Gaudi::Details::PropertyBase &p)
	Output stream List handler.
StatusCode	decodeOutStreams ()
	decodeOutStreamNameList & outStreamNameListHandler
Public Member Functions inherited from extends< Service, IEventProcessor >
void const *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast.
StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface.
std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames.
Public Member Functions inherited from Service
const std::string &	name () const override
	Retrieve name of the service.
StatusCode	configure () override
StatusCode	initialize () override
StatusCode	start () override
StatusCode	stop () override
StatusCode	finalize () override
StatusCode	terminate () override
Gaudi::StateMachine::State	FSMState () const override
Gaudi::StateMachine::State	targetFSMState () const override
StatusCode	reinitialize () override
StatusCode	restart () override
StatusCode	sysInitialize () override
	Initialize Service.
StatusCode	sysStart () override
	Initialize Service.
StatusCode	sysStop () override
	Initialize Service.
StatusCode	sysFinalize () override
	Finalize Service.
StatusCode	sysReinitialize () override
	Re-initialize the Service.
StatusCode	sysRestart () override
	Re-initialize the Service.
	Service (std::string name, ISvcLocator *svcloc)
	Standard Constructor.
SmartIF< ISvcLocator > &	serviceLocator () const override
	Retrieve pointer to service locator.
template<typename IFace = IService>
SmartIF< IFace >	service (const std::string &name, bool createIf=true) const
template<class T>
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, ToolHandle< T > &hndl, const std::string &doc="none")
template<class T>
StatusCode	declareTool (ToolHandle< T > &handle, bool createIf=true)
template<class T>
StatusCode	declareTool (ToolHandle< T > &handle, const std::string &toolTypeAndName, bool createIf=true)
	Declare used tool.
template<class T>
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, ToolHandleArray< T > &hndlArr, const std::string &doc="none")
template<class T>
void	addToolsArray (ToolHandleArray< T > &hndlArr)
const std::vector< IAlgTool * > &	tools () const
SmartIF< IAuditorSvc > &	auditorSvc () const
	The standard auditor service.May not be invoked before sysInitialize() has been invoked.
Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
StatusCode	setProperty (const Gaudi::Details::PropertyBase &p)
	Set the property from a property.
StatusCode	setProperty (const std::string &name, const char *v)
	Special case for string literals.
StatusCode	setProperty (const std::string &name, const std::string &v)
	Special case for std::string.
StatusCode	setProperty (const std::string &name, const TYPE &value)
	set the property form the value
	PropertyHolder ()=default
Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Details::PropertyBase &prop)
	Declare a property.
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, TYPE &value, const std::string &doc="none")
	Helper to wrap a regular data member and use it as a regular property.
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, Gaudi::Property< TYPE, VERIFIER, HANDLERS > &prop, const std::string &doc="none")
	Declare a PropertyBase instance setting name and documentation.
Gaudi::Details::PropertyBase *	declareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
	Declare a remote property.
StatusCode	setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p) override
	set the property from another property with a different name
StatusCode	setProperty (const std::string &s) override
	set the property from the formatted string
StatusCode	setProperty (const Gaudi::Details::PropertyBase &p)
	Set the property from a property.
StatusCode	setProperty (const std::string &name, const char *v)
	Special case for string literals.
StatusCode	setProperty (const std::string &name, const std::string &v)
	Special case for std::string.
StatusCode	setProperty (const std::string &name, const TYPE &value)
	set the property form the value
StatusCode	setPropertyRepr (const std::string &n, const std::string &r) override
	set the property from name and value string representation
StatusCode	getProperty (Gaudi::Details::PropertyBase *p) const override
	get the property
const Gaudi::Details::PropertyBase &	getProperty (std::string_view name) const override
	get the property by name
StatusCode	getProperty (std::string_view n, std::string &v) const override
	convert the property to the string
const std::vector< Gaudi::Details::PropertyBase * > &	getProperties () const override
	get all properties
bool	hasProperty (std::string_view name) const override
	Return true if we have a property with the given name.
Gaudi::Details::PropertyBase *	property (std::string_view name) const
	\fixme property and bindPropertiesTo should be protected
void	bindPropertiesTo (Gaudi::Interfaces::IOptionsSvc &optsSvc)
	PropertyHolder (const PropertyHolder &)=delete
PropertyHolder &	operator= (const PropertyHolder &)=delete
Public Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	msgLevel () const
	get the cached level (originally extracted from the embedded MsgStream)
bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream
Public Member Functions inherited from CommonMessagingBase
virtual	~CommonMessagingBase ()=default
	Virtual destructor.
const SmartIF< IMessageSvc > &	msgSvc () const
	The standard message service.
MsgStream &	msgStream () const
	Return an uninitialized MsgStream.
MsgStream &	msgStream (const MSG::Level level) const
	Predefined configurable message stream for the efficient printouts.
MsgStream &	always () const
	shortcut for the method msgStream(MSG::ALWAYS)
MsgStream &	fatal () const
	shortcut for the method msgStream(MSG::FATAL)
MsgStream &	err () const
	shortcut for the method msgStream(MSG::ERROR)
MsgStream &	error () const
	shortcut for the method msgStream(MSG::ERROR)
MsgStream &	warning () const
	shortcut for the method msgStream(MSG::WARNING)
MsgStream &	info () const
	shortcut for the method msgStream(MSG::INFO)
MsgStream &	debug () const
	shortcut for the method msgStream(MSG::DEBUG)
MsgStream &	verbose () const
	shortcut for the method msgStream(MSG::VERBOSE)
MsgStream &	msg () const
	shortcut for the method msgStream(MSG::INFO)

Protected Types
enum	State { OFFLINE , CONFIGURED , FINALIZED , INITIALIZED }

Protected Attributes
Gaudi::Property< std::vector< std::string > >	m_topAlgNames
Gaudi::Property< std::vector< std::string > >	m_outStreamNames
Gaudi::Property< bool >	m_printCFExp
SmartIF< IAppMgrUI >	m_appMgrUI
	Reference to the IAppMgrUI interface of the application manager.
SmartIF< IIncidentSvc >	m_incidentSvc
	Reference to the incident service.
SmartIF< IAlgExecStateSvc >	m_aess
	List of top level algorithms.
ListAlg	m_topAlgList
ListAlg	m_outStreamList
	List of output streams.
State	m_state = OFFLINE
	State of the object.
bool	m_scheduledStop = false
	Scheduled stop of event processing.
AbortEventListener	m_abortEventListener
	Instance of the incident listener waiting for AbortEvent.
SmartIF< IHiveWhiteBoard >	m_WB
	< Event data service (whiteboard)
size_t	m_nevt { 0 }
Protected Attributes inherited from Service
Gaudi::StateMachine::State	m_state = Gaudi::StateMachine::OFFLINE
	Service state.
Gaudi::StateMachine::State	m_targetState = Gaudi::StateMachine::OFFLINE
	Service state.
Gaudi::Property< int >	m_outputLevel { this, "OutputLevel", MSG::NIL, "output level" }
	flag indicating whether ToolHandle tools have been added to m_tools
Gaudi::Property< bool >	m_auditorInitialize { this, "AuditInitialize", false, "trigger auditor on initialize()" }
Gaudi::Property< bool >	m_auditorStart { this, "AuditStart", false, "trigger auditor on start()" }
Gaudi::Property< bool >	m_auditorStop { this, "AuditStop", false, "trigger auditor on stop()" }
Gaudi::Property< bool >	m_auditorFinalize { this, "AuditFinalize", false, "trigger auditor on finalize()" }
Gaudi::Property< bool >	m_auditorReinitialize { this, "AuditReinitialize", false, "trigger auditor on reinitialize()" }
Gaudi::Property< bool >	m_auditorRestart { this, "AuditRestart", false, "trigger auditor on restart()" }
Gaudi::Property< bool >	m_autoRetrieveTools
Gaudi::Property< bool >	m_checkToolDeps
SmartIF< IAuditorSvc >	m_pAuditorSvc
	Auditor Service.

Additional Inherited Members
Protected Member Functions inherited from Service
std::vector< IAlgTool * > &	tools ()
	~Service () override
int	outputLevel () const
	get the Service's output level
Protected Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	setUpMessaging () const
	Set up local caches.
MSG::Level	resetMessaging ()
	Reinitialize internal states.
void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream.

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, the list may as well be empty.

Author

Markus Frank

Version

1.0

Definition at line 33 of file MinimalEventLoopMgr.h.

Member Typedef Documentation

ListAlg

typedef std::vector<SmartIF<IAlgorithm> > MinimalEventLoopMgr::ListAlg

Definition at line 54 of file MinimalEventLoopMgr.h.

Member Enumeration Documentation

State

enum MinimalEventLoopMgr::State

protected

Enumerator
OFFLINE
CONFIGURED
FINALIZED
INITIALIZED

Definition at line 66 of file MinimalEventLoopMgr.h.

{ OFFLINE, CONFIGURED, FINALIZED, INITIALIZED };

Constructor & Destructor Documentation

MinimalEventLoopMgr() [1/2]

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

Standard Constructor.

Definition at line 38 of file MinimalEventLoopMgr.cpp.

    : base_class( nam, svcLoc ), m_appMgrUI( svcLoc ) {}

MinimalEventLoopMgr() [2/2]

MinimalEventLoopMgr::MinimalEventLoopMgr ( const MinimalEventLoopMgr & )

delete

No copy allowed.

Member Function Documentation

createEventContext()

EventContext MinimalEventLoopMgr::createEventContext ( )

override

implementation of IEventProcessor::createEventContext()

Definition at line 292 of file MinimalEventLoopMgr.cpp.

{ return EventContext{ m_nevt++, 0 }; }

decodeOutStreams()

StatusCode MinimalEventLoopMgr::decodeOutStreams

(

)

decodeOutStreamNameList & outStreamNameListHandler

Definition at line 470 of file MinimalEventLoopMgr.cpp.

                                                 {
  StatusCode sc = StatusCode::SUCCESS;
  if ( CONFIGURED == m_state || INITIALIZED == m_state ) {
    auto algMan = serviceLocator()->as<IAlgManager>();
    if ( algMan ) {
      // Reset the existing Top Algorithm List
      m_outStreamList.clear();
      for ( const auto& it : m_outStreamNames.value() ) {
        Gaudi::Utils::TypeNameString item( it );
        const bool                   CREATE = false;
        SmartIF<IAlgorithm>          os     = algMan->algorithm( item, CREATE );
        if ( os ) {
          DEBMSG << "Output Stream " << item.name() << " already exists" << endmsg;
        } else {
          DEBMSG << "Creating Output Stream " << it << endmsg;
          IAlgorithm* ios = nullptr;
          StatusCode  sc1 = algMan->createAlgorithm( item.type(), item.name(), ios );
          if ( !sc1.isSuccess() ) {
            error() << "Unable to create Output Stream " << it << endmsg;
            return sc1;
          }
          os = ios; // manage reference counting
        }
        m_outStreamList.push_back( os );
      }
      return sc;
    }
    sc = StatusCode::FAILURE;
  }
  return sc;
}

decodeTopAlgs()

StatusCode MinimalEventLoopMgr::decodeTopAlgs

(

)

decodeTopAlgNameList & topAlgNameListHandler

Definition at line 422 of file MinimalEventLoopMgr.cpp.

                                              {
  StatusCode sc = StatusCode::SUCCESS;
  if ( CONFIGURED == m_state || INITIALIZED == m_state ) {
    auto algMan = serviceLocator()->as<IAlgManager>();
    if ( algMan ) {
      // Reset the existing Top Algorithm List
      m_topAlgList.clear();
      m_topAlgList.reserve( m_topAlgNames.value().size() );
      for ( const auto& it : m_topAlgNames.value() ) {
        Gaudi::Utils::TypeNameString item{ it };
        // Got the type and name. Now creating the algorithm, avoiding duplicate creation.
        std::string         item_name = item.name();
        const bool          CREATE    = false;
        SmartIF<IAlgorithm> alg       = algMan->algorithm( item_name, CREATE );
        if ( alg ) {
          DEBMSG << "Top Algorithm " << item_name << " already exists" << endmsg;
        } else {
          DEBMSG << "Creating Top Algorithm " << item.type() << " with name " << item_name << endmsg;
          IAlgorithm* ialg = nullptr;
          StatusCode  sc1  = algMan->createAlgorithm( item.type(), item_name, ialg );
          if ( !sc1.isSuccess() ) {
            error() << "Unable to create Top Algorithm " << item.type() << " with name " << item_name << endmsg;
            return sc1;
          }
          alg = ialg; // manage reference counting
        }
        m_topAlgList.push_back( alg );
      }
      return sc;
    }
    sc = StatusCode::FAILURE;
  }
  return sc;
}

executeEvent()

StatusCode MinimalEventLoopMgr::executeEvent ( EventContext && ctx )

override

implementation of IEventProcessor::executeEvent(EventContext&&)

Definition at line 329 of file MinimalEventLoopMgr.cpp.

                                                                     {
  bool eventfailed = false;
 
  m_aess->reset( context );
 
  // select the appropriate store
  if ( m_WB.isValid() ) m_WB->selectStore( context.slot() ).ignore();
 
  // Get the IProperty interface of the ApplicationMgr to pass it to RetCodeGuard
  const auto appmgr = serviceLocator()->as<IProperty>();
  // Call the execute() method of all top algorithms
  for ( auto& ita : m_topAlgList ) {
    StatusCode sc( StatusCode::FAILURE );
    try {
      if ( m_abortEventListener.abortEvent ) {
        DEBMSG << "AbortEvent incident fired by " << m_abortEventListener.abortEventSource << endmsg;
        m_abortEventListener.abortEvent = false;
        sc.ignore();
        break;
      }
      RetCodeGuard rcg( appmgr, Gaudi::ReturnCode::UnhandledException );
      sc = ita->sysExecute( context );
      rcg.ignore(); // disarm the guard
    } catch ( const GaudiException& Exception ) {
      fatal() << ".executeEvent(): Exception with tag=" << Exception.tag() << " thrown by " << ita->name() << endmsg;
      error() << Exception << endmsg;
    } catch ( const std::exception& Exception ) {
      fatal() << ".executeEvent(): Standard std::exception thrown by " << ita->name() << endmsg;
      error() << Exception.what() << endmsg;
    } catch ( ... ) { fatal() << ".executeEvent(): UNKNOWN Exception thrown by " << ita->name() << endmsg; }
 
    if ( !sc.isSuccess() ) {
      warning() << "Execution of algorithm " << ita->name() << " failed" << endmsg;
      eventfailed = true;
    }
  }
 
  m_aess->updateEventStatus( eventfailed, context );
 
  // ensure that the abortEvent flag is cleared before the next event
  if ( m_abortEventListener.abortEvent ) {
    DEBMSG << "AbortEvent incident fired by " << m_abortEventListener.abortEventSource << endmsg;
    m_abortEventListener.abortEvent = false;
  }
 
  // Call the execute() method of all output streams
  for ( auto& ito : m_outStreamList ) {
    AlgExecStateRef state = m_aess->algExecState( ito, context );
    state.setFilterPassed( true );
    StatusCode sc = ito->sysExecute( context );
    if ( !sc.isSuccess() ) {
      warning() << "Execution of output stream " << ito->name() << " failed" << endmsg;
      eventfailed = true;
    }
  }
 
  // Check if there was an error processing current event
  if ( eventfailed ) {
    error() << "Error processing event loop." << endmsg;
    std::ostringstream ost;
    m_aess->dump( ost, context );
    debug() << "Dumping AlgExecStateSvc status:\n" << ost.str() << endmsg;
    return StatusCode::FAILURE;
  }
 
  return StatusCode::SUCCESS;
}

executeRun()

StatusCode MinimalEventLoopMgr::executeRun ( int maxevt )

override

implementation of IEventProcessor::executeRun( )

Definition at line 304 of file MinimalEventLoopMgr.cpp.

                                                       {
  // Call now the nextEvent(...)
  return nextEvent( maxevt );
}

finalize()

StatusCode MinimalEventLoopMgr::finalize ( )

override

implementation of IService::finalize

Definition at line 246 of file MinimalEventLoopMgr.cpp.

                                         {
  StatusCode sc    = StatusCode::SUCCESS;
  StatusCode scRet = StatusCode::SUCCESS;
  // Call the finalize() method of all top algorithms
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysFinalize();
    if ( !sc.isSuccess() ) {
      scRet = StatusCode::FAILURE;
      warning() << "Finalization of algorithm " << ita->name() << " failed" << endmsg;
    }
  }
  // Call the finalize() method of all Output streams
  for ( auto& ita : m_outStreamList ) {
    sc = ita->sysFinalize();
    if ( !sc.isSuccess() ) {
      scRet = StatusCode::FAILURE;
      warning() << "Finalization of algorithm " << ita->name() << " failed" << endmsg;
    }
  }
  // release all top algorithms
  auto algMan = serviceLocator()->as<IAlgManager>();
  for ( auto& ita : m_topAlgList ) {
    if ( algMan->removeAlgorithm( ita ).isFailure() ) {
      scRet = StatusCode::FAILURE;
      warning() << "Problems removing Algorithm " << ita->name() << endmsg;
    }
  }
  m_topAlgList.clear();
  m_outStreamList.clear();
  if ( sc.isSuccess() ) m_state = FINALIZED;
 
  m_incidentSvc->removeListener( &m_abortEventListener, IncidentType::AbortEvent );
 
  m_incidentSvc.reset();
  m_appMgrUI.reset();
 
  sc = Service::finalize();
 
  if ( sc.isFailure() ) {
    scRet = StatusCode::FAILURE;
    error() << "Problems finalizing Service base class" << endmsg;
  }
 
  return scRet;
}

initialize()

StatusCode MinimalEventLoopMgr::initialize ( )

override

implementation of IService::initialize

Definition at line 44 of file MinimalEventLoopMgr.cpp.

                                           {
 
  if ( !m_appMgrUI ) return StatusCode::FAILURE;
 
  StatusCode sc = Service::initialize();
  if ( !sc.isSuccess() ) {
    error() << "Failed to initialize Service Base class." << endmsg;
    return StatusCode::FAILURE;
  }
 
  auto prpMgr = serviceLocator()->as<IProperty>();
  if ( !prpMgr ) {
    error() << "Error retrieving AppMgr interface IProperty." << endmsg;
    return StatusCode::FAILURE;
  }
  if ( m_topAlgNames.value().empty() ) { setProperty( prpMgr->getProperty( "TopAlg" ) ).ignore(); }
  if ( m_outStreamNames.value().empty() ) { setProperty( prpMgr->getProperty( "OutStream" ) ).ignore(); }
 
  // Get the references to the services that are needed by the ApplicationMgr itself
  m_incidentSvc = serviceLocator()->service( "IncidentSvc" );
  if ( !m_incidentSvc ) {
    fatal() << "Error retrieving IncidentSvc." << endmsg;
    return StatusCode::FAILURE;
  }
 
  m_incidentSvc->addListener( &m_abortEventListener, IncidentType::AbortEvent );
 
  // The state is changed at this moment to allow decodeXXXX() to do something
  m_state = INITIALIZED;
 
  // Get WhiteBoard interface if implemented by EventDataSvc
  m_WB = service( "EventDataSvc" );
 
  // setup the default EventContext with slot 0
  Gaudi::Hive::setCurrentContextId( Gaudi::Hive::ContextIdType( 0 ) );
 
  //--------------------------------------------------------------------------------------------
  // 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() ) {
    error() << "Failed to initialize Output streams." << endmsg;
    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() ) {
    error() << "Failed to initialize Top Algorithms streams." << endmsg;
    m_state = CONFIGURED;
    return sc;
  }
 
  // Initialize all the new TopAlgs. In fact Algorithms are protected against
  // getting initialized twice.
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysInitialize();
    if ( !sc.isSuccess() ) {
      error() << "Unable to initialize Algorithm: " << ita->name() << endmsg;
      return sc;
    }
  }
  for ( auto& ita : m_outStreamList ) {
    sc = ita->sysInitialize();
    if ( !sc.isSuccess() ) {
      error() << "Unable to initialize Output Stream: " << ita->name() << endmsg;
      return sc;
    }
  }
 
  // get hold of the Algorithm Execution State mgr
  m_aess = serviceLocator()->service( "AlgExecStateSvc" );
  if ( !m_aess ) {
    fatal() << "Error retrieving AlgExecStateSvc." << endmsg;
    return StatusCode::FAILURE;
  }
 
  if ( m_printCFExp && !m_topAlgList.empty() ) {
    info() << "Control Flow Expression:" << endmsg;
    std::stringstream expr;
    auto&             first = m_topAlgList.front();
    for ( auto& ialg : m_topAlgList ) {
      if ( ialg != first ) expr << " >> ";
      ialg->toControlFlowExpression( expr );
    }
    info() << expr.str() << endmsg;
  }
  return StatusCode::SUCCESS;
}

nextEvent()

StatusCode MinimalEventLoopMgr::nextEvent ( int maxevt )

override

implementation of IEventProcessor::nextEvent

Definition at line 296 of file MinimalEventLoopMgr.cpp.

                                                 {
  error() << "This method cannot be called on an object of type " << System::typeinfoName( typeid( *this ) ) << endmsg;
  return StatusCode::FAILURE;
}

operator=()

MinimalEventLoopMgr & MinimalEventLoopMgr::operator= ( const MinimalEventLoopMgr & )

delete

No copy allowed.

outStreamHandler()

void MinimalEventLoopMgr::outStreamHandler

(

Gaudi::Details::PropertyBase &

p

)

Output stream List handler.

Definition at line 460 of file MinimalEventLoopMgr.cpp.

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

reinitialize()

StatusCode MinimalEventLoopMgr::reinitialize ( )

override

implementation of IService::reinitialize

Definition at line 195 of file MinimalEventLoopMgr.cpp.

                                             {
  StatusCode sc = StatusCode::SUCCESS;
 
  // Reinitialize all the TopAlgs.
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysReinitialize();
    if ( !sc.isSuccess() ) {
      error() << "Unable to reinitialize Algorithm: " << ita->name() << endmsg;
      return sc;
    }
  }
  for ( auto& ita : m_outStreamList ) {
    sc = ita->sysReinitialize();
    if ( !sc.isSuccess() ) {
      error() << "Unable to reinitialize Output Stream: " << ita->name() << endmsg;
      return sc;
    }
  }
 
  return sc;
}

restart()

StatusCode MinimalEventLoopMgr::restart ( )

override

implementation of IService::restart

Definition at line 219 of file MinimalEventLoopMgr.cpp.

                                        {
  StatusCode sc = StatusCode::SUCCESS;
 
  // Restart all the TopAlgs.
  for ( auto& ita : m_topAlgList ) {
    m_aess->resetErrorCount( ita );
    sc = ita->sysRestart();
    if ( !sc.isSuccess() ) {
      error() << "Unable to restart Algorithm: " << ita->name() << endmsg;
      return sc;
    }
  }
  for ( auto& ita : m_outStreamList ) {
    m_aess->resetErrorCount( ita );
    sc = ita->sysRestart();
    if ( !sc.isSuccess() ) {
      error() << "Unable to restart Output Stream: " << ita->name() << endmsg;
      return sc;
    }
  }
 
  return sc;
}

start()

StatusCode MinimalEventLoopMgr::start ( )

override

implementation of IService::start

Definition at line 142 of file MinimalEventLoopMgr.cpp.

                                      {
 
  StatusCode sc = Service::start();
  if ( !sc.isSuccess() ) return sc;
 
  // Start all the new TopAlgs. In fact Algorithms are protected against getting
  // started twice.
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysStart();
    if ( !sc.isSuccess() ) {
      error() << "Unable to start Algorithm: " << ita->name() << endmsg;
      return sc;
    }
  }
  for ( auto& ita : m_outStreamList ) {
    sc = ita->sysStart();
    if ( !sc.isSuccess() ) {
      error() << "Unable to start Output Stream: " << ita->name() << endmsg;
      return sc;
    }
  }
  return StatusCode::SUCCESS;
}

stop()

StatusCode MinimalEventLoopMgr::stop ( )

override

implementation of IService::stop

Definition at line 168 of file MinimalEventLoopMgr.cpp.

                                     {
 
  StatusCode sc{ StatusCode::SUCCESS };
 
  // Stop all the TopAlgs. In fact Algorithms are protected against getting
  // stopped twice.
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysStop();
    if ( !sc.isSuccess() ) {
      error() << "Unable to stop Algorithm: " << ita->name() << endmsg;
      return sc;
    }
  }
  for ( auto& ita : m_outStreamList ) {
    sc = ita->sysStop();
    if ( !sc.isSuccess() ) {
      error() << "Unable to stop Output Stream: " << ita->name() << endmsg;
      return sc;
    }
  }
 
  return Service::stop();
}

stopRun()

StatusCode MinimalEventLoopMgr::stopRun ( )

override

implementation of IEventProcessor::stopRun( )

Definition at line 399 of file MinimalEventLoopMgr.cpp.

                                        {
  // Set the application return code
  auto appmgr = serviceLocator()->as<IProperty>();
  if ( Gaudi::setAppReturnCode( appmgr, Gaudi::ReturnCode::ScheduledStop ).isFailure() ) {
    error() << "Could not set return code of the application (" << Gaudi::ReturnCode::ScheduledStop << ")" << endmsg;
  }
  m_scheduledStop = true;
  return StatusCode::SUCCESS;
}

topAlgHandler()

void MinimalEventLoopMgr::topAlgHandler

(

Gaudi::Details::PropertyBase &

p

)

Top algorithm List handler.

Definition at line 412 of file MinimalEventLoopMgr.cpp.

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

Member Data Documentation

m_abortEventListener

AbortEventListener MinimalEventLoopMgr::m_abortEventListener

protected

Instance of the incident listener waiting for AbortEvent.

Definition at line 81 of file MinimalEventLoopMgr.h.

m_aess

SmartIF<IAlgExecStateSvc> MinimalEventLoopMgr::m_aess

protected

List of top level algorithms.

Definition at line 72 of file MinimalEventLoopMgr.h.

m_appMgrUI

SmartIF<IAppMgrUI> MinimalEventLoopMgr::m_appMgrUI

protected

Reference to the IAppMgrUI interface of the application manager.

Definition at line 68 of file MinimalEventLoopMgr.h.

m_incidentSvc

SmartIF<IIncidentSvc> MinimalEventLoopMgr::m_incidentSvc

protected

Reference to the incident service.

Definition at line 70 of file MinimalEventLoopMgr.h.

m_nevt

size_t MinimalEventLoopMgr::m_nevt { 0 }

protected

Definition at line 128 of file MinimalEventLoopMgr.h.

{ 0 };

m_outStreamList

ListAlg MinimalEventLoopMgr::m_outStreamList

protected

List of output streams.

Definition at line 75 of file MinimalEventLoopMgr.h.

m_outStreamNames

Gaudi::Property<std::vector<std::string> > MinimalEventLoopMgr::m_outStreamNames

protected

Initial value:

{
      this, "OutStream", {}, &MinimalEventLoopMgr::outStreamHandler, "list of output stream names" }

Definition at line 60 of file MinimalEventLoopMgr.h.

                                                      {
      this, "OutStream", {}, &MinimalEventLoopMgr::outStreamHandler, "list of output stream names" };

m_printCFExp

Gaudi::Property<bool> MinimalEventLoopMgr::m_printCFExp

protected

Initial value:

{ this, "PrintControlFlowExpression", false,
                                      "Print the control flow expression representing the content of TopAlg" }

Definition at line 62 of file MinimalEventLoopMgr.h.

                                  { this, "PrintControlFlowExpression", false,
                                      "Print the control flow expression representing the content of TopAlg" };

m_scheduledStop

bool MinimalEventLoopMgr::m_scheduledStop = false

protected

Scheduled stop of event processing.

Definition at line 79 of file MinimalEventLoopMgr.h.

m_state

State MinimalEventLoopMgr::m_state = OFFLINE

protected

State of the object.

Definition at line 77 of file MinimalEventLoopMgr.h.

m_topAlgList

ListAlg MinimalEventLoopMgr::m_topAlgList

protected

Definition at line 73 of file MinimalEventLoopMgr.h.

m_topAlgNames

Gaudi::Property<std::vector<std::string> > MinimalEventLoopMgr::m_topAlgNames

protected

Initial value:

{
      this, "TopAlg", {}, &MinimalEventLoopMgr::topAlgHandler, "list of top level algorithms names" }

Definition at line 58 of file MinimalEventLoopMgr.h.

                                                   {
      this, "TopAlg", {}, &MinimalEventLoopMgr::topAlgHandler, "list of top level algorithms names" };

m_WB

SmartIF<IHiveWhiteBoard> MinimalEventLoopMgr::m_WB

protected

< Event data service (whiteboard)

Definition at line 125 of file MinimalEventLoopMgr.h.

---

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

• GaudiKernel/include/GaudiKernel/MinimalEventLoopMgr.h
• GaudiKernel/src/Lib/MinimalEventLoopMgr.cpp