FastTimerService Class Reference

#include <FastTimerService.h>

Inheritance diagram for FastTimerService:

Classes
struct	AtomicResources
struct	GroupOfModules
struct	Measurement
struct	PlotRanges
class	PlotsPerElement
class	PlotsPerJob
class	PlotsPerPath
class	PlotsPerProcess
struct	Resources
struct	ResourcesPerJob
struct	ResourcesPerModule
struct	ResourcesPerPath
struct	ResourcesPerProcess

Public Member Functions
	FastTimerService (const edm::ParameterSet &, edm::ActivityRegistry &)
template<typename T >
void	printEvent (T &out, ResourcesPerJob const &data) const
template<typename T >
void	printEventHeader (T &out, std::string const &label) const
template<typename T >
void	printEventLine (T &out, Resources const &data, std::string const &label) const
template<typename T >
void	printEventLine (T &out, AtomicResources const &data, std::string const &label) const
template<typename T >
void	printHeader (T &out, std::string const &label) const
template<typename T >
void	printPathSummaryHeader (T &out, std::string const &label) const
template<typename T >
void	printPathSummaryLine (T &out, Resources const &data, Resources const &total, uint64_t events, std::string const &label) const
template<typename T >
void	printSummary (T &out, ResourcesPerJob const &data, std::string const &label) const
template<typename T >
void	printSummaryHeader (T &out, std::string const &label, bool detailed) const
template<typename T >
void	printSummaryLine (T &out, Resources const &data, uint64_t events, std::string const &label) const
template<typename T >
void	printSummaryLine (T &out, Resources const &data, uint64_t events, uint64_t active, std::string const &label) const
template<typename T >
void	printTransition (T &out, AtomicResources const &data, std::string const &label) const
double	queryEventTime (edm::StreamID) const
double	queryEventTime (edm::StreamID, std::string const &process) const
double	queryHighlightTime (edm::StreamID sid, std::string const &label) const
double	queryModuleTime (edm::StreamID, const edm::ModuleDescription &module) const
double	queryModuleTime (edm::StreamID, unsigned int id) const
double	queryModuleTimeByLabel (edm::StreamID, std::string const &module) const
double	queryModuleTimeByLabel (edm::StreamID, std::string const &process, const std::string &module) const
double	queryPathTime (edm::StreamID, std::string const &path) const
double	queryPathTime (edm::StreamID, std::string const &process, std::string const &path) const
double	querySourceTime (edm::StreamID) const
	~FastTimerService () override

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Private Member Functions
void	ignoredSignal (const std::string &signal) const
bool	isFirstSubprocess (edm::StreamContext const &)
bool	isFirstSubprocess (edm::GlobalContext const &)
bool	isLastSubprocess (std::atomic< unsigned int > &check)
void	on_scheduler_entry (bool worker) final
void	on_scheduler_exit (bool worker) final
void	postBeginJob ()
void	postEndJob ()
void	postEvent (edm::StreamContext const &)
void	postEventReadFromSource (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postGlobalBeginLumi (edm::GlobalContext const &)
void	postGlobalBeginRun (edm::GlobalContext const &)
void	postGlobalEndLumi (edm::GlobalContext const &)
void	postGlobalEndRun (edm::GlobalContext const &)
void	postModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleEventDelayedGet (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleEventPrefetching (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleGlobalBeginLumi (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	postModuleGlobalBeginRun (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	postModuleGlobalEndLumi (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	postModuleGlobalEndRun (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	postModuleStreamBeginLumi (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleStreamBeginRun (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleStreamEndLumi (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postModuleStreamEndRun (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	postPathEvent (edm::StreamContext const &, edm::PathContext const &, edm::HLTPathStatus const &)
void	postSourceEvent (edm::StreamID)
void	postSourceLumi (edm::LuminosityBlockIndex)
void	postSourceRun (edm::RunIndex)
void	postStreamBeginLumi (edm::StreamContext const &)
void	postStreamBeginRun (edm::StreamContext const &)
void	postStreamEndLumi (edm::StreamContext const &)
void	postStreamEndRun (edm::StreamContext const &)
void	preallocate (edm::service::SystemBounds const &)
void	preBeginJob (edm::PathsAndConsumesOfModulesBase const &, edm::ProcessContext const &)
void	preEvent (edm::StreamContext const &)
void	preEventReadFromSource (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preGlobalBeginLumi (edm::GlobalContext const &)
void	preGlobalBeginRun (edm::GlobalContext const &)
void	preGlobalEndLumi (edm::GlobalContext const &)
void	preGlobalEndRun (edm::GlobalContext const &)
void	preModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleEventDelayedGet (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleEventPrefetching (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleGlobalBeginLumi (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	preModuleGlobalBeginRun (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	preModuleGlobalEndLumi (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	preModuleGlobalEndRun (edm::GlobalContext const &, edm::ModuleCallingContext const &)
void	preModuleStreamBeginLumi (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleStreamBeginRun (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleStreamEndLumi (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preModuleStreamEndRun (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	prePathEvent (edm::StreamContext const &, edm::PathContext const &)
void	preSourceConstruction (edm::ModuleDescription const &)
void	preSourceEvent (edm::StreamID)
void	preSourceLumi (edm::LuminosityBlockIndex)
void	preSourceRun (edm::RunIndex)
void	preStreamBeginLumi (edm::StreamContext const &)
void	preStreamBeginRun (edm::StreamContext const &)
void	preStreamEndLumi (edm::StreamContext const &)
void	preStreamEndRun (edm::StreamContext const &)
template<typename T >
void	printEvent (T &out, ResourcesPerJob const &) const
template<typename T >
void	printEventHeader (T &out, std::string const &label) const
template<typename T >
void	printEventLine (T &out, Resources const &data, std::string const &label) const
template<typename T >
void	printEventLine (T &out, AtomicResources const &data, std::string const &label) const
template<typename T >
void	printHeader (T &out, std::string const &label) const
template<typename T >
void	printPathSummaryHeader (T &out, std::string const &label) const
template<typename T >
void	printPathSummaryLine (T &out, Resources const &data, Resources const &total, uint64_t events, std::string const &label) const
template<typename T >
void	printSummary (T &out, ResourcesPerJob const &data, std::string const &label) const
template<typename T >
void	printSummaryHeader (T &out, std::string const &label, bool detailed) const
template<typename T >
void	printSummaryLine (T &out, Resources const &data, uint64_t events, std::string const &label) const
template<typename T >
void	printSummaryLine (T &out, Resources const &data, uint64_t events, uint64_t active, std::string const &label) const
template<typename T >
void	printTransition (T &out, AtomicResources const &data, std::string const &label) const
double	queryModuleTime_ (edm::StreamID, unsigned int id) const
Measurement &	thread ()
void	unsupportedSignal (const std::string &signal) const

Private Attributes
ProcessCallGraph	callgraph_
unsigned int	concurrent_lumis_
unsigned int	concurrent_runs_
unsigned int	concurrent_streams_
unsigned int	concurrent_threads_
const PlotRanges	dqm_event_ranges_
const unsigned int	dqm_lumisections_range_
const PlotRanges	dqm_module_ranges_
std::string	dqm_path_
const PlotRanges	dqm_path_ranges_
bool	enable_dqm_
const bool	enable_dqm_byls_
const bool	enable_dqm_bymodule_
const bool	enable_dqm_bynproc_
const bool	enable_dqm_bypath_
const bool	enable_dqm_transitions_
std::vector< edm::ParameterSet >	highlight_module_psets_
std::vector< GroupOfModules >	highlight_modules_
ResourcesPerJob	job_summary_
std::vector< AtomicResources >	lumi_transition_
AtomicResources	overhead_
std::unique_ptr< PlotsPerJob >	plots_
const bool	print_event_summary_
const bool	print_job_summary_
const bool	print_run_summary_
std::vector< ResourcesPerJob >	run_summary_
std::vector< AtomicResources >	run_transition_
std::vector< ResourcesPerJob >	streams_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_event_check_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_global_lumi_check_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_global_run_check_
std::mutex	summary_mutex_
tbb::enumerable_thread_specific< Measurement, tbb::cache_aligned_allocator< Measurement >, tbb::ets_key_per_instance >	threads_
tbb::concurrent_unordered_set< std::string >	unsupported_signals_

Detailed Description

Definition at line 51 of file FastTimerService.h.

Constructor & Destructor Documentation

FastTimerService::FastTimerService	(	const edm::ParameterSet &	config,
		edm::ActivityRegistry &	registry
	)

Definition at line 849 of file FastTimerService.cc.

References dqm_lumisections_range_, dqm_module_ranges_, dqm_path_, dqm_path_ranges_, edm::ParameterSet::getUntrackedParameter(), highlight_module_psets_, highlight_modules_, postBeginJob(), postEndJob(), postEvent(), postGlobalEndLumi(), postGlobalEndRun(), postModuleEvent(), postModuleEventDelayedGet(), postModuleGlobalBeginLumi(), postModuleGlobalBeginRun(), postModuleGlobalEndLumi(), postModuleGlobalEndRun(), postModuleStreamBeginLumi(), postModuleStreamBeginRun(), postModuleStreamEndLumi(), postModuleStreamEndRun(), postPathEvent(), postSourceEvent(), postSourceLumi(), postSourceRun(), postStreamEndLumi(), postStreamEndRun(), preallocate(), preBeginJob(), preEvent(), preGlobalBeginLumi(), preGlobalBeginRun(), preModuleEvent(), preModuleEventDelayedGet(), preModuleGlobalBeginLumi(), preModuleGlobalBeginRun(), preModuleGlobalEndLumi(), preModuleGlobalEndRun(), preModuleStreamBeginLumi(), preModuleStreamBeginRun(), preModuleStreamEndLumi(), preModuleStreamEndRun(), prePathEvent(), preSourceConstruction(), preSourceEvent(), preSourceLumi(), preSourceRun(), preStreamBeginLumi(), preStreamBeginRun(), PhysicsTools::registry, AlCaHLTBitMon_QueryRunRegistry::string, and ~FastTimerService().

                                                                                                 :
  // configuration
  callgraph_(),
  // job configuration
  concurrent_lumis_(            0 ),
  concurrent_runs_(             0 ),
  concurrent_streams_(          0 ),
  concurrent_threads_(          0 ),
  print_event_summary_(         config.getUntrackedParameter<bool>(     "printEventSummary"        ) ),
  print_run_summary_(           config.getUntrackedParameter<bool>(     "printRunSummary"          ) ),
  print_job_summary_(           config.getUntrackedParameter<bool>(     "printJobSummary"          ) ),
  // dqm configuration
  enable_dqm_(                  config.getUntrackedParameter<bool>(     "enableDQM"                ) ),
  enable_dqm_bymodule_(         config.getUntrackedParameter<bool>(     "enableDQMbyModule"        ) ),
  enable_dqm_bypath_(           config.getUntrackedParameter<bool>(     "enableDQMbyPath"          ) ),
  enable_dqm_byls_(             config.getUntrackedParameter<bool>(     "enableDQMbyLumiSection"   ) ),
  enable_dqm_bynproc_(          config.getUntrackedParameter<bool>(     "enableDQMbyProcesses"     ) ),
  enable_dqm_transitions_(      config.getUntrackedParameter<bool>(     "enableDQMTransitions"     ) ),
  dqm_event_ranges_(          { config.getUntrackedParameter<double>(   "dqmTimeRange"             ),              // ms
                                config.getUntrackedParameter<double>(   "dqmTimeResolution"        ),              // ms
                                config.getUntrackedParameter<double>(   "dqmMemoryRange"           ),              // kB
                                config.getUntrackedParameter<double>(   "dqmMemoryResolution"      ) } ),          // kB
  dqm_path_ranges_(           { config.getUntrackedParameter<double>(   "dqmPathTimeRange"         ),              // ms
                                config.getUntrackedParameter<double>(   "dqmPathTimeResolution"    ),              // ms
                                config.getUntrackedParameter<double>(   "dqmPathMemoryRange"       ),              // kB
                                config.getUntrackedParameter<double>(   "dqmPathMemoryResolution"  ) } ),          // kB
  dqm_module_ranges_(         { config.getUntrackedParameter<double>(   "dqmModuleTimeRange"       ),              // ms
                                config.getUntrackedParameter<double>(   "dqmModuleTimeResolution"  ),              // ms
                                config.getUntrackedParameter<double>(   "dqmModuleMemoryRange"     ),              // kB
                                config.getUntrackedParameter<double>(   "dqmModuleMemoryResolution") } ),          // kB
  dqm_lumisections_range_(      config.getUntrackedParameter<unsigned int>( "dqmLumiSectionsRange" ) ),
  dqm_path_(                    config.getUntrackedParameter<std::string>("dqmPath" ) ),
  // highlight configuration
  highlight_module_psets_(      config.getUntrackedParameter<std::vector<edm::ParameterSet>>("highlightModules") ),
  highlight_modules_(           highlight_module_psets_.size())         // filled in postBeginJob()
{
  // start observing when a thread enters or leaves the TBB global thread arena
  tbb::task_scheduler_observer::observe();

  // register EDM call backs
  registry.watchPreallocate(                this, & FastTimerService::preallocate );
  registry.watchPreBeginJob(                this, & FastTimerService::preBeginJob );
  registry.watchPostBeginJob(               this, & FastTimerService::postBeginJob );
  registry.watchPostEndJob(                 this, & FastTimerService::postEndJob );
  registry.watchPreGlobalBeginRun(          this, & FastTimerService::preGlobalBeginRun );
//registry.watchPostGlobalBeginRun(         this, & FastTimerService::postGlobalBeginRun );
//registry.watchPreGlobalEndRun(            this, & FastTimerService::preGlobalEndRun );
  registry.watchPostGlobalEndRun(           this, & FastTimerService::postGlobalEndRun );
  registry.watchPreStreamBeginRun(          this, & FastTimerService::preStreamBeginRun );
//registry.watchPostStreamBeginRun(         this, & FastTimerService::postStreamBeginRun );
//registry.watchPreStreamEndRun(            this, & FastTimerService::preStreamEndRun );
  registry.watchPostStreamEndRun(           this, & FastTimerService::postStreamEndRun );
  registry.watchPreGlobalBeginLumi(         this, & FastTimerService::preGlobalBeginLumi );
//registry.watchPostGlobalBeginLumi(        this, & FastTimerService::postGlobalBeginLumi );
//registry.watchPreGlobalEndLumi(           this, & FastTimerService::preGlobalEndLumi );
  registry.watchPostGlobalEndLumi(          this, & FastTimerService::postGlobalEndLumi );
  registry.watchPreStreamBeginLumi(         this, & FastTimerService::preStreamBeginLumi );
//registry.watchPostStreamBeginLumi(        this, & FastTimerService::postStreamBeginLumi );
//registry.watchPreStreamEndLumi(           this, & FastTimerService::preStreamEndLumi );
  registry.watchPostStreamEndLumi(          this, & FastTimerService::postStreamEndLumi );
  registry.watchPreEvent(                   this, & FastTimerService::preEvent );
  registry.watchPostEvent(                  this, & FastTimerService::postEvent );
  registry.watchPrePathEvent(               this, & FastTimerService::prePathEvent );
  registry.watchPostPathEvent(              this, & FastTimerService::postPathEvent );
  registry.watchPreSourceConstruction(      this, & FastTimerService::preSourceConstruction);
//registry.watchPostSourceConstruction(     this, & FastTimerService::postSourceConstruction);
  registry.watchPreSourceRun(               this, & FastTimerService::preSourceRun );
  registry.watchPostSourceRun(              this, & FastTimerService::postSourceRun );
  registry.watchPreSourceLumi(              this, & FastTimerService::preSourceLumi );
  registry.watchPostSourceLumi(             this, & FastTimerService::postSourceLumi );
  registry.watchPreSourceEvent(             this, & FastTimerService::preSourceEvent );
  registry.watchPostSourceEvent(            this, & FastTimerService::postSourceEvent );
//registry.watchPreModuleConstruction(      this, & FastTimerService::preModuleConstruction);
//registry.watchPostModuleConstruction(     this, & FastTimerService::postModuleConstruction);
//registry.watchPreModuleBeginJob(          this, & FastTimerService::preModuleBeginJob );
//registry.watchPostModuleBeginJob(         this, & FastTimerService::postModuleBeginJob );
//registry.watchPreModuleEndJob(            this, & FastTimerService::preModuleEndJob );
//registry.watchPostModuleEndJob(           this, & FastTimerService::postModuleEndJob );
//registry.watchPreModuleBeginStream(       this, & FastTimerService::preModuleBeginStream );
//registry.watchPostModuleBeginStream(      this, & FastTimerService::postModuleBeginStream );
//registry.watchPreModuleEndStream(         this, & FastTimerService::preModuleEndStream );
//registry.watchPostModuleEndStream(        this, & FastTimerService::postModuleEndStream );
  registry.watchPreModuleGlobalBeginRun(    this, & FastTimerService::preModuleGlobalBeginRun );
  registry.watchPostModuleGlobalBeginRun(   this, & FastTimerService::postModuleGlobalBeginRun );
  registry.watchPreModuleGlobalEndRun(      this, & FastTimerService::preModuleGlobalEndRun );
  registry.watchPostModuleGlobalEndRun(     this, & FastTimerService::postModuleGlobalEndRun );
  registry.watchPreModuleGlobalBeginLumi(   this, & FastTimerService::preModuleGlobalBeginLumi );
  registry.watchPostModuleGlobalBeginLumi(  this, & FastTimerService::postModuleGlobalBeginLumi );
  registry.watchPreModuleGlobalEndLumi(     this, & FastTimerService::preModuleGlobalEndLumi );
  registry.watchPostModuleGlobalEndLumi(    this, & FastTimerService::postModuleGlobalEndLumi );
  registry.watchPreModuleStreamBeginRun(    this, & FastTimerService::preModuleStreamBeginRun );
  registry.watchPostModuleStreamBeginRun(   this, & FastTimerService::postModuleStreamBeginRun );
  registry.watchPreModuleStreamEndRun(      this, & FastTimerService::preModuleStreamEndRun );
  registry.watchPostModuleStreamEndRun(     this, & FastTimerService::postModuleStreamEndRun );
  registry.watchPreModuleStreamBeginLumi(   this, & FastTimerService::preModuleStreamBeginLumi );
  registry.watchPostModuleStreamBeginLumi(  this, & FastTimerService::postModuleStreamBeginLumi );
  registry.watchPreModuleStreamEndLumi(     this, & FastTimerService::preModuleStreamEndLumi );
  registry.watchPostModuleStreamEndLumi(    this, & FastTimerService::postModuleStreamEndLumi );
//registry.watchPreModuleEventPrefetching(  this, & FastTimerService::preModuleEventPrefetching );
//registry.watchPostModuleEventPrefetching( this, & FastTimerService::postModuleEventPrefetching );
  registry.watchPreModuleEvent(             this, & FastTimerService::preModuleEvent );
  registry.watchPostModuleEvent(            this, & FastTimerService::postModuleEvent );
  registry.watchPreModuleEventDelayedGet(   this, & FastTimerService::preModuleEventDelayedGet );
  registry.watchPostModuleEventDelayedGet(  this, & FastTimerService::postModuleEventDelayedGet );
//registry.watchPreEventReadFromSource(     this, & FastTimerService::preEventReadFromSource );
//registry.watchPostEventReadFromSource(    this, & FastTimerService::postEventReadFromSource );
}

FastTimerService::~FastTimerService ( )

overridedefault

Referenced by FastTimerService().

Member Function Documentation

void FastTimerService::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 1903 of file FastTimerService.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addOptionalNode(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addVPSetUntracked(), edm::ParameterDescriptionNode::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

{
  edm::ParameterSetDescription desc;
  desc.addUntracked<bool>(        "printEventSummary",        false);
  desc.addUntracked<bool>(        "printRunSummary",          true);
  desc.addUntracked<bool>(        "printJobSummary",          true);
  desc.addUntracked<bool>(        "enableDQM",                true);
  desc.addUntracked<bool>(        "enableDQMbyModule",        false);
  desc.addUntracked<bool>(        "enableDQMbyPath",          false);
  desc.addUntracked<bool>(        "enableDQMbyLumiSection",   false);
  desc.addUntracked<bool>(        "enableDQMbyProcesses",     false);
  desc.addUntracked<bool>(        "enableDQMTransitions",     false);
  desc.addUntracked<double>(      "dqmTimeRange",             1000. );   // ms
  desc.addUntracked<double>(      "dqmTimeResolution",           5. );   // ms
  desc.addUntracked<double>(      "dqmMemoryRange",        1000000. );   // kB
  desc.addUntracked<double>(      "dqmMemoryResolution",      5000. );   // kB
  desc.addUntracked<double>(      "dqmPathTimeRange",          100. );   // ms
  desc.addUntracked<double>(      "dqmPathTimeResolution",       0.5);   // ms
  desc.addUntracked<double>(      "dqmPathMemoryRange",    1000000. );   // kB
  desc.addUntracked<double>(      "dqmPathMemoryResolution",  5000. );   // kB
  desc.addUntracked<double>(      "dqmModuleTimeRange",         40. );   // ms
  desc.addUntracked<double>(      "dqmModuleTimeResolution",     0.2);   // ms
  desc.addUntracked<double>(      "dqmModuleMemoryRange",   100000. );   // kB
  desc.addUntracked<double>(      "dqmModuleMemoryResolution", 500. );   // kB
  desc.addUntracked<unsigned>(    "dqmLumiSectionsRange",     2500  );   // ~ 16 hours
  desc.addUntracked<std::string>( "dqmPath",                  "HLT/TimerService");

  edm::ParameterSetDescription highlightModulesDescription;
  highlightModulesDescription.addUntracked<std::vector<std::string>>("modules", {});
  highlightModulesDescription.addUntracked<std::string>("label", "producers");
  desc.addVPSetUntracked("highlightModules", highlightModulesDescription, {});

  // # OBSOLETE - these parameters are ignored, they are left only not to break old configurations
  // they will not be printed in the generated cfi.py file
  desc.addOptionalNode(edm::ParameterDescription<bool>("useRealTimeClock",         true,  false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableTimingPaths",        true,  false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableTimingModules",      true,  false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableTimingExclusive",    false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableTimingSummary",      false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("skipFirstPath",            false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathActive",    false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathTotal",     true,  false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathOverhead",  false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathDetails",   false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathCounters",  true,  false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyPathExclusive", false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMbyModuleType",    false, false), false)->setComment("This parameter is obsolete and will be ignored.");
  desc.addOptionalNode(edm::ParameterDescription<bool>("enableDQMSummary",         false, false), false)->setComment("This parameter is obsolete and will be ignored.");

  descriptions.add("FastTimerService", desc);
}

void FastTimerService::ignoredSignal ( const std::string &  signal ) const

private

Definition at line 1077 of file FastTimerService.cc.

References LogDebug.

Referenced by postEvent(), postEventReadFromSource(), postGlobalBeginLumi(), postGlobalBeginRun(), postGlobalEndLumi(), postGlobalEndRun(), postModuleEventPrefetching(), postStreamBeginLumi(), postStreamBeginRun(), postStreamEndLumi(), postStreamEndRun(), preEvent(), preEventReadFromSource(), preGlobalBeginLumi(), preGlobalBeginRun(), preGlobalEndLumi(), preGlobalEndRun(), preModuleEventPrefetching(), preStreamBeginLumi(), preStreamBeginRun(), preStreamEndLumi(), and preStreamEndRun().

{
  LogDebug("FastTimerService") << "The FastTimerService received is currently not monitoring the signal \"" << signal << "\".\n";
}

bool FastTimerService::isFirstSubprocess ( edm::StreamContext const &  )

private

Referenced by preGlobalBeginLumi(), preGlobalBeginRun(), and printTransition().

bool FastTimerService::isFirstSubprocess ( edm::GlobalContext const &  )

private

bool FastTimerService::isLastSubprocess ( std::atomic< unsigned int > &  check )

private

Definition at line 1595 of file FastTimerService.cc.

References callgraph_, and ProcessCallGraph::processes().

Referenced by postEvent(), postGlobalEndLumi(), and postGlobalEndRun().

{
  // release-acquire semantic guarantees that all writes in this and other threads are visible
  // after this operation; full sequentially-consistent ordering is (probably) not needed.
  unsigned int old_value = check.fetch_add(1, std::memory_order_acq_rel);
  return (old_value == callgraph_.processes().size() - 1);
}

void FastTimerService::on_scheduler_entry ( bool  worker )

finalprivate

Definition at line 1881 of file FastTimerService.cc.

References FastTimerService::Measurement::measure(), and thread().

{
  // initialise the measurement point for a thread that has newly joining the TBB pool
  thread().measure();
}

void FastTimerService::on_scheduler_exit ( bool  worker )

finalprivate

Definition at line 1888 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

{
  // account any resources used or freed by the thread before leaving the TBB pool
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::postBeginJob ( )

private

Definition at line 1184 of file FastTimerService.cc.

References callgraph_, concurrent_runs_, concurrent_streams_, enable_dqm_, edmIntegrityCheck::group, highlight_module_psets_, highlight_modules_, mps_fire::i, job_summary_, diffTwoXMLs::label, tablePrinter::labels, ProcessCallGraph::module(), edm::ModuleDescription::moduleLabel(), electrons_cff::modules, plots_, run_summary_, ProcessCallGraph::size(), streams_, AlCaHLTBitMon_QueryRunRegistry::string, and groupFilesInBlocks::temp.

Referenced by FastTimerService().

                               {
  unsigned int modules = callgraph_.size();

  // module highlights
  for (unsigned int group: boost::irange(0ul, highlight_module_psets_.size())) {
    // copy and sort for faster search via std::binary_search
    auto labels = highlight_module_psets_[group].getUntrackedParameter<std::vector<std::string>>("modules");
    std::sort(labels.begin(), labels.end());

    highlight_modules_[group].label = highlight_module_psets_[group].getUntrackedParameter<std::string>("label");
    highlight_modules_[group].modules.reserve(labels.size());
    // convert the module labels in module ids
    for (unsigned int i = 0; i < modules; ++i) {
      auto const & label = callgraph_.module(i).moduleLabel();
      if (std::binary_search(labels.begin(), labels.end(), label))
        highlight_modules_[group].modules.push_back(i);
    }
  }
  highlight_module_psets_.clear();

  // allocate the resource counters for each stream, process, path and module
  ResourcesPerJob temp(callgraph_, highlight_modules_);
  streams_.resize(concurrent_streams_, temp);
  run_summary_.resize(concurrent_runs_, temp);
  job_summary_ = temp;

  // check that the DQMStore service is available
  if (enable_dqm_ and not edm::Service<DQMStore>().isAvailable()) {
    // the DQMStore is not available, disable all DQM plots
    enable_dqm_ = false;
    // FIXME issue a LogWarning ?
  }

  // allocate the structures to hold pointers to the DQM plots
  if (enable_dqm_) {
    plots_ = std::make_unique<PlotsPerJob>(callgraph_, highlight_modules_);
  }

}

void FastTimerService::postEndJob ( )

private

Definition at line 1364 of file FastTimerService.cc.

References job_summary_, MillePedeFileConverter_cfg::out, print_job_summary_, and printSummary().

Referenced by FastTimerService().

{
  if (print_job_summary_) {
    edm::LogVerbatim out("FastReport");
    printSummary(out, job_summary_, "Job");
  }
}

void FastTimerService::postEvent ( edm::StreamContext const &  sc )

private

Definition at line 1610 of file FastTimerService.cc.

References callgraph_, data, enable_dqm_, edm::StreamContext::eventID(), edmIntegrityCheck::group, highlight_modules_, mps_fire::i, ignoredSignal(), isLastSubprocess(), job_summary_, plotBeamSpotDB::last, edm::EventID::luminosityBlock(), MillePedeFileConverter_cfg::out, sysUtil::pid, plots_, print_event_summary_, printEvent(), LaserDQM_cfg::process, edm::StreamContext::processContext(), ProcessCallGraph::processDescription(), ProcessCallGraph::processId(), run_summary_, edm::StreamContext::runIndex(), edm::StreamContext::streamID(), streams_, subprocess_event_check_, and summary_mutex_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  unsigned int pid = callgraph_.processId(* sc.processContext());
  unsigned int sid = sc.streamID();
  auto & stream  = streams_[sid];
  auto & process = callgraph_.processDescription(pid);

  // measure the event resources as the sum of all modules' resources
  auto & data = stream.processes[pid].total;
  for (unsigned int i: process.modules_)
    data += stream.modules[i].total;
  stream.total += data;

  // handle the summaries and fill the plots only after the last subprocess has run
  bool last = isLastSubprocess(subprocess_event_check_[sid]);
  if (not last)
    return;

  // measure the event resources explicitly
  stream.event_measurement.measure_and_store(stream.event);

  // highlighted modules
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size()))
    for (unsigned int i: highlight_modules_[group].modules)
      stream.highlight[group] += stream.modules[i].total;

  // avoid concurrent access to the summary objects
  {
    std::lock_guard<std::mutex> guard(summary_mutex_);
    job_summary_ += stream;
    run_summary_[sc.runIndex()] += stream;
  }

  if (print_event_summary_) {
    edm::LogVerbatim out("FastReport");
    printEvent(out, stream);
  }

  if (enable_dqm_) {
    plots_->fill(callgraph_, stream, sc.eventID().luminosityBlock());
  }
}

void FastTimerService::postEventReadFromSource ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1771 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postGlobalBeginLumi ( edm::GlobalContext const &  gc )

private

Definition at line 1256 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postGlobalBeginRun ( edm::GlobalContext const &  gc )

private

Definition at line 1128 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postGlobalEndLumi ( edm::GlobalContext const &  gc )

private

Definition at line 1268 of file FastTimerService.cc.

References enable_dqm_transitions_, cmsPerfStripChart::format, ignoredSignal(), isLastSubprocess(), diffTwoXMLs::label, plotBeamSpotDB::last, lumi_transition_, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), edm::GlobalContext::luminosityBlockIndex(), MillePedeFileConverter_cfg::out, plots_, printTransition(), edm::LuminosityBlockID::run(), harvestTrackValidationPlots::str, and subprocess_global_lumi_check_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // handle the summaries only after the last subprocess has run
  auto index = gc.luminosityBlockIndex();
  bool last = isLastSubprocess(subprocess_global_lumi_check_[index]);
  if (not last)
    return;

  edm::LogVerbatim out("FastReport");
  auto const& label = (boost::format("run %d, lumisection %d") % gc.luminosityBlockID().run() % gc.luminosityBlockID().luminosityBlock()).str();
  printTransition(out, lumi_transition_[index], label);

  if (enable_dqm_transitions_) {
    plots_->fill_lumi(lumi_transition_[index], gc.luminosityBlockID().luminosityBlock());
  }
}

void FastTimerService::postGlobalEndRun ( edm::GlobalContext const &  gc )

private

Definition at line 1317 of file FastTimerService.cc.

References enable_dqm_transitions_, cmsPerfStripChart::format, ignoredSignal(), isLastSubprocess(), diffTwoXMLs::label, plotBeamSpotDB::last, edm::GlobalContext::luminosityBlockID(), MillePedeFileConverter_cfg::out, plots_, print_run_summary_, printSummary(), printTransition(), edm::LuminosityBlockID::run(), run_summary_, run_transition_, edm::GlobalContext::runIndex(), harvestTrackValidationPlots::str, and subprocess_global_run_check_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // handle the summaries only after the last subprocess has run
  auto index = gc.runIndex();
  bool last = isLastSubprocess(subprocess_global_run_check_[index]);
  if (not last)
    return;

  edm::LogVerbatim out("FastReport");
  auto const& label = (boost::format("Run %d") % gc.luminosityBlockID().run()).str();
  if (print_run_summary_) {
    printSummary(out, run_summary_[index], label);
  }
  printTransition(out, run_transition_[index], label);

  if (enable_dqm_transitions_) {
    plots_->fill_run(run_transition_[index]);
  }
}

void FastTimerService::postModuleEvent ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1729 of file FastTimerService.cc.

References triggerObjects_cff::id, edm::ModuleDescription::id(), FastTimerService::Measurement::measure_and_store(), edm::ModuleCallingContext::moduleDescription(), edm::StreamContext::streamID(), streams_, thread(), and edm::StreamID::value().

Referenced by FastTimerService().

{
  edm::ModuleDescription const& md = * mcc.moduleDescription();
  unsigned int id  = md.id();
  unsigned int sid = sc.streamID().value();
  auto & stream = streams_[sid];

  thread().measure_and_store(stream.modules[id].total);
  ++stream.modules[id].events;
}

void FastTimerService::postModuleEventDelayedGet ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1747 of file FastTimerService.cc.

References unsupportedSignal().

Referenced by FastTimerService().

{
  unsupportedSignal(__func__);
}

void FastTimerService::postModuleEventPrefetching ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1759 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postModuleGlobalBeginLumi ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1809 of file FastTimerService.cc.

References lumi_transition_, edm::GlobalContext::luminosityBlockIndex(), FastTimerService::Measurement::measure_and_accumulate(), and thread().

Referenced by FastTimerService().

{
  auto index = gc.luminosityBlockIndex();
  thread().measure_and_accumulate(lumi_transition_[index]);
}

void FastTimerService::postModuleGlobalBeginRun ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1783 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), run_transition_, edm::GlobalContext::runIndex(), and thread().

Referenced by FastTimerService().

{
  auto index = gc.runIndex();
  thread().measure_and_accumulate(run_transition_[index]);
}

void FastTimerService::postModuleGlobalEndLumi ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1822 of file FastTimerService.cc.

References lumi_transition_, edm::GlobalContext::luminosityBlockIndex(), FastTimerService::Measurement::measure_and_accumulate(), and thread().

Referenced by FastTimerService().

{
  auto index = gc.luminosityBlockIndex();
  thread().measure_and_accumulate(lumi_transition_[index]);
}

void FastTimerService::postModuleGlobalEndRun ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1796 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), run_transition_, edm::GlobalContext::runIndex(), and thread().

Referenced by FastTimerService().

{
  auto index = gc.runIndex();
  thread().measure_and_accumulate(run_transition_[index]);
}

void FastTimerService::postModuleStreamBeginLumi ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1861 of file FastTimerService.cc.

References lumi_transition_, edm::StreamContext::luminosityBlockIndex(), FastTimerService::Measurement::measure_and_accumulate(), and thread().

Referenced by FastTimerService().

{
  auto index = sc.luminosityBlockIndex();
  thread().measure_and_accumulate(lumi_transition_[index]);
}

void FastTimerService::postModuleStreamBeginRun ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1835 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), run_transition_, edm::StreamContext::runIndex(), and thread().

Referenced by FastTimerService().

{
  auto index = sc.runIndex();
  thread().measure_and_accumulate(run_transition_[index]);
}

void FastTimerService::postModuleStreamEndLumi ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1874 of file FastTimerService.cc.

References lumi_transition_, edm::StreamContext::luminosityBlockIndex(), FastTimerService::Measurement::measure_and_accumulate(), and thread().

Referenced by FastTimerService().

{
  auto index = sc.luminosityBlockIndex();
  thread().measure_and_accumulate(lumi_transition_[index]);
}

void FastTimerService::postModuleStreamEndRun ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1848 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), run_transition_, edm::StreamContext::runIndex(), and thread().

Referenced by FastTimerService().

{
  auto index = sc.runIndex();
  thread().measure_and_accumulate(run_transition_[index]);
}

void FastTimerService::postPathEvent ( edm::StreamContext const &  sc, edm::PathContext const &  pc, edm::HLTPathStatus const &  status  )

private

Definition at line 1698 of file FastTimerService.cc.

References callgraph_, data, ProcessCallGraph::ProcessType::endPaths_, mps_fire::i, triggerObjects_cff::id, edm::HLTPathStatus::index(), edm::PathContext::isEndPath(), callgraph::path, edm::PathContext::pathID(), ProcessCallGraph::ProcessType::paths_, sysUtil::pid, edm::StreamContext::processContext(), ProcessCallGraph::processDescription(), ProcessCallGraph::processId(), edm::StreamContext::streamID(), streams_, and edm::StreamID::value().

Referenced by FastTimerService().

{
  unsigned int sid = sc.streamID().value();
  unsigned int pid = callgraph_.processId(* sc.processContext());
  unsigned int id  = pc.pathID();
  auto & stream = streams_[sid];
  auto & data = pc.isEndPath() ? stream.processes[pid].endpaths[id] : stream.processes[pid].paths[id];

  auto const& path = pc.isEndPath() ? callgraph_.processDescription(pid).endPaths_[id] : callgraph_.processDescription(pid).paths_[id];
  unsigned int index = path.modules_on_path_.empty() ? 0 : status.index() + 1;
  data.last          = path.modules_on_path_.empty() ? 0 : path.last_dependency_of_module_[status.index()];

  for (unsigned int i = 0; i < index; ++i) {
    auto const& module = stream.modules[path.modules_on_path_[i]];
    data.active += module.total;
  }
  for (unsigned int i = 0; i < data.last; ++i) {
    auto const& module = stream.modules[path.modules_and_dependencies_[i]];
    data.total += module.total;
  }
}

void FastTimerService::postSourceEvent ( edm::StreamID  sid )

private

Definition at line 1673 of file FastTimerService.cc.

References callgraph_, triggerObjects_cff::id, edm::ModuleDescription::id(), FastTimerService::Measurement::measure_and_store(), ProcessCallGraph::source(), streams_, and thread().

Referenced by FastTimerService().

{
  edm::ModuleDescription const& md = callgraph_.source();
  unsigned int id  = md.id();
  auto & stream = streams_[sid];

  thread().measure_and_store(stream.modules[id].total);
  ++stream.modules[id].events;
}

void FastTimerService::postSourceLumi ( edm::LuminosityBlockIndex  index )

private

Definition at line 1358 of file FastTimerService.cc.

References lumi_transition_, FastTimerService::Measurement::measure_and_accumulate(), and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(lumi_transition_[index]);
}

void FastTimerService::postSourceRun ( edm::RunIndex  index )

private

Definition at line 1346 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), run_transition_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(run_transition_[index]);
}

void FastTimerService::postStreamBeginLumi ( edm::StreamContext const &  sc )

private

Definition at line 1294 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postStreamBeginRun ( edm::StreamContext const &  sc )

private

Definition at line 1225 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postStreamEndLumi ( edm::StreamContext const &  sc )

private

Definition at line 1306 of file FastTimerService.cc.

References ignoredSignal().

Referenced by FastTimerService().

                                                              {
  ignoredSignal(__func__);
}

void FastTimerService::postStreamEndRun ( edm::StreamContext const &  sc )

private

Definition at line 1237 of file FastTimerService.cc.

References ignoredSignal().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);
}

void FastTimerService::preallocate ( edm::service::SystemBounds const &  bounds )

private

Definition at line 1140 of file FastTimerService.cc.

References EnergyCorrector::c, concurrent_lumis_, concurrent_runs_, concurrent_streams_, concurrent_threads_, dqm_path_, enable_dqm_bynproc_, cmsPerfStripChart::format, mps_fire::i, lumi_transition_, edm::service::SystemBounds::maxNumberOfConcurrentLuminosityBlocks(), edm::service::SystemBounds::maxNumberOfConcurrentRuns(), edm::service::SystemBounds::maxNumberOfStreams(), edm::service::SystemBounds::maxNumberOfThreads(), processor_model, run_transition_, alignCSCRings::s, harvestTrackValidationPlots::str, subprocess_event_check_, subprocess_global_lumi_check_, and subprocess_global_run_check_.

Referenced by FastTimerService().

{
  concurrent_lumis_   = bounds.maxNumberOfConcurrentLuminosityBlocks();
  concurrent_runs_    = bounds.maxNumberOfConcurrentRuns();
  concurrent_streams_ = bounds.maxNumberOfStreams();
  concurrent_threads_ = bounds.maxNumberOfThreads();

  if (enable_dqm_bynproc_)
    dqm_path_ += (boost::format("/Running on %s with %d streams on %d threads") % processor_model % concurrent_streams_ % concurrent_threads_).str();

  // clean characters that are deemed unsafe for DQM
  // see the definition of `s_safe` in DQMServices/Core/src/DQMStore.cc
  auto safe_for_dqm = "/ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-+=_()# "s;
  for (auto & c: dqm_path_)
    if (safe_for_dqm.find(c) == std::string::npos)
      c = '_';

  // allocate atomic variables to keep track of the completion of each step, process by process
  subprocess_event_check_       = std::make_unique<std::atomic<unsigned int>[]>(concurrent_streams_);
  for (unsigned int i = 0; i < concurrent_streams_; ++i)
    subprocess_event_check_[i] = 0;
  subprocess_global_run_check_  = std::make_unique<std::atomic<unsigned int>[]>(concurrent_runs_);
  for (unsigned int i = 0; i < concurrent_runs_; ++i)
    subprocess_global_run_check_[i] = 0;
  subprocess_global_lumi_check_ = std::make_unique<std::atomic<unsigned int>[]>(concurrent_lumis_);
  for (unsigned int i = 0; i < concurrent_lumis_; ++i)
    subprocess_global_lumi_check_[i] = 0;

  // allocate buffers to keep track of the resources spent in the lumi and run transitions
  lumi_transition_.resize(concurrent_lumis_);
  run_transition_.resize(concurrent_runs_);
}

void FastTimerService::preBeginJob ( edm::PathsAndConsumesOfModulesBase const &  pathsAndConsumes, edm::ProcessContext const &  context  )

private

Definition at line 1179 of file FastTimerService.cc.

References callgraph_, and ProcessCallGraph::preBeginJob().

Referenced by FastTimerService().

                                                                                                                         {
  callgraph_.preBeginJob(pathsAndConsumes, context);
}

void FastTimerService::preEvent ( edm::StreamContext const &  sc )

private

Definition at line 1604 of file FastTimerService.cc.

References ignoredSignal().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);
}

void FastTimerService::preEventReadFromSource ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1765 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preGlobalBeginLumi ( edm::GlobalContext const &  gc )

private

Definition at line 1243 of file FastTimerService.cc.

References ignoredSignal(), isFirstSubprocess(), lumi_transition_, edm::GlobalContext::luminosityBlockIndex(), and subprocess_global_lumi_check_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // reset the lumi counters only during the main process being run
  if (isFirstSubprocess(gc)) {
    auto index = gc.luminosityBlockIndex();
    subprocess_global_lumi_check_[index] = 0;
    lumi_transition_[index].reset();
  }
}

void FastTimerService::preGlobalBeginRun ( edm::GlobalContext const &  gc )

private

Definition at line 1092 of file FastTimerService.cc.

References callgraph_, dqm_event_ranges_, dqm_lumisections_range_, dqm_module_ranges_, dqm_path_, dqm_path_ranges_, enable_dqm_, enable_dqm_byls_, enable_dqm_bymodule_, enable_dqm_bypath_, enable_dqm_transitions_, highlight_modules_, ignoredSignal(), isFirstSubprocess(), edm::GlobalContext::luminosityBlockID(), plots_, edm::LuminosityBlockID::run(), run_summary_, run_transition_, edm::GlobalContext::runIndex(), and subprocess_global_run_check_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // reset the run counters only during the main process being run
  if (isFirstSubprocess(gc)) {
    auto index = gc.runIndex();
    subprocess_global_run_check_[index] = 0;
    run_transition_[index].reset();
    run_summary_[index].reset();

    // book the DQM plots
    if (enable_dqm_) {
      // define a callback to book the MonitorElements
      auto bookTransactionCallback = [&, this] (DQMStore::ConcurrentBooker & booker)
      {
        booker.setCurrentFolder(dqm_path_);
        plots_->book(booker, callgraph_,
            highlight_modules_,
            dqm_event_ranges_,
            dqm_path_ranges_,
            dqm_module_ranges_,
            dqm_lumisections_range_,
            enable_dqm_bymodule_,
            enable_dqm_bypath_,
            enable_dqm_byls_,
            enable_dqm_transitions_);
      };

      // book MonitorElements for this stream
      edm::Service<DQMStore>()->bookConcurrentTransaction(bookTransactionCallback, gc.luminosityBlockID().run());
    }
  }
}

void FastTimerService::preGlobalEndLumi ( edm::GlobalContext const &  gc )

private

Definition at line 1262 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preGlobalEndRun ( edm::GlobalContext const &  gc )

private

Definition at line 1311 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preModuleEvent ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1721 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), edm::StreamContext::streamID(), streams_, thread(), and edm::StreamID::value().

Referenced by FastTimerService().

{
  unsigned int sid = sc.streamID().value();
  auto & stream = streams_[sid];
  thread().measure_and_accumulate(stream.overhead);
}

void FastTimerService::preModuleEventDelayedGet ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1741 of file FastTimerService.cc.

References unsupportedSignal().

Referenced by FastTimerService().

{
  unsupportedSignal(__func__);
}

void FastTimerService::preModuleEventPrefetching ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1753 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preModuleGlobalBeginLumi ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1803 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleGlobalBeginRun ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1777 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleGlobalEndLumi ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1816 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleGlobalEndRun ( edm::GlobalContext const &  gc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1790 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleStreamBeginLumi ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1855 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleStreamBeginRun ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1829 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleStreamEndLumi ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1868 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preModuleStreamEndRun ( edm::StreamContext const &  sc, edm::ModuleCallingContext const &  mcc  )

private

Definition at line 1842 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::prePathEvent ( edm::StreamContext const &  sc, edm::PathContext const &  pc  )

private

Definition at line 1685 of file FastTimerService.cc.

References callgraph_, data, triggerObjects_cff::id, edm::PathContext::isEndPath(), edm::PathContext::pathID(), sysUtil::pid, edm::StreamContext::processContext(), ProcessCallGraph::processId(), edm::StreamContext::streamID(), streams_, and edm::StreamID::value().

Referenced by FastTimerService().

{
  unsigned int sid = sc.streamID().value();
  unsigned int pid = callgraph_.processId(* sc.processContext());
  unsigned int id  = pc.pathID();
  auto & stream = streams_[sid];
  auto & data = pc.isEndPath() ? stream.processes[pid].endpaths[id] : stream.processes[pid].paths[id];
  data.status = false;
  data.last   = 0;
}

void FastTimerService::preSourceConstruction ( edm::ModuleDescription const &  module )

private

Definition at line 1174 of file FastTimerService.cc.

References callgraph_, and ProcessCallGraph::preSourceConstruction().

Referenced by FastTimerService().

                                                                          {
  callgraph_.preSourceConstruction(module);
}

void FastTimerService::preSourceEvent ( edm::StreamID  sid )

private

Definition at line 1656 of file FastTimerService.cc.

References streams_, subprocess_event_check_, and thread().

Referenced by FastTimerService().

{
  // clear the event counters
  auto & stream = streams_[sid];
  stream.reset();
  ++stream.events;

  subprocess_event_check_[sid] = 0;

  // reuse the same measurement for the Source module and for the explicit begin of the Event
  auto & measurement = thread();
  measurement.measure_and_accumulate(stream.overhead);
  stream.event_measurement = measurement;
}

void FastTimerService::preSourceLumi ( edm::LuminosityBlockIndex  index )

private

Definition at line 1352 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preSourceRun ( edm::RunIndex  index )

private

Definition at line 1340 of file FastTimerService.cc.

References FastTimerService::Measurement::measure_and_accumulate(), overhead_, and thread().

Referenced by FastTimerService().

{
  thread().measure_and_accumulate(overhead_);
}

void FastTimerService::preStreamBeginLumi ( edm::StreamContext const &  sc )

private

Definition at line 1288 of file FastTimerService.cc.

References ignoredSignal().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);
}

void FastTimerService::preStreamBeginRun ( edm::StreamContext const &  sc )

private

Definition at line 1134 of file FastTimerService.cc.

References ignoredSignal().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);
}

void FastTimerService::preStreamEndLumi ( edm::StreamContext const &  sc )

private

Definition at line 1300 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preStreamEndRun ( edm::StreamContext const &  sc )

private

Definition at line 1231 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

template<typename T >

void FastTimerService::printEvent ( T &  out, ResourcesPerJob const &    ) const

private

Referenced by postEvent().

template<typename T >

void FastTimerService::printEvent	(	T &	out,
		ResourcesPerJob const &	data
	)		const

Definition at line 1417 of file FastTimerService.cc.

References callgraph_, edmIntegrityCheck::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_, mps_fire::i, funct::m, ProcessCallGraph::module(), FastTimerService::ResourcesPerJob::modules, dataset::name, AlCaHLTBitMon_ParallelJobs::p, callgraph::path, printEventHeader(), printEventLine(), printHeader(), proc, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), FastTimerService::ResourcesPerJob::processes, source, ProcessCallGraph::source(), and FastTimerService::ResourcesPerJob::total.

{
  printHeader(out, "Event");
  printEventHeader(out, "Modules");
  auto const& source_d = callgraph_.source();
  auto const& source   = data.modules[source_d.id()];
  printEventLine(out, source.total, source_d.moduleLabel());
  for (unsigned int i = 0; i < callgraph_.processes().size(); ++i) {
    auto const& proc_d = callgraph_.processDescription(i);
    auto const& proc   = data.processes[i];
    printEventLine(out, proc.total, "process " + proc_d.name_);
    for (unsigned int m: proc_d.modules_) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      printEventLine(out, module.total, "  " + module_d.moduleLabel());
    }
  }
  printEventLine(out, data.total, "total");
  out << '\n';
  printEventHeader(out, "Processes and Paths");
  printEventLine(out, source.total, source_d.moduleLabel());
  for (unsigned int i = 0; i < callgraph_.processes().size(); ++i) {
    auto const& proc_d = callgraph_.processDescription(i);
    auto const& proc   = data.processes[i];
    printEventLine(out, proc.total, "process " + proc_d.name_);
    for (unsigned int p = 0; p < proc.paths.size(); ++p) {
      auto const& name = proc_d.paths_[p].name_;
      auto const& path = proc.paths[p];
      printEventLine(out, path.active, name + " (only scheduled modules)");
      printEventLine(out, path.total,  name + " (including dependencies)");
    }
    for (unsigned int p = 0; p < proc.endpaths.size(); ++p) {
      auto const& name = proc_d.endPaths_[p].name_;
      auto const& path = proc.endpaths[p];
      printEventLine(out, path.active, name + " (only scheduled modules)");
      printEventLine(out, path.total,  name + " (including dependencies)");
    }
  }
  printEventLine(out, data.total, "total");
  out << '\n';
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size())) {
    printEventHeader(out, "Highlighted modules");
    for (unsigned int m: highlight_modules_[group].modules) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      printEventLine(out, module.total, "  " + module_d.moduleLabel());
    }
    printEventLine(out, data.highlight[group], highlight_modules_[group].label);
    out << '\n';
  }
}

template<typename T >

void FastTimerService::printEventHeader ( T &  out, std::string const &  label  ) const

private

Referenced by printEvent(), and printTransition().

template<typename T >

void FastTimerService::printEventHeader	(	T &	out,
		std::string const &	label
	)		const

Definition at line 1388 of file FastTimerService.cc.

{
  out << "FastReport       CPU time      Real time      Allocated    Deallocated  " << label << "\n";
  //      FastReport  ########.# ms  ########.# ms  +######### kB  -######### kB  ...
}

template<typename T >

void FastTimerService::printEventLine ( T &  out, Resources const &  data, std::string const &  label  ) const

private

Referenced by printEvent(), and printTransition().

template<typename T >

void FastTimerService::printEventLine ( T &  out, AtomicResources const &  data, std::string const &  label  ) const

private

template<typename T >

void FastTimerService::printEventLine	(	T &	out,
		Resources const &	data,
		std::string const &	label
	)		const

Definition at line 1395 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, cmsPerfStripChart::format, AnalysisDataFormats_SUSYBSMObjects::ms, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

{
  out << boost::format("FastReport  %10.1f ms  %10.1f ms  %+10d kB  %+10d kB  %s\n")
    % ms(data.time_thread)
    % ms(data.time_real)
    % +static_cast<int64_t>(kB(data.allocated))
    % -static_cast<int64_t>(kB(data.deallocated))
    % label;
}

template<typename T >

void FastTimerService::printEventLine	(	T &	out,
		AtomicResources const &	data,
		std::string const &	label
	)		const

Definition at line 1406 of file FastTimerService.cc.

References FastTimerService::AtomicResources::allocated, FastTimerService::AtomicResources::deallocated, cmsPerfStripChart::format, AnalysisDataFormats_SUSYBSMObjects::ms, FastTimerService::AtomicResources::time_real, and FastTimerService::AtomicResources::time_thread.

{
  out << boost::format("FastReport  %10.1f ms  %10.1f ms  %+10d kB  %+10d kB  %s\n")
    % ms(boost::chrono::nanoseconds(data.time_thread.load()))
    % ms(boost::chrono::nanoseconds(data.time_real.load()))
    % +static_cast<int64_t>(kB(data.allocated))
    % -static_cast<int64_t>(kB(data.deallocated))
    % label;
}

template<typename T >

void FastTimerService::printHeader ( T &  out, std::string const &  label  ) const

private

Referenced by ntuplePrintersDiff.SeedPrinter::diff(), ntuplePrintersDiff.TrackPrinter::diff(), printEvent(), ntuplePrintersDiff.SeedPrinter::printSeed(), printSummary(), and ntuplePrintersDiff.TrackPrinter::printTrack().

template<typename T >

void FastTimerService::printHeader	(	T &	out,
		std::string const &	label
	)		const

Definition at line 1374 of file FastTimerService.cc.

References mps_fire::i.

{
  out << "FastReport ";
  if (label.size() < 60)
    for (unsigned int i = (60-label.size()) / 2; i > 0; --i)
      out << '-';
  out << ' ' << label << " Summary ";
  if (label.size() < 60)
    for (unsigned int i = (59-label.size()) / 2; i > 0; --i)
      out << '-';
  out << '\n';
}

template<typename T >

void FastTimerService::printPathSummaryHeader ( T &  out, std::string const &  label  ) const

private

Referenced by printSummary().

template<typename T >

void FastTimerService::printPathSummaryHeader	(	T &	out,
		std::string const &	label
	)		const

Definition at line 1482 of file FastTimerService.cc.

{
  out << "FastReport     CPU time sched. / depend.    Real time sched. / depend.       Alloc. sched. / depend.     Dealloc. sched. / depend.  ";
  //      FastReport  ########.# ms  ########.# ms  ########.# ms  ########.# ms  +######### kB  +######### kB  -######### kB  -######### kB  ...
  out << label << '\n';
}

template<typename T >

void FastTimerService::printPathSummaryLine ( T &  out, Resources const &  data, Resources const &  total, uint64_t  events, std::string const &  label  ) const

private

Referenced by printSummary().

template<typename T >

void FastTimerService::printPathSummaryLine	(	T &	out,
		Resources const &	data,
		Resources const &	total,
		uint64_t	events,
		std::string const &	label
	)		const

Definition at line 1512 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, cmsPerfStripChart::format, AnalysisDataFormats_SUSYBSMObjects::ms, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

{
  out << boost::format("FastReport  %10.1f ms  %10.1f ms  %10.1f ms  %10.1f ms  %+10d kB  %+10d kB  %+10d kB  %+10d kB  %s\n")
    % (events ? ms(data.time_thread) / events : 0) % (events ? ms(total.time_thread) / events : 0)
    % (events ? ms(data.time_real)   / events : 0) % (events ? ms(total.time_real)   / events : 0)
    % (events ? +static_cast<int64_t>(kB(data.allocated)   / events) : 0) % (events ? +static_cast<int64_t>(kB(total.allocated)   / events) : 0)
    % (events ? -static_cast<int64_t>(kB(data.deallocated) / events) : 0) % (events ? -static_cast<int64_t>(kB(total.deallocated) / events) : 0)
    % label;
}

template<typename T >

void FastTimerService::printSummary ( T &  out, ResourcesPerJob const &  data, std::string const &  label  ) const

private

Referenced by postEndJob(), and postGlobalEndRun().

template<typename T >

void FastTimerService::printSummary	(	T &	out,
		ResourcesPerJob const &	data,
		std::string const &	label
	)		const

Definition at line 1523 of file FastTimerService.cc.

References callgraph_, FastTimerService::ResourcesPerJob::events, edmIntegrityCheck::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_, mps_fire::i, funct::m, ProcessCallGraph::module(), FastTimerService::ResourcesPerJob::modules, dataset::name, AlCaHLTBitMon_ParallelJobs::p, callgraph::path, printHeader(), printPathSummaryHeader(), printPathSummaryLine(), printSummaryHeader(), printSummaryLine(), proc, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), FastTimerService::ResourcesPerJob::processes, source, ProcessCallGraph::source(), and FastTimerService::ResourcesPerJob::total.

{
  printHeader(out, label);
  printSummaryHeader(out, "Modules", true);
  auto const& source_d = callgraph_.source();
  auto const& source   = data.modules[source_d.id()];
  printSummaryLine(out, source.total, data.events, source.events, source_d.moduleLabel());
  for (unsigned int i = 0; i < callgraph_.processes().size(); ++i) {
    auto const& proc_d = callgraph_.processDescription(i);
    auto const& proc   = data.processes[i];
    printSummaryLine(out, proc.total, data.events, "process " + proc_d.name_);
    for (unsigned int m: proc_d.modules_) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      printSummaryLine(out, module.total, data.events, module.events, "  " + module_d.moduleLabel());
    }
  }
  printSummaryLine(out, data.total, data.events, "total");
  out << '\n';
  printPathSummaryHeader(out, "Processes and Paths");
  printSummaryLine(out, source.total, data.events, source_d.moduleLabel());
  for (unsigned int i = 0; i < callgraph_.processes().size(); ++i) {
    auto const& proc_d = callgraph_.processDescription(i);
    auto const& proc   = data.processes[i];
    printSummaryLine(out, proc.total, data.events, "process " + proc_d.name_);
    for (unsigned int p = 0; p < proc.paths.size(); ++p) {
      auto const& name = proc_d.paths_[p].name_;
      auto const& path = proc.paths[p];
      printPathSummaryLine(out, path.active, path.total, data.events, "  " + name);
    }
    for (unsigned int p = 0; p < proc.endpaths.size(); ++p) {
      auto const& name = proc_d.endPaths_[p].name_;
      auto const& path = proc.endpaths[p];
      printPathSummaryLine(out, path.active, path.total, data.events, "  " + name);
    }
  }
  printSummaryLine(out, data.total, data.events, "total");
  out << '\n';
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size())) {
    printSummaryHeader(out, "Highlighted modules", true);
    for (unsigned int m: highlight_modules_[group].modules) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      printSummaryLine(out, module.total, data.events, module.events, module_d.moduleLabel());
    }
    printSummaryLine(out, data.highlight[group], data.events, highlight_modules_[group].label);
    out << '\n';
  }
}

template<typename T >

void FastTimerService::printSummaryHeader ( T &  out, std::string const &  label, bool  detailed  ) const

private

Referenced by printSummary().

template<typename T >

void FastTimerService::printSummaryHeader	(	T &	out,
		std::string const &	label,
		bool	detailed
	)		const

Definition at line 1470 of file FastTimerService.cc.

{
  if (detailed)
    out << "FastReport   CPU time avg.      when run  Real time avg.      when run     Alloc. avg.      when run   Dealloc. avg.      when run  ";
    //      FastReport  ########.# ms  ########.# ms  ########.# ms  ########.# ms  +######### kB  +######### kB  -######### kB  -######### kB  ...
  else
    out << "FastReport   CPU time avg.                Real time avg.                   Alloc. avg.                 Dealloc. avg.                ";
    //      FastReport  ########.# ms                 ########.# ms                 +######### kB                 -######### kB                 ...
  out << label << '\n';
}

template<typename T >

void FastTimerService::printSummaryLine ( T &  out, Resources const &  data, uint64_t  events, std::string const &  label  ) const

private

Referenced by printSummary().

template<typename T >

void FastTimerService::printSummaryLine ( T &  out, Resources const &  data, uint64_t  events, uint64_t  active, std::string const &  label  ) const

private

template<typename T >

void FastTimerService::printSummaryLine	(	T &	out,
		Resources const &	data,
		uint64_t	events,
		std::string const &	label
	)		const

Definition at line 1490 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, cmsPerfStripChart::format, AnalysisDataFormats_SUSYBSMObjects::ms, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

{
  out << boost::format("FastReport  %10.1f ms                 %10.1f ms                 %+10d kB                 %+10d kB                 %s\n")
    % (events ? ms(data.time_thread) / events : 0)
    % (events ? ms(data.time_real)   / events : 0)
    % (events ? +static_cast<int64_t>(kB(data.allocated)   / events) : 0)
    % (events ? -static_cast<int64_t>(kB(data.deallocated) / events) : 0)
    % label;
}

template<typename T >

void FastTimerService::printSummaryLine	(	T &	out,
		Resources const &	data,
		uint64_t	events,
		uint64_t	active,
		std::string const &	label
	)		const

Definition at line 1501 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, cmsPerfStripChart::format, AnalysisDataFormats_SUSYBSMObjects::ms, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

{
  out << boost::format("FastReport  %10.1f ms  %10.1f ms  %10.1f ms  %10.1f ms  %+10d kB  %+10d kB  %+10d kB  %+10d kB  %s\n")
    % (events ? ms(data.time_thread) / events : 0) % (active ? ms(data.time_thread) / active : 0)
    % (events ? ms(data.time_real)   / events : 0) % (active ? ms(data.time_real)   / active : 0)
    % (events ? +static_cast<int64_t>(kB(data.allocated)   / events) : 0) % (active ? +static_cast<int64_t>(kB(data.allocated)   / active) : 0)
    % (events ? -static_cast<int64_t>(kB(data.deallocated) / events) : 0) % (active ? -static_cast<int64_t>(kB(data.deallocated) / active) : 0)
    % label;
}

template<typename T >

void FastTimerService::printTransition ( T &  out, AtomicResources const &  data, std::string const &  label  ) const

private

Referenced by postGlobalEndLumi(), and postGlobalEndRun().

template<typename T >

void FastTimerService::printTransition	(	T &	out,
		AtomicResources const &	data,
		std::string const &	label
	)		const

Definition at line 1574 of file FastTimerService.cc.

References isFirstSubprocess(), edm::ProcessContext::isSubProcess(), printEventHeader(), printEventLine(), edm::GlobalContext::processContext(), edm::StreamContext::processContext(), and SimDataFormats::CaloAnalysis::sc.

{
  printEventHeader(out, "Transition");
  printEventLine(out, data, label);
}

double FastTimerService::queryEventTime

(

edm::StreamID

)

const

Referenced by querySourceTime().

double FastTimerService::queryEventTime	(	edm::StreamID	,
		std::string const &	process
	)		const

double FastTimerService::queryHighlightTime	(	edm::StreamID	sid,
		std::string const &	label
	)		const

Definition at line 1064 of file FastTimerService.cc.

References edmIntegrityCheck::group, highlight_modules_, AnalysisDataFormats_SUSYBSMObjects::ms, and streams_.

{
  auto const& stream = streams_[sid];
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size()))
    if (highlight_modules_[group].label == label)
      return ms(stream.highlight[group].time_real);

  // FIXME issue a LogWarning, raise an exception, or return NaN
  return 0.;
}

double FastTimerService::queryModuleTime	(	edm::StreamID	,
		const edm::ModuleDescription &	module
	)		const

Referenced by querySourceTime().

double FastTimerService::queryModuleTime	(	edm::StreamID	,
		unsigned int	id
	)		const

double FastTimerService::queryModuleTime_ ( edm::StreamID  sid, unsigned int  id  ) const

private

Definition at line 960 of file FastTimerService.cc.

References triggerObjects_cff::id, AnalysisDataFormats_SUSYBSMObjects::ms, and streams_.

Referenced by querySourceTime().

{
  // private version, assume "id" is valid
  auto const& stream = streams_[sid];
  auto const& module = stream.modules[id];
  return ms(module.total.time_real);
}

double FastTimerService::queryModuleTimeByLabel	(	edm::StreamID	,
		std::string const &	module
	)		const

Referenced by querySourceTime(), and IsoTrig::studyTiming().

double FastTimerService::queryModuleTimeByLabel	(	edm::StreamID	,
		std::string const &	process,
		const std::string &	module
	)		const

double FastTimerService::queryPathTime	(	edm::StreamID	,
		std::string const &	path
	)		const

Referenced by querySourceTime().

double FastTimerService::queryPathTime	(	edm::StreamID	,
		std::string const &	process,
		std::string const &	path
	)		const

double FastTimerService::querySourceTime

(

edm::StreamID

sid

)

const

Definition at line 969 of file FastTimerService.cc.

References callgraph_, edm::ModuleDescription::id(), diffTwoXMLs::label, ProcessCallGraph::module(), edm::ModuleDescription::moduleLabel(), ProcessCallGraph::ProcessType::modules_, AnalysisDataFormats_SUSYBSMObjects::ms, callgraph::path, sysUtil::pid, LaserDQM_cfg::process, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), ProcessCallGraph::processId(), queryEventTime(), queryModuleTime(), queryModuleTime_(), queryModuleTimeByLabel(), queryPathTime(), ProcessCallGraph::size(), ProcessCallGraph::source(), streams_, and AlCaHLTBitMon_QueryRunRegistry::string.

{
  return queryModuleTime_(sid, callgraph_.source().id());
}

FastTimerService::Measurement & FastTimerService::thread ( )

private

Definition at line 1895 of file FastTimerService.cc.

References threads_.

Referenced by on_scheduler_entry(), on_scheduler_exit(), postModuleEvent(), postModuleGlobalBeginLumi(), postModuleGlobalBeginRun(), postModuleGlobalEndLumi(), postModuleGlobalEndRun(), postModuleStreamBeginLumi(), postModuleStreamBeginRun(), postModuleStreamEndLumi(), postModuleStreamEndRun(), postSourceEvent(), postSourceLumi(), postSourceRun(), preModuleEvent(), preModuleGlobalBeginLumi(), preModuleGlobalBeginRun(), preModuleGlobalEndLumi(), preModuleGlobalEndRun(), preModuleStreamBeginLumi(), preModuleStreamBeginRun(), preModuleStreamEndLumi(), preModuleStreamEndRun(), preSourceEvent(), preSourceLumi(), and preSourceRun().

{
  return threads_.local();
}

void FastTimerService::unsupportedSignal ( const std::string &  signal ) const

private

Definition at line 1083 of file FastTimerService.cc.

References unsupported_signals_.

Referenced by postModuleEventDelayedGet(), and preModuleEventDelayedGet().

{
  // warn about each signal only once per job
  if (unsupported_signals_.insert(signal).second)
    edm::LogWarning("FastTimerService") << "The FastTimerService received the unsupported signal \"" << signal << "\".\n"
      << "Please report how to reproduce the issue to cms-hlt@cern.ch .";
}

Member Data Documentation

ProcessCallGraph FastTimerService::callgraph_

private

Definition at line 412 of file FastTimerService.h.

Referenced by isLastSubprocess(), postBeginJob(), postEvent(), postPathEvent(), postSourceEvent(), preBeginJob(), preGlobalBeginRun(), prePathEvent(), preSourceConstruction(), printEvent(), printSummary(), and querySourceTime().

unsigned int FastTimerService::concurrent_lumis_

private

Definition at line 443 of file FastTimerService.h.

Referenced by preallocate().

unsigned int FastTimerService::concurrent_runs_

private

Definition at line 444 of file FastTimerService.h.

Referenced by postBeginJob(), and preallocate().

unsigned int FastTimerService::concurrent_streams_

private

Definition at line 445 of file FastTimerService.h.

Referenced by postBeginJob(), and preallocate().

unsigned int FastTimerService::concurrent_threads_

private

Definition at line 446 of file FastTimerService.h.

Referenced by preallocate().

const PlotRanges FastTimerService::dqm_event_ranges_

private

Definition at line 461 of file FastTimerService.h.

Referenced by preGlobalBeginRun().

const unsigned int FastTimerService::dqm_lumisections_range_

private

Definition at line 464 of file FastTimerService.h.

Referenced by FastTimerService(), and preGlobalBeginRun().

const PlotRanges FastTimerService::dqm_module_ranges_

private

Definition at line 463 of file FastTimerService.h.

Referenced by FastTimerService(), and preGlobalBeginRun().

std::string FastTimerService::dqm_path_

private

Definition at line 465 of file FastTimerService.h.

Referenced by FastTimerService(), preallocate(), and preGlobalBeginRun().

const PlotRanges FastTimerService::dqm_path_ranges_

private

Definition at line 462 of file FastTimerService.h.

Referenced by FastTimerService(), and preGlobalBeginRun().

bool FastTimerService::enable_dqm_

private

Definition at line 454 of file FastTimerService.h.

Referenced by postBeginJob(), postEvent(), and preGlobalBeginRun().

const bool FastTimerService::enable_dqm_byls_

private

Definition at line 457 of file FastTimerService.h.

Referenced by preGlobalBeginRun().

const bool FastTimerService::enable_dqm_bymodule_

private

Definition at line 455 of file FastTimerService.h.

Referenced by preGlobalBeginRun().

const bool FastTimerService::enable_dqm_bynproc_

private

Definition at line 458 of file FastTimerService.h.

Referenced by preallocate().

const bool FastTimerService::enable_dqm_bypath_

private

Definition at line 456 of file FastTimerService.h.

Referenced by preGlobalBeginRun().

const bool FastTimerService::enable_dqm_transitions_

private

Definition at line 459 of file FastTimerService.h.

Referenced by postGlobalEndLumi(), postGlobalEndRun(), and preGlobalBeginRun().

std::vector<edm::ParameterSet> FastTimerService::highlight_module_psets_

private

Definition at line 468 of file FastTimerService.h.

Referenced by FastTimerService(), and postBeginJob().

std::vector<GroupOfModules> FastTimerService::highlight_modules_

private

Definition at line 469 of file FastTimerService.h.

Referenced by FastTimerService(), postBeginJob(), postEvent(), preGlobalBeginRun(), printEvent(), printSummary(), and queryHighlightTime().

ResourcesPerJob FastTimerService::job_summary_

private

Definition at line 426 of file FastTimerService.h.

Referenced by postBeginJob(), postEndJob(), and postEvent().

std::vector<AtomicResources> FastTimerService::lumi_transition_

private

Definition at line 421 of file FastTimerService.h.

Referenced by postGlobalEndLumi(), postModuleGlobalBeginLumi(), postModuleGlobalEndLumi(), postModuleStreamBeginLumi(), postModuleStreamEndLumi(), postSourceLumi(), preallocate(), and preGlobalBeginLumi().

AtomicResources FastTimerService::overhead_

private

Definition at line 423 of file FastTimerService.h.

Referenced by on_scheduler_exit(), preModuleGlobalBeginLumi(), preModuleGlobalBeginRun(), preModuleGlobalEndLumi(), preModuleGlobalEndRun(), preModuleStreamBeginLumi(), preModuleStreamBeginRun(), preModuleStreamEndLumi(), preModuleStreamEndRun(), preSourceLumi(), and preSourceRun().

std::unique_ptr<PlotsPerJob> FastTimerService::plots_

private

Definition at line 418 of file FastTimerService.h.

Referenced by postBeginJob(), postEvent(), postGlobalEndLumi(), postGlobalEndRun(), and preGlobalBeginRun().

const bool FastTimerService::print_event_summary_

private

Definition at line 449 of file FastTimerService.h.

Referenced by postEvent().

const bool FastTimerService::print_job_summary_

private

Definition at line 451 of file FastTimerService.h.

Referenced by postEndJob().

const bool FastTimerService::print_run_summary_

private

Definition at line 450 of file FastTimerService.h.

Referenced by postGlobalEndRun().

std::vector<ResourcesPerJob> FastTimerService::run_summary_

private

Definition at line 427 of file FastTimerService.h.

Referenced by postBeginJob(), postEvent(), postGlobalEndRun(), and preGlobalBeginRun().

std::vector<AtomicResources> FastTimerService::run_transition_

private

Definition at line 422 of file FastTimerService.h.

Referenced by postGlobalEndRun(), postModuleGlobalBeginRun(), postModuleGlobalEndRun(), postModuleStreamBeginRun(), postModuleStreamEndRun(), postSourceRun(), preallocate(), and preGlobalBeginRun().

std::vector<ResourcesPerJob> FastTimerService::streams_

private

Definition at line 415 of file FastTimerService.h.

Referenced by postBeginJob(), postEvent(), postModuleEvent(), postPathEvent(), postSourceEvent(), preModuleEvent(), prePathEvent(), preSourceEvent(), queryHighlightTime(), queryModuleTime_(), and querySourceTime().

std::unique_ptr<std::atomic<unsigned int>[]> FastTimerService::subprocess_event_check_

private

Definition at line 435 of file FastTimerService.h.

Referenced by postEvent(), preallocate(), and preSourceEvent().

std::unique_ptr<std::atomic<unsigned int>[]> FastTimerService::subprocess_global_lumi_check_

private

Definition at line 436 of file FastTimerService.h.

Referenced by postGlobalEndLumi(), preallocate(), and preGlobalBeginLumi().

std::unique_ptr<std::atomic<unsigned int>[]> FastTimerService::subprocess_global_run_check_

private

Definition at line 437 of file FastTimerService.h.

Referenced by postGlobalEndRun(), preallocate(), and preGlobalBeginRun().

std::mutex FastTimerService::summary_mutex_

private

Definition at line 428 of file FastTimerService.h.

Referenced by postEvent().

tbb::enumerable_thread_specific<Measurement, tbb::cache_aligned_allocator<Measurement>, tbb::ets_key_per_instance> FastTimerService::threads_

private

Definition at line 432 of file FastTimerService.h.

Referenced by thread().

tbb::concurrent_unordered_set<std::string> FastTimerService::unsupported_signals_

mutableprivate

Definition at line 472 of file FastTimerService.h.

Referenced by unsupportedSignal().