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

Inheritance diagram for MinimalEventLoopMgr:

[legend]

Collaboration diagram for MinimalEventLoopMgr:

[legend]

Classes
class	AbortEventListener

Public Types
typedef std::vector< SmartIF< IAlgorithm > >	ListAlg

Public Types inherited from extends< Service, IEventProcessor >
using	base_class = extends
	Typedef to this class. More...

using	extend_interfaces_base = extend_interfaces< Interfaces... >
	Typedef to the base of this class. More...

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 = PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
	Typedef used to refer to this class from derived classes, as in. More...

Public Types inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
using	base_class = CommonMessaging

Public Types inherited from extend_interfaces< Interfaces... >
using	ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids... >::type
	take union of the ext_iids of all Interfaces... More...

Public Member Functions
	MinimalEventLoopMgr (const std::string &nam, ISvcLocator *svcLoc)
	Standard Constructor. More...

	MinimalEventLoopMgr (const MinimalEventLoopMgr &)=delete
	No copy allowed. More...

MinimalEventLoopMgr &	operator= (const MinimalEventLoopMgr &)=delete
	No copy allowed. More...

StatusCode	initialize () override
	implementation of IService::initialize More...

StatusCode	start () override
	implementation of IService::start More...

StatusCode	stop () override
	implementation of IService::stop More...

StatusCode	finalize () override
	implementation of IService::finalize More...

StatusCode	reinitialize () override
	implementation of IService::reinitialize More...

StatusCode	restart () override
	implementation of IService::restart More...

EventContext	createEventContext () override
	implementation of IEventProcessor::createEventContext() More...

StatusCode	nextEvent (int maxevt) override
	implementation of IEventProcessor::nextEvent More...

StatusCode	executeEvent (EventContext &&ctx) override
	implementation of IEventProcessor::executeEvent(EventContext&&) More...

StatusCode	executeRun (int maxevt) override
	implementation of IEventProcessor::executeRun( ) More...

StatusCode	stopRun () override
	implementation of IEventProcessor::stopRun( ) More...

void	topAlgHandler (Gaudi::Details::PropertyBase &p)
	Top algorithm List handler. More...

StatusCode	decodeTopAlgs ()
	decodeTopAlgNameList & topAlgNameListHandler More...

void	outStreamHandler (Gaudi::Details::PropertyBase &p)
	Output stream List handler. More...

StatusCode	decodeOutStreams ()
	decodeOutStreamNameList & outStreamNameListHandler More...

Public Member Functions inherited from extends< Service, IEventProcessor >
void *	i_cast (const InterfaceID &tid) const override
	Implementation of IInterface::i_cast. More...

StatusCode	queryInterface (const InterfaceID &ti, void **pp) override
	Implementation of IInterface::queryInterface. More...

std::vector< std::string >	getInterfaceNames () const override
	Implementation of IInterface::getInterfaceNames. More...

Public Member Functions inherited from Service
const std::string &	name () const override
	Retrieve name of the service More...

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 More...

StatusCode	sysStart () override
	Initialize Service More...

StatusCode	sysStop () override
	Initialize Service More...

StatusCode	sysFinalize () override
	Finalize Service More...

StatusCode	sysReinitialize () override
	Re-initialize the Service. More...

StatusCode	sysRestart () override
	Re-initialize the Service. More...

	Service (std::string name, ISvcLocator *svcloc)
	Standard Constructor More...

SmartIF< ISvcLocator > &	serviceLocator () const override
	Retrieve pointer to service locator More...

template<class T >
StatusCode	service (const std::string &name, const T *&psvc, bool createIf=true) const
	Access a service by name, creating it if it doesn't already exist. More...

template<class T >
StatusCode	service (const std::string &name, T *&psvc, bool createIf=true) const

template<typename IFace = IService>
SmartIF< IFace >	service (const std::string &name, bool createIf=true) const

template<class T >
StatusCode	service (const std::string &svcType, const std::string &svcName, T *&psvc) const
	Access a service by name and type, creating it if it doesn't already exist. More...

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. More...

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. More...

Public Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
	PropertyHolder ()=default

Gaudi::Details::PropertyBase &	declareProperty (Gaudi::Details::PropertyBase &prop)
	Declare a property. More...

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. More...

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. More...

Gaudi::Details::PropertyBase *	declareRemoteProperty (const std::string &name, IProperty *rsvc, const std::string &rname="")
	Declare a remote property. More...

StatusCode	setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p) override
	set the property from another property with a different name More...

StatusCode	setProperty (const std::string &s) override
	set the property from the formatted string More...

StatusCode	setProperty (const Gaudi::Details::PropertyBase &p)
	Set the property from a property. More...

virtual StatusCode	setProperty (const std::string &name, const Gaudi::Details::PropertyBase &p)=0
	Set the property from a property with a different name. More...

virtual StatusCode	setProperty (const std::string &s)=0
	Set the property by string. More...

StatusCode	setProperty (const std::string &name, const char *v)
	Special case for string literals. More...

StatusCode	setProperty (const std::string &name, const std::string &v)
	Special case for std::string. More...

StatusCode	setProperty (const std::string &name, const TYPE &value)
	set the property form the value More...

StatusCode	setPropertyRepr (const std::string &n, const std::string &r) override
	set the property from name and value string representation More...

StatusCode	getProperty (Gaudi::Details::PropertyBase *p) const override
	get the property More...

const Gaudi::Details::PropertyBase &	getProperty (std::string_view name) const override
	get the property by name More...

StatusCode	getProperty (std::string_view n, std::string &v) const override
	convert the property to the string More...

const std::vector< Gaudi::Details::PropertyBase * > &	getProperties () const override
	get all properties More...

bool	hasProperty (std::string_view name) const override
	Return true if we have a property with the given name. More...

Gaudi::Details::PropertyBase *	property (std::string_view name) const
	\fixme property and bindPropertiesTo should be protected More...

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) More...

bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream More...

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. More...

SmartIF< IIncidentSvc >	m_incidentSvc
	Reference to the incident service. More...

SmartIF< IAlgExecStateSvc >	m_aess
	List of top level algorithms. More...

ListAlg	m_topAlgList

ListAlg	m_outStreamList
	List of output streams. More...

State	m_state = OFFLINE
	State of the object. More...

bool	m_scheduledStop = false
	Scheduled stop of event processing. More...

AbortEventListener	m_abortEventListener
	Instance of the incident listener waiting for AbortEvent. More...

SmartIF< IHiveWhiteBoard >	m_WB
	< Event data service (whiteboard) More...

size_t	m_nevt { 0 }

Protected Attributes inherited from Service
Gaudi::StateMachine::State	m_state = Gaudi::StateMachine::OFFLINE
	Service state More...

Gaudi::StateMachine::State	m_targetState = Gaudi::StateMachine::OFFLINE
	Service state More...

Gaudi::Property< int >	m_outputLevel { this, "OutputLevel", MSG::NIL, "output level" }
	flag indicating whether ToolHandle tools have been added to m_tools More...

Gaudi::Property< bool >	m_auditInit { this, "AuditServices", false, "[[deprecated]] unused" }

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 More...

Additional Inherited Members
Protected Member Functions inherited from Service
std::vector< IAlgTool * > &	tools ()

	~Service () override
	Standard Destructor More...

int	outputLevel () const
	get the `Service's` output level More...

Protected Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	setUpMessaging () const
	Set up local caches. More...

MSG::Level	resetMessaging ()
	Reinitialize internal states. More...

void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream. More...

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 34 of file MinimalEventLoopMgr.h.

Member Typedef Documentation

◆ ListAlg

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

Definition at line 55 of file MinimalEventLoopMgr.h.

Member Enumeration Documentation

◆ State

enum MinimalEventLoopMgr::State

protected

Enumerator
OFFLINE
CONFIGURED
FINALIZED
INITIALIZED

Definition at line 67 of file MinimalEventLoopMgr.h.

67 { 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.

39 : 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.

292 { 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 ) {
     AlgExecState& 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 82 of file MinimalEventLoopMgr.h.

◆ m_aess

SmartIF<IAlgExecStateSvc> MinimalEventLoopMgr::m_aess

protected

List of top level algorithms.

Definition at line 73 of file MinimalEventLoopMgr.h.

◆ m_appMgrUI

SmartIF<IAppMgrUI> MinimalEventLoopMgr::m_appMgrUI

protected

Reference to the IAppMgrUI interface of the application manager.

Definition at line 69 of file MinimalEventLoopMgr.h.

◆ m_incidentSvc

SmartIF<IIncidentSvc> MinimalEventLoopMgr::m_incidentSvc

protected

Reference to the incident service.

Definition at line 71 of file MinimalEventLoopMgr.h.

◆ m_nevt

size_t MinimalEventLoopMgr::m_nevt { 0 }

protected

Definition at line 141 of file MinimalEventLoopMgr.h.

◆ m_outStreamList

ListAlg MinimalEventLoopMgr::m_outStreamList

protected

List of output streams.

Definition at line 76 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 61 of file MinimalEventLoopMgr.h.

◆ 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 63 of file MinimalEventLoopMgr.h.

◆ m_scheduledStop

bool MinimalEventLoopMgr::m_scheduledStop = false

protected

Scheduled stop of event processing.

Definition at line 80 of file MinimalEventLoopMgr.h.

◆ m_state

State MinimalEventLoopMgr::m_state = OFFLINE

protected

State of the object.

Definition at line 78 of file MinimalEventLoopMgr.h.

◆ m_topAlgList

ListAlg MinimalEventLoopMgr::m_topAlgList

protected

Definition at line 74 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 59 of file MinimalEventLoopMgr.h.

◆ m_WB

SmartIF<IHiveWhiteBoard> MinimalEventLoopMgr::m_WB

protected

< Event data service (whiteboard)

Definition at line 138 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

Classes

Public Types

Public Member Functions

Protected Types

Protected Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ListAlg

Member Enumeration Documentation

◆ State

Constructor & Destructor Documentation

◆ MinimalEventLoopMgr() [1/2]

◆ MinimalEventLoopMgr() [2/2]

Member Function Documentation

◆ createEventContext()

◆ decodeOutStreams()

◆ decodeTopAlgs()

◆ executeEvent()

◆ executeRun()

◆ finalize()

◆ initialize()

◆ nextEvent()

◆ operator=()

◆ outStreamHandler()

◆ reinitialize()

◆ restart()

◆ start()

◆ stop()

◆ stopRun()

◆ topAlgHandler()

Member Data Documentation

◆ m_abortEventListener

◆ m_aess

◆ m_appMgrUI

◆ m_incidentSvc

◆ m_nevt

◆ m_outStreamList

◆ m_outStreamNames

◆ m_printCFExp

◆ m_scheduledStop

◆ m_state

◆ m_topAlgList

◆ m_topAlgNames

◆ m_WB