ApplicationMgr Class Reference

The Application Manager class. More...

#include <src/ApplicationMgr/ApplicationMgr.h>

Inheritance diagram for ApplicationMgr:

Collaboration diagram for ApplicationMgr:

Public Types
typedef std::list< std::pair< IService *, int > >	ListSvc
typedef std::vector< std::string >	VectorName
Public Types inherited from CommonMessaging< implements4< IAppMgrUI, IEventProcessor, IService, IStateful > >
using	base_class = CommonMessaging
using	base_class = CommonMessaging

Public Member Functions
	ApplicationMgr (IInterface *=nullptr)
	~ApplicationMgr () override=default
StatusCode	queryInterface (const InterfaceID &iid, void **pinterface) override
StatusCode	run () override
StatusCode	configure () override
StatusCode	terminate () override
StatusCode	initialize () override
StatusCode	start () override
StatusCode	stop () override
StatusCode	finalize () override
StatusCode	nextEvent (int maxevt) override
const std::string &	name () const override
StatusCode	executeEvent (void *par) override
	implementation of IEventProcessor::executeEvent(void*) More...
StatusCode	executeRun (int evtmax) override
	implementation of IEventProcessor::executeRun(int) More...
StatusCode	stopRun () override
	implementation of IEventProcessor::stopRun() More...
Gaudi::StateMachine::State	FSMState () const override
Gaudi::StateMachine::State	targetFSMState () const override
StatusCode	reinitialize () override
StatusCode	restart () override
StatusCode	sysInitialize () override
StatusCode	sysStart () override
StatusCode	sysStop () override
StatusCode	sysFinalize () override
StatusCode	sysReinitialize () override
StatusCode	sysRestart () override
void	SIGoHandler (Property &theProp)
void	SIExitHandler (Property &theProp)
template<class I >
SmartIF< IComponentManager > &	getManager ()
SmartIF< ISvcManager > &	svcManager ()
SmartIF< IAlgManager > &	algManager ()
SmartIF< ISvcLocator > &	serviceLocator () const override
	Needed to locate the message service. More...
Property handlers
void	evtLoopPropertyHandler (Property &theProp)
StatusCode	decodeExtSvcNameList ()
StatusCode	decodeCreateSvcNameList ()
void	createSvcNameListHandler (Property &)
void	extSvcNameListHandler (Property &theProp)
StatusCode	decodeMultiThreadSvcNameList ()
void	multiThreadSvcNameListHandler (Property &theProp)
StatusCode	decodeDllNameList ()
void	dllNameListHandler (Property &theProp)
void	pluginDebugPropertyHandler (Property &theProp)
void	initLoopCheckHndlr (Property &)
Public Member Functions inherited from CommonMessaging< implements4< IAppMgrUI, IEventProcessor, IService, IStateful > >
	~CommonMessaging () override=default
	Virtual destructor. More...
	~CommonMessaging () override=default
	Virtual destructor. More...
SmartIF< IMessageSvc > &	msgSvc () const
	The standard message service. More...
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 &	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 &	always () const
	shortcut for the method msgStream(MSG::ALWAYS) More...
MsgStream &	fatal () const
	shortcut for the method msgStream(MSG::FATAL) More...
MsgStream &	fatal () const
	shortcut for the method msgStream(MSG::FATAL) More...
MsgStream &	err () const
	shortcut for the method msgStream(MSG::ERROR) More...
MsgStream &	err () const
	shortcut for the method msgStream(MSG::ERROR) More...
MsgStream &	error () 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 &	warning () const
	shortcut for the method msgStream(MSG::WARNING) More...
MsgStream &	info () const
	shortcut for the method msgStream(MSG::INFO) More...
MsgStream &	info () const
	shortcut for the method msgStream(MSG::INFO) More...
MsgStream &	debug () const
	shortcut for the method msgStream(MSG::DEBUG) More...
MsgStream &	debug () const
	shortcut for the method msgStream(MSG::DEBUG) More...
MsgStream &	verbose () const
	shortcut for the method msgStream(MSG::VERBOSE) More...
MsgStream &	verbose () const
	shortcut for the method msgStream(MSG::VERBOSE) More...
MsgStream &	msg () const
	shortcut for the method msgStream(MSG::INFO) More...
MsgStream &	msg () const
	shortcut for the method msgStream(MSG::INFO) More...
MSG::Level	msgLevel () const
	get the output level from the embedded MsgStream More...
bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream More...
MSG::Level	msgLevel () const
	get the output level from the embedded MsgStream More...
bool	msgLevel (MSG::Level lvl) const
	get the output level from the embedded MsgStream More...

Protected Types
typedef std::map< unsigned long, SmartIF< IComponentManager > >	ManagersMap
	Typedef for the map of component managers, the key is the "id" field of the basic InterfaceID of the managed components. More...

Protected Member Functions
StatusCode	declareMultiSvcType (const std::string &name, const std::string &type)
	declare one or more copies of svc type/name as determined by NoOfThreads More...
StatusCode	addMultiSvc (const Gaudi::Utils::TypeNameString &typeName, int prio)
	add one or more copies of svc type/name as determined by NoOfThreads More...
void	setServiceManager (ISvcManager *) override
StatusCode	i_startup ()
	Internal startup routine. More...
StatusCode	GoToState (Gaudi::StateMachine::State state, bool ignoreFailures=false)
	Reach a state from current state (whichever it is) going through the correct transitions. More...
Protected Member Functions inherited from CommonMessaging< implements4< IAppMgrUI, IEventProcessor, IService, IStateful > >
void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream. More...
void	updateMsgStreamOutputLevel (int level)
	Update the output level of the cached MsgStream. More...

Protected Attributes
ManagersMap	m_managers
	Map of known component managers. More...
StringArrayProperty	m_declaredManagers
	Property to declare the list of known managers. More...
SmartIF< ISvcManager >	m_svcManager
	Cached pointer to the manager of services. More...
SmartIF< IAlgManager >	m_algManager
	Cached pointer to the manager of algorithms. More...
SmartIF< ISvcLocator >	m_svcLocator
	Reference to its own service locator (must be instantiated prior to any service!) More...
SmartIF< DLLClassManager >	m_classManager
	Reference to the class manager. More...
SmartIF< PropertyMgr >	m_propertyMgr
	Reference to Property Manager. More...
IntegerProperty	m_SIGo
	For SI's "Go" command via callback. More...
IntegerProperty	m_SIExit
	For SI's "Exit" command via callback. More...
StringArrayProperty	m_topAlgNameList
	List of top level algorithms names. More...
StringArrayProperty	m_outStreamNameList
	List of output stream names. More...
StringProperty	m_outStreamType
	Output stream type (obsolete?) More...
StringProperty	m_messageSvcType
	MessageSvc type. More...
StringProperty	m_jobOptionsSvcType
	JobOptionsSvc type. More...
std::string	m_name = "ApplicationMgr"
	Name. More...
Gaudi::StateMachine::State	m_state = Gaudi::StateMachine::OFFLINE
	Internal State. More...
Gaudi::StateMachine::State	m_targetState = Gaudi::StateMachine::OFFLINE
	Internal State. More...
VectorName	m_defServices
	Vector default services names. More...
VectorName	m_svcMapping
	Default mapping of services. More...
VectorName	m_svcOptMapping
	Default mapping of services. More...
SmartIF< IMessageSvc >	m_messageSvc
	Reference to the message service. More...
SmartIF< IRunable >	m_runable
	Reference to the runable object. More...
SmartIF< IEventProcessor >	m_processingMgr
	Reference to processing manager object. More...
SmartIF< IJobOptionsSvc >	m_jobOptionsSvc
	Reference to JobOption service. More...
int	m_evtMax
	Number of events to be processed. More...
StringArrayProperty	m_extSvcNameList
	List of external services names. More...
BooleanProperty	m_extSvcCreates
	LHCb or ATLAS defn of "ExtSvc". More...
StringArrayProperty	m_multiThreadSvcNameList
	List of external services names for which we want a copy per evt thread. More...
int	m_noOfEvtThreads
	no of multiThreadSvc copies More...
StringArrayProperty	m_dllNameList
	List of DDL's names. More...
std::string	m_jobOptionsType
	Source type (e.g. dbase, file...) More...
std::string	m_jobOptionsPath
	The "file" to look for properties. More...
std::string	m_jobOptionsPreAction
	additional command to run on config More...
std::string	m_jobOptionsPostAction
	additional command to run on config More...
std::string	m_runableType
	Runable type. More...
std::string	m_eventLoopMgr
	Processing manager type. More...
std::string	m_evtsel
	Event selection. More...
std::string	m_histPersName
	CGL: Name of the Hist Pers Svc. More...
int	m_outputLevel
	Message output level. More...
std::string	m_appName
	The name of the application. More...
std::string	m_appVersion
	The version of the application. More...
bool	m_actHistory
	Activate HistorySvc. More...
bool	m_codeCheck
	Activate StatusCode checking. More...
IntegerProperty	m_pluginDebugLevel
	Debug level for the plugin system. More...
StringArrayProperty	m_createSvcNameList
BooleanProperty	m_auditTools
	Defaults for auditors. More...
BooleanProperty	m_auditSvcs
BooleanProperty	m_auditAlgs
std::map< std::string, std::string >	m_environment
	Environment variables to set. More...
BooleanProperty	m_loopCheck
	For ServiceMgr initialization loop checking. More...
BooleanProperty	m_stopOnSignal
	Property to enable/disable the "stop on signal" service (enabled by default). More...
BooleanProperty	m_stalledEventMonitoring
	Property to enable/disable the monitoring and reporting of stalled events (enabled by default). More...
bool	m_propertiesPrint
	flag to activate the printout of properties More...
IntegerProperty	m_returnCode
	Property to record the error conditions occurring during the running. More...
bool	m_useHiveAlgorithmManager
Protected Attributes inherited from CommonMessaging< implements4< IAppMgrUI, IEventProcessor, IService, IStateful > >
SmartIF< IMessageSvc >	m_msgsvc
	Pointer to the message service;. More...
std::unique_ptr< MsgStream >	m_msgStream
	The predefined message stream. More...
bool	m_streamWithService
	Flag to create a new MsgStream if it was created without the message service. More...

Private Types
typedef CommonMessaging< implements4< IAppMgrUI, IEventProcessor, IService, IStateful > >	base_class

Private Attributes
std::vector< std::string >	m_okDlls
	names of successfully loaded dlls More...

Detailed Description

The Application Manager class.

The main purpose of the Application Manager is to steer any data processing application. This includes all data processing applications for LHCb data in all stages: simulation, reconstruction, analysis, high level triggers, etc. Specific implementations of the ApplicationMgr will be developed to cope with the different environments (on-line, off-line, interactive, batch, etc.).

Author

Pere Mato

Definition at line 46 of file ApplicationMgr.h.

Member Typedef Documentation

typedef CommonMessaging<implements4<IAppMgrUI, IEventProcessor, IService, IStateful> > ApplicationMgr::base_class

private

Definition at line 53 of file ApplicationMgr.h.

typedef std::list<std::pair<IService*,int> > ApplicationMgr::ListSvc

Definition at line 55 of file ApplicationMgr.h.

typedef std::map<unsigned long, SmartIF<IComponentManager> > ApplicationMgr::ManagersMap

protected

Typedef for the map of component managers, the key is the "id" field of the basic InterfaceID of the managed components.

Definition at line 182 of file ApplicationMgr.h.

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

Definition at line 56 of file ApplicationMgr.h.

Constructor & Destructor Documentation

ApplicationMgr::ApplicationMgr

(

IInterface *

= nullptr

)

Definition at line 53 of file ApplicationMgr.cpp.

{
  // IInterface initialization
  addRef(); // Initial count set to 1

  // Instantiate component managers
  m_managers[IService::interfaceID().id()] = new ServiceManager(this);

  m_propertyMgr  = new PropertyMgr(this);
  m_svcLocator = svcManager();

  // Instantiate internal services
  // SvcLocator/Factory HAS to be already instantiated
  m_classManager = new DLLClassManager(this);

  AlgorithmManager *algMgr = new AlgorithmManager(this);
  m_managers[IAlgorithm::interfaceID().id()] = algMgr;
  //  m_managers[IAlgorithm::interfaceID().id()] = new HiveAlgorithmManager(this);

  m_propertyMgr->declareProperty("Go",            m_SIGo = 0 );
  m_propertyMgr->declareProperty("Exit",          m_SIExit = 0 );
  m_propertyMgr->declareProperty("Dlls",          m_dllNameList );
  m_propertyMgr->declareProperty("ExtSvc",        m_extSvcNameList );
  m_propertyMgr->declareProperty("CreateSvc",     m_createSvcNameList );
  m_propertyMgr->declareProperty("ExtSvcCreates", m_extSvcCreates=true );

  m_propertyMgr->declareProperty("SvcMapping",    m_svcMapping );
  m_propertyMgr->declareProperty("SvcOptMapping", m_svcOptMapping );

  m_propertyMgr->declareProperty("TopAlg",        m_topAlgNameList );
  m_propertyMgr->declareProperty("OutStream",     m_outStreamNameList );
  m_propertyMgr->declareProperty("OutStreamType", m_outStreamType = "OutputStream" );
  m_propertyMgr->declareProperty("MessageSvcType",m_messageSvcType= "MessageSvc" );
  m_propertyMgr->declareProperty("JobOptionsSvcType",
                                 m_jobOptionsSvcType = "JobOptionsSvc" );
  m_propertyMgr->declareProperty( s_runable,      m_runableType   = "AppMgrRunable");
  m_propertyMgr->declareProperty( s_eventloop,    m_eventLoopMgr  = "EventLoopMgr");

  m_propertyMgr->declareProperty("HistogramPersistency", m_histPersName="NONE");

  // Declare Job Options Service properties and set default
  m_propertyMgr->declareProperty("JobOptionsType", m_jobOptionsType = "FILE");
  m_propertyMgr->declareProperty("JobOptionsPath", m_jobOptionsPath = "");
  m_propertyMgr->declareProperty("JobOptionsPostAction", m_jobOptionsPostAction = "");
  m_propertyMgr->declareProperty("JobOptionsPreAction", m_jobOptionsPreAction = "");
  m_propertyMgr->declareProperty("EvtMax",         m_evtMax = -1);
  m_propertyMgr->declareProperty("EvtSel",         m_evtsel );
  m_propertyMgr->declareProperty("OutputLevel",    m_outputLevel = MSG::INFO);

  m_propertyMgr->declareProperty("MultiThreadExtSvc", m_multiThreadSvcNameList);
  m_propertyMgr->declareProperty("NoOfThreads",    m_noOfEvtThreads = 0);
  m_propertyMgr->declareProperty("AppName",        m_appName = "ApplicationMgr");
  m_propertyMgr->declareProperty("AppVersion",     m_appVersion = "");

  m_propertyMgr->declareProperty("AuditTools",      m_auditTools = false);
  m_propertyMgr->declareProperty("AuditServices",   m_auditSvcs = false);
  m_propertyMgr->declareProperty("AuditAlgorithms", m_auditAlgs = false);

  m_propertyMgr->declareProperty("ActivateHistory", m_actHistory = false);
  m_propertyMgr->declareProperty("StatusCodeCheck", m_codeCheck = false);

  m_propertyMgr->declareProperty("Environment",    m_environment);

  // ServiceMgr Initialization loop checking
  m_propertyMgr->declareProperty("InitializationLoopCheck", m_loopCheck = true)
    ->declareUpdateHandler(&ApplicationMgr::initLoopCheckHndlr, this);
  svcManager()->setLoopCheckEnabled(m_loopCheck);

  // Flag to activate the printout of properties
  m_propertyMgr->declareProperty
    ( "PropertiesPrint",
      m_propertiesPrint = false,
      "Flag to activate the printout of properties" );

  m_propertyMgr->declareProperty("PluginDebugLevel", m_pluginDebugLevel = 0 );

  m_propertyMgr->declareProperty("StopOnSignal", m_stopOnSignal = false,
      "Flag to enable/disable the signal handler that schedule a stop of the event loop");

  m_propertyMgr->declareProperty("StalledEventMonitoring", m_stalledEventMonitoring = false,
      "Flag to enable/disable the monitoring and reporting of stalled events");

  m_propertyMgr->declareProperty("ReturnCode", m_returnCode = Gaudi::ReturnCode::Success,
      "Return code of the application. Set internally in case of error conditions.");

  m_propertyMgr->declareProperty("AlgTypeAliases", algMgr->typeAliases(),
      "Aliases of algorithm types, to replace an algorithm type for every instance");

  // Add action handlers to the appropriate properties
  m_SIGo.declareUpdateHandler  ( &ApplicationMgr::SIGoHandler         , this );
  m_SIExit.declareUpdateHandler( &ApplicationMgr::SIExitHandler       , this );
  m_topAlgNameList.declareUpdateHandler(&ApplicationMgr::evtLoopPropertyHandler, this);
  m_outStreamNameList.declareUpdateHandler(&ApplicationMgr::evtLoopPropertyHandler, this);
  m_outStreamType.declareUpdateHandler(&ApplicationMgr::evtLoopPropertyHandler, this);
  m_pluginDebugLevel.declareUpdateHandler(&ApplicationMgr::pluginDebugPropertyHandler, this);

  m_svcMapping.insert( std::end(m_svcMapping),
                     { "EvtDataSvc/EventDataSvc",
                       "DetDataSvc/DetectorDataSvc",
                       "HistogramSvc/HistogramDataSvc",
                       "HbookCnv::PersSvc/HbookHistSvc",
                       "RootHistCnv::PersSvc/RootHistSvc",
                       "EvtPersistencySvc/EventPersistencySvc",
                       "DetPersistencySvc/DetectorPersistencySvc",
                       "HistogramPersistencySvc/HistogramPersistencySvc" } );
}

ApplicationMgr::~ApplicationMgr ( )

overridedefault

Member Function Documentation

StatusCode ApplicationMgr::addMultiSvc ( const Gaudi::Utils::TypeNameString &  typeName, int  prio  )

protected

add one or more copies of svc type/name as determined by NoOfThreads

Definition at line 1168 of file ApplicationMgr.cpp.

                                                 {
  using Gaudi::Utils::TypeNameString;
  StatusCode result = StatusCode::SUCCESS;
  MsgStream log( m_messageSvc, m_name );
  if (0 == m_noOfEvtThreads) {
    result = svcManager()->addService(typeName, prio);
    // result = svcManager()->addService(name, type, prio); // CHECKME???
    if( result.isFailure() ) {
      log << MSG::ERROR << "addMultiSvc: Cannot add service "
          << typeName.type() << "/" << typeName.name() << endmsg;
    } else {
      ON_VERBOSE
        log << MSG::VERBOSE << "addMultiSvc: added service "
            << typeName.type() << "/" << typeName.name() << endmsg;
    }
  } else {
    for(int iCopy=0; iCopy<m_noOfEvtThreads; ++iCopy) {
      const std::string &type = typeName.type();
      std::string thrName(typeName.name() + getGaudiThreadIDfromID(iCopy));
      result = svcManager()->addService(TypeNameString(thrName, type), prio);
      if( result.isFailure() ) {
        log << MSG::ERROR << "addMultiSvc: Cannot add service "
            << type << "/" << thrName << endmsg;
      } else {
        ON_VERBOSE
          log << MSG::VERBOSE << "addMultiSvc: added service "
              << type << "/" << thrName << endmsg;
      }
    }
  }
  return result;
}

SmartIF<IAlgManager>& ApplicationMgr::algManager ( )

inline

Definition at line 147 of file ApplicationMgr.h.

                                            {
    // Cache the casted pointer to IAlgManager
    if (!m_algManager) {
      m_algManager = getManager<IAlgorithm>();
    }
    return m_algManager;
  }

StatusCode ApplicationMgr::configure ( )

override

Definition at line 311 of file ApplicationMgr.cpp.

                                     {

  // Check if the state is compatible with the transition
  MsgStream tlog( m_messageSvc, name() );
  if( Gaudi::StateMachine::CONFIGURED == m_state ) {
    tlog << MSG::INFO << "Already Configured" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( Gaudi::StateMachine::OFFLINE != m_state ) {
    tlog << MSG::FATAL
         << "configure: Invalid state \""  << m_state << "\"" << endmsg;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::CONFIGURED;

  // Reset application return code.
  m_returnCode = Gaudi::ReturnCode::Success;

  StatusCode  sc;
  sc = i_startup();
  if ( !sc.isSuccess() )    {
    return sc;
  }

  MsgStream log( m_messageSvc, name() );

  // Get my own options using the Job options service
  if (log.level() <= MSG::DEBUG)
    log << MSG::DEBUG << "Getting my own properties" << endmsg;
  sc = m_jobOptionsSvc->setMyProperties( name(), m_propertyMgr );
  if( !sc.isSuccess() ) {
    log << MSG::WARNING << "Problems getting my properties from JobOptionsSvc"
        << endmsg;
    return sc;
  }

  // Check current outputLevel to eventually inform the MessageSvc
  if( m_outputLevel != MSG::NIL && !m_appName.empty() ) {
    assert(m_messageSvc);
    m_messageSvc->setOutputLevel( name(), m_outputLevel );
    // Print a welcome message
    log << MSG::ALWAYS
        << std::endl
        << "=================================================================="
        << "=================================================================="
        << std::endl
        << "                                "
        << "                   Welcome to " << m_appName;

    if( "" != m_appVersion ) {
      log << MSG::ALWAYS << " version " << m_appVersion;
    }
    else {
      log << MSG::ALWAYS
          << " (GaudiCoreSvc "
          << "v" << GAUDICORESVC_MAJOR_VERSION
          << "r" << GAUDICORESVC_MINOR_VERSION
#if GAUDICORESVC_PATCH_VERSION
          << "p" << GAUDICORESVC_PATCH_VERSION
#endif
          << ")";
    }

    // Add the host name and current time to the message
    log << MSG::ALWAYS
        << std::endl
        << "                                "
        << "          running on " << System::hostName()
        << " on " << Gaudi::Time::current().format(true) << std::endl
        << "=================================================================="
        << "=================================================================="
        << endmsg;
  }

  // print all own properties if the options "PropertiesPrint" is set to true
  if ( m_propertiesPrint )
  {
    const auto& properties = m_propertyMgr->getProperties() ;
    log << MSG::ALWAYS
        << "List of ALL properties of "
        << System::typeinfoName ( typeid( *this ) ) << "/" << this->name()
        << "  #properties = " << properties.size() << endmsg ;
    for ( const auto& property : properties )
    { log << "Property ['Name': Value] = " <<  *property << endmsg ; }
  }

  // Check if StatusCode need to be checked
  if (m_codeCheck) {
    StatusCode::enableChecking();
    sc = addMultiSvc("StatusCodeSvc", -9999);
    if ( sc.isFailure() ) {
      log << MSG::FATAL << "Error adding StatusCodeSvc for multiple threads" << endmsg;
      return StatusCode::FAILURE;
    }
  } else {
    StatusCode::disableChecking();
  }

  // set the requested environment variables
  for ( auto& var : m_environment ) {
    const std::string &name  = var.first;
    const std::string &value = var.second;
    std::string old = System::getEnv(name.c_str());
    const MSG::Level lvl = (!old.empty() && (old != "UNKNOWN" ))
        ? MSG::WARNING
        : MSG::DEBUG;
    if (UNLIKELY(m_outputLevel <= lvl))
      log << lvl << "Setting " << name << " = " << value << endmsg;
    System::setEnv(name,value);
  }

  //Declare Service Types
  for(auto& j : m_svcMapping)  {
    Gaudi::Utils::TypeNameString itm(j);
    if ( declareMultiSvcType(itm.name(), itm.type()).isFailure() )  {
      log << MSG::ERROR << "configure: declaring svc type:'" << j << "' failed." << endmsg;
      return StatusCode::FAILURE;
    }
  }
  for(auto& j : m_svcOptMapping)  {
    Gaudi::Utils::TypeNameString itm(j);
    if ( declareMultiSvcType(itm.name(), itm.type()).isFailure() )  {
      log << MSG::ERROR << "configure: declaring svc type:'" << j << "' failed." << endmsg;
      return StatusCode::FAILURE;
    }
  }

  //--------------------------------------------------------------------------
  // Declare other Services and Algorithms by loading DLL's
  sc = decodeDllNameList( );
  if ( sc.isFailure( ) ) {
    log << MSG::ERROR << "Failure loading declared DLL's" << endmsg;
    return sc;
  }

  //--------------------------------------------------------------------------
  // Deal with the services explicitly declared by the user.
  sc = decodeExtSvcNameList();
  if ( sc.isFailure( ) ) {
    log << MSG::ERROR << "Failure during external service association" << endmsg;
    return sc;
  }

  sc = decodeMultiThreadSvcNameList( );
  if ( sc.isFailure( ) ) {
    log << MSG::ERROR << "Failure during multi thread service creation"
        << endmsg;
    return sc;
  }

  sc = decodeCreateSvcNameList();
  if ( sc.isFailure( ) ) {
    log << MSG::ERROR << "Failure during external service creation" << endmsg;
    return sc;
  }


  //--------------------------------------------------------------------------
  // Retrieve intrinsic services. If needed configure them.
  //--------------------------------------------------------------------------
  Gaudi::Utils::TypeNameString evtloop_item(m_eventLoopMgr);
  sc = addMultiSvc(evtloop_item, ServiceManager::DEFAULT_SVC_PRIORITY*10);
  if( !sc.isSuccess() )  {
    log << MSG::FATAL << "Error adding :" << m_eventLoopMgr << endmsg;
    return sc;
  }

  if (m_noOfEvtThreads == 0) {
    m_runable = m_svcLocator->service(m_runableType);
    if( !m_runable )  {
      log << MSG::FATAL
          << "Error retrieving Runable:" << m_runableType
          << "\n Check option ApplicationMgr." << s_runable << endmsg;
      return sc;
    }
    m_processingMgr = m_svcLocator->service(evtloop_item);
    if( !m_processingMgr )  {
      log << MSG::FATAL
          << "Error retrieving Processing manager:" << m_eventLoopMgr
          << "\n Check option ApplicationMgr." << s_eventloop
          << "\n No events will be processed." << endmsg;
      return sc;
    }
  }

  // Establish Update Handlers for ExtSvc and DLLs Properties
  m_extSvcNameList.declareUpdateHandler (&ApplicationMgr::extSvcNameListHandler,
                                         this);
  m_createSvcNameList.declareUpdateHandler (&ApplicationMgr::createSvcNameListHandler,
                                         this);
  m_multiThreadSvcNameList.declareUpdateHandler
    (&ApplicationMgr::multiThreadSvcNameListHandler, this);
  m_dllNameList.declareUpdateHandler (&ApplicationMgr::dllNameListHandler,
                                      this );

  if (m_actHistory) {
    // Create HistorySvc with a priority to ensure it's initialized last, finalized first
    sc = svcManager()->addService("HistorySvc",std::numeric_limits<int>::max());
    if ( sc.isFailure() ) {
      log << MSG::FATAL << "Error adding HistorySvc" << endmsg;
      return StatusCode::FAILURE;
    }

    if (m_noOfEvtThreads > 0) {
      sc = addMultiSvc("HistorySvc",std::numeric_limits<int>::max());
      if ( sc.isFailure() ) {
        log << MSG::FATAL << "Error adding HistorySvc for multiple threads"
            << endmsg;
        return StatusCode::FAILURE;
      }
    }
  }

  log << MSG::INFO << "Application Manager Configured successfully" << endmsg;
  m_state = m_targetState;
  return StatusCode::SUCCESS;
}

void ApplicationMgr::createSvcNameListHandler

(

Property &

)

Definition at line 1019 of file ApplicationMgr.cpp.

                                                           {
  if ( !(decodeCreateSvcNameList()).isSuccess() ) {
    throw GaudiException("Failed to create ext services",
                         "MinimalEventLoopMgr::createSvcNameListHandler",
                         StatusCode::FAILURE);
  }
}

StatusCode ApplicationMgr::declareMultiSvcType ( const std::string &  name, const std::string &  type  )

protected

declare one or more copies of svc type/name as determined by NoOfThreads

Definition at line 1135 of file ApplicationMgr.cpp.

                                                                      {
  StatusCode result = StatusCode::SUCCESS;
  MsgStream log( m_messageSvc, m_name );
  if (0 == m_noOfEvtThreads) {
    result = svcManager()->declareSvcType(name, type);
    if( result.isFailure() ) {
      log << MSG::ERROR << "declareMultiSvcType: Cannot declare service "
          << type << "/" << name << endmsg;
    } else {
      ON_VERBOSE
        log << MSG::VERBOSE << "declareMultiSvcType: declared service "
            << type << "/" << name << endmsg;
    }
  } else {
    for(int iCopy=0; iCopy<m_noOfEvtThreads; ++iCopy) {
      std::string thrName(name + getGaudiThreadIDfromID(iCopy));
      result = svcManager()->declareSvcType(thrName, type);
      if( result.isFailure() ) {
        log << MSG::ERROR << "declareMultiSvcType: Cannot declare service "
            << type << "/" << thrName << endmsg;
      } else {
        ON_VERBOSE
          log << MSG::VERBOSE << "declareMultiSvcType: declared service "
              << type << "/" << thrName << endmsg;
      }
    }
  }
  return result;
}

StatusCode ApplicationMgr::decodeCreateSvcNameList

(

)

Definition at line 1029 of file ApplicationMgr.cpp.

                                                   {
  StatusCode result = StatusCode::SUCCESS;
  const auto& theNames = m_createSvcNameList.value( );
  auto it = theNames.begin();
  auto et = theNames.end();
  while(result.isSuccess() && it != et) {
    Gaudi::Utils::TypeNameString item(*it++);
    if( (result = svcManager()->addService(item, ServiceManager::DEFAULT_SVC_PRIORITY) ).isFailure()) {
      MsgStream log( m_messageSvc, m_name );
      log << MSG::ERROR << "decodeCreateSvcNameList: Cannot create service "
          << item.type() << "/" << item.name() << endmsg;
    } else {
      ON_DEBUG {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::DEBUG << "decodeCreateSvcNameList: Created service "
            << item.type() << "/" << item.name() << endmsg;
      }
    }
  }
  return result;
}

StatusCode ApplicationMgr::decodeDllNameList

(

)

Definition at line 1216 of file ApplicationMgr.cpp.

                                             {

  MsgStream log( m_messageSvc, m_name );
  StatusCode result = StatusCode::SUCCESS;

  // Clean up multiple entries from DLL list
  // -------------------------------------------------------------------------
  std::vector<std::string> newList;
  std::map<std::string,unsigned int> dllInList, duplicateList;
  {for ( const auto it : m_dllNameList.value()) {
    if ( 0 == dllInList[it] ) {
      newList.push_back(it);        // first instance of this module
    } else { ++duplicateList[it]; } // module listed multiple times
    ++dllInList[it];                // increment count for this module
  }}
  //m_dllNameList = newList; // update primary list to new, filtered list (do not use the
                             // property itself otherwise we get called again infinitely)
  // List modules that were in there twice..
  ON_DEBUG if ( !duplicateList.empty() ) {
    log << MSG::DEBUG << "Removed duplicate entries for modules : ";
    for ( auto it = duplicateList.begin(); it != duplicateList.end(); ++it ) {
      log << it->first << "(" << 1+it->second << ")";
      if ( it != --duplicateList.end() ) log << ", ";
    }
    log << endmsg;
  }
  // -------------------------------------------------------------------------

  const std::vector<std::string>& theNames = newList;

  // only load the new dlls or previously failed dlls
  ON_DEBUG log << MSG::DEBUG << "Loading declared DLL's" << endmsg;

  std::vector<std::string> successNames, failNames;
  for (const auto& it : theNames) {
    if (std::find (m_okDlls.rbegin(), m_okDlls.rend(), it) == m_okDlls.rend()){
      // found a new module name
      StatusCode status = m_classManager->loadModule( it );
      if( status.isFailure() ) {
        failNames.push_back(it);
        result = StatusCode::FAILURE;
      }
      else {
        successNames.push_back(it);
      }
    }
  }

  // report back to the user and store the names of the succesfully loaded dlls
  if ( !successNames.empty() ) {
    log << MSG::INFO << "Successfully loaded modules : ";
    for (auto it = successNames.begin(); it != successNames.end(); it++) {
      log<< (*it);
      if( (it+1) != successNames.end())  log << ", ";
      // save name
      m_okDlls.push_back( *it );
    }
    log << endmsg;
  }

  if ( result == StatusCode::FAILURE ) {
    log << MSG::WARNING << "Failed to load modules: ";
    for (auto it = failNames.begin(); it != failNames.end(); it++) {
      log<< (*it);
      if( (it+1) != failNames.end())  log << ", ";
    }
    log << endmsg;
  }
  return result;
}

StatusCode ApplicationMgr::decodeExtSvcNameList

(

)

Definition at line 1065 of file ApplicationMgr.cpp.

                                                 {
  StatusCode result = StatusCode::SUCCESS;

  const auto& theNames = m_extSvcNameList.value( );

  auto it = theNames.begin();
  auto et = theNames.end();
  while(result.isSuccess() && it != et) {
    Gaudi::Utils::TypeNameString item(*it++);
    if (m_extSvcCreates) {
      if ( (result = svcManager()->addService(item, ServiceManager::DEFAULT_SVC_PRIORITY)).isFailure()) {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::ERROR << "decodeExtSvcNameList: Cannot create service "
            << item.type() << "/" << item.name() << endmsg;
      }
    } else {
      if( ( result = svcManager()->declareSvcType(item.name(),
                                                  item.type()) ).isFailure()) {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::ERROR << "decodeExtSvcNameList: Cannot declare service "
            << item.type() << "/" << item.name() << endmsg;
      }
    }
  }
  return result;
}

StatusCode ApplicationMgr::decodeMultiThreadSvcNameList

(

)

Definition at line 1107 of file ApplicationMgr.cpp.

                                                         {
  StatusCode result = StatusCode::SUCCESS;
  const auto& theNames = m_multiThreadSvcNameList.value( );
  for(int iCopy=0; iCopy<m_noOfEvtThreads; ++iCopy) {
    for (const auto& it : theNames ) {
      Gaudi::Utils::TypeNameString item(it);
      result = addMultiSvc(item, ServiceManager::DEFAULT_SVC_PRIORITY);
      //FIXME SHOULD CLONE?
      if( result.isFailure() ) {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::ERROR
            << "decodeMultiThreadSvcNameList: Cannot create service "
            << item.type() << "/" << item.name() << endmsg;
      } else {
        ON_VERBOSE {
          MsgStream log( m_messageSvc, m_name );
          log << MSG::VERBOSE
              << "decodeMultiThreadSvcNameList: created service "
              << item.type() << "/" << item.name() << endmsg;
        }
      }
    }
  }
  return result;
}

void ApplicationMgr::dllNameListHandler

(

Property &

theProp

)

Definition at line 1205 of file ApplicationMgr.cpp.

                                                     {
  if ( !(decodeDllNameList( )).isSuccess() ) {
    throw GaudiException("Failed to load DLLs.",
                         "MinimalEventLoopMgr::dllNameListHandler",
                         StatusCode::FAILURE);
  }
}

void ApplicationMgr::evtLoopPropertyHandler

(

Property &

theProp

)

Definition at line 1009 of file ApplicationMgr.cpp.

                                                         {
  if ( m_processingMgr )    {
    auto props = m_processingMgr.as<IProperty>();
    if ( props ) props->setProperty( p ).ignore();
  }
}

StatusCode ApplicationMgr::executeEvent ( void *  par )

override

implementation of IEventProcessor::executeEvent(void*)

Definition at line 883 of file ApplicationMgr.cpp.

                                                    {
  MsgStream log( m_messageSvc, name() );
  if( m_state == Gaudi::StateMachine::RUNNING ) {
    if ( m_processingMgr )    {
      return m_processingMgr->executeEvent(par);
    }
  }
  log << MSG::FATAL << "executeEvent: Invalid state \"" << FSMState() << "\""
      <<endmsg;
  return StatusCode::FAILURE;
}

StatusCode ApplicationMgr::executeRun ( int  evtmax )

override

implementation of IEventProcessor::executeRun(int)

Definition at line 898 of file ApplicationMgr.cpp.

                                                   {
  MsgStream log( m_messageSvc, name() );
  if( m_state == Gaudi::StateMachine::RUNNING ) {
    if ( m_processingMgr )    {
      return m_processingMgr->executeRun(evtmax);
    }
    log << MSG::WARNING << "No EventLoop Manager specified " << endmsg;
    return StatusCode::SUCCESS;
  }
  log << MSG::FATAL << "executeRun: Invalid state \"" << FSMState() << "\""
      << endmsg;
  return StatusCode::FAILURE;
}

void ApplicationMgr::extSvcNameListHandler

(

Property &

theProp

)

Definition at line 1054 of file ApplicationMgr.cpp.

                                                        {
  if ( !(decodeExtSvcNameList( )).isSuccess() ) {
    throw GaudiException("Failed to declare ext services",
                         "MinimalEventLoopMgr::extSvcNameListHandler",
                         StatusCode::FAILURE);
  }
}

StatusCode ApplicationMgr::finalize ( )

override

Definition at line 677 of file ApplicationMgr.cpp.

                                    {
  MsgStream log( m_messageSvc, name() );
  if( m_state == Gaudi::StateMachine::CONFIGURED ) {
    log << MSG::INFO << "Already Finalized" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( m_state != Gaudi::StateMachine::INITIALIZED ) {
    log << MSG::FATAL << "finalize: Invalid state \"" << m_state << "\""
        << endmsg;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::CONFIGURED;

  // disable message suppression in finalize
  m_svcLocator->service<IProperty>("MessageSvc")->setProperty(BooleanProperty("enableSuppression", false)).ignore();

  // Finalize independently managed Algorithms
  StatusCode sc = algManager()->finalize();
  if (sc.isFailure()) {
    log << MSG::WARNING << "Failed to finalize an algorithm." << endmsg;
    m_returnCode = Gaudi::ReturnCode::FinalizationFailure;
  }

  // Finalize all Services
  sc = svcManager()->finalize();
  if (sc.isFailure()) {
    log << MSG::WARNING << "Failed to finalize a service." << endmsg;
    m_returnCode = Gaudi::ReturnCode::FinalizationFailure;
  }

  //svcManager()->removeService( (IService*) m_processingMgr.get() );
  //svcManager()->removeService( (IService*) m_runable.get() );

  if (m_codeCheck) {
    StatusCode::disableChecking();
  }

  if (sc.isSuccess()) {
    log << MSG::INFO << "Application Manager Finalized successfully" << endmsg;
  } else {
    log << MSG::ERROR << "Application Manager failed to finalize" << endmsg;
  }

  m_state = m_targetState;
  return sc;
}

Gaudi::StateMachine::State ApplicationMgr::FSMState ( ) const

override

Definition at line 934 of file ApplicationMgr.cpp.

                                                       {
  return m_state;
}

template<class I >

SmartIF<IComponentManager>& ApplicationMgr::getManager ( )

inline

Definition at line 135 of file ApplicationMgr.h.

                                           {
    return m_managers[I::interfaceID().id()];
  }

StatusCode ApplicationMgr::GoToState ( Gaudi::StateMachine::State  state, bool  ignoreFailures = false  )

protected

Reach a state from current state (whichever it is) going through the correct transitions.

By default, if a transition fails, the chain is interrupted, but the behavior can be changed with the parameter "gnoreFailures"

Definition at line 786 of file ApplicationMgr.cpp.

                                                                                      {
  StatusCode sc = StatusCode(StatusCode::SUCCESS,true);

  switch (state) {

  case Gaudi::StateMachine::OFFLINE:
    switch (m_state) {
    case Gaudi::StateMachine::OFFLINE    : return StatusCode::SUCCESS; break;
    case Gaudi::StateMachine::CONFIGURED : return terminate(); break;
    default: // Gaudi::StateMachine::INITIALIZED or Gaudi::StateMachine::RUNNING
      sc = GoToState(Gaudi::StateMachine::CONFIGURED);
      if (sc.isSuccess()) {
        return terminate();
      } break;
    } break;

  case Gaudi::StateMachine::CONFIGURED:
    switch (m_state) {
    case Gaudi::StateMachine::CONFIGURED  : return StatusCode::SUCCESS; break;
    case Gaudi::StateMachine::OFFLINE     : return configure(); break;
    case Gaudi::StateMachine::INITIALIZED : return finalize(); break;
    default: // Gaudi::StateMachine::RUNNING
      sc = GoToState(Gaudi::StateMachine::INITIALIZED);
      if (sc.isSuccess()) {
        return finalize();
      } break;
    } break;

  case Gaudi::StateMachine::INITIALIZED:
    switch (m_state) {
    case Gaudi::StateMachine::INITIALIZED : return StatusCode::SUCCESS; break;
    case Gaudi::StateMachine::CONFIGURED  : return initialize(); break;
    case Gaudi::StateMachine::RUNNING     : return stop(); break;
    default: // Gaudi::StateMachine::OFFLINE
      sc = GoToState(Gaudi::StateMachine::CONFIGURED);
      if (sc.isSuccess()) {
        return initialize();
      } break;
    } break;

  case Gaudi::StateMachine::RUNNING:
    switch (m_state) {
    case Gaudi::StateMachine::RUNNING     : return StatusCode::SUCCESS; break;
    case Gaudi::StateMachine::INITIALIZED : return start(); break;
    default: // Gaudi::StateMachine::OFFLINE or Gaudi::StateMachine::CONFIGURED
      sc = GoToState(Gaudi::StateMachine::INITIALIZED);
      if (sc.isSuccess()) {
        return start();
      } break;
    } break;

  }

  // If I get here, there has been a problem in the recursion

  if (ignoreFailures){
    // force the new state
    m_state = state;
    return StatusCode::SUCCESS;
  }

  return sc;
}

StatusCode ApplicationMgr::i_startup ( )

protected

Internal startup routine.

Definition at line 200 of file ApplicationMgr.cpp.

                                     {

  StatusCode  sc;

  // declare factories in current module
  m_classManager->loadModule("").ignore();

  // Create the Message service
  auto msgsvc = svcManager()->createService(Gaudi::Utils::TypeNameString("MessageSvc", m_messageSvcType));
  if( !msgsvc )  {
    fatal() << "Error creating MessageSvc of type " << m_messageSvcType << endmsg;
    return sc;
  }
  // Create the Job Options service
  auto jobsvc = svcManager()->createService(Gaudi::Utils::TypeNameString("JobOptionsSvc", m_jobOptionsSvcType));
  if( !jobsvc )   {
    fatal() << "Error creating JobOptionsSvc" << endmsg;
    return sc;
  }

  auto jobOptsIProp = jobsvc.as<IProperty>();
  if ( !jobOptsIProp )   {
    fatal() << "Error locating JobOptionsSvc" << endmsg;
    return sc;
  }
  sc = jobOptsIProp->setProperty( StringProperty("TYPE", m_jobOptionsType) );
  if( !sc.isSuccess() )   {
    fatal() << "Error setting TYPE option in JobOptionsSvc" << endmsg;
    return sc;
  }

  if ( m_jobOptionsPreAction != "") {
    sc = jobOptsIProp->setProperty( StringProperty("PYTHONPARAMS", m_jobOptionsPreAction) );
    if( !sc.isSuccess() ) {
      fatal() << "Error setting JobOptionsPreAction option in JobOptionsSvc" << endmsg;
      return sc;
    }
  }

  if ( m_jobOptionsPostAction != "") {
    sc = jobOptsIProp->setProperty( StringProperty("PYTHONACTION", m_jobOptionsPostAction) );
    if( !sc.isSuccess() ) {
      fatal() << "Error setting JobOptionsPostAction option in JobOptionsSvc" << endmsg;
      return sc;
    }
  }

  if ( !m_jobOptionsPath.empty() ) {         // The command line takes precedence
    sc = jobOptsIProp->setProperty( StringProperty("PATH", m_jobOptionsPath) );
    if( !sc.isSuccess() )   {
      fatal() << "Error setting PATH option in JobOptionsSvc" << endmsg;
      return sc;
    }
  }
  else if ( isEnvSet("JOBOPTPATH") ) {// Otherwise the Environment JOBOPTPATH
    sc = jobOptsIProp->setProperty (StringProperty("PATH",
                                                   getEnv("JOBOPTPATH")));
    if( !sc.isSuccess() )   {
      fatal()
           << "Error setting PATH option in JobOptionsSvc from env"
           << endmsg;
      return sc;
    }
  }
  else {                                   // Otherwise the default
    sc = jobOptsIProp->setProperty (StringProperty("PATH",
                                                   "../options/job.opts"));
    if( !sc.isSuccess() )   {
      fatal()
           << "Error setting PATH option in JobOptionsSvc to default"
           << endmsg;
      return sc;
    }
  }
  jobOptsIProp.reset();

  // Sets my default the Output Level of the Message service to be
  // the same as this
  auto msgSvcIProp = msgsvc.as<IProperty>();
  msgSvcIProp->setProperty( IntegerProperty("OutputLevel", m_outputLevel)).ignore();
  msgSvcIProp.reset();

  sc = jobsvc->sysInitialize();
  if( !sc.isSuccess() )   {
    fatal() << "Error initializing JobOptionsSvc" << endmsg;
    return sc;
  }
  sc = msgsvc->sysInitialize();
  if( !sc.isSuccess() )  {
    fatal() << "Error initializing MessageSvc" << endmsg;
    return sc;
  }

  // Get the useful interface from Message and JobOptions services
  m_messageSvc = m_svcLocator->service("MessageSvc");
  if( !m_messageSvc )  {
    fatal() << "Error retrieving MessageSvc." << endmsg;
    return sc;
  }
  m_jobOptionsSvc = m_svcLocator->service("JobOptionsSvc");
  if( !m_jobOptionsSvc )  {
    fatal() << "Error retrieving JobOptionsSvc." << endmsg;
    return sc;
  }

  return sc;
}

StatusCode ApplicationMgr::initialize ( )

override

Definition at line 532 of file ApplicationMgr.cpp.

                                      {

  MsgStream log( m_messageSvc, name() );
  StatusCode sc;

  // I cannot add these services in configure() because they are coming from GaudiUtils
  // and it messes up genconf when rebuilding it.
  if (m_stopOnSignal) {
    // Instantiate the service that schedules a stop when a signal is received
    std::string svcname("Gaudi::Utils::StopSignalHandler");
    sc = svcManager()->addService(svcname);
    if ( sc.isFailure() ) {
      log << MSG::INFO << "Cannot instantiate " << svcname << "signals will be ignored" << endmsg;
    }
  }

  if (m_stalledEventMonitoring) {
    // Instantiate the service that schedules a stop when a signal is received
    std::string svcname("StalledEventMonitor");
    sc = svcManager()->addService(svcname);
    if ( sc.isFailure() ) {
      log << MSG::INFO << "Cannot instantiate " << svcname << "signals will be ignored" << endmsg;
    }
  }

  if( m_state == Gaudi::StateMachine::INITIALIZED ) {
    log << MSG::INFO << "Already Initialized!" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( m_state != Gaudi::StateMachine::CONFIGURED ) {
    log << MSG::FATAL
         << "initialize: Invalid state \""  << m_state << "\"" << endmsg;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::INITIALIZED;

  //--------------------------------------------------------------------------
  // Initialize the list of top Services
  //--------------------------------------------------------------------------
  sc = svcManager()->initialize();
  if( !sc.isSuccess() ) return sc;

  //--------------------------------------------------------------------------
  // Final steps: Inform user and change internal state
  //--------------------------------------------------------------------------
  log << MSG::INFO << "Application Manager Initialized successfully"  << endmsg;
  m_state = m_targetState;

  return sc;
}

void ApplicationMgr::initLoopCheckHndlr

(

Property &

)

Definition at line 1304 of file ApplicationMgr.cpp.

                                                 {
  svcManager()->setLoopCheckEnabled(m_loopCheck);
}

void ApplicationMgr::multiThreadSvcNameListHandler

(

Property &

theProp

)

Definition at line 1095 of file ApplicationMgr.cpp.

                                                                {
  if ( !(decodeMultiThreadSvcNameList( )).isSuccess() ) {
    throw GaudiException("Failed to create copies of mt services",
                         "MinimalEventLoopMgr::multiThreadSvcNameListHandler",
                         StatusCode::FAILURE);
  }

}

const std::string & ApplicationMgr::name ( ) const

override

Definition at line 929 of file ApplicationMgr.cpp.

                                            {
  return m_name;
}

StatusCode ApplicationMgr::nextEvent ( int  maxevt )

override

Definition at line 620 of file ApplicationMgr.cpp.

                                                  {
  if( m_state != Gaudi::StateMachine::RUNNING ) {
    MsgStream log( m_messageSvc, name() );
    log << MSG::FATAL << "nextEvent: Invalid state \"" << m_state << "\""
        << endmsg;
    return StatusCode::FAILURE;
  }
  if (!m_processingMgr)   {
    MsgStream log( m_messageSvc, name() );
    log << MSG::FATAL << "No event processing manager specified. Check option:"
        << s_eventloop << endmsg;
    return StatusCode::FAILURE;
  }
  return m_processingMgr->nextEvent(maxevt);
}

void ApplicationMgr::pluginDebugPropertyHandler

(

Property &

theProp

)

Definition at line 1290 of file ApplicationMgr.cpp.

{
  // Setup debug level for the plugin system
  MsgStream log (m_messageSvc, name());
  log << MSG::INFO
      << "Updating Gaudi::PluginService::SetDebug(level) to level="
      << m_pluginDebugLevel
      << endmsg;
  Gaudi::PluginService::SetDebug(m_pluginDebugLevel);
}

StatusCode ApplicationMgr::queryInterface ( const InterfaceID &  iid, void **  pinterface  )

override

Definition at line 165 of file ApplicationMgr.cpp.

{
  if ( !ppvi ) { return StatusCode::FAILURE ; }

  // try to find own/direct interfaces:
  StatusCode sc = base_class::queryInterface(iid,ppvi);
  if (sc.isSuccess()) return sc;

  // find indirect interfaces :
  if      ( ISvcLocator     ::interfaceID() . versionMatch ( iid ) )
  { return serviceLocator()-> queryInterface ( iid , ppvi ) ; }
  if ( ISvcManager     ::interfaceID() . versionMatch ( iid ) )
  { return svcManager()    -> queryInterface ( iid , ppvi ) ; }
  if ( IAlgManager     ::interfaceID() . versionMatch ( iid ) )
  { return algManager()    -> queryInterface ( iid , ppvi ) ; }
  if ( IClassManager   ::interfaceID() . versionMatch ( iid ) )
  { return m_classManager  -> queryInterface ( iid , ppvi ) ; }
  if ( IProperty       ::interfaceID() . versionMatch ( iid ) )
  { return m_propertyMgr   -> queryInterface ( iid , ppvi ) ; }
  if ( IMessageSvc     ::interfaceID() . versionMatch ( iid ) )
  {
    *ppvi = reinterpret_cast<void*>(m_messageSvc.get());
    if (m_messageSvc) m_messageSvc->addRef();
    // Note that 0 can be a valid IMessageSvc pointer value (when used for
    // MsgStream).
    return StatusCode::SUCCESS;
  }
  *ppvi = nullptr;
  return StatusCode::FAILURE;
}

StatusCode ApplicationMgr::reinitialize ( )

override

Definition at line 946 of file ApplicationMgr.cpp.

                                        {
  StatusCode retval = StatusCode::SUCCESS;
  StatusCode sc;
  if ( m_state < Gaudi::StateMachine::INITIALIZED ) {
    throw GaudiException("Cannot reinitialize application if not INITIALIZED or RUNNING",
                         "ApplicationMgr::reinitialize", StatusCode::FAILURE);
  }
  if ( m_state == Gaudi::StateMachine::RUNNING ) {
    retval = GoToState(Gaudi::StateMachine::INITIALIZED);
  }
  sc = svcManager()->reinitialize();
  if (sc.isFailure()) retval = sc;
  sc = algManager()->reinitialize();
  if (sc.isFailure()) retval = sc;
  return retval;
}

StatusCode ApplicationMgr::restart ( )

override

Definition at line 966 of file ApplicationMgr.cpp.

                                   {
  StatusCode retval = StatusCode::SUCCESS;
  StatusCode sc;
  if ( m_state != Gaudi::StateMachine::RUNNING ) {
    throw GaudiException("Cannot restart application if not RUNNING",
                         "ApplicationMgr::restart", StatusCode::FAILURE);
  }
  sc = svcManager()->restart();
  if (sc.isFailure()) retval = sc;
  sc = algManager()->restart();
  if (sc.isFailure()) retval = sc;
  return retval;
}

StatusCode ApplicationMgr::run ( )

override

Definition at line 853 of file ApplicationMgr.cpp.

                               {
  StatusCode sc = StatusCode::SUCCESS;

  sc = GoToState(Gaudi::StateMachine::RUNNING);
  if ( sc.isSuccess() ) {
    MsgStream log(m_messageSvc, name());
    if ( m_runable != 0 ) { // loop over the events
      sc = m_runable->run();
      if ( !sc.isSuccess() ) {
        log << MSG::FATAL << "Application execution failed. Ending the job."
            << endmsg;
      }
    } else {
      log << MSG::FATAL << "Application has no runable object. Check option:"
          << s_runable << endmsg;
    }
  }
  if (sc.isSuccess()) { // try to close cleanly
    sc = GoToState(Gaudi::StateMachine::OFFLINE);
  }
  // either the runable failed of the stut-down
  if (sc.isFailure()) { // try to close anyway (but keep the StatusCode unchanged)
    GoToState(Gaudi::StateMachine::OFFLINE,true).ignore();
  }
  return sc;
}

SmartIF<ISvcLocator>& ApplicationMgr::serviceLocator ( ) const

inlineoverride

Needed to locate the message service.

Definition at line 156 of file ApplicationMgr.h.

                                                        {
    return m_svcLocator;
  }

void ApplicationMgr::setServiceManager ( ISvcManager *  )

inlineoverrideprotected

Definition at line 169 of file ApplicationMgr.h.

{}

void ApplicationMgr::SIExitHandler

(

Property &

theProp

)

Definition at line 999 of file ApplicationMgr.cpp.

                                              {
  StatusCode status;
  status = finalize();
  status = terminate();
  ::exit( 0 );
}

void ApplicationMgr::SIGoHandler

(

Property &

theProp

)

Definition at line 983 of file ApplicationMgr.cpp.

                                            {

  MsgStream log (m_messageSvc, name());
  StatusCode sc;

  // Re-initialize everything
  sc = reinitialize();
  // Execute a number of events
  executeRun(m_evtMax);

  return;
}

StatusCode ApplicationMgr::start ( )

override

Definition at line 586 of file ApplicationMgr.cpp.

                                 {

  MsgStream log( m_messageSvc, name() );
  StatusCode sc;

  if( m_state == Gaudi::StateMachine::RUNNING ) {
    log << MSG::INFO << "Already Initialized!" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( m_state != Gaudi::StateMachine::INITIALIZED ) {
    log << MSG::FATAL
         << "start: Invalid state \""  << m_state << "\"" << endmsg;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::RUNNING;

  //--------------------------------------------------------------------------
  // Initialize the list of top Services
  //--------------------------------------------------------------------------
  sc = svcManager()->start();
  if( !sc.isSuccess() ) return sc;

  //--------------------------------------------------------------------------
  // Final steps: Inform user and change internal state
  //--------------------------------------------------------------------------
  log << MSG::INFO << "Application Manager Started successfully"  << endmsg;
  m_state = m_targetState;

  return sc;
}

StatusCode ApplicationMgr::stop ( )

override

Definition at line 639 of file ApplicationMgr.cpp.

                                {

  MsgStream log( m_messageSvc, name() );
  StatusCode sc;

  if( m_state == Gaudi::StateMachine::INITIALIZED ) {
    log << MSG::INFO << "Already Initialized!" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( m_state != Gaudi::StateMachine::RUNNING ) {
    log << MSG::FATAL
         << "stop: Invalid state \""  << m_state << "\"" << endmsg;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::INITIALIZED;

  // Stop independently managed Algorithms
  sc = algManager()->stop();
  if( !sc.isSuccess() ) return sc;

  //--------------------------------------------------------------------------
  // Stop the list of top Services
  //--------------------------------------------------------------------------
  sc = svcManager()->stop();
  if( !sc.isSuccess() ) return sc;

  //--------------------------------------------------------------------------
  // Final steps: Inform user and change internal state
  //--------------------------------------------------------------------------
  log << MSG::INFO << "Application Manager Stopped successfully"  << endmsg;
  m_state = m_targetState;

  return sc;
}

StatusCode ApplicationMgr::stopRun ( )

override

implementation of IEventProcessor::stopRun()

Definition at line 915 of file ApplicationMgr.cpp.

                                      {
  MsgStream log( m_messageSvc, name() );
  if( m_state == Gaudi::StateMachine::RUNNING ) {
    if ( m_processingMgr )    {
      return m_processingMgr->stopRun();
    }
    log << MSG::WARNING << "No EventLoop Manager specified " << endmsg;
    return StatusCode::SUCCESS;
  }
  log << MSG::FATAL << "stopRun: Invalid state \"" << FSMState() << "\""
      << endmsg;
  return StatusCode::FAILURE;
}

SmartIF<ISvcManager>& ApplicationMgr::svcManager ( )

inline

Definition at line 139 of file ApplicationMgr.h.

                                            {
    // Cache the casted pointer to ISvcManager
    if (!m_svcManager) {
      m_svcManager = getManager<IService>();
    }
    return m_svcManager;
  }

StatusCode ApplicationMgr::sysFinalize ( )

inlineoverride

Definition at line 108 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

StatusCode ApplicationMgr::sysInitialize ( )

inlineoverride

Definition at line 102 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

StatusCode ApplicationMgr::sysReinitialize ( )

inlineoverride

Definition at line 110 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

StatusCode ApplicationMgr::sysRestart ( )

inlineoverride

Definition at line 112 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

StatusCode ApplicationMgr::sysStart ( )

inlineoverride

Definition at line 104 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

StatusCode ApplicationMgr::sysStop ( )

inlineoverride

Definition at line 106 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

Gaudi::StateMachine::State ApplicationMgr::targetFSMState ( ) const

override

Definition at line 938 of file ApplicationMgr.cpp.

                                                             {
  return m_targetState;
}

StatusCode ApplicationMgr::terminate ( )

override

Definition at line 727 of file ApplicationMgr.cpp.

                                     {
  MsgStream log( m_messageSvc, name() );

  if( m_state == Gaudi::StateMachine::OFFLINE ) {
    log << MSG::INFO << "Already Offline" << endmsg;
    return StatusCode::SUCCESS;
  }
  if( m_state != Gaudi::StateMachine::CONFIGURED ) {
    log << MSG::FATAL << "terminate: Invalid state \"" << m_state << "\""
        << endmsg;
    return StatusCode::FAILURE;
  }
  // release all Services
  m_targetState = Gaudi::StateMachine::OFFLINE;

  if (m_returnCode.value() == Gaudi::ReturnCode::Success) {
    log << MSG::INFO << "Application Manager Terminated successfully" << endmsg;
  } else if (m_returnCode.value() == Gaudi::ReturnCode::ScheduledStop ) {
    log << MSG::INFO << "Application Manager Terminated successfully with a user requested ScheduledStop" << endmsg;
  } else {
    log << MSG::ERROR << "Application Manager Terminated with error code " << m_returnCode.value() << endmsg;
  }

  { // Force a disable the auditing of finalize for MessageSvc
    auto prop = m_messageSvc.as<IProperty>();
    if (prop) {
      prop->setProperty(BooleanProperty("AuditFinalize", false)).ignore();
    }
  }
  { // Force a disable the auditing of finalize for JobOptionsSvc
    auto prop = m_jobOptionsSvc.as<IProperty>();
    if (prop) {
      prop->setProperty(BooleanProperty("AuditFinalize", false)).ignore();
    }
  }

  // finalize MessageSvc
  auto svc = m_messageSvc.as<IService>();
  if ( !svc ) {
    log << MSG::ERROR << "Could not get the IService interface of the MessageSvc" << endmsg;
  } else {
    svc->sysFinalize().ignore();
  }

  // finalize JobOptionsSvc
  svc = m_jobOptionsSvc.as<IService>();
  if ( !svc ) {
    log << MSG::ERROR << "Could not get the IService interface of the JobOptionsSvc" << endmsg;
  } else {
    svc->sysFinalize().ignore();
  }

  m_state = m_targetState;
  return StatusCode::SUCCESS;
}

Member Data Documentation

bool ApplicationMgr::m_actHistory

protected

Activate HistorySvc.

Definition at line 247 of file ApplicationMgr.h.

SmartIF<IAlgManager> ApplicationMgr::m_algManager

protected

Cached pointer to the manager of algorithms.

Definition at line 194 of file ApplicationMgr.h.

std::string ApplicationMgr::m_appName

protected

The name of the application.

Definition at line 245 of file ApplicationMgr.h.

std::string ApplicationMgr::m_appVersion

protected

The version of the application.

Definition at line 246 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditAlgs

protected

Definition at line 256 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditSvcs

protected

Definition at line 255 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditTools

protected

Defaults for auditors.

Definition at line 254 of file ApplicationMgr.h.

SmartIF<DLLClassManager> ApplicationMgr::m_classManager

protected

Reference to the class manager.

Definition at line 199 of file ApplicationMgr.h.

bool ApplicationMgr::m_codeCheck

protected

Activate StatusCode checking.

Definition at line 248 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_createSvcNameList

protected

Definition at line 251 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_declaredManagers

protected

Property to declare the list of known managers.

Definition at line 188 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_defServices

protected

Vector default services names.

Definition at line 214 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_dllNameList

protected

List of DDL's names.

Definition at line 235 of file ApplicationMgr.h.

std::map<std::string,std::string> ApplicationMgr::m_environment

protected

Environment variables to set.

Definition at line 258 of file ApplicationMgr.h.

std::string ApplicationMgr::m_eventLoopMgr

protected

Processing manager type.

Definition at line 241 of file ApplicationMgr.h.

int ApplicationMgr::m_evtMax

protected

Number of events to be processed.

Definition at line 227 of file ApplicationMgr.h.

std::string ApplicationMgr::m_evtsel

protected

Event selection.

Definition at line 242 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_extSvcCreates

protected

LHCb or ATLAS defn of "ExtSvc".

Definition at line 229 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_extSvcNameList

protected

List of external services names.

Definition at line 228 of file ApplicationMgr.h.

std::string ApplicationMgr::m_histPersName

protected

CGL: Name of the Hist Pers Svc.

Definition at line 243 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsPath

protected

The "file" to look for properties.

Definition at line 237 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsPostAction

protected

additional command to run on config

Definition at line 239 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsPreAction

protected

additional command to run on config

Definition at line 238 of file ApplicationMgr.h.

SmartIF<IJobOptionsSvc> ApplicationMgr::m_jobOptionsSvc

protected

Reference to JobOption service.

Definition at line 221 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_jobOptionsSvcType

protected

JobOptionsSvc type.

Definition at line 208 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsType

protected

Source type (e.g. dbase, file...)

Definition at line 236 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_loopCheck

protected

For ServiceMgr initialization loop checking.

Definition at line 261 of file ApplicationMgr.h.

ManagersMap ApplicationMgr::m_managers

protected

Map of known component managers.

It contains (at least) the managers for IService and IAlgorithm. IAlgTool and IAuditor are not mandatory (but a missing manager for IAlgTool will probably not allow any job to run).

Definition at line 186 of file ApplicationMgr.h.

SmartIF<IMessageSvc> ApplicationMgr::m_messageSvc

protected

Reference to the message service.

Definition at line 218 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_messageSvcType

protected

MessageSvc type.

Definition at line 207 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_multiThreadSvcNameList

protected

List of external services names for which we want a copy per evt thread.

Definition at line 232 of file ApplicationMgr.h.

std::string ApplicationMgr::m_name = "ApplicationMgr"

protected

Name.

Definition at line 210 of file ApplicationMgr.h.

int ApplicationMgr::m_noOfEvtThreads

protected

no of multiThreadSvc copies

Definition at line 233 of file ApplicationMgr.h.

std::vector<std::string> ApplicationMgr::m_okDlls

private

names of successfully loaded dlls

Definition at line 281 of file ApplicationMgr.h.

int ApplicationMgr::m_outputLevel

protected

Message output level.

Definition at line 244 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_outStreamNameList

protected

List of output stream names.

Definition at line 205 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_outStreamType

protected

Output stream type (obsolete?)

Definition at line 206 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_pluginDebugLevel

protected

Debug level for the plugin system.

Definition at line 249 of file ApplicationMgr.h.

SmartIF<IEventProcessor> ApplicationMgr::m_processingMgr

protected

Reference to processing manager object.

Definition at line 220 of file ApplicationMgr.h.

bool ApplicationMgr::m_propertiesPrint

protected

flag to activate the printout of properties

Definition at line 272 of file ApplicationMgr.h.

SmartIF<PropertyMgr> ApplicationMgr::m_propertyMgr

protected

Reference to Property Manager.

Definition at line 200 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_returnCode

protected

Property to record the error conditions occurring during the running.

Definition at line 275 of file ApplicationMgr.h.

SmartIF<IRunable> ApplicationMgr::m_runable

protected

Reference to the runable object.

Definition at line 219 of file ApplicationMgr.h.

std::string ApplicationMgr::m_runableType

protected

Runable type.

Definition at line 240 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_SIExit

protected

For SI's "Exit" command via callback.

Definition at line 203 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_SIGo

protected

For SI's "Go" command via callback.

Definition at line 202 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_stalledEventMonitoring

protected

Property to enable/disable the monitoring and reporting of stalled events (enabled by default).

See also

StalledEventMonitor

Definition at line 269 of file ApplicationMgr.h.

Gaudi::StateMachine::State ApplicationMgr::m_state = Gaudi::StateMachine::OFFLINE

protected

Internal State.

Definition at line 211 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_stopOnSignal

protected

Property to enable/disable the "stop on signal" service (enabled by default).

See also

Gaudi::Utils::StopSignalHandler

Definition at line 265 of file ApplicationMgr.h.

SmartIF<ISvcLocator> ApplicationMgr::m_svcLocator

mutableprotected

Reference to its own service locator (must be instantiated prior to any service!)

Definition at line 198 of file ApplicationMgr.h.

SmartIF<ISvcManager> ApplicationMgr::m_svcManager

protected

Cached pointer to the manager of services.

Definition at line 191 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_svcMapping

protected

Default mapping of services.

Definition at line 215 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_svcOptMapping

protected

Default mapping of services.

Definition at line 216 of file ApplicationMgr.h.

Gaudi::StateMachine::State ApplicationMgr::m_targetState = Gaudi::StateMachine::OFFLINE

protected

Internal State.

Definition at line 212 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_topAlgNameList

protected

List of top level algorithms names.

Definition at line 204 of file ApplicationMgr.h.

bool ApplicationMgr::m_useHiveAlgorithmManager

protected

Definition at line 278 of file ApplicationMgr.h.

---

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

• GaudiCoreSvc/src/ApplicationMgr/ApplicationMgr.h
• GaudiCoreSvc/src/ApplicationMgr/ApplicationMgr.cpp