ApplicationMgr Class Reference

#include <ApplicationMgr.h>

Inheritance diagram for ApplicationMgr:

[legend]

Collaboration diagram for ApplicationMgr:

[legend]

List of all members.

---

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 42 of file ApplicationMgr.h.

Public Types
typedef std::list< std::pair < IService *, int > >	ListSvc
typedef std::list< std::string >	ListName
typedef std::vector< std::string >	VectorName
Public Member Functions
	ApplicationMgr (IInterface *=0)
virtual	~ApplicationMgr ()
virtual unsigned long	addRef ()
	Increment the reference count of Interface instance.
virtual unsigned long	release ()
	Release Interface instance.
virtual StatusCode	queryInterface (const InterfaceID &iid, void **pinterface)
	Query interfaces of Interface.
virtual StatusCode	run ()
	Run the complete job (from intialize to terminate).
virtual StatusCode	configure ()
	Configure the job.
virtual StatusCode	terminate ()
	Terminate the job.
virtual StatusCode	initialize ()
	Initialize the job.
virtual StatusCode	start ()
	Start (from INITIALIZED to RUNNING).
virtual StatusCode	stop ()
	Stop (from RUNNING to INITIALIZED).
virtual StatusCode	finalize ()
	Finalize the job.
virtual StatusCode	nextEvent (int maxevt)
	Process the next maxevt events.
virtual const std::string &	name () const
	The identifying name of the AppMgrUI object.
virtual StatusCode	executeEvent (void *par)
	implementation of IEventProcessor::executeEvent(void*)
virtual StatusCode	executeRun (int evtmax)
	implementation of IEventProcessor::executeRun(int)
virtual StatusCode	stopRun ()
	implementation of IEventProcessor::stopRun()
virtual const InterfaceID &	type () const
	Retrieve ID of the Service. Not really used.
virtual Gaudi::StateMachine::State	FSMState () const
	Get the current state.
virtual Gaudi::StateMachine::State	targetFSMState () const
	When we are in the middle of a transition, get the state where the transition is leading us.
virtual StatusCode	reinitialize ()
	Initialization (from INITIALIZED or RUNNING to INITIALIZED, via CONFIGURED).
virtual StatusCode	restart ()
	Initialization (from RUNNING to RUNNING, via INITIALIZED).
virtual StatusCode	sysInitialize ()
	Initilize Service.
virtual StatusCode	sysStart ()
	Start Service.
virtual StatusCode	sysStop ()
	Stop Service.
virtual StatusCode	sysFinalize ()
	Finalize Service.
virtual StatusCode	sysReinitialize ()
	Re-initialize the Service.
virtual StatusCode	sysRestart ()
	Re-start the Service.
void	SIGoHandler (Property &theProp)
void	SIExitHandler (Property &theProp)
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	reflexDebugPropertyHandler (Property &theProp)
void	initLoopCheckHndlr (Property &)
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
StatusCode	addMultiSvc (const std::string &name, const std::string &type, int prio)
	add one or more copies of svc type/name as determined by NoOfThreads
void	setServiceManager (ISvcManager *)
StatusCode	i_startup ()
	Internal startup routine.
StatusCode	GoToState (Gaudi::StateMachine::State state, bool ignoreFailures=false)
	Reach a state from current state (whichever it is) going through the correct transitions.
Protected Attributes
int	m_refcount
	Reference count.
ServiceManager *	m_svcManager
	Reference to the service factory.
AlgorithmManager *	m_algManager
	Reference to the algorimth factory.
DLLClassManager *	m_classManager
	Reference to the class manager.
ISvcLocator *	m_svcLocator
	Reference to its own service locator.
IntegerProperty	m_SIGo
	For SI's "Go" command via callback.
IntegerProperty	m_SIExit
	For SI's "Exit" command via callback.
StringArrayProperty	m_topAlgNameList
	List of top level algorithms names.
StringArrayProperty	m_outStreamNameList
	List of output stream names.
StringProperty	m_outStreamType
	Output stream type (obsolete?).
StringProperty	m_messageSvcType
	MessageSvc type.
StringProperty	m_jobOptionsSvcType
	JobOptionsSvc type.
ListSvc	m_topSvcList
	List of top level services.
ListName	m_topSvcNameList
	List of top level services names.
std::string	m_name
	Name.
Gaudi::StateMachine::State	m_state
	Internal State.
Gaudi::StateMachine::State	m_targetState
	Internal State.
VectorName	m_defServices
	Vector default services names.
VectorName	m_svcMapping
	Default mapping of services.
VectorName	m_svcOptMapping
	Default mapping of services.
PropertyMgr *	m_propertyMgr
	Reference to Property Manager.
IMessageSvc *	m_messageSvc
	Reference to the message service.
IRunable *	m_runable
	Reference to the runable object.
IEventProcessor *	m_processingMgr
	Reference to processing manager object.
IJobOptionsSvc *	m_jobOptionsSvc
	Reference to JobOption service.
int	m_evtMax
	Number of events to be processed.
StringArrayProperty	m_extSvcNameList
	List of external services names.
BooleanProperty	m_extSvcCreates
	LHCb or ATLAS defn of "ExtSvc".
StringArrayProperty	m_multiThreadSvcNameList
	List of external services names for which we want a copy per evt thread.
int	m_noOfEvtThreads
	no of multiThreadSvc copies
StringArrayProperty	m_dllNameList
	List of DDL's names.
std::string	m_jobOptionsType
	Source type (e.g. dbase, file...).
std::string	m_jobOptionsPath
	The "file" to look for properties.
std::string	m_runableType
	Runable type.
std::string	m_eventLoopMgr
	Processing manager type.
std::string	m_evtsel
	Event selection.
std::string	m_histPersName
	CGL: Name of the Hist Pers Svc.
int	m_outputLevel
	Message output level.
std::string	m_appName
	The name of the application.
std::string	m_appVersion
	The version of the application.
bool	m_actHistory
	Activate HistorySvc.
bool	m_codeCheck
	Activate StatusCode checking.
IntegerProperty	m_reflexDebugLevel
	Debug level for the reflex plugin system.
StringArrayProperty	m_createSvcNameList
BooleanProperty	m_auditTools
	Defaults for auditors.
BooleanProperty	m_auditSvcs
BooleanProperty	m_auditAlgs
std::map< std::string, std::string >	m_environment
	Environment variables to set.
BooleanProperty	m_loopCheck
	For ServiceMgr initialization loop checking.
bool	m_propertiesPrint
	flag to actiavte the printout of properties
Private Attributes
std::vector< std::string >	m_okDlls
	names of successfully loaded dlls

---

Member Typedef Documentation

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

Definition at line 47 of file ApplicationMgr.h.

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

Definition at line 48 of file ApplicationMgr.h.

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

Definition at line 49 of file ApplicationMgr.h.

---

Constructor & Destructor Documentation

ApplicationMgr::ApplicationMgr

(

IInterface *

= 0

)

Definition at line 44 of file ApplicationMgr.cpp.

                                          {
  // IInterface initialization
  m_refcount = 1;

  // Initialize two basic services: messagesvc & joboptions
  m_messageSvc        = 0;
  m_jobOptionsSvc     = 0;
  // Service Locator/Factory has to be instantiated FIRST!!!!!
  // as subsequent internal services need access to SvcLocator/Factory obj
  m_svcManager        = new ServiceManager(this);
  m_svcLocator        = m_svcManager; // alias to distinguish dual function

  // Instanciate internal services
  // SvcLocator/Factory HAS to be already instantiated
  m_algManager   = new AlgorithmManager(this);
  m_classManager = new DLLClassManager(this);
  m_propertyMgr  = new PropertyMgr(this);

  m_name  = "ApplicationMgr";
  m_state = Gaudi::StateMachine::OFFLINE;
  m_targetState = Gaudi::StateMachine::OFFLINE;

  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("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);
  m_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("ReflexPluginDebugLevel", m_reflexDebugLevel = 0 );

  // 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_reflexDebugLevel.declareUpdateHandler(&ApplicationMgr::reflexDebugPropertyHandler, this);
  m_processingMgr = 0;
  m_runable = 0;
  m_svcMapping.push_back("EvtDataSvc/EventDataSvc");
  m_svcMapping.push_back("DetDataSvc/DetectorDataSvc");
  m_svcMapping.push_back("HistogramSvc/HistogramDataSvc");
  m_svcMapping.push_back("HbookCnv::PersSvc/HbookHistSvc");
  m_svcMapping.push_back("RootHistCnv::PersSvc/RootHistSvc");
  m_svcMapping.push_back("EvtPersistencySvc/EventPersistencySvc");
  m_svcMapping.push_back("DetPersistencySvc/DetectorPersistencySvc");
  m_svcMapping.push_back("HistogramPersistencySvc/HistogramPersistencySvc");
}

ApplicationMgr::~ApplicationMgr

(

)

[virtual]

Definition at line 143 of file ApplicationMgr.cpp.

                                {
  if( m_algManager ) m_algManager->release();
  if( m_classManager ) m_classManager->release();
  if( m_propertyMgr ) m_propertyMgr->release();
  if( m_messageSvc ) m_messageSvc->release();
  if( m_jobOptionsSvc ) m_jobOptionsSvc->release();
  if( m_svcManager ) m_svcManager->release();  // Need to be the last one!!
}

---

Member Function Documentation

unsigned long ApplicationMgr::addRef

(

)

[virtual]

Increment the reference count of Interface instance.

Implements IInterface.

Definition at line 155 of file ApplicationMgr.cpp.

                                     {
  m_refcount++;
  return m_refcount;
}

unsigned long ApplicationMgr::release

(

)

[virtual]

Release Interface instance.

Implements IInterface.

Definition at line 163 of file ApplicationMgr.cpp.

                                      {
  long count = --m_refcount;
  if( count <= 0) {
    delete this;
  }
  return count;
}

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

Query interfaces of Interface.

Parameters:

	riid	ID of Interface to be retrieved
	ppvInterface	Pointer to Location for interface pointer

Implements IInterface.

Definition at line 175 of file ApplicationMgr.cpp.

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

  // try to find own/direct interfaces:
  if      ( IAppMgrUI       ::interfaceID() . versionMatch ( iid ) )
  { *ppvi = static_cast<IAppMgrUI*>        ( this ) ; }
  else if ( IEventProcessor ::interfaceID() .versionMatch  ( iid ) )
  { *ppvi = static_cast<IEventProcessor*>  ( this ) ; }
  else if ( IService        ::interfaceID() . versionMatch ( iid ) )
  { *ppvi = static_cast<IService*>         ( this ) ; }
  else if ( INamedInterface ::interfaceID() . versionMatch ( iid ) )
  { *ppvi = static_cast<INamedInterface*>  ( this ) ; }
  else if ( IStateful       ::interfaceID() . versionMatch ( iid ) )
  { *ppvi = static_cast<IStateful*>        ( this ) ; }
  else if ( IInterface      ::interfaceID() . versionMatch ( iid ) )
  { *ppvi = static_cast<IInterface*>       ( this ) ; }
  // find indirect interfaces :
  else if ( ISvcLocator     ::interfaceID() . versionMatch ( iid ) )
  { return m_svcLocator   -> queryInterface ( iid , ppvi ) ; }
  else if ( ISvcManager     ::interfaceID() . versionMatch ( iid ) )
  { return m_svcManager   -> queryInterface ( iid , ppvi ) ; }
  else if ( IAlgManager     ::interfaceID() . versionMatch ( iid ) )
  { return m_algManager   -> queryInterface ( iid , ppvi ) ; }
  else if ( IClassManager   ::interfaceID() . versionMatch ( iid ) )
  { return m_classManager -> queryInterface ( iid , ppvi ) ; }
  else if ( IProperty       ::interfaceID() . versionMatch ( iid ) )
  { return m_propertyMgr  -> queryInterface ( iid , ppvi ) ; }
  else
  { *ppvi = 0 ; return StatusCode::FAILURE; }              // RETURN
  // increment the reference counter:
  addRef ();
  //
  return StatusCode::SUCCESS ;
}

StatusCode ApplicationMgr::run

(

)

[virtual]

Run the complete job (from intialize to terminate).

Implements IAppMgrUI.

Definition at line 816 of file ApplicationMgr.cpp.

                               {
  StatusCode sc = StatusCode::SUCCESS;

  sc = GoToState(Gaudi::StateMachine::RUNNING);
  if ( sc.isSuccess() ) {
    MsgStream log(m_messageSvc, name());
    if ( 0 != m_runable ) { // loop over the events
      sc = m_runable->run();
      if ( !sc.isSuccess() ) {
        log << MSG::FATAL << "Application execution failed. Ending the job."
            << endreq;
      }
    } else {
      log << MSG::FATAL << "Application has no runable object. Check option:"
          << s_runable << endreq;
    }
  }
  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;
}

StatusCode ApplicationMgr::configure

(

)

[virtual]

Configure the job.

Implements IAppMgrUI.

Definition at line 318 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" << endreq;
    return StatusCode::SUCCESS;
  }
  else if( Gaudi::StateMachine::OFFLINE != m_state ) {
    tlog << MSG::FATAL
         << "configure: Invalid state \""  << m_state << "\"" << endreq;
    return StatusCode::FAILURE;
  }
  m_targetState = Gaudi::StateMachine::CONFIGURED;

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

  MsgStream log( m_messageSvc, name() );

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

  // Check current outputLevel to eventually inform the MessageSvc
  if( m_outputLevel != MSG::NIL && !m_appName.empty() ) {
    assert(0 != 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 << " $Revision: 1.77 $";
    }

    // Add the host name and current time to the message
    time_t t;
    std::time( &t );
    tm* localt = std::localtime( &t );

    log << MSG::ALWAYS
        << std::endl
        << "                                "
        << "          running on " << System::hostName()
        << " on " << std::asctime( localt )
        << "=================================================================="
        << "=================================================================="
        << endmsg;
  }

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

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

  // set the requested environment variables
  std::map<std::string,std::string>::iterator var;
  for ( var = m_environment.begin(); var != m_environment.end(); ++var ) {
    const std::string &name  = var->first;
    const std::string &value = var->second;
    std::string old = System::getEnv(name.c_str());
    if ( !old.empty() && (old != "UNKNOWN" )) {
      log << MSG::WARNING;
    }
    else {
      log << MSG::DEBUG;
    }
    log << "Setting " << name << " = " << value << endmsg;
    System::setEnv(name,value);
  }

  //Declare Service Types
  VectorName::const_iterator j;
  for(j=m_svcMapping.begin(); j != m_svcMapping.end(); ++j)  {
    ListItem itm(*j);
    if ( declareMultiSvcType(itm.name(), itm.type()).isFailure() )  {
      log << MSG::ERROR << "configure: declaring svc type:'" << *j << "' failed." << endmsg;
      return StatusCode::FAILURE;
    }
  }
  for(j=m_svcOptMapping.begin(); j != m_svcOptMapping.end(); ++j)  {
    ListItem 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" << endreq;
    return sc;
  }

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

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

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


  //--------------------------------------------------------------------------
  // Retrieve intrinsic services. If needed configure them.
  //--------------------------------------------------------------------------
  ListItem evtloop_item(m_eventLoopMgr);
  sc = addMultiSvc(evtloop_item.type(), evtloop_item.name(), 100);
  if( !sc.isSuccess() )  {
    log << MSG::FATAL << "Error adding :" << m_eventLoopMgr << endreq;
    return sc;
  }

  if (m_noOfEvtThreads == 0) {
    sc = m_svcLocator->service(m_runableType, m_runable);
    if( !sc.isSuccess() )  {
      log << MSG::FATAL
          << "Error retrieving Runable:" << m_runableType
          << "\n Check option ApplicationMgr." << s_runable << endreq;
      return sc;
    }
    sc = m_svcLocator->service( evtloop_item.name(), m_processingMgr);
    if( !sc.isSuccess() )  {
      log << MSG::FATAL
          << "Error retrieving Processing manager:" << m_eventLoopMgr
          << "\n Check option ApplicationMgr." << s_eventloop
          << "\n No events will be processed." << endreq;
      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 = m_svcManager->addService("HistorySvc","HistorySvc",std::numeric_limits<int>::max());
    if ( sc.isFailure() ) {
      log << MSG::FATAL << "Error adding HistorySvc" << endreq;
      return StatusCode::FAILURE;
    }

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

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

StatusCode ApplicationMgr::terminate

(

)

[virtual]

Terminate the job.

Implements IAppMgrUI.

Definition at line 704 of file ApplicationMgr.cpp.

                                     {
  MsgStream log( m_messageSvc, name() );

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


  log << MSG::INFO << "Application Manager Terminated successfully" << endreq;

  // finalize MessageSvc
  IService *svc = 0;
  StatusCode sc = m_messageSvc->queryInterface(IService::interfaceID(),pp_cast<void>(&svc));
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR << "Could not get the IService interface of the MessageSvc" << endreq;
  } else {
    svc->sysFinalize().ignore();
    svc->release();
  }

  // finalize JobOptionsSvc
  svc = 0;
  sc = m_jobOptionsSvc->queryInterface(IService::interfaceID(),pp_cast<void>(&svc));
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR << "Could not get the IService interface of the JobOptionsSvc" << endreq;
  } else {
    svc->sysFinalize().ignore();
    svc->release();
  }

  m_state = m_targetState;
  return StatusCode::SUCCESS;
}

StatusCode ApplicationMgr::initialize

(

)

[virtual]

Initialize the job.

Implements IAppMgrUI.

Definition at line 537 of file ApplicationMgr.cpp.

                                      {

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

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

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

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

  return sc;
}

StatusCode ApplicationMgr::start

(

)

[virtual]

Start (from INITIALIZED to RUNNING).

Implements IAppMgrUI.

Definition at line 571 of file ApplicationMgr.cpp.

                                 {

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

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

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

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

  return sc;
}

StatusCode ApplicationMgr::stop

(

)

[virtual]

Stop (from RUNNING to INITIALIZED).

Implements IAppMgrUI.

Definition at line 624 of file ApplicationMgr.cpp.

                                {

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

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

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

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

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

  return sc;
}

StatusCode ApplicationMgr::finalize

(

)

[virtual]

Finalize the job.

Implements IAppMgrUI.

Definition at line 662 of file ApplicationMgr.cpp.

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

  IProperty* msgSvcIProp = 0;
  // disable message suppression in finalize
  m_svcLocator->service( "MessageSvc", msgSvcIProp).ignore();
  msgSvcIProp->setProperty( BooleanProperty("enableSuppression", false)).ignore();
  msgSvcIProp->release();

  // Finalize independently managed Algorithms
  StatusCode sc = m_algManager->finalizeAlgorithms();


  // Finalize all Services
  sc = m_svcManager->finalizeServices();

  m_svcManager->removeService( (IService*) m_processingMgr );
  m_svcManager->removeService( (IService*) m_runable );

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

  log << MSG::INFO << "Application Manager Finalized successfully" << endreq;

  m_state = m_targetState;
  return sc;
}

StatusCode ApplicationMgr::nextEvent

(

int

maxevt

)

[virtual]

Process the next maxevt events.

Implements IAppMgrUI.

Definition at line 605 of file ApplicationMgr.cpp.

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

const std::string & ApplicationMgr::name

(

)

const [virtual]

The identifying name of the AppMgrUI object.

Implements IAppMgrUI.

Definition at line 895 of file ApplicationMgr.cpp.

                                            {
  return m_name;
}

StatusCode ApplicationMgr::executeEvent

(

void *

par

)

[virtual]

implementation of IEventProcessor::executeEvent(void*)

Implements IEventProcessor.

Definition at line 846 of file ApplicationMgr.cpp.

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

StatusCode ApplicationMgr::executeRun

(

int

evtmax

)

[virtual]

implementation of IEventProcessor::executeRun(int)

Implements IEventProcessor.

Definition at line 862 of file ApplicationMgr.cpp.

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

StatusCode ApplicationMgr::stopRun

(

)

[virtual]

implementation of IEventProcessor::stopRun()

Implements IEventProcessor.

Definition at line 880 of file ApplicationMgr.cpp.

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

const InterfaceID & ApplicationMgr::type

(

)

const [virtual]

Retrieve ID of the Service. Not really used.

Implements IService.

Definition at line 900 of file ApplicationMgr.cpp.

                                              {
  return IID_IService;
}

Gaudi::StateMachine::State ApplicationMgr::FSMState

(

)

const [virtual]

Get the current state.

Implements IAppMgrUI.

Definition at line 904 of file ApplicationMgr.cpp.

                                                       {
  return m_state;
}

Gaudi::StateMachine::State ApplicationMgr::targetFSMState

(

)

const [virtual]

When we are in the middle of a transition, get the state where the transition is leading us.

Otherwise it returns the same state as state().

Implements IService.

Definition at line 908 of file ApplicationMgr.cpp.

                                                             {
  return m_targetState;
}

StatusCode ApplicationMgr::reinitialize

(

)

[virtual]

Initialization (from INITIALIZED or RUNNING to INITIALIZED, via CONFIGURED).

Implements IAppMgrUI.

Definition at line 916 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 = m_svcManager->reinitializeServices();
  if (sc.isFailure()) retval = sc;
  sc = m_algManager->reinitializeAlgorithms();
  if (sc.isFailure()) retval = sc;
  return retval;
}

StatusCode ApplicationMgr::restart

(

)

[virtual]

Initialization (from RUNNING to RUNNING, via INITIALIZED).

Implements IAppMgrUI.

Definition at line 936 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 = m_svcManager->restartServices();
  if (sc.isFailure()) retval = sc;
  sc = m_algManager->restartAlgorithms();
  if (sc.isFailure()) retval = sc;
  return retval;
}

virtual StatusCode ApplicationMgr::sysInitialize

(

)

[inline, virtual]

Initilize Service.

Implements IService.

Definition at line 101 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

virtual StatusCode ApplicationMgr::sysStart

(

)

[inline, virtual]

Start Service.

Implements IService.

Definition at line 103 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

virtual StatusCode ApplicationMgr::sysStop

(

)

[inline, virtual]

Stop Service.

Implements IService.

Definition at line 105 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

virtual StatusCode ApplicationMgr::sysFinalize

(

)

[inline, virtual]

Finalize Service.

Implements IService.

Definition at line 107 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

virtual StatusCode ApplicationMgr::sysReinitialize

(

)

[inline, virtual]

Re-initialize the Service.

Implements IService.

Definition at line 109 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

virtual StatusCode ApplicationMgr::sysRestart

(

)

[inline, virtual]

Re-start the Service.

Implements IService.

Definition at line 111 of file ApplicationMgr.h.

{ return StatusCode::SUCCESS; }

void ApplicationMgr::SIGoHandler

(

Property &

theProp

)

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

void ApplicationMgr::SIExitHandler

(

Property &

theProp

)

Definition at line 969 of file ApplicationMgr.cpp.

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

void ApplicationMgr::evtLoopPropertyHandler

(

Property &

theProp

)

Definition at line 979 of file ApplicationMgr.cpp.

                                                         {
  if ( m_processingMgr )    {
    SmartIF<IProperty> props(IID_IProperty, m_processingMgr);
    if ( props.isValid() )    {
      props->setProperty( p ).ignore();
    }
  }
}

StatusCode ApplicationMgr::decodeExtSvcNameList

(

)

Definition at line 1035 of file ApplicationMgr.cpp.

                                                 {
  StatusCode result = StatusCode::SUCCESS;

  std::vector<std::string> theNames = m_extSvcNameList.value( );

  VectorName::const_iterator it(theNames.begin());
  VectorName::const_iterator et(theNames.end());
  while(result.isSuccess() && it != et) {
    ListItem item(*it++);
    if (m_extSvcCreates == true) {
      if ( (result = m_svcManager->addService(item.type(),
                                              item.name(), 10)).isFailure()) {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::ERROR << "decodeExtSvcNameList: Cannot create service "
            << item.type() << "/" << item.name() << endmsg;
      }
    } else {
      if( ( result = m_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::decodeCreateSvcNameList

(

)

Definition at line 1001 of file ApplicationMgr.cpp.

                                                   {
  StatusCode result = StatusCode::SUCCESS;
  const std::vector<std::string>& theNames = m_createSvcNameList.value( );
  VectorName::const_iterator it(theNames.begin());
  VectorName::const_iterator et(theNames.end());
  while(result.isSuccess() && it != et) {
    ListItem item(*it++);
    if( (result = m_svcManager->addService(item.type(), item.name(), 10) ).isFailure()) {
      MsgStream log( m_messageSvc, m_name );
      log << MSG::ERROR << "decodeCreateSvcNameList: Cannot create service "
          << item.type() << "/" << item.name() << endmsg;
    } else {
      MsgStream log( m_messageSvc, m_name );
      log << MSG::DEBUG << "decodeCreateSvcNameList: Created service "
          << item.type() << "/" << item.name() << endmsg;
    }
  }
  return result;
}

void ApplicationMgr::createSvcNameListHandler

(

Property &

)

Definition at line 991 of file ApplicationMgr.cpp.

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

void ApplicationMgr::extSvcNameListHandler

(

Property &

theProp

)

Definition at line 1024 of file ApplicationMgr.cpp.

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

StatusCode ApplicationMgr::decodeMultiThreadSvcNameList

(

)

Definition at line 1078 of file ApplicationMgr.cpp.

                                                         {
  StatusCode result = StatusCode::SUCCESS;
  const std::vector<std::string>& theNames = m_multiThreadSvcNameList.value( );
  for(int iCopy=0; iCopy<m_noOfEvtThreads; ++iCopy) {
    for (VectorName::const_iterator it = theNames.begin();
         it != theNames.end();
         ++it) {
      ListItem item(*it);
      result = addMultiSvc(item.type(), item.name(), 10);
      //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 {
        MsgStream log( m_messageSvc, m_name );
        log << MSG::VERBOSE
            << "decodeMultiThreadSvcNameList: created service "
            << item.type() << "/" << item.name() << endmsg;
      }
    }
  }
  return result;
}

void ApplicationMgr::multiThreadSvcNameListHandler

(

Property &

theProp

)

Definition at line 1066 of file ApplicationMgr.cpp.

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

}

StatusCode ApplicationMgr::decodeDllNameList

(

)

Definition at line 1182 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 ( std::vector<std::string>::const_iterator it = m_dllNameList.value().begin();
        it != m_dllNameList.value().end(); ++it ) {
    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..
  if ( !duplicateList.empty() ) {
    log << MSG::DEBUG << "Removed duplicate entries for modules : ";
    for ( std::map<std::string,unsigned int>::const_iterator it = duplicateList.begin();
          it != duplicateList.end(); ++it ) {
      log << it->first << "(" << 1+it->second << ")";
      if ( it != --duplicateList.end() ) log << ", ";
    }
    log << endreq;
  }
  // -------------------------------------------------------------------------

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

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

  std::vector<std::string> successNames, failNames;
  std::vector<std::string>::const_iterator it;

  for (it = theNames.begin(); it != theNames.end(); it++) {
    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 (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 (it = failNames.begin(); it != failNames.end(); it++) {
      log<< (*it);
      if( (it+1) != failNames.end())  log << ", ";
    }
    log << endmsg;
  }
  return result;
}

void ApplicationMgr::dllNameListHandler

(

Property &

theProp

)

Definition at line 1171 of file ApplicationMgr.cpp.

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

void ApplicationMgr::reflexDebugPropertyHandler

(

Property &

theProp

)

Definition at line 1260 of file ApplicationMgr.cpp.

{
  // Setup debug level for Reflex plugin system
  MsgStream log (m_messageSvc, name());
  log << MSG::INFO
      << "Updating ROOT::Reflex::PluginService::SetDebug(level) to level="
      << (int)m_reflexDebugLevel
      << endreq;
  ROOT::Reflex::PluginService::SetDebug(m_reflexDebugLevel);
}

void ApplicationMgr::initLoopCheckHndlr

(

Property &

)

Definition at line 1274 of file ApplicationMgr.cpp.

                                                 {
  m_svcManager->setLoopCheckEnabled(m_loopCheck);
}

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 1106 of file ApplicationMgr.cpp.

                                                                      {
  StatusCode result = StatusCode::SUCCESS;
  MsgStream log( m_messageSvc, m_name );
  if (0 == m_noOfEvtThreads) {
    result = m_svcManager->declareSvcType(name, type);
    if( result.isFailure() ) {
      log << MSG::ERROR << "declareMultiSvcType: Cannot declare service "
          << type << "/" << name << endmsg;
    } else {
      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 = m_svcManager->declareSvcType(thrName, type);
      if( result.isFailure() ) {
        log << MSG::ERROR << "declareMultiSvcType: Cannot declare service "
            << type << "/" << thrName << endmsg;
      } else {
        log << MSG::VERBOSE << "declareMultiSvcType: declared service "
            << type << "/" << thrName << endmsg;
      }
    }
  }
  return result;
}

StatusCode ApplicationMgr::addMultiSvc	(	const std::string &	name,
		const std::string &	type,
		int	prio
	)			[protected]

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

Definition at line 1137 of file ApplicationMgr.cpp.

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

void ApplicationMgr::setServiceManager

(

ISvcManager *

)

[inline, protected, virtual]

Implements IService.

Definition at line 142 of file ApplicationMgr.h.

{}

StatusCode ApplicationMgr::i_startup

(

)

[protected]

Internal startup routine.

Definition at line 215 of file ApplicationMgr.cpp.

                                     {
  MsgStream tlog( m_messageSvc, name() );
  IService   *msgsvc = 0, *jobsvc = 0;
  IProperty* jobOptsIProp = 0;
  IProperty* msgSvcIProp = 0;
  StatusCode  sc;

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

  // Create the Message service
  sc = m_svcManager->createService( m_messageSvcType, "MessageSvc", msgsvc );
  if( !sc.isSuccess() )  {
    tlog << MSG::FATAL << "Error creating MessageSvc of type "
         << m_messageSvcType << endreq;
    return sc;
  }
  // Create the Job Options service
  sc = m_svcManager->createService( m_jobOptionsSvcType, "JobOptionsSvc", jobsvc );
  if( !sc.isSuccess() )   {
    tlog << MSG::FATAL << "Error creating JobOptionsSvc" << endreq;
    return sc;
  }

  sc = m_svcLocator->service( "JobOptionsSvc", jobOptsIProp);
  if (  !sc.isSuccess() )   {
    tlog << MSG::FATAL << "Error locating JobOptionsSvc" << endreq;
    return sc;
  }
  sc = jobOptsIProp->setProperty( StringProperty("TYPE", m_jobOptionsType) );
  if( !sc.isSuccess() )   {
    tlog << MSG::FATAL << "Error setting TYPE option in JobOptionsSvc"
         << endreq;
    return sc;
  }

  if ( m_jobOptionsPath != "") {         // The command line takes precedence
    sc = jobOptsIProp->setProperty( StringProperty("PATH", m_jobOptionsPath) );
    if( !sc.isSuccess() )   {
      tlog << MSG::FATAL << "Error setting PATH option in JobOptionsSvc"
           << endreq;
      return sc;
    }
  }
  else if ( 0 != getenv("JOBOPTPATH") ) {// Otherwise the Environment JOBOPTPATH
    sc = jobOptsIProp->setProperty (StringProperty("PATH",
                                                   getenv("JOBOPTPATH")));
    if( !sc.isSuccess() )   {
      tlog << MSG::FATAL
           << "Error setting PATH option in JobOptionsSvc from env"
           << endreq;
      return sc;
    }
  }
  else {                                   // Otherwise the default
    sc = jobOptsIProp->setProperty (StringProperty("PATH",
                                                   "../options/job.opts"));
    if( !sc.isSuccess() )   {
      tlog << MSG::FATAL
           << "Error setting PATH option in JobOptionsSvc to default"
           << endreq;
      return sc;
    }
  }
  jobOptsIProp->release();

  // Sets my default the Output Level of the Message service to be
  // the same as this
  m_svcLocator->service( "MessageSvc", msgSvcIProp).ignore();
  msgSvcIProp->setProperty( IntegerProperty("OutputLevel", m_outputLevel)).ignore();
  msgSvcIProp->release();

  sc = jobsvc->sysInitialize();
  if( !sc.isSuccess() )   {
    tlog << MSG::FATAL << "Error initializing JobOptionsSvc" << endreq;
    return sc;
  }
  sc = msgsvc->sysInitialize();
  if( !sc.isSuccess() )  {
    tlog << MSG::FATAL << "Error initializing MessageSvc" << endreq;
    return sc;
  }

  // Get the useful interface from Message anf JobOptions services
  sc = m_svcLocator->service( "MessageSvc", m_messageSvc);
  if( !sc.isSuccess() )  {
    tlog << MSG::FATAL << "Error retrieving MessageSvc." << endreq;
    return sc;
  }
  sc = m_svcLocator->service( "JobOptionsSvc", m_jobOptionsSvc);
  if( !sc.isSuccess() )  {
    tlog << MSG::FATAL << "Error retrieving JobOptionsSvc." << endreq;
    return sc;
  }
  jobsvc->release();
  msgsvc->release();

  return sc;
}

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 paramenter "gnoreFailures"

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

---

Member Data Documentation

int ApplicationMgr::m_refcount [protected]

Reference count.

Definition at line 154 of file ApplicationMgr.h.

ServiceManager* ApplicationMgr::m_svcManager [protected]

Reference to the service factory.

Definition at line 155 of file ApplicationMgr.h.

AlgorithmManager* ApplicationMgr::m_algManager [protected]

Reference to the algorimth factory.

Definition at line 156 of file ApplicationMgr.h.

DLLClassManager* ApplicationMgr::m_classManager [protected]

Reference to the class manager.

Definition at line 157 of file ApplicationMgr.h.

ISvcLocator* ApplicationMgr::m_svcLocator [protected]

Reference to its own service locator.

Definition at line 158 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_SIGo [protected]

For SI's "Go" command via callback.

Definition at line 160 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_SIExit [protected]

For SI's "Exit" command via callback.

Definition at line 161 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_topAlgNameList [protected]

List of top level algorithms names.

Definition at line 162 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_outStreamNameList [protected]

List of output stream names.

Definition at line 163 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_outStreamType [protected]

Output stream type (obsolete?).

Definition at line 164 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_messageSvcType [protected]

MessageSvc type.

Definition at line 165 of file ApplicationMgr.h.

StringProperty ApplicationMgr::m_jobOptionsSvcType [protected]

JobOptionsSvc type.

Definition at line 166 of file ApplicationMgr.h.

ListSvc ApplicationMgr::m_topSvcList [protected]

List of top level services.

Definition at line 169 of file ApplicationMgr.h.

ListName ApplicationMgr::m_topSvcNameList [protected]

List of top level services names.

Definition at line 170 of file ApplicationMgr.h.

std::string ApplicationMgr::m_name [protected]

Name.

Definition at line 172 of file ApplicationMgr.h.

Gaudi::StateMachine::State ApplicationMgr::m_state [protected]

Internal State.

Definition at line 173 of file ApplicationMgr.h.

Gaudi::StateMachine::State ApplicationMgr::m_targetState [protected]

Internal State.

Definition at line 174 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_defServices [protected]

Vector default services names.

Definition at line 176 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_svcMapping [protected]

Default mapping of services.

Definition at line 177 of file ApplicationMgr.h.

VectorName ApplicationMgr::m_svcOptMapping [protected]

Default mapping of services.

Definition at line 178 of file ApplicationMgr.h.

PropertyMgr* ApplicationMgr::m_propertyMgr [protected]

Reference to Property Manager.

Definition at line 180 of file ApplicationMgr.h.

IMessageSvc* ApplicationMgr::m_messageSvc [protected]

Reference to the message service.

Definition at line 181 of file ApplicationMgr.h.

IRunable* ApplicationMgr::m_runable [protected]

Reference to the runable object.

Definition at line 182 of file ApplicationMgr.h.

IEventProcessor* ApplicationMgr::m_processingMgr [protected]

Reference to processing manager object.

Definition at line 183 of file ApplicationMgr.h.

IJobOptionsSvc* ApplicationMgr::m_jobOptionsSvc [protected]

Reference to JobOption service.

Definition at line 184 of file ApplicationMgr.h.

int ApplicationMgr::m_evtMax [protected]

Number of events to be processed.

Definition at line 190 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_extSvcNameList [protected]

List of external services names.

Definition at line 191 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_extSvcCreates [protected]

LHCb or ATLAS defn of "ExtSvc".

Definition at line 192 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 195 of file ApplicationMgr.h.

int ApplicationMgr::m_noOfEvtThreads [protected]

no of multiThreadSvc copies

Definition at line 196 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_dllNameList [protected]

List of DDL's names.

Definition at line 198 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsType [protected]

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

Definition at line 199 of file ApplicationMgr.h.

std::string ApplicationMgr::m_jobOptionsPath [protected]

The "file" to look for properties.

Definition at line 200 of file ApplicationMgr.h.

std::string ApplicationMgr::m_runableType [protected]

Runable type.

Definition at line 201 of file ApplicationMgr.h.

std::string ApplicationMgr::m_eventLoopMgr [protected]

Processing manager type.

Definition at line 202 of file ApplicationMgr.h.

std::string ApplicationMgr::m_evtsel [protected]

Event selection.

Definition at line 203 of file ApplicationMgr.h.

std::string ApplicationMgr::m_histPersName [protected]

CGL: Name of the Hist Pers Svc.

Definition at line 204 of file ApplicationMgr.h.

int ApplicationMgr::m_outputLevel [protected]

Message output level.

Definition at line 205 of file ApplicationMgr.h.

std::string ApplicationMgr::m_appName [protected]

The name of the application.

Definition at line 206 of file ApplicationMgr.h.

std::string ApplicationMgr::m_appVersion [protected]

The version of the application.

Definition at line 207 of file ApplicationMgr.h.

bool ApplicationMgr::m_actHistory [protected]

Activate HistorySvc.

Definition at line 208 of file ApplicationMgr.h.

bool ApplicationMgr::m_codeCheck [protected]

Activate StatusCode checking.

Definition at line 209 of file ApplicationMgr.h.

IntegerProperty ApplicationMgr::m_reflexDebugLevel [protected]

Debug level for the reflex plugin system.

Definition at line 210 of file ApplicationMgr.h.

StringArrayProperty ApplicationMgr::m_createSvcNameList [protected]

Definition at line 212 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditTools [protected]

Defaults for auditors.

Definition at line 215 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditSvcs [protected]

Definition at line 216 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_auditAlgs [protected]

Definition at line 217 of file ApplicationMgr.h.

std::map<std::string,std::string> ApplicationMgr::m_environment [protected]

Environment variables to set.

Definition at line 219 of file ApplicationMgr.h.

BooleanProperty ApplicationMgr::m_loopCheck [protected]

For ServiceMgr initialization loop checking.

Definition at line 222 of file ApplicationMgr.h.

bool ApplicationMgr::m_propertiesPrint [protected]

flag to actiavte the printout of properties

Definition at line 225 of file ApplicationMgr.h.

std::vector<std::string> ApplicationMgr::m_okDlls [private]

names of successfully loaded dlls

Definition at line 228 of file ApplicationMgr.h.

---

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

• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r4/GaudiSvc/src/ApplicationMgr/ApplicationMgr.h
• /afs/cern.ch/sw/Gaudi/releases/GAUDI/GAUDI_v20r4/GaudiSvc/src/ApplicationMgr/ApplicationMgr.cpp