MinimalEventLoopMgr Class Reference

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

#include <GaudiKernel/MinimalEventLoopMgr.h>

Inheritance diagram for MinimalEventLoopMgr:

Collaboration diagram for MinimalEventLoopMgr:

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
typedef Gaudi::PluginService::Factory< IService *, const std::string &, ISvcLocator * >	Factory
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...
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...
StatusCode	nextEvent (int maxevt) override
	implementation of IEventProcessor::nextEvent More...
StatusCode	executeEvent (void *par) override
	implementation of IEventProcessor::executeEvent(void* par) 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...
	~extends () override=default
	Virtual destructor. 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...
StatusCode	setProperties ()
	Method for setting declared properties to the values specified for the job. 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 >
StatusCode	declareTool (ToolHandle< T > &handle, std::string toolTypeAndName, bool createIf=true)
	Declare used tool. More...
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
	~PropertyHolder () override=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, TYPE &value, const std::string &doc="none") const
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 Gaudi::Details::PropertyBase &p) override
	set the property form another property More...
StatusCode	setProperty (const std::string &s) override
	set the property from the formatted string More...
StatusCode	setProperty (const std::string &n, const std::string &v) override
	set the property from name and the value More...
StatusCode	setProperty (const std::string &name, const TYPE &value)
	set the property form the value More...
StatusCode	getProperty (Gaudi::Details::PropertyBase *p) const override
	get the property More...
const Gaudi::Details::PropertyBase &	getProperty (const std::string &name) const override
	get the property by name More...
StatusCode	getProperty (const std::string &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 (const std::string &name) const override
	Return true if we have a property with the given name. More...
	PropertyHolder (const PropertyHolder &)=delete
PropertyHolder &	operator= (const PropertyHolder &)=delete
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, GaudiHandleBase &ref, const std::string &doc="none")
	Specializations for various GaudiHandles. More...
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, GaudiHandleArrayBase &ref, const std::string &doc="none")
Gaudi::Details::PropertyBase *	declareProperty (const std::string &name, DataObjectHandleBase &ref, const std::string &doc="none")
Public Member Functions inherited from CommonMessagingBase
virtual	~CommonMessagingBase ()=default
	Virtual destructor. More...
const SmartIF< IMessageSvc > &	msgSvc () const
	The standard message service. More...
MsgStream &	msgStream () const
	Return an uninitialized MsgStream. More...
MsgStream &	msgStream (const MSG::Level level) const
	Predefined configurable message stream for the efficient printouts. More...
MsgStream &	always () const
	shortcut for the method msgStream(MSG::ALWAYS) More...
MsgStream &	fatal () const
	shortcut for the method msgStream(MSG::FATAL) More...
MsgStream &	err () const
	shortcut for the method msgStream(MSG::ERROR) More...
MsgStream &	error () const
	shortcut for the method msgStream(MSG::ERROR) More...
MsgStream &	warning () const
	shortcut for the method msgStream(MSG::WARNING) More...
MsgStream &	info () const
	shortcut for the method msgStream(MSG::INFO) More...
MsgStream &	debug () const
	shortcut for the method msgStream(MSG::DEBUG) More...
MsgStream &	verbose () const
	shortcut for the method msgStream(MSG::VERBOSE) More...
MsgStream &	msg () const
	shortcut for the method msgStream(MSG::INFO) More...
MSG::Level	msgLevel () const
	get the cached level (originally extracted from the embedded MsgStream) More...
MSG::Level	outputLevel () const __attribute__((deprecated))
	Backward compatibility function for getting the output level. More...
bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream More...
Public Member Functions inherited from extend_interfaces< Interfaces... >
	~extend_interfaces () override=default
	Virtual destructor. More...

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

Protected Attributes
Gaudi::Property< std::vector< std::string > >	m_topAlgNames {this, "TopAlg", {}, "list of top level algorithms names"}
Gaudi::Property< std::vector< std::string > >	m_outStreamNames {this, "OutStream", {}, "list of output stream names"}
Gaudi::Property< std::string >	m_outStreamType
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...
SmartIF< IIncidentListener >	m_abortEventListener
	Instance of the incident listener waiting for AbortEvent. More...
bool	m_abortEvent = false
	Flag signalling that the event being processedhas to be aborted (skip all following top algs). More...
std::string	m_abortEventSource
	Source of the AbortEvent incident. More...
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"}
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()"}
SmartIF< IAuditorSvc >	m_pAuditorSvc
	Auditor Service. More...

Private Member Functions
	MinimalEventLoopMgr (const MinimalEventLoopMgr &)
	Fake copy constructor (never implemented). More...
MinimalEventLoopMgr &	operator= (const MinimalEventLoopMgr &)
	Fake assignment operator (never implemented). More...

Private Attributes
SmartIF< IHiveWhiteBoard >	m_WB
size_t	m_nevt {0}

Additional Inherited Members
Protected Member Functions inherited from Service
	~Service () override
	Standard Destructor. More...
int	outputLevel () const
	get the Service's output level More...
Protected Member Functions inherited from PropertyHolder< CommonMessaging< implements< IService, IProperty, IStateful > > >
Gaudi::Details::PropertyBase *	property (const std::string &name) const
Protected Member Functions inherited from CommonMessaging< implements< IService, IProperty, IStateful > >
MSG::Level	setUpMessaging ()
	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, they list may as well be empty.

Author

Markus Frank

Version

1.0

Definition at line 28 of file MinimalEventLoopMgr.h.

Member Typedef Documentation

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

Definition at line 31 of file MinimalEventLoopMgr.h.

Member Enumeration Documentation

enum MinimalEventLoopMgr::State

protected

Enumerator
OFFLINE
CONFIGURED
FINALIZED
INITIALIZED

Definition at line 43 of file MinimalEventLoopMgr.h.

{ OFFLINE, CONFIGURED, FINALIZED, INITIALIZED };

Constructor & Destructor Documentation

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

Standard Constructor.

Definition at line 56 of file MinimalEventLoopMgr.cpp.

    : base_class( nam, svcLoc ), m_appMgrUI( svcLoc )
{
  m_topAlgNames.declareUpdateHandler( &MinimalEventLoopMgr::topAlgHandler, this );
  m_outStreamNames.declareUpdateHandler( &MinimalEventLoopMgr::outStreamHandler, this );
}

MinimalEventLoopMgr::MinimalEventLoopMgr ( const MinimalEventLoopMgr &  )

private

Fake copy constructor (never implemented).

Member Function Documentation

StatusCode MinimalEventLoopMgr::decodeOutStreams

(

)

decodeOutStreamNameList & outStreamNameListHandler

Definition at line 558 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, m_outStreamType );
        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;
}

StatusCode MinimalEventLoopMgr::decodeTopAlgs

(

)

decodeTopAlgNameList & topAlgNameListHandler

Definition at line 508 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() + getGaudiThreadIDfromName( 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;
}

StatusCode MinimalEventLoopMgr::executeEvent ( void *  par )

override

implementation of IEventProcessor::executeEvent(void* par)

Definition at line 395 of file MinimalEventLoopMgr.cpp.

{
  bool eventfailed = false;

  // reset state of ALL "known" algorithms
  // (before we were reseting only the topalgs)
  const EventContext& context = Gaudi::Hive::currentContext();
  m_aess->reset( context );

  // Set event number in the context
  Gaudi::Hive::setCurrentContextEvt( m_nevt );

  // 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 );
    AlgExecState& algState = m_aess->algExecState( ita, context );
    try {
      if ( UNLIKELY( m_abortEvent ) ) {
        DEBMSG << "AbortEvent incident fired by " << m_abortEventSource << endmsg;
        m_abortEvent = false;
        sc.ignore();
        break;
      }
      RetCodeGuard rcg( appmgr, Gaudi::ReturnCode::UnhandledException );
      algState.setState( AlgExecState::State::Executing );
      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;
    }

    algState.setState( AlgExecState::State::Done );
    algState.setExecStatus( sc );

    if ( UNLIKELY( !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 ( UNLIKELY( m_abortEvent ) ) {
    DEBMSG << "AbortEvent incident fired by " << m_abortEventSource << endmsg;
    m_abortEvent = false;
  }

  // Call the execute() method of all output streams
  for ( auto& ito : m_outStreamList ) {
    AlgExecState& state = m_aess->algExecState( ito, context );
    state.setState( AlgExecState::State::Executing );
    state.setFilterPassed( true );
    StatusCode sc = ito->sysExecute( context );
    state.setState( AlgExecState::State::Done, sc );
    if ( UNLIKELY( !sc.isSuccess() ) ) {
      warning() << "Execution of output stream " << ito->name() << " failed" << endmsg;
      eventfailed = true;
    }
  }

  m_nevt++;

  // Check if there was an error processing current event
  if ( UNLIKELY( 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( StatusCode::FAILURE, true );
  }

  return StatusCode( StatusCode::SUCCESS, true );
}

StatusCode MinimalEventLoopMgr::executeRun ( int  maxevt )

override

implementation of IEventProcessor::executeRun( )

Definition at line 338 of file MinimalEventLoopMgr.cpp.

{
  StatusCode sc;
  bool       eventfailed = false;

  // Call the beginRun() method of all top algorithms
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysBeginRun();
    if ( !sc.isSuccess() ) {
      warning() << "beginRun() of algorithm " << ita->name() << " failed" << endmsg;
      eventfailed = true;
    }
  }

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

  // Call the endRun() method of all top algorithms
  for ( auto& ita : m_topAlgList ) {
    sc = ita->sysEndRun();
    if ( !sc.isSuccess() ) {
      warning() << "endRun() of algorithm " << ita->name() << " failed" << endmsg;
      eventfailed = true;
    }
  }

  return eventfailed ? StatusCode::FAILURE : StatusCode::SUCCESS;
}

StatusCode MinimalEventLoopMgr::finalize ( )

override

implementation of IService::finalize

Definition at line 278 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_abortEventListener.reset();

  m_incidentSvc.reset();
  m_appMgrUI.reset();

  sc = Service::finalize();

  if ( sc.isFailure() ) {
    scRet = StatusCode::FAILURE;
    error() << "Problems finalizing Service base class" << endmsg;
  }

  return scRet;
}

StatusCode MinimalEventLoopMgr::initialize ( )

override

implementation of IService::initialize

Definition at line 66 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_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;

  // 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;
}

StatusCode MinimalEventLoopMgr::nextEvent ( int  maxevt )

override

implementation of IEventProcessor::nextEvent

Definition at line 329 of file MinimalEventLoopMgr.cpp.

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

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

private

Fake assignment operator (never implemented).

Event data service (whiteboard)

void MinimalEventLoopMgr::outStreamHandler

(

Gaudi::Details::PropertyBase &

p

)

Output stream List handler.

Definition at line 547 of file MinimalEventLoopMgr.cpp.

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

StatusCode MinimalEventLoopMgr::reinitialize ( )

override

implementation of IService::reinitialize

Definition at line 225 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;
}

StatusCode MinimalEventLoopMgr::restart ( )

override

implementation of IService::restart

Definition at line 250 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;
}

StatusCode MinimalEventLoopMgr::start ( )

override

implementation of IService::start

Definition at line 170 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;
}

StatusCode MinimalEventLoopMgr::stop ( )

override

implementation of IService::stop

Definition at line 197 of file MinimalEventLoopMgr.cpp.

{

  StatusCode sc( StatusCode::SUCCESS, true );

  // 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();
}

StatusCode MinimalEventLoopMgr::stopRun ( )

override

implementation of IEventProcessor::stopRun( )

Definition at line 483 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;
}

void MinimalEventLoopMgr::topAlgHandler

(

Gaudi::Details::PropertyBase &

p

)

Top algorithm List handler.

Definition at line 497 of file MinimalEventLoopMgr.cpp.

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

Member Data Documentation

bool MinimalEventLoopMgr::m_abortEvent = false

protected

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

Definition at line 61 of file MinimalEventLoopMgr.h.

SmartIF<IIncidentListener> MinimalEventLoopMgr::m_abortEventListener

protected

Instance of the incident listener waiting for AbortEvent.

Definition at line 58 of file MinimalEventLoopMgr.h.

std::string MinimalEventLoopMgr::m_abortEventSource

protected

Source of the AbortEvent incident.

Definition at line 63 of file MinimalEventLoopMgr.h.

SmartIF<IAlgExecStateSvc> MinimalEventLoopMgr::m_aess

protected

List of top level algorithms.

Definition at line 49 of file MinimalEventLoopMgr.h.

SmartIF<IAppMgrUI> MinimalEventLoopMgr::m_appMgrUI

protected

Reference to the IAppMgrUI interface of the application manager.

Definition at line 45 of file MinimalEventLoopMgr.h.

SmartIF<IIncidentSvc> MinimalEventLoopMgr::m_incidentSvc

protected

Reference to the incident service.

Definition at line 47 of file MinimalEventLoopMgr.h.

size_t MinimalEventLoopMgr::m_nevt {0}

private

Definition at line 123 of file MinimalEventLoopMgr.h.

ListAlg MinimalEventLoopMgr::m_outStreamList

protected

List of output streams.

Definition at line 52 of file MinimalEventLoopMgr.h.

Gaudi::Property<std::vector<std::string> > MinimalEventLoopMgr::m_outStreamNames {this, "OutStream", {}, "list of output stream names"}

protected

Definition at line 36 of file MinimalEventLoopMgr.h.

Gaudi::Property<std::string> MinimalEventLoopMgr::m_outStreamType

protected

Initial value:

{this, "OutStreamType", "OutputStream",
                                               "[[deprecated]] default type for OutputStream instances"}

Definition at line 37 of file MinimalEventLoopMgr.h.

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

bool MinimalEventLoopMgr::m_scheduledStop = false

protected

Scheduled stop of event processing.

Definition at line 56 of file MinimalEventLoopMgr.h.

State MinimalEventLoopMgr::m_state = OFFLINE

protected

State of the object.

Definition at line 54 of file MinimalEventLoopMgr.h.

ListAlg MinimalEventLoopMgr::m_topAlgList

protected

Definition at line 50 of file MinimalEventLoopMgr.h.

Gaudi::Property<std::vector<std::string> > MinimalEventLoopMgr::m_topAlgNames {this, "TopAlg", {}, "list of top level algorithms names"}

protected

Definition at line 35 of file MinimalEventLoopMgr.h.

SmartIF<IHiveWhiteBoard> MinimalEventLoopMgr::m_WB

private

Definition at line 120 of file MinimalEventLoopMgr.h.

---

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

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