FastTimerService Class Reference

#include <FastTimerService.h>

Classes
struct	GroupOfModules
struct	Measurement
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 &)
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 ()

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

Private Member Functions
void	ignoredSignal (std::string signal) const
bool	isFirstSubprocess (edm::StreamContext const &)
bool	isFirstSubprocess (edm::GlobalContext const &)
bool	isLastSubprocess (std::atomic< unsigned int > &check)
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 ()
void	postSourceRun ()
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 ()
void	preSourceRun ()
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	printSummary (T &out, ResourcesPerJob const &, std::string const &label) const
double	queryModuleTime_ (edm::StreamID, unsigned int id) const
Measurement &	thread ()
void	unsupportedSignal (std::string signal) const

Private Attributes
ProcessCallGraph	callgraph_
unsigned int	concurrent_runs_
unsigned int	concurrent_streams_
unsigned int	concurrent_threads_
const double	dqm_eventtime_range_
const double	dqm_eventtime_resolution_
const unsigned int	dqm_lumisections_range_
const double	dqm_moduletime_range_
const double	dqm_moduletime_resolution_
std::string	dqm_path_
const double	dqm_pathtime_range_
const double	dqm_pathtime_resolution_
bool	enable_dqm_
const bool	enable_dqm_byls_
const bool	enable_dqm_bymodule_
const bool	enable_dqm_bynproc_
std::vector< edm::ParameterSet >	highlight_module_psets_
std::vector< GroupOfModules >	highlight_modules_
ResourcesPerJob	job_summary_
unsigned int	module_id_
const bool	print_event_summary_
const bool	print_job_summary_
const bool	print_run_summary_
std::vector< ResourcesPerJob >	run_summary_
std::vector< PlotsPerJob >	stream_plots_
std::vector< ResourcesPerJob >	streams_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_event_check_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_global_run_check_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_lumisection_check_
std::unique_ptr< std::atomic< unsigned int >[]>	subprocess_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 82 of file FastTimerService.h.

Constructor & Destructor Documentation

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

Definition at line 652 of file FastTimerService.cc.

References postBeginJob(), postEndJob(), postEvent(), postGlobalEndRun(), postModuleEvent(), postModuleEventDelayedGet(), postPathEvent(), postSourceEvent(), postStreamEndLumi(), postStreamEndRun(), preallocate(), preBeginJob(), preGlobalBeginRun(), preModuleEvent(), preModuleEventDelayedGet(), prePathEvent(), preSourceConstruction(), preSourceEvent(), preStreamBeginLumi(), preStreamBeginRun(), edm::ActivityRegistry::watchPostBeginJob(), edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPostEvent(), edm::ActivityRegistry::watchPostGlobalEndRun(), edm::ActivityRegistry::watchPostModuleEvent(), edm::ActivityRegistry::watchPostModuleEventDelayedGet(), edm::ActivityRegistry::watchPostPathEvent(), edm::ActivityRegistry::watchPostSourceEvent(), edm::ActivityRegistry::watchPostStreamEndLumi(), edm::ActivityRegistry::watchPostStreamEndRun(), edm::ActivityRegistry::watchPreallocate(), edm::ActivityRegistry::watchPreBeginJob(), edm::ActivityRegistry::watchPreGlobalBeginRun(), edm::ActivityRegistry::watchPreModuleEvent(), edm::ActivityRegistry::watchPreModuleEventDelayedGet(), edm::ActivityRegistry::watchPrePathEvent(), edm::ActivityRegistry::watchPreSourceConstruction(), edm::ActivityRegistry::watchPreSourceEvent(), edm::ActivityRegistry::watchPreStreamBeginLumi(), edm::ActivityRegistry::watchPreStreamBeginRun(), and ~FastTimerService().

                                                                                                 :
  // configuration
  callgraph_(),
  // job configuration
  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
  module_id_(                   edm::ModuleDescription::invalidID() ),
  enable_dqm_(                  config.getUntrackedParameter<bool>(     "enableDQM"                ) ),
  enable_dqm_bymodule_(         config.getUntrackedParameter<bool>(     "enableDQMbyModule"        ) ),
  enable_dqm_byls_(             config.getUntrackedParameter<bool>(     "enableDQMbyLumiSection"   ) ),
  enable_dqm_bynproc_(          config.getUntrackedParameter<bool>(     "enableDQMbyProcesses"     ) ),
  dqm_eventtime_range_(         config.getUntrackedParameter<double>(   "dqmTimeRange"             ) ),            // ms
  dqm_eventtime_resolution_(    config.getUntrackedParameter<double>(   "dqmTimeResolution"        ) ),            // ms
  dqm_pathtime_range_(          config.getUntrackedParameter<double>(   "dqmPathTimeRange"         ) ),            // ms
  dqm_pathtime_resolution_(     config.getUntrackedParameter<double>(   "dqmPathTimeResolution"    ) ),            // ms
  dqm_moduletime_range_(        config.getUntrackedParameter<double>(   "dqmModuleTimeRange"       ) ),            // ms
  dqm_moduletime_resolution_(   config.getUntrackedParameter<double>(   "dqmModuleTimeResolution"  ) ),            // ms
  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()
{
  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.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 ( )

default

Referenced by FastTimerService().

Member Function Documentation

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

static

Definition at line 1600 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>(        "enableDQMbyLumiSection",   false);
  desc.addUntracked<bool>(        "enableDQMbyProcesses",     false);
  desc.addUntracked<double>(      "dqmTimeRange",             1000. );   // ms
  desc.addUntracked<double>(      "dqmTimeResolution",           5. );   // ms
  desc.addUntracked<double>(      "dqmPathTimeRange",          100. );   // ms
  desc.addUntracked<double>(      "dqmPathTimeResolution",       0.5);   // ms
  desc.addUntracked<double>(      "dqmModuleTimeRange",         40. );   // ms
  desc.addUntracked<double>(      "dqmModuleTimeResolution",     0.2);   // ms
  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 ( std::string  signal ) const

private

Definition at line 866 of file FastTimerService.cc.

References LogDebug.

Referenced by postEvent(), postEventReadFromSource(), postGlobalBeginLumi(), postGlobalBeginRun(), postGlobalEndLumi(), postGlobalEndRun(), postModuleEventPrefetching(), postModuleGlobalBeginLumi(), postModuleGlobalBeginRun(), postModuleGlobalEndLumi(), postModuleGlobalEndRun(), postModuleStreamBeginLumi(), postModuleStreamBeginRun(), postModuleStreamEndLumi(), postModuleStreamEndRun(), postSourceLumi(), postSourceRun(), postStreamBeginLumi(), postStreamBeginRun(), postStreamEndLumi(), postStreamEndRun(), preEvent(), preEventReadFromSource(), preGlobalBeginLumi(), preGlobalBeginRun(), preGlobalEndLumi(), preGlobalEndRun(), preModuleEventPrefetching(), preModuleGlobalBeginLumi(), preModuleGlobalBeginRun(), preModuleGlobalEndLumi(), preModuleGlobalEndRun(), preModuleStreamBeginLumi(), preModuleStreamBeginRun(), preModuleStreamEndLumi(), preModuleStreamEndRun(), preSourceLumi(), preSourceRun(), preStreamBeginLumi(), preStreamBeginRun(), preStreamEndLumi(), and preStreamEndRun().

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

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

private

Definition at line 1309 of file FastTimerService.cc.

References edm::ProcessContext::isSubProcess(), and edm::StreamContext::processContext().

Referenced by preGlobalBeginRun(), preStreamBeginLumi(), and preStreamBeginRun().

{
  return (not sc.processContext()->isSubProcess());
}

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

private

Definition at line 1315 of file FastTimerService.cc.

References edm::ProcessContext::isSubProcess(), and edm::GlobalContext::processContext().

{
  return (not gc.processContext()->isSubProcess());
}

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

private

Definition at line 1322 of file FastTimerService.cc.

References callgraph_, and ProcessCallGraph::processes().

Referenced by postEvent(), postGlobalEndRun(), postStreamEndLumi(), and postStreamEndRun().

{
  // 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::postBeginJob ( )

private

Definition at line 974 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(), ErrorSummaryFilter_cfi::modules, run_summary_, ProcessCallGraph::size(), stream_plots_, 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_)
    stream_plots_.resize(concurrent_streams_, PlotsPerJob(callgraph_, highlight_modules_));

}

void FastTimerService::postEndJob ( )

private

Definition at line 1146 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 1337 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, print_event_summary_, printEvent(), LaserDQM_cfg::process, edm::StreamContext::processContext(), ProcessCallGraph::processDescription(), ProcessCallGraph::processId(), run_summary_, edm::StreamContext::runIndex(), stream_plots_, 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);

  // compute the event timing as the sum of all modules' timing
  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;

  // 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_)
    stream_plots_[sid].fill(callgraph_, stream, sc.eventID().luminosityBlock());
}

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

private

Definition at line 1489 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1047 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 893 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1059 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1109 of file FastTimerService.cc.

References ignoredSignal(), isLastSubprocess(), plotBeamSpotDB::last, MillePedeFileConverter_cfg::out, print_run_summary_, printSummary(), run_summary_, edm::GlobalContext::runIndex(), and subprocess_global_run_check_.

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // handle the summaries only after the last subprocess has run
  bool last = isLastSubprocess(subprocess_global_run_check_[gc.runIndex()]);
  if (print_run_summary_ and last) {
    edm::LogVerbatim out("FastReport");
    printSummary(out, run_summary_[gc.runIndex()], "Run");
  }
}

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

private

Definition at line 1447 of file FastTimerService.cc.

References hcalTTPDigis_cfi::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 1465 of file FastTimerService.cc.

References unsupportedSignal().

Referenced by FastTimerService().

{
  unsupportedSignal(__func__);
}

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

private

Definition at line 1477 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1525 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1501 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1537 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1513 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1573 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1549 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1585 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1561 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1418 of file FastTimerService.cc.

References callgraph_, data, ProcessCallGraph::ProcessType::endPaths_, mps_fire::i, hcalTTPDigis_cfi::id, edm::HLTPathStatus::index(), diffTreeTool::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 1393 of file FastTimerService.cc.

References callgraph_, hcalTTPDigis_cfi::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 ( )

private

Definition at line 1140 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::postSourceRun ( )

private

Definition at line 1128 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1077 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1014 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1089 of file FastTimerService.cc.

References enable_dqm_, edm::StreamContext::eventID(), ignoredSignal(), isLastSubprocess(), plotBeamSpotDB::last, edm::EventID::luminosityBlock(), DQMStore::mergeAndResetMEsLuminositySummaryCache(), module_id_, edm::EventID::run(), edm::StreamContext::streamID(), subprocess_lumisection_check_, and edm::StreamID::value().

Referenced by FastTimerService().

                                                              {
  ignoredSignal(__func__);

  unsigned int sid = sc.streamID().value();

  // merge plots only after the last subprocess has run
  bool last = isLastSubprocess(subprocess_lumisection_check_[sid]);
  if (enable_dqm_ and last) {
    DQMStore & store = * edm::Service<DQMStore>();
    store.mergeAndResetMEsLuminositySummaryCache(sc.eventID().run(),sc.eventID().luminosityBlock(),sid, module_id_);
  }
}

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

private

Definition at line 1026 of file FastTimerService.cc.

References enable_dqm_, edm::StreamContext::eventID(), ignoredSignal(), isLastSubprocess(), plotBeamSpotDB::last, DQMStore::mergeAndResetMEsRunSummaryCache(), module_id_, edm::EventID::run(), edm::StreamContext::streamID(), subprocess_run_check_, and edm::StreamID::value().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  unsigned int sid = sc.streamID().value();

  // merge plots only after the last subprocess has run
  bool last = isLastSubprocess(subprocess_run_check_[sid]);
  if (enable_dqm_ and last) {
    DQMStore & store = * edm::Service<DQMStore>();
    store.mergeAndResetMEsRunSummaryCache(sc.eventID().run(), sid, module_id_);
  }
}

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

private

Definition at line 936 of file FastTimerService.cc.

References concurrent_runs_, concurrent_streams_, concurrent_threads_, dqm_path_, enable_dqm_bynproc_, cmsPerfStripChart::format, edm::ModuleDescription::getUniqueID(), mps_fire::i, edm::service::SystemBounds::maxNumberOfConcurrentRuns(), edm::service::SystemBounds::maxNumberOfStreams(), edm::service::SystemBounds::maxNumberOfThreads(), module_id_, harvestTrackValidationPlots::str, subprocess_event_check_, subprocess_global_run_check_, subprocess_lumisection_check_, and subprocess_run_check_.

Referenced by FastTimerService().

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

  if (enable_dqm_bynproc_)
    dqm_path_ += (boost::format("/Running %d processes") % concurrent_threads_).str();

  // 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_lumisection_check_ = std::make_unique<std::atomic<unsigned int>[]>(concurrent_streams_);
  for (unsigned int i = 0; i < concurrent_streams_; ++i)
    subprocess_lumisection_check_[i] = 0;
  subprocess_run_check_         = std::make_unique<std::atomic<unsigned int>[]>(concurrent_streams_);
  for (unsigned int i = 0; i < concurrent_streams_; ++i)
    subprocess_run_check_[i] = 0;
  subprocess_global_run_check_  = std::make_unique<std::atomic<unsigned int>[]>(concurrent_streams_);
  for (unsigned int i = 0; i < concurrent_runs_; ++i)
    subprocess_global_run_check_[i] = 0;

  // assign a pseudo module id to the FastTimerService
  module_id_ = edm::ModuleDescription::getUniqueID();
}

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

private

Definition at line 969 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 1331 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1483 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1041 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 881 of file FastTimerService.cc.

References ignoredSignal(), isFirstSubprocess(), run_summary_, 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)) {
    subprocess_global_run_check_[gc.runIndex()] = 0;
    run_summary_[gc.runIndex()].reset();
  }
}

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

private

Definition at line 1053 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1103 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1441 of file FastTimerService.cc.

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

Referenced by FastTimerService().

{
  thread().measure();
}

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

private

Definition at line 1459 of file FastTimerService.cc.

References unsupportedSignal().

Referenced by FastTimerService().

{
  unsupportedSignal(__func__);
}

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

private

Definition at line 1471 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1519 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1495 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1531 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1507 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1567 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1543 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1579 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1555 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1405 of file FastTimerService.cc.

References callgraph_, data, hcalTTPDigis_cfi::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 964 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 1379 of file FastTimerService.cc.

References FastTimerService::Measurement::measure(), 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;

  thread().measure();
}

void FastTimerService::preSourceLumi ( )

private

Definition at line 1134 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

void FastTimerService::preSourceRun ( )

private

Definition at line 1122 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1065 of file FastTimerService.cc.

References ignoredSignal(), isFirstSubprocess(), edm::StreamContext::streamID(), subprocess_lumisection_check_, and edm::StreamID::value().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  // reset counters only during the main process transition
  if (isFirstSubprocess(sc)) {
    unsigned int sid = sc.streamID().value();
    subprocess_lumisection_check_[sid] = 0;
  }
}

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

private

Definition at line 899 of file FastTimerService.cc.

References callgraph_, dqm_eventtime_range_, dqm_eventtime_resolution_, dqm_lumisections_range_, dqm_moduletime_range_, dqm_moduletime_resolution_, dqm_path_, dqm_pathtime_range_, dqm_pathtime_resolution_, enable_dqm_, enable_dqm_byls_, enable_dqm_bymodule_, edm::StreamContext::eventID(), highlight_modules_, ignoredSignal(), isFirstSubprocess(), module_id_, edm::EventID::run(), stream_plots_, edm::StreamContext::streamID(), subprocess_run_check_, and edm::StreamID::value().

Referenced by FastTimerService().

{
  ignoredSignal(__func__);

  unsigned int sid = sc.streamID().value();

  // reset counters and book the DQM plots during the main process being run
  if (isFirstSubprocess(sc)) {
    subprocess_run_check_[sid] = 0;

    // book the DQM plots
    if (enable_dqm_) {
      // define a callback to book the MonitorElements
      auto bookTransactionCallback = [&, this] (DQMStore::IBooker & booker)
      {
        booker.setCurrentFolder(dqm_path_);
        stream_plots_[sid].book(booker, callgraph_,
            highlight_modules_,
            dqm_eventtime_range_,
            dqm_eventtime_resolution_,
            dqm_pathtime_range_,
            dqm_pathtime_resolution_,
            dqm_moduletime_range_,
            dqm_moduletime_resolution_,
            dqm_lumisections_range_,
            enable_dqm_bymodule_,
            enable_dqm_byls_);
      };

      // book MonitorElements for this stream
      edm::Service<DQMStore>()->bookTransaction(bookTransactionCallback, sc.eventID().run(), sid, module_id_);
    }
  }
}

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

private

Definition at line 1083 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

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

private

Definition at line 1020 of file FastTimerService.cc.

References ignoredSignal().

{
  ignoredSignal(__func__);
}

template<typename T >

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

private

Definition at line 1157 of file FastTimerService.cc.

References callgraph_, cmsPerfStripChart::format, edmIntegrityCheck::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_, mps_fire::i, funct::m, ProcessCallGraph::module(), FastTimerService::ResourcesPerJob::modules, AnalysisDataFormats_SUSYBSMObjects::ms, dataset::name, AlCaHLTBitMon_ParallelJobs::p, callgraph::path, proc, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), FastTimerService::ResourcesPerJob::processes, source, ProcessCallGraph::source(), FastTimerService::Resources::time_real, FastTimerService::Resources::time_thread, and FastTimerService::ResourcesPerJob::total.

Referenced by postEvent().

{
  out << "FastReport --------------------------- Event Summary ---------------------------\n";
  out << "FastReport       CPU time      Real time  Modules\n";
  auto const& source_d = callgraph_.source();
  auto const& source   = data.modules[source_d.id()];
  out << boost::format("FastReport  %10.3f ms  %10.3f ms  %s\n") % ms(source.total.time_thread) % ms(source.total.time_real) % 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];
    out << boost::format("FastReport  %10.3f ms  %10.3f ms  process %s\n") % ms(proc.total.time_thread) % ms(proc.total.time_real) % proc_d.name_;
    for (unsigned int m: proc_d.modules_) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s\n") % ms(module.total.time_thread) % ms(module.total.time_real) % module_d.moduleLabel();
    }
  }
  out << boost::format("FastReport  %10.3f ms  %10.3f ms  total\n") % ms(data.total.time_thread) % ms(data.total.time_real);
  out << '\n';
  out << "FastReport       CPU time      Real time  Processes and Paths\n";
  out << boost::format("FastReport  %10.3f ms  %10.3f ms  %s\n") % ms(source.total.time_thread) % ms(source.total.time_real) % 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];
    out << boost::format("FastReport  %10.3f ms  %10.3f ms  process %s\n") % ms(proc.total.time_thread) % ms(proc.total.time_real) % 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];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s (only scheduled modules)\n") % ms(path.active.time_thread) % ms(path.active.time_real) % name;
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s (including dependencies)\n") % ms(path.total.time_thread)  % ms(path.total.time_real)  % 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];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s (only scheduled modules)\n") % ms(path.active.time_thread) % ms(path.active.time_real) % name;
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s (including dependencies)\n") % ms(path.total.time_thread)  % ms(path.total.time_real)  % name;
    }
  }
  out << boost::format("FastReport  %10.3f ms  %10.3f ms  total\n") % ms(data.total.time_thread) % ms(data.total.time_real);
  out << '\n';
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size())) {
    out << "FastReport       CPU time      Real time  Highlighted modules\n";
    for (unsigned int m: highlight_modules_[group].modules) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms    %s\n") % ms(module.total.time_thread) % ms(module.total.time_real) % module_d.moduleLabel();
    }
    out << boost::format("FastReport  %10.3f ms  %10.3f ms  %s\n") % ms(data.highlight[group].time_thread) % ms(data.highlight[group].time_real) % highlight_modules_[group].label;
    out << '\n';
  }
}

template<typename T >

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

private

Definition at line 1210 of file FastTimerService.cc.

References callgraph_, FastTimerService::ResourcesPerJob::events, cmsPerfStripChart::format, edmIntegrityCheck::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_, mps_fire::i, funct::m, ProcessCallGraph::module(), FastTimerService::ResourcesPerJob::modules, AnalysisDataFormats_SUSYBSMObjects::ms, dataset::name, AlCaHLTBitMon_ParallelJobs::p, callgraph::path, proc, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), FastTimerService::ResourcesPerJob::processes, source, ProcessCallGraph::source(), FastTimerService::Resources::time_real, FastTimerService::Resources::time_thread, and FastTimerService::ResourcesPerJob::total.

Referenced by postEndJob(), and postGlobalEndRun().

{
  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';
  out << "FastReport   CPU time avg.      when run  Real time avg.      when run  Modules\n";
  auto const& source_d = callgraph_.source();
  auto const& source   = data.modules[source_d.id()];
  out << boost::format("FastReport  %10.3f ms  %10.3f ms  %10.3f ms  %10.3f ms  %s\n")
    % (ms(source.total.time_thread) / data.events) % (ms(source.total.time_thread) / source.events)
    % (ms(source.total.time_real) / data.events)   % (ms(source.total.time_real) / 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];
    out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 process %s\n")
      % (ms(proc.total.time_thread) / data.events)
      % (ms(proc.total.time_real) / data.events)
      % proc_d.name_;
    for (unsigned int m: proc_d.modules_) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms  %10.3f ms  %10.3f ms    %s\n")
        % (ms(module.total.time_thread) / data.events) % (ms(module.total.time_thread) / module.events)
        % (ms(module.total.time_real) / data.events)   % (ms(module.total.time_real) / module.events)
        % module_d.moduleLabel();
    }
  }
  out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 total\n")
    % (ms(data.total.time_thread) / data.events)
    % (ms(data.total.time_real) / data.events);
  out << '\n';
  out << "FastReport       CPU time                     Real time                 Processes and Paths\n";
  out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 %s\n")
    % (ms(source.total.time_thread) / data.events)
    % (ms(source.total.time_real) / 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];
    out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 process %s\n")
      % (ms(proc.total.time_thread) / data.events)
      % (ms(proc.total.time_real) / data.events)
      % 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];
      out << boost::format("FastReport  %10.3f ms                 %10.3f ms                   %s (only scheduled modules)\n")
       % (ms(path.active.time_thread) / data.events)
       % (ms(path.active.time_real) / data.events)
       % name;
      out << boost::format("FastReport  %10.3f ms                 %10.3f ms                   %s (including dependencies)\n")
       % (ms(path.total.time_thread) / data.events)
       % (ms(path.total.time_real) / 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];
      out << boost::format("FastReport  %10.3f ms                 %10.3f ms                   %s (only scheduled modules)\n")
       % (ms(path.active.time_thread) / data.events)
       % (ms(path.active.time_real) / data.events)
       % name;
      out << boost::format("FastReport  %10.3f ms                 %10.3f ms                   %s (including dependencies)\n")
       % (ms(path.total.time_thread) / data.events)
       % (ms(path.total.time_real) / data.events)
       % name;
    }
  }
  out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 total\n")
       % (ms(data.total.time_thread) / data.events)
       % (ms(data.total.time_real) / data.events);
  out << '\n';
  for (unsigned int group: boost::irange(0ul, highlight_modules_.size())) {
    out << "FastReport   CPU time avg.      when run  Real time avg.      when run  Highlighted modules\n";
    for (unsigned int m: highlight_modules_[group].modules) {
      auto const& module_d = callgraph_.module(m);
      auto const& module   = data.modules[m];
      out << boost::format("FastReport  %10.3f ms  %10.3f ms  %10.3f ms  %10.3f ms    %s\n")
        % (ms(module.total.time_thread) / data.events) % (ms(module.total.time_thread) / module.events)
        % (ms(module.total.time_real) / data.events)   % (ms(module.total.time_real) / module.events)
        % module_d.moduleLabel();
    }
    out << boost::format("FastReport  %10.3f ms                 %10.3f ms                 %s\n")
      % (ms(data.highlight[group].time_thread) / data.events)
      % (ms(data.highlight[group].time_real) / data.events)
      % highlight_modules_[group].label;
    out << '\n';
  }
}

double FastTimerService::queryEventTime

(

edm::StreamID

sid

)

const

Definition at line 764 of file FastTimerService.cc.

References AnalysisDataFormats_SUSYBSMObjects::ms, and streams_.

{
  auto const& stream = streams_[sid];
  return ms(stream.total.time_real);
}

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

Definition at line 771 of file FastTimerService.cc.

References callgraph_, AnalysisDataFormats_SUSYBSMObjects::ms, sysUtil::pid, ProcessCallGraph::processId(), and streams_.

{
  unsigned int pid = callgraph_.processId(process);
  auto const& stream = streams_[sid];
  return ms(stream.processes[pid].total.time_real);
}

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

Definition at line 853 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	sid,
		const edm::ModuleDescription &	module
	)		const

Definition at line 779 of file FastTimerService.cc.

References edm::ModuleDescription::id(), and queryModuleTime_().

{
  return queryModuleTime_(sid, md.id());
}

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

Definition at line 785 of file FastTimerService.cc.

References callgraph_, queryModuleTime_(), and ProcessCallGraph::size().

{
  if (id < callgraph_.size())
    return queryModuleTime_(sid, id);

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

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

private

Definition at line 749 of file FastTimerService.cc.

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

Referenced by queryModuleTime(), queryModuleTimeByLabel(), and 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	sid,
		std::string const &	module
	)		const

Definition at line 795 of file FastTimerService.cc.

References callgraph_, diffTwoXMLs::label, ProcessCallGraph::module(), edm::ModuleDescription::moduleLabel(), queryModuleTime_(), and ProcessCallGraph::size().

Referenced by IsoTrig::studyTiming().

{
  for (unsigned int id: boost::irange(0u, callgraph_.size()))
    if (callgraph_.module(id).moduleLabel() == label)
      return queryModuleTime_(sid, id);

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

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

Definition at line 806 of file FastTimerService.cc.

References callgraph_, diffTwoXMLs::label, ProcessCallGraph::module(), edm::ModuleDescription::moduleLabel(), ProcessCallGraph::ProcessType::modules_, ProcessCallGraph::processDescription(), and queryModuleTime_().

{
  for (unsigned int id: callgraph_.processDescription(process).modules_)
    if (callgraph_.module(id).moduleLabel() == label)
      return queryModuleTime_(sid, id);

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

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

Definition at line 817 of file FastTimerService.cc.

References callgraph_, AnalysisDataFormats_SUSYBSMObjects::ms, sysUtil::pid, ProcessCallGraph::processDescription(), ProcessCallGraph::processes(), and streams_.

{
  auto const& stream = streams_[sid];
  for (unsigned int pid: boost::irange(0ul, callgraph_.processes().size()))
  {
    auto const& desc = callgraph_.processDescription(pid);
    for (unsigned int id: boost::irange(0ul, desc.paths_.size()))
      if (desc.paths_[id].name_ == path)
        return ms(stream.processes[pid].paths[id].total.time_real);
    for (unsigned int id: boost::irange(0ul, desc.endPaths_.size()))
      if (desc.paths_[id].name_ == path)
        return ms(stream.processes[pid].endpaths[id].total.time_real);
  }

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

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

Definition at line 836 of file FastTimerService.cc.

References callgraph_, AnalysisDataFormats_SUSYBSMObjects::ms, sysUtil::pid, ProcessCallGraph::processDescription(), ProcessCallGraph::processId(), and streams_.

{
  auto const& stream = streams_[sid];
  unsigned int pid = callgraph_.processId(process);
  auto const& desc = callgraph_.processDescription(pid);
  for (unsigned int id: boost::irange(0ul, desc.paths_.size()))
    if (desc.paths_[id].name_ == path)
      return ms(stream.processes[pid].paths[id].total.time_real);
  for (unsigned int id: boost::irange(0ul, desc.endPaths_.size()))
    if (desc.paths_[id].name_ == path)
      return ms(stream.processes[pid].endpaths[id].total.time_real);

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

double FastTimerService::querySourceTime

(

edm::StreamID

sid

)

const

Definition at line 758 of file FastTimerService.cc.

References callgraph_, edm::ModuleDescription::id(), queryModuleTime_(), and ProcessCallGraph::source().

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

FastTimerService::Measurement & FastTimerService::thread ( )

private

Definition at line 1592 of file FastTimerService.cc.

References threads_.

Referenced by postModuleEvent(), postSourceEvent(), preModuleEvent(), and preSourceEvent().

{
  return threads_.local();
}

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

private

Definition at line 872 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 393 of file FastTimerService.h.

Referenced by isLastSubprocess(), postBeginJob(), postEvent(), postPathEvent(), postSourceEvent(), preBeginJob(), prePathEvent(), preSourceConstruction(), preStreamBeginRun(), printEvent(), printSummary(), queryEventTime(), queryModuleTime(), queryModuleTimeByLabel(), queryPathTime(), and querySourceTime().

unsigned int FastTimerService::concurrent_runs_

private

Definition at line 418 of file FastTimerService.h.

Referenced by postBeginJob(), and preallocate().

unsigned int FastTimerService::concurrent_streams_

private

Definition at line 419 of file FastTimerService.h.

Referenced by postBeginJob(), and preallocate().

unsigned int FastTimerService::concurrent_threads_

private

Definition at line 420 of file FastTimerService.h.

Referenced by preallocate().

const double FastTimerService::dqm_eventtime_range_

private

Definition at line 435 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const double FastTimerService::dqm_eventtime_resolution_

private

Definition at line 436 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const unsigned int FastTimerService::dqm_lumisections_range_

private

Definition at line 441 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const double FastTimerService::dqm_moduletime_range_

private

Definition at line 439 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const double FastTimerService::dqm_moduletime_resolution_

private

Definition at line 440 of file FastTimerService.h.

Referenced by preStreamBeginRun().

std::string FastTimerService::dqm_path_

private

Definition at line 442 of file FastTimerService.h.

Referenced by preallocate(), and preStreamBeginRun().

const double FastTimerService::dqm_pathtime_range_

private

Definition at line 437 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const double FastTimerService::dqm_pathtime_resolution_

private

Definition at line 438 of file FastTimerService.h.

Referenced by preStreamBeginRun().

bool FastTimerService::enable_dqm_

private

Definition at line 430 of file FastTimerService.h.

Referenced by postBeginJob(), postEvent(), postStreamEndLumi(), postStreamEndRun(), and preStreamBeginRun().

const bool FastTimerService::enable_dqm_byls_

private

Definition at line 432 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const bool FastTimerService::enable_dqm_bymodule_

private

Definition at line 431 of file FastTimerService.h.

Referenced by preStreamBeginRun().

const bool FastTimerService::enable_dqm_bynproc_

private

Definition at line 433 of file FastTimerService.h.

Referenced by preallocate().

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

private

Definition at line 445 of file FastTimerService.h.

Referenced by postBeginJob().

std::vector<GroupOfModules> FastTimerService::highlight_modules_

private

Definition at line 446 of file FastTimerService.h.

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

ResourcesPerJob FastTimerService::job_summary_

private

Definition at line 400 of file FastTimerService.h.

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

unsigned int FastTimerService::module_id_

private

Definition at line 428 of file FastTimerService.h.

Referenced by postStreamEndLumi(), postStreamEndRun(), preallocate(), and preStreamBeginRun().

const bool FastTimerService::print_event_summary_

private

Definition at line 423 of file FastTimerService.h.

Referenced by postEvent().

const bool FastTimerService::print_job_summary_

private

Definition at line 425 of file FastTimerService.h.

Referenced by postEndJob().

const bool FastTimerService::print_run_summary_

private

Definition at line 424 of file FastTimerService.h.

Referenced by postGlobalEndRun().

std::vector<ResourcesPerJob> FastTimerService::run_summary_

private

Definition at line 401 of file FastTimerService.h.

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

std::vector<PlotsPerJob> FastTimerService::stream_plots_

private

Definition at line 397 of file FastTimerService.h.

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

std::vector<ResourcesPerJob> FastTimerService::streams_

private

Definition at line 396 of file FastTimerService.h.

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

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

private

Definition at line 409 of file FastTimerService.h.

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

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

private

Definition at line 412 of file FastTimerService.h.

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

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

private

Definition at line 410 of file FastTimerService.h.

Referenced by postStreamEndLumi(), preallocate(), and preStreamBeginLumi().

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

private

Definition at line 411 of file FastTimerService.h.

Referenced by postStreamEndRun(), preallocate(), and preStreamBeginRun().

std::mutex FastTimerService::summary_mutex_

private

Definition at line 402 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 406 of file FastTimerService.h.

Referenced by thread().

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

mutableprivate

Definition at line 449 of file FastTimerService.h.

Referenced by unsupportedSignal().