The Gaudi Framework  v33r1 (b1225454)
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 (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 (std::string type, std::string name, const IInterface *ancestor)
 Standard constructor. More...
 
 GaudiCommon ()=delete
 Standard constructor. More...
 
 GaudiCommon (const GaudiCommon &)=delete
 Standard constructor. More...
 
- Public Member Functions inherited from GaudiCommon< Gaudi::Sequence >
Gaudi::Utils::GetData< TYPE >::return_type get (IDataProviderSvc *svc, std::string_view 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, std::string_view 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, std::string_view 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, std::string_view 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, std::string_view location, const bool useRootInTES=true) const
 Register a data object or container into Gaudi Event Transient Store. More...
 
DataObjectput (IDataProviderSvc *svc, DataObject *object, std::string_view location, const bool useRootInTES=true) const
 
TOOL * tool (std::string_view type, std::string_view name, const IInterface *parent=0, bool create=true) const
 Useful method for the easy location of tools. More...
 
TOOL * tool (std::string_view type, const IInterface *parent=0, bool create=true) const
 A useful method for the easy location of tools. More...
 
SmartIF< SERVICE > svc (std::string_view 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...
 
StatusCode Error (std::string_view msg, const StatusCode st=StatusCode::FAILURE, const size_t mx=10) const
 Print the error message and return with the given StatusCode. More...
 
StatusCode Warning (std::string_view msg, const StatusCode st=StatusCode::FAILURE, const size_t mx=10) const
 Print the warning message and return with the given StatusCode. More...
 
StatusCode Info (std::string_view msg, const StatusCode st=StatusCode::SUCCESS, const size_t mx=10) const
 Print the info message and return with the given StatusCode. More...
 
StatusCode Print (std::string_view 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, std::string_view message="", const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Assertion - throw exception if the given condition is not fulfilled. More...
 
void Exception (std::string_view msg, const GaudiException &exc, const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and (re)-throw a given GaudiException. More...
 
void Exception (std::string_view msg, const std::exception &exc, const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and (re)-throw a given exception. More...
 
void Exception (std::string_view msg="no message", const StatusCode sc=StatusCode(StatusCode::FAILURE, true)) const
 Create and throw an exception with the given message. More...
 
StatEntitycounter (std::string_view tag) const
 accessor to certain counter by name More...
 
StatEntitycounter (std::string_view 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 (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 (std::string type, std::string name, const IInterface *ancestor)
 Tool constructor - SFINAE-ed to insure this constructor is only defined if PBASE derives from AlgTool. More...
 
 GaudiCommon ()=delete
 
 GaudiCommon (const GaudiCommon &)=delete
 
StatusCode initialize () override
 standard initialization method More...
 
StatusCode finalize () override
 standard finalization method More...
 
GaudiCommonoperator= (const GaudiCommon &)=delete
 
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 (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 (std::string type, 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, StatEntity, std::less<> > StatisticsOwn
 the actual type of general counters More...
 
typedef std::map< std::string, std::reference_wrapper< Gaudi::Accumulators::PrintableCounter >, std::less<> > Statistics
 
typedef std::map< std::string, unsigned int, std::less<> > 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 139 of file GaudiSequencer.cpp.

139  {
141  m_entries.clear();
142 
143  //== Get the "Context" option if in the file...
144  auto jos = service<IJobOptionsSvc>( "JobOptionsSvc" );
145 
146  //= Get the Application manager, to see if algorithm exist
147  auto appMgr = service<IAlgManager>( "ApplicationMgr" );
148  for ( const auto& item : m_names.value() ) {
150  const std::string& theName = typeName.name();
151  const std::string& theType = typeName.type();
152 
153  //== Check wether the specified algorithm already exists. If not, create it
155  SmartIF<IAlgorithm> myIAlg = appMgr->algorithm( typeName, false ); // do not create it now
156  if ( !myIAlg ) {
157  Gaudi::Algorithm* myAlg = nullptr;
158  result = createSubAlgorithm( theType, theName, myAlg );
159  if ( myAlg ) {
160  // Override the default values of the special properties Context and RootInTES,
161  // which will be superseded by the explicit value in options (if present).
162  if ( !isDefault( context() ) && myAlg->hasProperty( "Context" ) ) {
163  myAlg->setProperty( "Context", context() ).ignore();
164  }
165  if ( !isDefault( rootInTES() ) && myAlg->hasProperty( "RootInTES" ) ) {
166  myAlg->setProperty( "RootInTES", rootInTES() ).ignore();
167  }
168  }
169  myIAlg = myAlg; // ensure that myIAlg.isValid() from here onwards!
170  } else {
171  Gaudi::Algorithm* myAlg = dynamic_cast<Gaudi::Algorithm*>( myIAlg.get() );
172  if ( myAlg ) {
173  subAlgorithms()->push_back( myAlg );
174  // when the algorithm is not created, the ref count is short by one, so we have to fix it.
175  myAlg->addRef();
176  }
177  }
178 
179  // propagate the sub-algorithm into own state.
180  if ( result.isSuccess() && Gaudi::StateMachine::INITIALIZED <= FSMState() && myIAlg &&
181  Gaudi::StateMachine::INITIALIZED > myIAlg->FSMState() ) {
182  StatusCode sc = myIAlg->sysInitialize();
183  if ( sc.isFailure() ) result = sc;
184  }
185 
186  // propagate the sub-algorithm into own state.
187  if ( result.isSuccess() && Gaudi::StateMachine::RUNNING <= FSMState() && myIAlg &&
188  Gaudi::StateMachine::RUNNING > myIAlg->FSMState() ) {
189  StatusCode sc = myIAlg->sysStart();
190  if ( sc.isFailure() ) result = sc;
191  }
192 
193  //== Is it an Algorithm ? Strange test...
194  if ( result.isSuccess() ) {
195  // TODO: (MCl) it is possible to avoid the dynamic_cast in most of the
196  // cases by keeping the result of createSubAlgorithm.
197  Gaudi::Algorithm* myAlg = dynamic_cast<Gaudi::Algorithm*>( myIAlg.get() );
198  if ( myAlg ) {
199  // Note: The reference counting is kept by the system of sub-algorithms
200  m_entries.emplace_back( myAlg );
201  if ( msgLevel( MSG::DEBUG ) ) debug() << "Added algorithm " << theName << endmsg;
202  } else {
203  warning() << theName << " is not a Gaudi::Algorithm - failed dynamic_cast" << endmsg;
204  final = StatusCode::FAILURE;
205  }
206  } else {
207  warning() << "Unable to find or create " << theName << endmsg;
208  final = result;
209  }
210  }
211 
212  //== Print the list of algorithms
213  MsgStream& msg = info();
214  if ( m_modeOR ) msg << "OR ";
215  msg << "Member list: ";
217  []( auto& os, const AlgorithmEntry& e ) -> decltype( auto ) {
218  Gaudi::Algorithm* alg = e.algorithm();
219  std::string typ = System::typeinfoName( typeid( *alg ) );
220  os << typ;
221  if ( alg->name() != typ ) os << "/" << alg->name();
222  return os;
223  } );
224  if ( !isDefault( context() ) ) msg << ", with context '" << context() << "'";
225  if ( !isDefault( rootInTES() ) ) msg << ", with rootInTES '" << rootInTES() << "'";
226  msg << endmsg;
227 
228  return final;
229 }
Definition of the MsgStream class used to transmit messages.
Definition: MsgStream.h:34
virtual StatusCode sysStart()=0
Startup method invoked by the framework.
StatusCode setProperty(const Gaudi::Details::PropertyBase &p) override
set the property form another property
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:100
TYPE * get() const
Get interface pointer.
Definition: SmartIF.h:86
bool hasProperty(const std::string &name) const override
Return true if we have a property with the given name.
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:365
const std::string & context() const
Returns the "context" string. Used to identify different processing states.
Definition: GaudiCommon.h:694
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:61
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:168
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:101
bool isFailure() const
Definition: StatusCode.h:145
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 74 of file GaudiSequencer.cpp.

74  {
75 
77 
78  if ( msgLevel( MSG::DEBUG ) ) debug() << "==> Execute" << endmsg;
79 
80  StatusCode result = StatusCode( StatusCode::SUCCESS, true );
81 
82  bool seqPass = !m_modeOR; // for OR, result will be false, unless (at least) one is true
83  // for AND, result will be true, unless (at least) one is false
84  // also see comment below ....
85 
86  for ( auto& entry : m_entries ) {
87  Gaudi::Algorithm* myAlg = entry.algorithm();
88  if ( !myAlg->isEnabled() ) continue;
89  if ( myAlg->execState( ctx ).state() != AlgExecState::State::Done ) {
90 
91  if ( m_measureTime ) m_timerTool->start( entry.timer() );
92  result = myAlg->sysExecute( ctx );
93  if ( m_measureTime ) m_timerTool->stop( entry.timer() );
94  if ( !result.isSuccess() ) break; //== Abort and return bad status
95  }
96  //== Check the returned status
97  if ( !m_ignoreFilter ) {
98  bool passed = myAlg->execState( ctx ).filterPassed();
99  if ( msgLevel( MSG::VERBOSE ) )
100  verbose() << "Algorithm " << myAlg->name() << " returned filter passed " << ( passed ? "true" : "false" )
101  << endmsg;
102  if ( entry.reverse() ) passed = !passed;
103 
104  //== indicate our own result. For OR, exit as soon as true.
105  // If no more, will exit with false.
106  //== for AND, exit as soon as false. Else, will be true (default)
107 
108  // if not short-circuiting, make sure we latch iPass to 'true' in
109  // OR mode (i.e. it is sufficient for one item to be true in order
110  // to be true at the end, and thus we start out at 'false'), and latch
111  // to 'false' in AND mode (i.e. it is sufficient for one item to
112  // be false to the false in the end, and thus we start out at 'true')
113  // -- i.e. we should not just blindly return the 'last' passed status!
114 
115  // or to put it another way: in OR mode, we don't care about things
116  // which are false, as they leave our current state alone (provided
117  // we stared as 'false'!), and in AND mode, we keep our current
118  // state until someone returns 'false' (provided we started as 'true')
119  if ( m_modeOR ? passed : !passed ) {
120  seqPass = passed;
121  if ( msgLevel( MSG::VERBOSE ) ) verbose() << "SeqPass is now " << ( seqPass ? "true" : "false" ) << endmsg;
122  if ( m_shortCircuit ) break;
123  }
124  }
125  }
126  if ( msgLevel( MSG::VERBOSE ) ) verbose() << "SeqPass is " << ( seqPass ? "true" : "false" ) << endmsg;
127  auto& state = execState( ctx );
128  if ( !m_ignoreFilter && !m_entries.empty() ) state.setFilterPassed( m_invert ? !seqPass : seqPass );
129  state.setState( AlgExecState::State::Done );
130 
132 
133  return m_returnOK ? ( result.ignore(), StatusCode::SUCCESS ) : result;
134 }
Gaudi::Property< bool > m_measureTime
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
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:365
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:168
AlgExecState & execState(const EventContext &ctx) const override
reference to AlgExecState of Alg
Definition: Algorithm.cpp:561
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:559
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:549
StatusCode sysExecute(const EventContext &ctx) override
The actions to be performed by the algorithm on an event.
Definition: Algorithm.cpp:338

◆ GaudiCommon() [1/4]

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 636 of file GaudiCommon.h.

637  : base_class( std::move( type ), std::move( name ), ancestor ) {
639  }
FixTESPath< Gaudi::Sequence > base_class
Definition: GaudiCommon.h:97
T move(T... args)
const Gaudi::Algorithm & parent
void initGaudiCommonConstructor(const IInterface *parent=nullptr)
Constructor initializations.

◆ GaudiCommon() [2/4]

GaudiCommon< PBASE >::GaudiCommon
delete

Standard constructor.

◆ GaudiCommon() [3/4]

GaudiCommon< PBASE >::GaudiCommon
delete

Standard constructor.

◆ GaudiCommon() [4/4]

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 630 of file GaudiCommon.h.

630  : base_class( std::move( name ), pSvcLocator ) {
632  }
FixTESPath< Gaudi::Sequence > base_class
Definition: GaudiCommon.h:97
T move(T... args)
void initGaudiCommonConstructor(const IInterface *parent=nullptr)
Constructor initializations.

◆ initialize()

StatusCode GaudiSequencer::initialize ( )
override

Definition at line 40 of file GaudiSequencer.cpp.

40  {
41  // Note: not calling base class initialize because we want to reimplement the loop over sub algs
42  if ( msgLevel( MSG::DEBUG ) ) debug() << "==> Initialise" << endmsg;
43 
44  auto status = decodeNames();
45  if ( !status.isSuccess() ) return status;
46 
47  m_timerTool = tool<ISequencerTimerTool>( "SequencerTimerTool" );
48 
49  if ( m_timerTool->globalTiming() ) m_measureTime = true;
50 
51  if ( m_measureTime ) {
54  } else {
56  m_timerTool = nullptr;
57  }
58 
59  //== Initialize the algorithms
60  for ( auto& entry : m_entries ) {
61  if ( m_measureTime ) { entry.setTimer( m_timerTool->addTimer( entry.algorithm()->name() ) ); }
62 
63  status = entry.algorithm()->sysInitialize();
64  if ( !status.isSuccess() ) { return Error( "Can not initialize " + entry.algorithm()->name(), status ); }
65  }
67 
68  return StatusCode::SUCCESS;
69 }
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
StatusCode Error(std::string_view 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:100
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.
const StatusCode & ignore() const
Ignore/check StatusCode.
Definition: StatusCode.h:168
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 234 of file GaudiSequencer.cpp.

234  {
235  // no action for not-yet initialized sequencer
236  if ( Gaudi::StateMachine::INITIALIZED > FSMState() ) return; // RETURN
237 
238  decodeNames().ignore();
239 
240  if ( !m_measureTime ) return; // RETURN
241 
242  // add the entries into timer table:
243 
244  if ( !m_timerTool ) { m_timerTool = tool<ISequencerTimerTool>( "SequencerTimerTool" ); }
245 
246  if ( m_timerTool->globalTiming() ) m_measureTime = true;
247 
250 
251  for ( auto& entry : m_entries ) { entry.setTimer( m_timerTool->addTimer( entry.algorithm()->name() ) ); }
252 
254 }
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:168
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 278 of file GaudiSequencer.cpp.

278  {
280 
281  IAlgContextSvc* algCtx = nullptr;
282  if ( registerContext() ) { algCtx = contextSvc(); }
283  // Lock the context
284  Gaudi::Utils::AlgContext cnt( this, algCtx, ctx );
285 
286  // Do not execute if one or more of the m_vetoObjs exist in TES
287  const auto it = find_if( begin( m_vetoObjs ), end( m_vetoObjs ),
288  [&]( const std::string& loc ) { return this->exist<DataObject>( evtSvc(), loc ); } );
289  if ( it != end( m_vetoObjs ) ) {
290  if ( msgLevel( MSG::DEBUG ) ) debug() << *it << " found, skipping event " << endmsg;
291  return sc;
292  }
293 
294  // Execute if m_requireObjs is empty
295  // or if one or more of the m_requireObjs exist in TES
296  bool doIt = m_requireObjs.empty() ||
298  [&]( const std::string& loc ) { return this->exist<DataObject>( evtSvc(), loc ); } );
299 
300  // execute the generic method:
301  if ( doIt ) sc = GaudiCommon<Gaudi::Sequence>::sysExecute( ctx );
302  return sc;
303 }
Helper "sentry" class to automatize the safe register/unregister the algorithm's context.
constexpr static const auto SUCCESS
Definition: StatusCode.h:100
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:95
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 256 of file GaudiSequencer.cpp.

256  {
257  if ( m_invert ) os << "~";
258  // the default filterpass value for an empty sequencer depends on ModeOR
259  if ( m_entries.empty() ) return os << ( ( !m_modeOR ) ? "CFTrue" : "CFFalse" );
260 
261  // if we have only one element, we do not need a name
262  if ( m_entries.size() > 1 ) os << "seq(";
263 
264  const auto op = m_modeOR ? " | " : " & ";
265  const auto last = end( m_entries );
266  const auto first = begin( m_entries );
267  for ( auto iterator = first; iterator != last; ++iterator ) {
268  if ( iterator != first ) os << op;
269  if ( iterator->reverse() ) os << "~";
270  iterator->algorithm()->toControlFlowExpression( os );
271  }
272 
273  if ( m_entries.size() > 1 ) os << ")";
274  return os;
275 }
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: