 |
Belle II Software
release-05-02-19
|
319 std::vector<std::string>
void setZMQEventBufferSize(unsigned int zmqEventBufferSize)
Number of events to keep in flight for every worker.
void setJobInformation(const std::shared_ptr< Path > &path)
Set info from path executed by the framework.
bool getZMQRestartFailedWorkers() const
If a worker dies, restart it.
void setZMQSocketAddress(const std::string &zmqSocketAddress)
Socket address to use in ZMQ.
unsigned int m_zmqWorkerTimeout
How long should a worker maximally need to process all of his events in the queue.
bool getVisualizeDataFlow() const
Wether to generate DOT files with data store inputs/outputs of each module.
std::string m_jobInfoOutput
Output for printJobInformation(), generated by setJobInformation().
std::string getPicklePath() const
Returns the path to the file where the pickled path is stored.
unsigned int getNumberOfMCEvents() const
Number of generated events (from EventInfoSetter).
void setNumberEventsOverride(unsigned int nevents)
Override the number of events in run 1 for EventInfoSetter module.
bool getZMQUseEventBackup() const
If a worker dies, store its events in a backup.
void setNumberProcessesOverride(int nproc)
Override number of processes to run in parallel.
void setProfileModuleName(const std::string &name)
Set the name of a module to be profiled.
void setZMQUseEventBackup(bool zmqUseEventBackup)
If a worker dies, store its events in a backup.
int m_numberProcessesOverride
Override m_numberProcesses if >= 0.
int m_run
override run for EventInfoSetter.
void setStreamingObjects(const std::vector< std::string > &strobjs)
Set list of streaming objects.
void setSkipEventsOverride(unsigned int skipEvents)
Set skipNEvents override.
void setZMQWorkerTimeout(unsigned int zmqWorkerTimeout)
How long should a worker maximally need to process all of his events in the queue....
void setLogLevelOverride(int level)
Override global log level if != LogConfig::c_Default.
const std::vector< std::string > & getInputFilesOverride() const
Return overriden input file names, or empty vector if none were set.
int m_numberProcesses
The number of worker processes that should be used for the parallel processing.
unsigned int m_zmqMaximalWaitingTime
Maximal waiting time of any ZMQ module for any communication in ms.
std::string m_externalsPath
The path in which the externals are located.
std::vector< std::string > getEntrySequencesOverride() const
Returns the number sequences (e.g.
void setZMQMaximalWaitingTime(unsigned int zmqMaximalWaitingTime)
Maximal waiting time of any ZMQ module for any communication in ms.
bool getDryRun() const
Read steering file, but do not start any actually start any event processing.
void setInputFilesOverride(const std::vector< std::string > &names)
Override input file names for modules.
unsigned int m_skipNEvents
override skipNEvents for EventInfoSetter/RootInput.
unsigned int m_numberEventsOverride
Override number of events in the first run.
void setNoStats(bool noStats)
Disable collection of statistics during event processing.
bool isMC() const
Do we have generated, not real data?
bool m_noStats
Disable collection of statistics during event processing.
unsigned int m_zmqEventBufferSize
Number of events to keep in flight for every worker.
bool getZMQFailOnFailedWorkers() const
If a worker dies, fail also.
std::string m_profileModuleName
Name of the module which should be profiled, empty if no profiling requested.
int getExperimentOverride() const
Get experiment override, or -1 if unset.
std::string m_outputFileOverrideModule
Name of the module which consumed the output file Override if any was given.
unsigned int getZMQEventBufferSize() const
Number of events to keep in flight for every worker.
void setEntrySequencesOverride(const std::vector< std::string > &sequences)
Override the number sequences (e.g.
void setSteering(const std::string &steering)
Sets the steering file content.
void setRunExperimentOverride(int run, int experiment)
Override run and experiment for EventInfoSetter.
bool m_zmqFailOnFailedWorkers
If a worker dies, fail also.
Environment()
Set up environment from standard BELLE2_ environment variables.
Environment & operator=(const Environment &)=delete
Disable/Hide the copy assignment operator.
int getRunOverride() const
Get run override, or -1 if unset.
std::string m_outputFileOverride
Override name of output file for output module.
void setNumberProcesses(int number)
Sets the number of processes which should be used for the parallel processing.
std::vector< std::string > m_streamingObjects
objects to be streamed in Tx module (all if empty)
int getNumberProcesses() const
Returns the number of worker processes which should be used for the parallel processing.
unsigned int getSkipEventsOverride() const
Get skipNEvents override, or 0 if unset.
unsigned int m_mcEvents
counter for number of generated events.
std::string consumeOutputFileOverride(const std::string &moduleName)
Return overriden output file name, or "" if none was set.
Abstract base class for different kinds of events.
void setUseZMQ(bool useZMQ)
Set the flag if ZMQ should be used instead of the RingBuffer multiprocessing implementation.
std::string m_picklePath
Path to the file where the pickled path is stored.
~Environment()
The Environment destructor.
const std::list< std::string > & getModuleSearchPaths() const
Returns a list of file paths searched for module libraries.
void setZMQFailOnFailedWorkers(bool zmqFailOnFailedWorkers)
If a worker dies, fail also.
void setPicklePath(const std::string &path)
Sets the path to the file where the pickled path is stored.
int m_experiment
override experiment for EventInfoSetter.
const std::string & getSteering() const
Returns the steering file content.
unsigned int getZMQMaximalWaitingTime() const
Maximal waiting time of any ZMQ module for any communication in ms.
std::vector< std::string > m_inputFilesOverride
Override input file names for input modules.
unsigned int getNumberOfEvents() const
Return the number of events, from either input or EventInfoSetter, or -n command line override (if le...
const std::string & getOutputFileOverrideModule() const
Return the name of the module which consumed the OutputFileOverride, "" if no output file override wa...
bool getNoStats() const
Disable collection of statistics during event processing.
bool m_dryRun
Read steering file, but do not start any actually start any event processing.
bool getUseZMQ() const
Flag if ZMQ should be used instead of the RingBuffer multiprocesing implementation.
void setNumberOfMCEvents(unsigned int n)
Set number of generated events (for EventInfoSetter).
This class stores all environment information required to run the framework, such as module or data f...
bool m_visualizeDataFlow
Wether to generate DOT files with data store inputs/outputs of each module.
void setZMQRestartFailedWorkers(bool zmqRestartFailedWorkers)
If a worker dies, restart it.
unsigned int getNumberEventsOverride() const
Returns number of events in run 1 for EventInfoSetter module, or 0 for no override.
unsigned int getZMQWorkerTimeout() const
How long should a worker maximally need to process all of his events in the queue....
void setExternalsPath(const std::string &externalsPath)
Sets the path which points to the externals directory of the framework.
bool m_zmqUseEventBackup
If a worker dies, store its events in a backup.
const std::string & getZMQSocketAddress() const
Socket address to use in ZMQ.
std::vector< std::string > m_entrySequencesOverride
A number sequence (e.g.
bool m_useZMQ
Set to true to use ZMQ instead of RingBuffer.
static Environment & Instance()
Static method to get a reference to the Environment instance.
std::string m_zmqSocketAddress
Socket address to use in ZMQ.
const std::vector< std::string > & getStreamingObjects() const
Get list of streaming objects.
bool m_zmqRestartFailedWorkers
If a worker dies, restart it.
int m_logLevelOverride
Override global log level if != LogConfig::c_Default.
std::string getProfileModuleName() const
Return the name of the module to be profiled, empty if no profiling was requested.
const std::string & getOutputFileOverride() const
Return overriden output file name, or "" if none was set.
void setOutputFileOverride(const std::string &name)
Override output file name for modules.
void setDryRun(bool dryRun)
Read steering file, but do not start any actually start any event processing.
const std::string & getExternalsPath() const
Returns the path which points to the externals directory of the framework.
int getLogLevelOverride() const
Get log level override.
void setVisualizeDataFlow(bool on)
Wether to generate DOT files with data store inputs/outputs of each module.
void printJobInformation() const
Print information on input/output files in current steering file, used by –dry-run.
std::string m_steering
The content of the steering file.