The Gaudi Framework  v33r0 (d5ea422b)
GaudiSequencer Class Reference

Sequencer for executing several algorithms, stopping when one is faulty. More...

#include <GaudiAlg/GaudiSequencer.h>

Inheritance diagram for GaudiSequencer:
Collaboration diagram for GaudiSequencer:

Classes

class  AlgorithmEntry
 

Public Member Functions

StatusCode initialize () override
 
StatusCode execute (const EventContext &ctx) const override
 
StatusCode sysExecute (const EventContext &ctx) override
 
std::ostreamtoControlFlowExpression (std::ostream &os) const override
 Produce string represention of the control flow expression. More...
 
template<typename U = PBASE, typename = std::enable_if_t<std::is_base_of_v<Gaudi::Algorithm, PBASE>, U>>
 GaudiCommon (const std::string &name, ISvcLocator *pSvcLocator)
 Standard constructor. More...
 
template<typename U = PBASE, typename = std::enable_if_t<std::is_base_of_v<AlgTool, PBASE>, U>>
 GaudiCommon (const std::string &type, const std::string &name, const IInterface *ancestor)
 Standard constructor. More...
 
- Public Member Functions inherited from GaudiCommon< Gaudi::Sequence >
Gaudi::Utils::GetData< TYPE >::return_type get (IDataProviderSvc *svc, const std::string &location, const bool useRootInTES=true) const
 Templated access to the data in Gaudi Transient Store. More...
 
Gaudi::Utils::GetData< TYPE >::return_type getIfExists (IDataProviderSvc *svc, const std::string &location, const bool useRootInTES=true) const
 Quicker version of the get function which bypasses the check on the retrieved data. More...
 
bool exist (IDataProviderSvc *svc, const std::string &location, const bool useRootInTES=true) const
 Check the existence of a data object or container in the Gaudi Transient Event Store. More...
 
Gaudi::Utils::GetData< TYPE >::return_type getOrCreate (IDataProviderSvc *svc, const std::string &location, const bool useRootInTES=true) const
 Get the existing data object from Gaudi Event Transient store. More...
 
DataObjectput (IDataProviderSvc *svc, std::unique_ptr< DataObject > object, const std::string &location, const bool useRootInTES=true) const
 Register a data object or container into Gaudi Event Transient Store. More...
 
DataObjectput (IDataProviderSvc *svc, DataObject *object, const std::string &location, const bool useRootInTES=true) const
 
TOOL * tool (const std::string &type, const std::string &name, const IInterface *parent=0, bool create=true) const
 Useful method for the easy location of tools. More...
 
TOOL * tool (const std::string &type, const IInterface *parent=0, bool create=true) const
 A useful method for the easy location of tools. More...
 
SmartIF< SERVICE > svc (const std::string &name, const bool create=true) const
 A useful method for the easy location of services. More...
 
IUpdateManagerSvcupdMgrSvc () const
 Short-cut to locate the Update Manager Service. More...
 
WARN_UNUSED StatusCode Error (const std::string &msg, const StatusCode st=StatusCode::FAILURE, const size_t mx=10) const
 Print the error message and return with the given StatusCode. More...
 
WARN_UNUSED StatusCode Warning (const std::string &msg, const StatusCode st=StatusCode::FAILURE, const size_t mx=10) const
 Print the warning message and return with the given StatusCode. More...
 
WARN_UNUSED StatusCode Info (const std::string &msg, const StatusCode st=StatusCode::SUCCESS, const size_t mx=10) const
 Print the info message and return with the given StatusCode. More...
 
WARN_UNUSED StatusCode Print (const std::string &msg, const StatusCode st=StatusCode::SUCCESS, const MSG::Level lev=MSG::INFO) const
 Print the message and return with the given StatusCode. More...
 
void Assert (const bool ok, const std::string &message="", const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Assertion - throw exception if the given condition is not fulfilled. More...
 
void Assert (const bool ok, const char *message, const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Assertion - throw exception if the given condition is not fulfilled. More...
 
void Exception (const std::string &msg, const GaudiException &exc, const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and (re)-throw a given GaudiException. More...
 
void Exception (const std::string &msg, const std::exception &exc, const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and (re)-throw a given exception. More...
 
void Exception (const std::string &msg="no message", const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and throw an exception with the given message. More...
 
StatEntitycounter (const std::string &tag) const
 accessor to certain counter by name More...
 
StatEntitycounter (const std::string &tag)
 
bool typePrint () const
 Insert the actual C++ type of the algorithm/tool in the messages ? More...
 
bool propsPrint () const
 Print properties at initialization ? More...
 
bool statPrint () const
 Print statistical counters at finalization ? More...
 
bool errorsPrint () const
 Print error counters at finalization ? More...
 
long printStat (const MSG::Level level=MSG::ALWAYS) const
 perform the actual printout of statistical counters More...
 
long printErrors (const MSG::Level level=MSG::ALWAYS) const
 perform the actual printout of error counters More...
 
long printProps (const MSG::Level level=MSG::ALWAYS) const
 perform the actual printout of properties More...
 
void registerCondition (const std::string &condition, StatusCode(CallerClass::*mf)()=nullptr)
 register the current instance to the UpdateManagerSvc as a consumer for a condition. More...
 
void registerCondition (const std::string &condition, CondType *&condPtrDest, StatusCode(CallerClass::*mf)()=NULL)
 register the current instance to the UpdateManagerSvc as a consumer for a condition. More...
 
void registerCondition (char *condition, StatusCode(CallerClass::*mf)()=NULL)
 just to avoid conflicts with the version using a pointer to a template class. More...
 
void registerCondition (TargetClass *condition, StatusCode(CallerClass::*mf)()=NULL)
 register the current instance to the UpdateManagerSvc as a consumer for a condition. More...
 
StatusCode runUpdate ()
 asks the UpdateManagerSvc to perform an update of the instance (if needed) without waiting the next BeginEvent incident. More...
 
 GaudiCommon (const std::string &name, ISvcLocator *pSvcLocator)
 Algorithm constructor - the SFINAE constraint below ensures that this is constructor is only defined if PBASE derives from Algorithm. More...
 
 GaudiCommon (const std::string &type, const std::string &name, const IInterface *ancestor)
 Tool constructor - SFINAE-ed to insure this constructor is only defined if PBASE derives from AlgTool. More...
 
StatusCode initialize () override
 standard initialization method More...
 
StatusCode finalize () override
 standard finalization method More...
 
StatusCode release (const IInterface *interface) const
 Manual forced (and 'safe') release of the active tool or service. More...
 
const Servicesservices () const
 get the list of aquired services More...
 
const std::stringcontext () const
 Returns the "context" string. Used to identify different processing states. More...
 
- Public Member Functions inherited from FixTESPath< BASE >
template<typename U = BASE, typename = std::enable_if_t<std::is_base_of_v<Gaudi::Algorithm, BASE>, U>>
 FixTESPath (const std::string &name, ISvcLocator *pSvcLocator)
 Algorithm constructor - the SFINAE constraint below ensures that this is constructor is only defined if BASE derives from Algorithm. More...
 
template<typename U = BASE, typename = std::enable_if_t<std::is_base_of_v<AlgTool, BASE>, U>>
 FixTESPath (const std::string &type, const std::string &name, const IInterface *ancestor)
 Tool constructor - SFINAE-ed to insure this constructor is only defined if BASE derives from AlgTool. More...
 
StatusCode initialize () override
 
const std::stringrootInTES () const
 Returns the "rootInTES" string. More...
 
std::string fullTESLocation (std::string_view location, bool useRootInTES) const
 Returns the full correct event location given the rootInTes settings. More...
 

Private Member Functions

StatusCode decodeNames ()
 Decode a vector of string. More...
 
void membershipHandler ()
 for asynchronous changes in the list of algorithms More...
 

Private Attributes

Gaudi::Property< std::vector< std::string > > m_vetoObjs
 
Gaudi::Property< std::vector< std::string > > m_requireObjs
 
Gaudi::Property< std::vector< std::string > > m_names
 
Gaudi::Property< bool > m_sequential = {this, "Sequential", false, "execute members one at a time"}
 
Gaudi::Property< bool > m_modeOR = {this, "ModeOR", false, "use OR logic instead of AND"}
 
Gaudi::Property< bool > m_ignoreFilter = {this, "IgnoreFilterPassed", false, "always continue"}
 
Gaudi::Property< bool > m_measureTime = {this, "MeasureTime", false, "measure time"}
 
Gaudi::Property< bool > m_returnOK = {this, "ReturnOK", false, "forces the sequencer to return a good status"}
 
Gaudi::Property< bool > m_shortCircuit = {this, "ShortCircuit", true, "stop processing as soon as possible"}
 
Gaudi::Property< bool > m_invert = {this, "Invert", false, "invert the logic result of the sequencer"}
 
std::vector< AlgorithmEntrym_entries
 List of algorithms to process. More...
 
ISequencerTimerToolm_timerTool = nullptr
 Pointer to the timer tool. More...
 
int m_timer
 Timer number for the sequencer. More...
 

Additional Inherited Members

- Protected Types inherited from GaudiCommon< Gaudi::Sequence >
using base_class = FixTESPath< Gaudi::Sequence >
 
typedef std::map< std::string, StatEntityStatisticsOwn
 the actual type of general counters More...
 
typedef std::map< std::string, std::reference_wrapper< Gaudi::Accumulators::PrintableCounter > > Statistics
 
typedef std::map< std::string, unsigned int > Counter
 the actual type error/warning counter More...
 
typedef std::vector< IAlgTool * > AlgTools
 storage for active tools More...
 
typedef std::vector< SmartIF< IService > > Services
 storage for active services More...
 
- Protected Member Functions inherited from GaudiCommon< Gaudi::Sequence >
StatusCode releaseTool (const IAlgTool *tool) const
 manual forced (and 'safe') release of the tool More...
 
StatusCode releaseSvc (const IInterface *svc) const
 manual forced (and 'safe') release of the service More...
 
- Protected Attributes inherited from GaudiCommon< Gaudi::Sequence >
SmartIF< ICounterSummarySvcm_counterSummarySvc
 a pointer to the CounterSummarySvc More...
 
- Static Protected Attributes inherited from GaudiCommon< Gaudi::Sequence >
static const bool IgnoreRootInTES
 Simple definition to be used with the new useRootInTES argument get<TYPE> and put methods. More...
 
static const bool UseRootInTES
 Simple definition to be used with the new useRootInTES argument get<TYPE> and put methods. More...
 

Detailed Description

Sequencer for executing several algorithms, stopping when one is faulty.

Default behaviour (ModeOR=False) is to execute all algorithms until one returns filterPassed() = False. If ShortCircuit is set to False, then all algorithms will be executed.

In OR mode, the logic is opposite. All algorithms until one returns filterPassed() = True. To then exit one must conter-intuitively set ShortCircuit to False. If the default value ShortCircuit=True is left then all algorithms will be executed.

Author
Olivier Callot
Date
2004-05-13

Definition at line 38 of file GaudiSequencer.h.

Member Function Documentation

◆ decodeNames()

StatusCode GaudiSequencer::decodeNames ( )
private

Decode a vector of string.

Definition at line 182 of file GaudiSequencer.cpp.

182  {
184  m_entries.clear();
185 
186  //== Get the "Context" option if in the file...
187  auto jos = service<IJobOptionsSvc>( "JobOptionsSvc" );
188 
189  //= Get the Application manager, to see if algorithm exist
190  auto appMgr = service<IAlgManager>( "ApplicationMgr" );
191  for ( const auto& item : m_names.value() ) {
193  const std::string& theName = typeName.name();
194  const std::string& theType = typeName.type();
195 
196  //== Check wether the specified algorithm already exists. If not, create it
198  SmartIF<IAlgorithm> myIAlg = appMgr->algorithm( typeName, false ); // do not create it now
199  if ( !myIAlg ) {
200  // ensure some magic properties are set while we create the subalgorithm so
201  // that it effectively inherites 'our' settings -- if they have non-default
202  // values... and are not set explicitly already.
203  populate_JobOptionsSvc_t populate_guard{theName, jos, std::forward_as_tuple( "Context", context() ),
204  std::forward_as_tuple( "RootInTES", rootInTES() )};
205  Gaudi::Algorithm* myAlg = nullptr;
206  result = createSubAlgorithm( theType, theName, myAlg );
207  myIAlg = myAlg; // ensure that myIAlg.isValid() from here onwards!
208  } else {
209  Gaudi::Algorithm* myAlg = dynamic_cast<Gaudi::Algorithm*>( myIAlg.get() );
210  if ( myAlg ) {
211  subAlgorithms()->push_back( myAlg );
212  // when the algorithm is not created, the ref count is short by one, so we have to fix it.
213  myAlg->addRef();
214  }
215  }
216 
217  // propagate the sub-algorithm into own state.
218  if ( result.isSuccess() && Gaudi::StateMachine::INITIALIZED <= FSMState() && myIAlg &&
219  Gaudi::StateMachine::INITIALIZED > myIAlg->FSMState() ) {
220  StatusCode sc = myIAlg->sysInitialize();
221  if ( sc.isFailure() ) result = sc;
222  }
223 
224  // propagate the sub-algorithm into own state.
225  if ( result.isSuccess() && Gaudi::StateMachine::RUNNING <= FSMState() && myIAlg &&
226  Gaudi::StateMachine::RUNNING > myIAlg->FSMState() ) {
227  StatusCode sc = myIAlg->sysStart();
228  if ( sc.isFailure() ) result = sc;
229  }
230 
231  //== Is it an Algorithm ? Strange test...
232  if ( result.isSuccess() ) {
233  // TODO: (MCl) it is possible to avoid the dynamic_cast in most of the
234  // cases by keeping the result of createSubAlgorithm.
235  Gaudi::Algorithm* myAlg = dynamic_cast<Gaudi::Algorithm*>( myIAlg.get() );
236  if ( myAlg ) {
237  // Note: The reference counting is kept by the system of sub-algorithms
238  m_entries.emplace_back( myAlg );
239  if ( msgLevel( MSG::DEBUG ) ) debug() << "Added algorithm " << theName << endmsg;
240  } else {
241  warning() << theName << " is not a Gaudi::Algorithm - failed dynamic_cast" << endmsg;
242  final = StatusCode::FAILURE;
243  }
244  } else {
245  warning() << "Unable to find or create " << theName << endmsg;
246  final = result;
247  }
248  }
249 
250  //== Print the list of algorithms
251  MsgStream& msg = info();
252  if ( m_modeOR ) msg << "OR ";
253  msg << "Member list: ";
255  []( auto& os, const AlgorithmEntry& e ) -> decltype( auto ) {
256  Gaudi::Algorithm* alg = e.algorithm();
257  std::string typ = System::typeinfoName( typeid( *alg ) );
258  os << typ;
259  if ( alg->name() != typ ) os << "/" << alg->name();
260  return os;
261  } );
262  if ( !isDefault( context() ) ) msg << ", with context '" << context() << "'";
263  if ( !isDefault( rootInTES() ) ) msg << ", with rootInTES '" << rootInTES() << "'";
264  msg << endmsg;
265 
266  return final;
267 }
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:34
T forward_as_tuple(T... args)
virtual StatusCode sysStart()=0
Startup method invoked by the framework.
GAUDI_API const std::string typeinfoName(const std::type_info &)
Get platform independent information about the class type.
Definition: System.cpp:308
constexpr static const auto SUCCESS
Definition: StatusCode.h:96
TYPE * get() const
Get interface pointer.
Definition: SmartIF.h:86
virtual StatusCode sysInitialize()=0
Initialization method invoked by the framework.
STL class.
Helper class to parse a string of format "type/name".
Gaudi::Property< std::vector< std::string > > m_names
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
bool isSuccess() const
Definition: StatusCode.h:361
const std::string & context() const
Returns the "context" string. Used to identify different processing states.
Definition: GaudiCommon.h:717
Gaudi::Property< bool > m_modeOR
Stream & ostream_joiner(Stream &os, Iterator first, Iterator last, Separator sep, OutputElement output=OutputElement{})
Definition: SerializeSTL.h:47
const std::string & rootInTES() const
Returns the "rootInTES" string.
Definition: FixTESPath.h:62
Base class from which all concrete algorithm classes should be derived.
Definition: Algorithm.h:89
appMgr
Definition: IOTest.py:103
constexpr static const auto FAILURE
Definition: StatusCode.h:97
bool isFailure() const
Definition: StatusCode.h:141
std::string typeName(const std::type_info &typ)
Definition: Dictionary.cpp:31
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
std::vector< AlgorithmEntry > m_entries
List of algorithms to process.

◆ execute()

StatusCode GaudiSequencer::execute ( const EventContext ctx) const
override

Definition at line 117 of file GaudiSequencer.cpp.

117  {
118 
120 
121  if ( msgLevel( MSG::DEBUG ) ) debug() << "==> Execute" << endmsg;
122 
123  StatusCode result = StatusCode( StatusCode::SUCCESS, true );
124 
125  bool seqPass = !m_modeOR; // for OR, result will be false, unless (at least) one is true
126  // for AND, result will be true, unless (at least) one is false
127  // also see comment below ....
128 
129  for ( auto& entry : m_entries ) {
130  Gaudi::Algorithm* myAlg = entry.algorithm();
131  if ( !myAlg->isEnabled() ) continue;
132  if ( myAlg->execState( ctx ).state() != AlgExecState::State::Done ) {
133 
134  if ( m_measureTime ) m_timerTool->start( entry.timer() );
135  result = myAlg->sysExecute( ctx );
136  if ( m_measureTime ) m_timerTool->stop( entry.timer() );
137  if ( !result.isSuccess() ) break; //== Abort and return bad status
138  }
139  //== Check the returned status
140  if ( !m_ignoreFilter ) {
141  bool passed = myAlg->execState( ctx ).filterPassed();
142  if ( msgLevel( MSG::VERBOSE ) )
143  verbose() << "Algorithm " << myAlg->name() << " returned filter passed " << ( passed ? "true" : "false" )
144  << endmsg;
145  if ( entry.reverse() ) passed = !passed;
146 
147  //== indicate our own result. For OR, exit as soon as true.
148  // If no more, will exit with false.
149  //== for AND, exit as soon as false. Else, will be true (default)
150 
151  // if not short-circuiting, make sure we latch iPass to 'true' in
152  // OR mode (i.e. it is sufficient for one item to be true in order
153  // to be true at the end, and thus we start out at 'false'), and latch
154  // to 'false' in AND mode (i.e. it is sufficient for one item to
155  // be false to the false in the end, and thus we start out at 'true')
156  // -- i.e. we should not just blindly return the 'last' passed status!
157 
158  // or to put it another way: in OR mode, we don't care about things
159  // which are false, as they leave our current state alone (provided
160  // we stared as 'false'!), and in AND mode, we keep our current
161  // state until someone returns 'false' (provided we started as 'true')
162  if ( m_modeOR ? passed : !passed ) {
163  seqPass = passed;
164  if ( msgLevel( MSG::VERBOSE ) ) verbose() << "SeqPass is now " << ( seqPass ? "true" : "false" ) << endmsg;
165  if ( m_shortCircuit ) break;
166  }
167  }
168  }
169  if ( msgLevel( MSG::VERBOSE ) ) verbose() << "SeqPass is " << ( seqPass ? "true" : "false" ) << endmsg;
170  auto& state = execState( ctx );
171  if ( !m_ignoreFilter && !m_entries.empty() ) state.setFilterPassed( m_invert ? !seqPass : seqPass );
172  state.setState( AlgExecState::State::Done );
173 
175 
176  return m_returnOK ? ( result.ignore(), StatusCode::SUCCESS ) : result;
177 }
Gaudi::Property< bool > m_measureTime
constexpr static const auto SUCCESS
Definition: StatusCode.h:96
bool filterPassed() const
ISequencerTimerTool * m_timerTool
Pointer to the timer tool.
Gaudi::Property< bool > m_ignoreFilter
Gaudi::Property< bool > m_invert
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
State state() const
bool isSuccess() const
Definition: StatusCode.h:361
Gaudi::Property< bool > m_modeOR
Gaudi::Property< bool > m_shortCircuit
virtual void start(int index)=0
start the counter, i.e.
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:164
AlgExecState & execState(const EventContext &ctx) const override
reference to AlgExecState of Alg
Definition: Algorithm.cpp:568
Base class from which all concrete algorithm classes should be derived.
Definition: Algorithm.h:89
Gaudi::Property< bool > m_returnOK
bool isEnabled() const override
Is this algorithm enabled or disabled?
Definition: Algorithm.cpp:566
virtual double stop(int index)=0
stop the counter, return the elapsed time
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
int m_timer
Timer number for the sequencer.
std::vector< AlgorithmEntry > m_entries
List of algorithms to process.
const std::string & name() const override
The identifying name of the algorithm object.
Definition: Algorithm.cpp:556
StatusCode sysExecute(const EventContext &ctx) override
The actions to be performed by the algorithm on an event.
Definition: Algorithm.cpp:345

◆ GaudiCommon() [1/2]

template<typename U = PBASE, typename = std::enable_if_t<std::is_base_of_v<AlgTool, PBASE>, U>>
GaudiCommon< PBASE >::GaudiCommon ( typename U  = PBASE,
typename  = std::enable_if_t<std::is_base_of_v<AlgTool, PBASE>, U> 
)
inline

Standard constructor.

Definition at line 658 of file GaudiCommon.h.

659  : base_class( type, name, ancestor ) {
660  initGaudiCommonConstructor( this->parent() );
661  }
FixTESPath< Gaudi::Sequence > base_class
Definition: GaudiCommon.h:103
void initGaudiCommonConstructor(const IInterface *parent=nullptr)
Constructor initializations.

◆ GaudiCommon() [2/2]

template<typename U = PBASE, typename = std::enable_if_t<std::is_base_of_v<Gaudi::Algorithm, PBASE>, U>>
GaudiCommon< PBASE >::GaudiCommon ( typename U  = PBASE,
typename  = std::enable_if_t<std::is_base_of_v<Gaudi::Algorithm, PBASE>, U> 
)
inline

Standard constructor.

Definition at line 652 of file GaudiCommon.h.

652  : base_class( name, pSvcLocator ) {
654  }
FixTESPath< Gaudi::Sequence > base_class
Definition: GaudiCommon.h:103
void initGaudiCommonConstructor(const IInterface *parent=nullptr)
Constructor initializations.

◆ initialize()

StatusCode GaudiSequencer::initialize ( )
override

Definition at line 83 of file GaudiSequencer.cpp.

83  {
84  // Note: not calling base class initialize because we want to reimplement the loop over sub algs
85  if ( msgLevel( MSG::DEBUG ) ) debug() << "==> Initialise" << endmsg;
86 
87  auto status = decodeNames();
88  if ( !status.isSuccess() ) return status;
89 
90  m_timerTool = tool<ISequencerTimerTool>( "SequencerTimerTool" );
91 
92  if ( m_timerTool->globalTiming() ) m_measureTime = true;
93 
94  if ( m_measureTime ) {
97  } else {
99  m_timerTool = nullptr;
100  }
101 
102  //== Initialize the algorithms
103  for ( auto& entry : m_entries ) {
104  if ( m_measureTime ) { entry.setTimer( m_timerTool->addTimer( entry.algorithm()->name() ) ); }
105 
106  status = entry.algorithm()->sysInitialize();
107  if ( !status.isSuccess() ) { return Error( "Can not initialize " + entry.algorithm()->name(), status ); }
108  }
110 
111  return StatusCode::SUCCESS;
112 }
Gaudi::Property< bool > m_measureTime
virtual void decreaseIndent()=0
Decrease the indentation of the name.
virtual int addTimer(const std::string &name)=0
add a timer entry with the specified name
WARN_UNUSED StatusCode Error(const std::string &msg, const StatusCode st=StatusCode::FAILURE, const size_t mx=10) const
Print the error message and return with the given StatusCode.
constexpr static const auto SUCCESS
Definition: StatusCode.h:96
virtual void increaseIndent()=0
Increase the indentation of the name.
virtual bool globalTiming()=0
returns the flag telling that global timing is wanted
ISequencerTimerTool * m_timerTool
Pointer to the timer tool.
StatusCode decodeNames()
Decode a vector of string.
StatusCode release(const IInterface *interface) const
Manual forced (and 'safe') release of the active tool or service.
virtual StatusCode sysInitialize()=0
Initialization of the Tool.
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202
int m_timer
Timer number for the sequencer.
std::vector< AlgorithmEntry > m_entries
List of algorithms to process.

◆ membershipHandler()

void GaudiSequencer::membershipHandler ( )
private

for asynchronous changes in the list of algorithms

Definition at line 272 of file GaudiSequencer.cpp.

272  {
273  // no action for not-yet initialized sequencer
274  if ( Gaudi::StateMachine::INITIALIZED > FSMState() ) return; // RETURN
275 
276  decodeNames().ignore();
277 
278  if ( !m_measureTime ) return; // RETURN
279 
280  // add the entries into timer table:
281 
282  if ( !m_timerTool ) { m_timerTool = tool<ISequencerTimerTool>( "SequencerTimerTool" ); }
283 
284  if ( m_timerTool->globalTiming() ) m_measureTime = true;
285 
288 
289  for ( auto& entry : m_entries ) { entry.setTimer( m_timerTool->addTimer( entry.algorithm()->name() ) ); }
290 
292 }
Gaudi::Property< bool > m_measureTime
virtual void decreaseIndent()=0
Decrease the indentation of the name.
virtual int addTimer(const std::string &name)=0
add a timer entry with the specified name
virtual void increaseIndent()=0
Increase the indentation of the name.
virtual bool globalTiming()=0
returns the flag telling that global timing is wanted
ISequencerTimerTool * m_timerTool
Pointer to the timer tool.
StatusCode decodeNames()
Decode a vector of string.
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:164
int m_timer
Timer number for the sequencer.
std::vector< AlgorithmEntry > m_entries
List of algorithms to process.

◆ sysExecute()

StatusCode GaudiSequencer::sysExecute ( const EventContext ctx)
override

< guard/sentry

Definition at line 316 of file GaudiSequencer.cpp.

316  {
318 
319  IAlgContextSvc* algCtx = nullptr;
320  if ( registerContext() ) { algCtx = contextSvc(); }
321  // Lock the context
322  Gaudi::Utils::AlgContext cnt( this, algCtx, ctx );
323 
324  // Do not execute if one or more of the m_vetoObjs exist in TES
325  const auto it = find_if( begin( m_vetoObjs ), end( m_vetoObjs ),
326  [&]( const std::string& loc ) { return this->exist<DataObject>( evtSvc(), loc ); } );
327  if ( it != end( m_vetoObjs ) ) {
328  if ( msgLevel( MSG::DEBUG ) ) debug() << *it << " found, skipping event " << endmsg;
329  return sc;
330  }
331 
332  // Execute if m_requireObjs is empty
333  // or if one or more of the m_requireObjs exist in TES
334  bool doIt = m_requireObjs.empty() ||
336  [&]( const std::string& loc ) { return this->exist<DataObject>( evtSvc(), loc ); } );
337 
338  // execute the generic method:
339  if ( doIt ) sc = GaudiCommon<Gaudi::Sequence>::sysExecute( ctx );
340  return sc;
341 }
Helper "sentry" class to automatize the safe register/unregister the algorithm's context.
constexpr static const auto SUCCESS
Definition: StatusCode.h:96
STL class.
This class is used for returning status codes from appropriate routines.
Definition: StatusCode.h:61
def end
Definition: IOTest.py:123
T find_if(T... args)
T any_of(T... args)
Implements the common functionality between GaudiTools and GaudiAlgorithms.
Definition: GaudiCommon.h:101
An abstract interface for Algorithm Context Service.
AttribStringParser::Iterator begin(const AttribStringParser &parser)
Gaudi::Property< std::vector< std::string > > m_requireObjs
Gaudi::Property< std::vector< std::string > > m_vetoObjs
MsgStream & endmsg(MsgStream &s)
MsgStream Modifier: endmsg. Calls the output method of the MsgStream.
Definition: MsgStream.h:202

◆ toControlFlowExpression()

std::ostream & GaudiSequencer::toControlFlowExpression ( std::ostream os) const
override

Produce string represention of the control flow expression.

Definition at line 294 of file GaudiSequencer.cpp.

294  {
295  if ( m_invert ) os << "~";
296  // the default filterpass value for an empty sequencer depends on ModeOR
297  if ( m_entries.empty() ) return os << ( ( !m_modeOR ) ? "CFTrue" : "CFFalse" );
298 
299  // if we have only one element, we do not need a name
300  if ( m_entries.size() > 1 ) os << "seq(";
301 
302  const auto op = m_modeOR ? " | " : " & ";
303  const auto last = end( m_entries );
304  const auto first = begin( m_entries );
305  for ( auto iterator = first; iterator != last; ++iterator ) {
306  if ( iterator != first ) os << op;
307  if ( iterator->reverse() ) os << "~";
308  iterator->algorithm()->toControlFlowExpression( os );
309  }
310 
311  if ( m_entries.size() > 1 ) os << ")";
312  return os;
313 }
Gaudi::Property< bool > m_invert
def end
Definition: IOTest.py:123
Gaudi::Property< bool > m_modeOR
AttribStringParser::Iterator begin(const AttribStringParser &parser)
std::vector< AlgorithmEntry > m_entries
List of algorithms to process.

Member Data Documentation

◆ m_entries

std::vector<AlgorithmEntry> GaudiSequencer::m_entries
private

List of algorithms to process.

Definition at line 90 of file GaudiSequencer.h.

◆ m_ignoreFilter

Gaudi::Property<bool> GaudiSequencer::m_ignoreFilter = {this, "IgnoreFilterPassed", false, "always continue"}
private

Definition at line 84 of file GaudiSequencer.h.

◆ m_invert

Gaudi::Property<bool> GaudiSequencer::m_invert = {this, "Invert", false, "invert the logic result of the sequencer"}
private

Definition at line 88 of file GaudiSequencer.h.

◆ m_measureTime

Gaudi::Property<bool> GaudiSequencer::m_measureTime = {this, "MeasureTime", false, "measure time"}
private

Definition at line 85 of file GaudiSequencer.h.

◆ m_modeOR

Gaudi::Property<bool> GaudiSequencer::m_modeOR = {this, "ModeOR", false, "use OR logic instead of AND"}
private

Definition at line 83 of file GaudiSequencer.h.

◆ m_names

Gaudi::Property<std::vector<std::string> > GaudiSequencer::m_names
private
Initial value:
= {
this, "Members", {}, &GaudiSequencer::membershipHandler, "list of algorithms"}

Definition at line 80 of file GaudiSequencer.h.

◆ m_requireObjs

Gaudi::Property<std::vector<std::string> > GaudiSequencer::m_requireObjs
private
Initial value:
{
this, "RequireObjects", {}, "execute only if one or more of these TES objects exist"}

Definition at line 77 of file GaudiSequencer.h.

◆ m_returnOK

Gaudi::Property<bool> GaudiSequencer::m_returnOK = {this, "ReturnOK", false, "forces the sequencer to return a good status"}
private

Definition at line 86 of file GaudiSequencer.h.

◆ m_sequential

Gaudi::Property<bool> GaudiSequencer::m_sequential = {this, "Sequential", false, "execute members one at a time"}
private

Definition at line 82 of file GaudiSequencer.h.

◆ m_shortCircuit

Gaudi::Property<bool> GaudiSequencer::m_shortCircuit = {this, "ShortCircuit", true, "stop processing as soon as possible"}
private

Definition at line 87 of file GaudiSequencer.h.

◆ m_timer

int GaudiSequencer::m_timer
private

Timer number for the sequencer.

Definition at line 92 of file GaudiSequencer.h.

◆ m_timerTool

ISequencerTimerTool* GaudiSequencer::m_timerTool = nullptr
private

Pointer to the timer tool.

Definition at line 91 of file GaudiSequencer.h.

◆ m_vetoObjs

Gaudi::Property<std::vector<std::string> > GaudiSequencer::m_vetoObjs
private
Initial value:
{
this, "VetoObjects", {}, "skip execute if one or more of these TES objects exist"}

Definition at line 75 of file GaudiSequencer.h.


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