Loading [MathJax]/extensions/tex2jax.js
The Gaudi Framework  v36r11 (bdb84f5f)
All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Modules Pages
AlgorithmManager Class Reference

#include </builds/gaudi/Gaudi/GaudiCoreSvc/src/ApplicationMgr/AlgorithmManager.h>

Inheritance diagram for AlgorithmManager:
Collaboration diagram for AlgorithmManager:

Classes

struct  AlgorithmItem
 

Public Types

typedef std::map< std::string, std::string, std::less<> > AlgTypeAliasesMap
 typedefs and classes More...
 
- Public Types inherited from extends< ComponentManager, IAlgManager >
using base_class = extends
 Typedef to this class. More...
 
using extend_interfaces_base = extend_interfaces< Interfaces... >
 Typedef to the base of this class. More...
 
- Public Types inherited from CommonMessaging< implements< IComponentManager > >
using base_class = CommonMessaging
 
- Public Types inherited from extend_interfaces< Interfaces... >
using ext_iids = typename Gaudi::interface_list_cat< typename Interfaces::ext_iids... >::type
 take union of the ext_iids of all Interfaces... More...
 

Public Member Functions

 AlgorithmManager (IInterface *iface)
 default creator More...
 
StatusCode addAlgorithm (IAlgorithm *alg) override
 implementation of IAlgManager::addAlgorithm More...
 
StatusCode removeAlgorithm (IAlgorithm *alg) override
 implementation of IAlgManager::removeAlgorithm More...
 
StatusCode createAlgorithm (std::string algtype, std::string algname, IAlgorithm *&algorithm, bool managed=false, bool checkIfExists=true) override
 implementation of IAlgManager::createAlgorithm More...
 
bool existsAlgorithm (std::string_view name) const override
 implementation of IAlgManager::existsAlgorithm More...
 
const std::vector< IAlgorithm * > & getAlgorithms () const override
 implementation of IAlgManager::getAlgorithms More...
 
StatusCode initialize () override
 Initialization (from CONFIGURED to INITIALIZED). More...
 
StatusCode start () override
 Start (from INITIALIZED to RUNNING). More...
 
StatusCode stop () override
 Stop (from RUNNING to INITIALIZED). More...
 
StatusCode finalize () override
 Finalize (from INITIALIZED to CONFIGURED). More...
 
StatusCode reinitialize () override
 Initialization (from INITIALIZED or RUNNING to INITIALIZED, via CONFIGURED). More...
 
StatusCode restart () override
 Initialization (from RUNNING to RUNNING, via INITIALIZED). More...
 
const std::stringname () const override
 Return the name of the manager (implementation of INamedInterface) More...
 
SmartIF< IAlgorithm > & algorithm (const Gaudi::Utils::TypeNameString &typeName, const bool createIf=true) override
 
AlgTypeAliasesMaptypeAliases ()
 
const AlgTypeAliasesMaptypeAliases () const
 
void outputLevelUpdate () override
 Function to call to update the outputLevel of the components (after a change in MessageSvc). More...
 
- Public Member Functions inherited from extends< ComponentManager, IAlgManager >
void * i_cast (const InterfaceID &tid) const override
 Implementation of IInterface::i_cast. More...
 
StatusCode queryInterface (const InterfaceID &ti, void **pp) override
 Implementation of IInterface::queryInterface. More...
 
std::vector< std::stringgetInterfaceNames () const override
 Implementation of IInterface::getInterfaceNames. More...
 
- Public Member Functions inherited from ComponentManager
 ComponentManager (IInterface *application, const InterfaceID &baseIID)
 Constructor. More...
 
const InterfaceIDcomponentBaseInterface () const override
 Basic interface id of the managed components. More...
 
StatusCode queryInterface (const InterfaceID &iid, void **pinterface) override
 Specialized queryInterface implementation. More...
 
SmartIF< ISvcLocator > & serviceLocator () const override
 
StatusCode configure () override
 Configuration (from OFFLINE to CONFIGURED). More...
 
StatusCode initialize () override
 Initialization (from CONFIGURED to INITIALIZED). More...
 
StatusCode start () override
 Start (from INITIALIZED to RUNNING). More...
 
StatusCode stop () override
 Stop (from RUNNING to INITIALIZED). More...
 
StatusCode finalize () override
 Finalize (from INITIALIZED to CONFIGURED). More...
 
StatusCode terminate () override
 Initialization (from CONFIGURED to OFFLINE). More...
 
StatusCode reinitialize () override
 Initialization (from INITIALIZED or RUNNING to INITIALIZED, via CONFIGURED). More...
 
StatusCode restart () override
 Initialization (from RUNNING to RUNNING, via INITIALIZED). More...
 
Gaudi::StateMachine::State FSMState () const override
 Get the current state. More...
 
Gaudi::StateMachine::State targetFSMState () const override
 When we are in the middle of a transition, get the state where the transition is leading us. More...
 
- Public Member Functions inherited from CommonMessaging< implements< IComponentManager > >
MSG::Level msgLevel () const
 get the cached level (originally extracted from the embedded MsgStream) More...
 
bool msgLevel (MSG::Level lvl) const
 get the output level from the embedded MsgStream More...
 

Private Attributes

std::vector< AlgorithmItemm_algs
 algorithms maintained by AlgorithmManager More...
 
std::vector< IAlgorithm * > m_listOfPtrs
 List of pointers to the know services used to implement getAlgorithms() More...
 
AlgTypeAliasesMap m_algTypeAliases
 

Additional Inherited Members

- Protected Member Functions inherited from CommonMessaging< implements< IComponentManager > >
MSG::Level setUpMessaging () const
 Set up local caches. More...
 
MSG::Level resetMessaging ()
 Reinitialize internal states. More...
 
void updateMsgStreamOutputLevel (int level)
 Update the output level of the cached MsgStream. More...
 
- Protected Attributes inherited from ComponentManager
SmartIF< IInterfacem_application
 Pointer to the owner of the manager. More...
 
SmartIF< IStatefulm_stateful
 Pointer to the IStateful interface of the owner. More...
 
InterfaceID m_basicInterfaceId
 Basic interface id of the managed components. More...
 
SmartIF< ISvcLocatorm_svcLocator
 Service locator (needed to access the MessageSvc) More...
 
friend ApplicationMgr
 

Detailed Description

The AlgorithmManager class is in charge of the creation of concrete instances of Algorithms. The ApplicationMgr delegates the creation and bookkeeping of algorithms to the algorithm factory. In order to be able to create algorithms from which it does not know the concrete type it requires that the algorithm has been declared in one of 3 possible ways: an abstract static creator function, a dynamic link library or an abstract factory reference.

Author
Pere Mato

Definition at line 41 of file AlgorithmManager.h.

Member Typedef Documentation

◆ AlgTypeAliasesMap

typedefs and classes

Definition at line 52 of file AlgorithmManager.h.

Constructor & Destructor Documentation

◆ AlgorithmManager()

AlgorithmManager::AlgorithmManager ( IInterface iface)

default creator

Definition at line 29 of file AlgorithmManager.cpp.

29  : base_class( application, IAlgorithm::interfaceID() ) {
30  addRef(); // Initial count set to 1
31 }

Member Function Documentation

◆ addAlgorithm()

StatusCode AlgorithmManager::addAlgorithm ( IAlgorithm alg)
override

implementation of IAlgManager::addAlgorithm

Definition at line 34 of file AlgorithmManager.cpp.

34  {
35  m_algs.push_back( alg );
36  return StatusCode::SUCCESS;
37 }

◆ algorithm()

SmartIF< IAlgorithm > & AlgorithmManager::algorithm ( const Gaudi::Utils::TypeNameString typeName,
const bool  createIf = true 
)
override

Definition at line 103 of file AlgorithmManager.cpp.

103  {
104  auto it = std::find( m_algs.begin(), m_algs.end(), typeName.name() );
105  if ( it != m_algs.end() ) { // found
106  return it->algorithm;
107  }
108  if ( createIf ) {
109  IAlgorithm* alg;
110  if ( createAlgorithm( typeName.type(), typeName.name(), alg, true ).isSuccess() ) {
111  return algorithm( typeName, false );
112  }
113  }
114  return no_algorithm;
115 }

◆ createAlgorithm()

StatusCode AlgorithmManager::createAlgorithm ( std::string  algtype,
std::string  algname,
IAlgorithm *&  algorithm,
bool  managed = false,
bool  checkIfExists = true 
)
override

implementation of IAlgManager::createAlgorithm

Definition at line 50 of file AlgorithmManager.cpp.

51  {
52  // Check is the algorithm is already existing
53  if ( checkIfExists ) {
54  if ( existsAlgorithm( algname ) ) {
55  // return an error because an algorithm with that name already exists
56  return StatusCode::FAILURE;
57  }
58  }
59  std::string actualalgtype( algtype );
60  // a '\' in front of the type name prevents alias replacement
61  if ( ( actualalgtype.size() > 8 ) && ( actualalgtype.compare( 0, 8, "unalias:" ) == 0 ) ) {
62  actualalgtype = actualalgtype.substr( 8 );
63  } else {
64  auto typeAlias = m_algTypeAliases.find( algtype );
65  if ( typeAlias != m_algTypeAliases.end() ) { actualalgtype = typeAlias->second; }
66  }
67  algorithm = Gaudi::Algorithm::Factory::create( actualalgtype, algname, serviceLocator().get() ).release();
68  if ( !algorithm ) {
69  this->error() << "Algorithm of type " << actualalgtype << " is unknown (No factory available)." << endmsg;
70 #ifndef _WIN32
71  errno =
72  0xAFFEDEAD; // code used by Gaudi for library load errors: forces getLastErrorString do use dlerror (on Linux)
73 #endif
75  if ( !err.empty() ) this->error() << err << endmsg;
76  this->error() << "More information may be available by setting the global jobOpt \"PluginDebugLevel\" to 1"
77  << endmsg;
78  return StatusCode::FAILURE;
79  }
80  // Check the compatibility of the version of the interface obtained
81  if ( !isValidInterface( algorithm ) ) {
82  fatal() << "Incompatible interface IAlgorithm version for " << actualalgtype << endmsg;
83  return StatusCode::FAILURE;
84  }
85  m_algs.emplace_back( algorithm, managed );
86  // let the algorithm know its type
87  algorithm->setType( std::move( actualalgtype ) );
88  // this is needed to keep the reference count correct, since isValidInterface(algorithm)
89  // implies an increment of the counter by 1
90  algorithm->release();
91  StatusCode rc;
92  if ( managed ) {
93  // Bring the created algorithm to the target state of the ApplicationMgr
95  rc = algorithm->sysInitialize();
96  if ( rc.isSuccess() && targetFSMState() >= Gaudi::StateMachine::RUNNING ) { rc = algorithm->sysStart(); }
97  }
98  if ( !rc.isSuccess() ) { this->error() << "Failed to initialize algorithm: [" << algname << "]" << endmsg; }
99  }
100  return rc;
101 }

◆ existsAlgorithm()

bool AlgorithmManager::existsAlgorithm ( std::string_view  name) const
override

implementation of IAlgManager::existsAlgorithm

Definition at line 118 of file AlgorithmManager.cpp.

118  {
119  return m_algs.end() != std::find( m_algs.begin(), m_algs.end(), name );
120 }

◆ finalize()

StatusCode AlgorithmManager::finalize ( )
override

Finalize (from INITIALIZED to CONFIGURED).

Definition at line 161 of file AlgorithmManager.cpp.

161  {
162  StatusCode rc;
163  auto it = m_algs.begin();
164  while ( it != m_algs.end() ) { // finalize and remove from the list the managed algorithms
165  if ( it->managed ) {
166  rc = it->algorithm->sysFinalize();
167  if ( rc.isFailure() ) return rc;
168  it = m_algs.erase( it );
169  } else {
170  ++it;
171  }
172  }
173  return rc;
174 }

◆ getAlgorithms()

const std::vector< IAlgorithm * > & AlgorithmManager::getAlgorithms ( ) const
override

implementation of IAlgManager::getAlgorithms

Definition at line 123 of file AlgorithmManager.cpp.

123  {
125  m_listOfPtrs.reserve( m_algs.size() );
127  []( const AlgorithmItem& alg ) { return alg.algorithm.get(); } );
128  return m_listOfPtrs;
129 }

◆ initialize()

StatusCode AlgorithmManager::initialize ( )
override

Initialization (from CONFIGURED to INITIALIZED).

Definition at line 131 of file AlgorithmManager.cpp.

131  {
132  StatusCode rc;
133  for ( auto& it : m_algs ) {
134  if ( !it.managed || it.algorithm->FSMState() >= Gaudi::StateMachine::INITIALIZED ) continue;
135  rc = it.algorithm->sysInitialize();
136  if ( rc.isFailure() ) return rc;
137  }
138  return rc;
139 }

◆ name()

const std::string& AlgorithmManager::name ( ) const
inlineoverride

Return the name of the manager (implementation of INamedInterface)

Definition at line 85 of file AlgorithmManager.h.

85  {
86  static const std::string _name = "AlgorithmManager";
87  return _name;
88  }

◆ outputLevelUpdate()

void AlgorithmManager::outputLevelUpdate ( )
override

Function to call to update the outputLevel of the components (after a change in MessageSvc).

Definition at line 211 of file AlgorithmManager.cpp.

211  {
212  resetMessaging();
213  for ( auto& algItem : m_algs ) {
214  const auto alg = dynamic_cast<Gaudi::Algorithm*>( algItem.algorithm.get() );
215  if ( alg ) alg->resetMessaging();
216  }
217 }

◆ reinitialize()

StatusCode AlgorithmManager::reinitialize ( )
override

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

Definition at line 176 of file AlgorithmManager.cpp.

176  {
177  StatusCode rc;
178  for ( auto& it : m_algs ) {
179  if ( !it.managed ) continue;
180  rc = it.algorithm->sysReinitialize();
181  if ( rc.isFailure() ) {
182  this->error() << "Unable to re-initialize algorithm: " << it.algorithm->name() << endmsg;
183  return rc;
184  }
185  }
186  return rc;
187 }

◆ removeAlgorithm()

StatusCode AlgorithmManager::removeAlgorithm ( IAlgorithm alg)
override

implementation of IAlgManager::removeAlgorithm

Definition at line 40 of file AlgorithmManager.cpp.

40  {
41  auto it = std::find( m_algs.begin(), m_algs.end(), alg );
42  if ( it != m_algs.end() ) {
43  m_algs.erase( it );
44  return StatusCode::SUCCESS;
45  }
46  return StatusCode::FAILURE;
47 }

◆ restart()

StatusCode AlgorithmManager::restart ( )
override

Initialization (from RUNNING to RUNNING, via INITIALIZED).

Definition at line 189 of file AlgorithmManager.cpp.

189  {
191  m_aess = serviceLocator()->service( "AlgExecStateSvc" );
192  if ( !m_aess.isValid() ) {
193  fatal() << "Error retrieving AlgExecStateSvc" << endmsg;
194  return StatusCode::FAILURE;
195  }
196 
197  StatusCode rc;
198 
199  for ( auto& it : m_algs ) {
200  if ( !it.managed ) continue;
201  rc = it.algorithm->sysRestart();
202  m_aess->resetErrorCount( it.algorithm );
203  if ( rc.isFailure() ) {
204  this->error() << "Unable to re-initialize algorithm: " << it.algorithm->name() << endmsg;
205  return rc;
206  }
207  }
208  return rc;
209 }

◆ start()

StatusCode AlgorithmManager::start ( )
override

Start (from INITIALIZED to RUNNING).

Definition at line 141 of file AlgorithmManager.cpp.

141  {
142  StatusCode rc;
143  for ( auto& it : m_algs ) {
144  if ( !it.managed || it.algorithm->FSMState() >= Gaudi::StateMachine::RUNNING ) continue;
145  rc = it.algorithm->sysStart();
146  if ( rc.isFailure() ) return rc;
147  }
148  return rc;
149 }

◆ stop()

StatusCode AlgorithmManager::stop ( )
override

Stop (from RUNNING to INITIALIZED).

Definition at line 151 of file AlgorithmManager.cpp.

151  {
152  StatusCode rc;
153  for ( auto& it : m_algs ) {
154  if ( !it.managed ) continue;
155  rc = it.algorithm->sysStop();
156  if ( rc.isFailure() ) return rc;
157  }
158  return rc;
159 }

◆ typeAliases() [1/2]

AlgTypeAliasesMap& AlgorithmManager::typeAliases ( )
inline

Definition at line 92 of file AlgorithmManager.h.

92 { return m_algTypeAliases; }

◆ typeAliases() [2/2]

const AlgTypeAliasesMap& AlgorithmManager::typeAliases ( ) const
inline

Definition at line 93 of file AlgorithmManager.h.

93 { return m_algTypeAliases; }

Member Data Documentation

◆ m_algs

std::vector<AlgorithmItem> AlgorithmManager::m_algs
private

algorithms maintained by AlgorithmManager

Definition at line 99 of file AlgorithmManager.h.

◆ m_algTypeAliases

AlgTypeAliasesMap AlgorithmManager::m_algTypeAliases
private

Definition at line 104 of file AlgorithmManager.h.

◆ m_listOfPtrs

std::vector<IAlgorithm*> AlgorithmManager::m_listOfPtrs
mutableprivate

List of pointers to the know services used to implement getAlgorithms()

Definition at line 102 of file AlgorithmManager.h.


The documentation for this class was generated from the following files:
ComponentManager::targetFSMState
Gaudi::StateMachine::State targetFSMState() const override
When we are in the middle of a transition, get the state where the transition is leading us.
Definition: ComponentManager.h:73
AlgorithmManager::m_algTypeAliases
AlgTypeAliasesMap m_algTypeAliases
Definition: AlgorithmManager.h:104
std::string
STL class.
AlgorithmManager::existsAlgorithm
bool existsAlgorithm(std::string_view name) const override
implementation of IAlgManager::existsAlgorithm
Definition: AlgorithmManager.cpp:118
std::move
T move(T... args)
CommonMessaging< implements< IComponentManager > >::resetMessaging
MSG::Level resetMessaging()
Reinitialize internal states.
Definition: CommonMessaging.h:179
StatusCode::isSuccess
bool isSuccess() const
Definition: StatusCode.h:314
std::vector::reserve
T reserve(T... args)
std::find
T find(T... args)
std::back_inserter
T back_inserter(T... args)
extends< ComponentManager, IAlgManager >::base_class
extends base_class
Typedef to this class.
Definition: extends.h:24
std::vector::clear
T clear(T... args)
basic.alg
alg
Definition: basic.py:15
AlgorithmManager::m_listOfPtrs
std::vector< IAlgorithm * > m_listOfPtrs
List of pointers to the know services used to implement getAlgorithms()
Definition: AlgorithmManager.h:102
SmartIF::isValid
bool isValid() const
Allow for check if smart pointer is valid.
Definition: SmartIF.h:72
Gaudi::Functional::details::get
auto get(const Handle &handle, const Algo &, const EventContext &) -> decltype(details::deref(handle.get()))
Definition: FunctionalDetails.h:444
StatusCode
Definition: StatusCode.h:65
IAlgorithm
Definition: IAlgorithm.h:38
AlgorithmManager::createAlgorithm
StatusCode createAlgorithm(std::string algtype, std::string algname, IAlgorithm *&algorithm, bool managed=false, bool checkIfExists=true) override
implementation of IAlgManager::createAlgorithm
Definition: AlgorithmManager.cpp:50
Gaudi::Algorithm
Base class from which all concrete algorithm classes should be derived.
Definition: Algorithm.h:90
SmartIF< IAlgExecStateSvc >
endmsg
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:203
ComponentManager::serviceLocator
SmartIF< ISvcLocator > & serviceLocator() const override
Definition: ComponentManager.h:39
std::transform
T transform(T... args)
AlgorithmManager::m_algs
std::vector< AlgorithmItem > m_algs
algorithms maintained by AlgorithmManager
Definition: AlgorithmManager.h:99
AlgorithmManager::name
const std::string & name() const override
Return the name of the manager (implementation of INamedInterface)
Definition: AlgorithmManager.h:85
Gaudi::StateMachine::RUNNING
@ RUNNING
Definition: StateMachine.h:26
AlgorithmManager::algorithm
SmartIF< IAlgorithm > & algorithm(const Gaudi::Utils::TypeNameString &typeName, const bool createIf=true) override
Definition: AlgorithmManager.cpp:103
StatusCode::SUCCESS
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
GaudiDict::typeName
std::string typeName(const std::type_info &typ)
Definition: Dictionary.cpp:31
std::begin
T begin(T... args)
Gaudi::StateMachine::INITIALIZED
@ INITIALIZED
Definition: StateMachine.h:25
isValidInterface
bool isValidInterface(IFace *i)
Templated function that throws an exception if the version if the interface implemented by the object...
Definition: IInterface.h:334
std::string::empty
T empty(T... args)
std::map::end
T end(T... args)
StatusCode::FAILURE
constexpr static const auto FAILURE
Definition: StatusCode.h:101
System::getLastErrorString
GAUDI_API const std::string getLastErrorString()
Get last system error as string.
Definition: System.cpp:274
gaudirun.application
application
Definition: gaudirun.py:323
IOTest.rc
rc
Definition: IOTest.py:117