#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

struct	ThreadGuard

Public Member Functions
template<typename T >
json	encodeToJSON (std::string const &type, std::string const &label, unsigned int events, T const &data) const

	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, AtomicResources const &data, uint64_t events, uint64_t active, std::string const &label) const

template<typename T >
void	printSummaryLine (T &out, AtomicResources 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

	~FastTimerService () override=default

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

Private Member Functions
template<typename T >
json	encodeToJSON (std::string const &type, std::string const &label, unsigned int events, T const &data) const

json	encodeToJSON (edm::ModuleDescription const &module, ResourcesPerModule const &data) const

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	postModuleEventAcquire (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	preModuleEventAcquire (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	printSummaryLine (T &out, AtomicResources const &data, uint64_t events, std::string const &label) const

template<typename T >
void	printSummaryLine (T &out, AtomicResources 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

Measurement &	thread ()

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

void	writeSummaryJSON (ResourcesPerJob const &data, std::string const &filename) 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_

ThreadGuard	guard_

std::vector< edm::ParameterSet >	highlight_module_psets_

std::vector< GroupOfModules >	highlight_modules_

ResourcesPerJob	job_summary_

const std::string	json_filename_

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::concurrent_unordered_set < std::string >	unsupported_signals_

const bool	write_json_summary_

Detailed Description

Definition at line 54 of file FastTimerService.h.

Constructor & Destructor Documentation

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

Definition at line 769 of file FastTimerService.cc.

References edm::ParameterSet::getUntrackedParameter().

     :  // 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")),
       // JSON configuration
       //write_json_per_event_(config.getUntrackedParameter<bool>("writeJSONByEvent")),
       //write_json_per_ls_(config.getUntrackedParameter<bool>("writeJSONByLumiSection")),
       //write_json_per_run_(config.getUntrackedParameter<bool>("writeJSONByRun")),
       write_json_summary_(config.getUntrackedParameter<bool>("writeJSONSummary")),
       json_filename_(config.getUntrackedParameter<std::string>("jsonFileName")),
       // 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

FastTimerService::~FastTimerService ( )

overridedefault

Member Function Documentation

template<typename T >

json FastTimerService::encodeToJSON	(	std::string const &	type,
		std::string const &	label,
		unsigned int	events,
		T const &	data
	)		const

private

json FastTimerService::encodeToJSON	(	edm::ModuleDescription const &	module,
		ResourcesPerModule const &	data
	)		const

private

template<typename T >

json FastTimerService::encodeToJSON	(	std::string const &	type,
		std::string const &	label,
		unsigned int	events,
		T const &	data
	)		const

Definition at line 1366 of file FastTimerService.cc.

                                                          {
   return json{{"type", type},
               {"label", label},
               {"events", events},
               {"time_thread", ms(data.time_thread)},
               {"time_real", ms(data.time_real)},
               {"mem_alloc", kB(data.allocated)},
               {"mem_free", kB(data.deallocated)}};
 }

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

static

Definition at line 1733 of file FastTimerService.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addOptionalNode(), edm::ParameterSetDescription::addUntracked(), edm::ParameterSetDescription::addVPSetUntracked(), submitPVResolutionJobs::desc, 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);
   // JSON configuration
   //desc.addUntracked<bool>("writeJSONByEvent", false);
   //desc.addUntracked<bool>("writeJSONByLumiSection", false);
   //desc.addUntracked<bool>("writeJSONByRun", false);
   desc.addUntracked<bool>("writeJSONSummary", false);
   desc.addUntracked<std::string>("jsonFileName", "resources.json");
   // DQM configuration
   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 885 of file FastTimerService.cc.

References LogDebug.

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

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

private

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

private

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

private

Definition at line 1420 of file FastTimerService.cc.

                                                                       {
   // 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 1721 of file FastTimerService.cc.

References guard_, FastTimerService::Measurement::measure(), overhead_, FastTimerService::ThreadGuard::register_thread(), and thread().

                                                      {
   if (guard_.register_thread(overhead_)) {
     // initialise the measurement point for a thread that has newly joined the TBB pool
     thread().measure();
   }
 }

void FastTimerService::on_scheduler_exit ( bool worker )

finalprivate

Definition at line 1728 of file FastTimerService.cc.

1728 {}

void FastTimerService::postBeginJob ( )

private

Definition at line 982 of file FastTimerService.cc.

References watchdog::group, highlight_module_psets_(), highlight_modules_(), mps_fire::i, label, HLT_FULL_cff::labels, TrackingSourceConfig_Tier0_Cosmic_cff::modules, AlCaHLTBitMon_QueryRunRegistry::string, and groupFilesInBlocks::temp.

Referenced by highlight_modules_().

                                     {
   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<dqm::legacy::DQMStore>().isAvailable()) {
     // the DQMStore is not available, disable all DQM plots
     enable_dqm_ = false;
     edm::LogWarning("FastTimerService") << "The DQMStore is not avalable, the DQM plots will not be generated";
   }
 
   // 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 1102 of file FastTimerService.cc.

References submitPVResolutionJobs::out, and SiStripPI::printSummary().

Referenced by highlight_modules_().

                                   {
   // stop observing to avoid potential race conditions at exit
   tbb::task_scheduler_observer::observe(false);
   guard_.finalize();
   if (print_job_summary_) {
     edm::LogVerbatim out("FastReport");
     printSummary(out, job_summary_, "Job");
   }
   if (write_json_summary_) {
     writeSummaryJSON(job_summary_, json_filename_);
   }
 }

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

private

Definition at line 1429 of file FastTimerService.cc.

References data, edm::StreamContext::eventID(), watchdog::group, highlight_modules_(), mps_fire::i, gpuClustering::id, dqmdumpme::last, edm::EventID::luminosityBlock(), TrackingSourceConfig_Tier0_Cosmic_cff::modules, submitPVResolutionJobs::out, LaserDQM_cfg::process, edm::StreamContext::processContext(), edm::StreamContext::runIndex(), cms::cuda::stream, and edm::StreamContext::streamID().

Referenced by highlight_modules_().

                                                            {
   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 id : process.modules_)
     data += stream.modules[id].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);
 
   // add to the event resources those used by source (which is not part of any process)
   unsigned int id = 0;
   stream.total += stream.modules[id].total;
 
   // 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 1593 of file FastTimerService.cc.

                                                                                                              {
   ignoredSignal(__func__);
 }

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

private

Definition at line 1038 of file FastTimerService.cc.

1038 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 936 of file FastTimerService.cc.

936 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1042 of file FastTimerService.cc.

References label, dqmdumpme::last, edm::LuminosityBlockID::luminosityBlock(), edm::GlobalContext::luminosityBlockID(), edm::GlobalContext::luminosityBlockIndex(), submitPVResolutionJobs::out, and edm::LuminosityBlockID::run().

Referenced by highlight_modules_().

                                                                    {
   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 =
       fmt::sprintf("run %d, lumisection %d", gc.luminosityBlockID().run(), gc.luminosityBlockID().luminosityBlock());
   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 1071 of file FastTimerService.cc.

References label, dqmdumpme::last, edm::GlobalContext::luminosityBlockID(), submitPVResolutionJobs::out, SiStripPI::printSummary(), edm::LuminosityBlockID::run(), and edm::GlobalContext::runIndex().

Referenced by highlight_modules_().

                                                                   {
   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 = fmt::sprintf("Run %d", gc.luminosityBlockID().run());
   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 1558 of file FastTimerService.cc.

References gpuClustering::id, edm::ModuleDescription::id(), edm::ModuleCallingContext::moduleDescription(), cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

                                                                                                      {
   edm::ModuleDescription const& md = *mcc.moduleDescription();
   unsigned int id = md.id();
   unsigned int sid = sc.streamID().value();
   auto& stream = streams_[sid];
   auto& module = stream.modules[id];
 
   if (module.has_acquire) {
     thread().measure_and_accumulate(module.total);
   } else {
     thread().measure_and_store(module.total);
   }
   ++module.events;
 }

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

private

Definition at line 1541 of file FastTimerService.cc.

References gpuClustering::id, edm::ModuleDescription::id(), edm::ModuleCallingContext::moduleDescription(), cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

                                                                                                             {
   edm::ModuleDescription const& md = *mcc.moduleDescription();
   unsigned int id = md.id();
   unsigned int sid = sc.streamID().value();
   auto& stream = streams_[sid];
   auto& module = stream.modules[id];
 
   module.has_acquire = true;
   thread().measure_and_store(module.total);
 }

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

private

Definition at line 1577 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                                {
   unsupportedSignal(__func__);
 }

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

private

Definition at line 1585 of file FastTimerService.cc.

                                                                                                                 {
   ignoredSignal(__func__);
 }

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

private

Definition at line 1619 of file FastTimerService.cc.

References edm::GlobalContext::luminosityBlockIndex().

Referenced by highlight_modules_().

                                                                                                                {
   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 1601 of file FastTimerService.cc.

References edm::GlobalContext::runIndex().

Referenced by highlight_modules_().

                                                                                                               {
   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 1628 of file FastTimerService.cc.

References edm::GlobalContext::luminosityBlockIndex().

Referenced by highlight_modules_().

                                                                                                              {
   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 1610 of file FastTimerService.cc.

References edm::GlobalContext::runIndex().

Referenced by highlight_modules_().

                                                                                                             {
   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 1655 of file FastTimerService.cc.

References edm::StreamContext::luminosityBlockIndex().

Referenced by highlight_modules_().

                                                                                                                {
   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 1637 of file FastTimerService.cc.

References edm::StreamContext::runIndex().

Referenced by highlight_modules_().

                                                                                                               {
   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 1664 of file FastTimerService.cc.

References edm::StreamContext::luminosityBlockIndex().

Referenced by highlight_modules_().

                                                                                                              {
   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 1646 of file FastTimerService.cc.

References edm::StreamContext::runIndex().

Referenced by highlight_modules_().

                                                                                                             {
   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 1511 of file FastTimerService.cc.

References mps_fire::i, gpuClustering::id, edm::HLTPathStatus::index(), edm::PathContext::isEndPath(), fed_dqm_sourceclient-live_cfg::path, edm::PathContext::pathID(), edm::StreamContext::processContext(), cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

                                                                      {
   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 1491 of file FastTimerService.cc.

References gpuClustering::id, edm::ModuleDescription::id(), and cms::cuda::stream.

Referenced by highlight_modules_().

                                                       {
   edm::ModuleDescription const& md = callgraph_.source();
   unsigned int id = md.id();
   auto& stream = streams_[sid];
   auto& module = stream.modules[id];
 
   thread().measure_and_store(module.total);
   ++stream.modules[id].events;
 }

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

private

Definition at line 1098 of file FastTimerService.cc.

Referenced by highlight_modules_().

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

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

private

Definition at line 1094 of file FastTimerService.cc.

Referenced by highlight_modules_().

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

FastTimerService::thread

Measurement & thread()

Definition: FastTimerService.cc:1730

FastTimerService::run_transition_

std::vector< AtomicResources > run_transition_

Definition: FastTimerService.h:451

FastTimerService::Measurement::measure_and_accumulate

void measure_and_accumulate(Resources &store) noexcept

Definition: FastTimerService.cc:337

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

private

Definition at line 1063 of file FastTimerService.cc.

1063 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1021 of file FastTimerService.cc.

1021 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1067 of file FastTimerService.cc.

Referenced by highlight_modules_().

1067 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1025 of file FastTimerService.cc.

Referenced by highlight_modules_().

1025 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 940 of file FastTimerService.cc.

References c, dqm_path_(), mps_fire::i, edm::service::SystemBounds::maxNumberOfConcurrentLuminosityBlocks(), edm::service::SystemBounds::maxNumberOfConcurrentRuns(), edm::service::SystemBounds::maxNumberOfStreams(), edm::service::SystemBounds::maxNumberOfThreads(), processor_model, and alignCSCRings::s.

Referenced by highlight_modules_().

                                                                        {
   concurrent_lumis_ = bounds.maxNumberOfConcurrentLuminosityBlocks();
   concurrent_runs_ = bounds.maxNumberOfConcurrentRuns();
   concurrent_streams_ = bounds.maxNumberOfStreams();
   concurrent_threads_ = bounds.maxNumberOfThreads();
 
   if (enable_dqm_bynproc_)
     dqm_path_ += fmt::sprintf(
         "/Running on %s with %d streams on %d threads", processor_model, concurrent_streams_, concurrent_threads_);
 
   // 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 977 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                      {
   callgraph_.preBeginJob(pathsAndConsumes, context);
 }

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

private

Definition at line 1427 of file FastTimerService.cc.

Referenced by highlight_modules_().

1427 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1589 of file FastTimerService.cc.

                                                                                                             {
   ignoredSignal(__func__);
 }

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

private

Definition at line 1027 of file FastTimerService.cc.

References edm::GlobalContext::luminosityBlockIndex().

Referenced by highlight_modules_().

                                                                     {
   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 898 of file FastTimerService.cc.

References dqm_lumisections_range_(), dqm_module_ranges_(), dqm_path_(), dqm_path_ranges_(), highlight_modules_(), edm::GlobalContext::runIndex(), and dqm::implementation::NavigatorBase::setCurrentFolder().

Referenced by highlight_modules_().

                                                                    {
   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](dqm::reco::DQMStore::IBooker& booker, dqm::reco::DQMStore::IGetter&) {
         auto scope = dqm::reco::DQMStore::IBooker::UseRunScope(booker);
         // we should really do this, but only DQMStore is allowed to touch it
         // We could move to postGlobalBeginRun, then the DQMStore has sure set it up.
         //booker.setRunLumi(gc.luminosityBlockID());
         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<dqm::legacy::DQMStore>()->meBookerGetter(bookTransactionCallback);
     }
   }
 }

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

private

Definition at line 1040 of file FastTimerService.cc.

1040 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1069 of file FastTimerService.cc.

1069 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1552 of file FastTimerService.cc.

References cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

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

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

private

Definition at line 1535 of file FastTimerService.cc.

References cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

                                                                                                            {
   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 1573 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                               {
   unsupportedSignal(__func__);
 }

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

private

Definition at line 1581 of file FastTimerService.cc.

                                                                                                                {
   ignoredSignal(__func__);
 }

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

private

Definition at line 1615 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                               {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1597 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                              {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1624 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                             {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1606 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                            {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1651 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                               {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1633 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                              {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1660 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                             {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1642 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                                            {
   thread().measure_and_accumulate(overhead_);
 }

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

private

Definition at line 1501 of file FastTimerService.cc.

References gpuClustering::id, edm::PathContext::isEndPath(), edm::PathContext::pathID(), edm::StreamContext::processContext(), cms::cuda::stream, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by highlight_modules_().

                                                                                         {
   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 973 of file FastTimerService.cc.

Referenced by highlight_modules_().

                                                                                {
   callgraph_.preSourceConstruction(module);
 }

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

private

Definition at line 1477 of file FastTimerService.cc.

References cms::cuda::stream.

Referenced by highlight_modules_().

                                                      {
   // 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 1096 of file FastTimerService.cc.

Referenced by highlight_modules_().

1096 { thread().measure_and_accumulate(overhead_); }

FastTimerService::overhead_

AtomicResources overhead_

Definition: FastTimerService.h:452

FastTimerService::thread

Measurement & thread()

Definition: FastTimerService.cc:1730

FastTimerService::Measurement::measure_and_accumulate

void measure_and_accumulate(Resources &store) noexcept

Definition: FastTimerService.cc:337

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

private

Definition at line 1092 of file FastTimerService.cc.

Referenced by highlight_modules_().

1092 { thread().measure_and_accumulate(overhead_); }

FastTimerService::overhead_

AtomicResources overhead_

Definition: FastTimerService.h:452

FastTimerService::thread

Measurement & thread()

Definition: FastTimerService.cc:1730

FastTimerService::Measurement::measure_and_accumulate

void measure_and_accumulate(Resources &store) noexcept

Definition: FastTimerService.cc:337

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

private

Definition at line 1061 of file FastTimerService.cc.

Referenced by highlight_modules_().

1061 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 938 of file FastTimerService.cc.

Referenced by highlight_modules_().

938 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1065 of file FastTimerService.cc.

1065 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

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

private

Definition at line 1023 of file FastTimerService.cc.

1023 { ignoredSignal(__func__); }

FastTimerService::ignoredSignal

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

Definition: FastTimerService.cc:885

template<typename T >

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

private

template<typename T >

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

Definition at line 1155 of file FastTimerService.cc.

References watchdog::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_(), mps_fire::i, visualization-live-secondInstance_cfg::m, callgraph::module, TrackingSourceConfig_Tier0_Cosmic_cff::modules, FastTimerService::ResourcesPerJob::modules, mergeVDriftHistosByStation::name, AlCaHLTBitMon_ParallelJobs::p, fed_dqm_sourceclient-live_cfg::path, ValidateTausOnZEEFastSim_cff::proc, FastTimerService::ResourcesPerJob::processes, 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

template<typename T >

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

Definition at line 1129 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

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 1135 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

                                                                                                  {
   out << fmt::sprintf("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 1145 of file FastTimerService.cc.

References FastTimerService::AtomicResources::allocated, FastTimerService::AtomicResources::deallocated, FastTimerService::AtomicResources::time_real, and FastTimerService::AtomicResources::time_thread.

                                                                                                        {
   out << fmt::sprintf("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(), ntuplePrintersDiff.SeedPrinter::printSeed(), and ntuplePrintersDiff.TrackPrinter::printTrack().

template<typename T >

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

Definition at line 1116 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

template<typename T >

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

Definition at line 1220 of file FastTimerService.cc.

                                                                                   {
   // clang-format off
   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';
   // clang-format on
 }

template<typename T >

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

private

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 1292 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

                                                                                                           {
   out << fmt::sprintf(
       "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

template<typename T >

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

Definition at line 1308 of file FastTimerService.cc.

References FastTimerService::ResourcesPerJob::events, watchdog::group, FastTimerService::ResourcesPerJob::highlight, highlight_modules_(), mps_fire::i, visualization-live-secondInstance_cfg::m, callgraph::module, TrackingSourceConfig_Tier0_Cosmic_cff::modules, FastTimerService::ResourcesPerJob::modules, mergeVDriftHistosByStation::name, FastTimerService::ResourcesPerJob::overhead, AlCaHLTBitMon_ParallelJobs::p, fed_dqm_sourceclient-live_cfg::path, ValidateTausOnZEEFastSim_cff::proc, FastTimerService::ResourcesPerJob::processes, 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");
   printSummaryLine(out, data.overhead, data.events, "other");
   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");
   printSummaryLine(out, data.overhead, data.events, "other");
   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

template<typename T >

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

Definition at line 1207 of file FastTimerService.cc.

                                                                                              {
   // clang-format off
   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';
   // clang-format on
 }

template<typename T >

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

private

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,
		AtomicResources const &	data,
		uint64_t	events,
		std::string const &	label
	)		const

private

template<typename T >

void FastTimerService::printSummaryLine	(	T &	out,
		AtomicResources 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 1229 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

                                                                                                                     {
   out << fmt::sprintf(
       // clang-format off
       "FastReport  %10.1f ms                 %10.1f ms                 %+10d kB                 %+10d kB                 %s\n",
       // clang-format on
       (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,
		AtomicResources const &	data,
		uint64_t	events,
		uint64_t	active,
		std::string const &	label
	)		const

Definition at line 1242 of file FastTimerService.cc.

References FastTimerService::AtomicResources::allocated, FastTimerService::AtomicResources::deallocated, FastTimerService::AtomicResources::time_real, and FastTimerService::AtomicResources::time_thread.

                                                                                                          {
   out << fmt::sprintf(
       // clang-format off
       "FastReport  %10.1f ms  %10.1f ms  %10.1f ms  %10.1f ms  %+10d kB  %+10d kB  %+10d kB  %+10d kB  %s\n",
       // clang-format on
       (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::printSummaryLine	(	T &	out,
		AtomicResources const &	data,
		uint64_t	events,
		std::string const &	label
	)		const

Definition at line 1260 of file FastTimerService.cc.

References FastTimerService::AtomicResources::allocated, FastTimerService::AtomicResources::deallocated, FastTimerService::AtomicResources::time_real, and FastTimerService::AtomicResources::time_thread.

                                                                       {
   out << fmt::sprintf(
       // clang-format off
       "FastReport  %10.1f ms                 %10.1f ms                 %+10d kB                 %+10d kB                 %s\n",
       // clang-format on
       (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 1276 of file FastTimerService.cc.

References FastTimerService::Resources::allocated, FastTimerService::Resources::deallocated, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

                                                                                                    {
   out << fmt::sprintf(
       "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

template<typename T >

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

Definition at line 1360 of file FastTimerService.cc.

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

FastTimerService::Measurement & FastTimerService::thread ( )

private

Definition at line 1730 of file FastTimerService.cc.

References guard_, and FastTimerService::ThreadGuard::thread().

Referenced by on_scheduler_entry().

1730 { return guard_.thread(); }

FastTimerService::ThreadGuard::thread

Measurement & thread()

Definition: FastTimerService.cc:1717

FastTimerService::guard_

ThreadGuard guard_

Definition: FastTimerService.h:485

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

private

Definition at line 890 of file FastTimerService.cc.

                                                                       {
   // 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 .";
 }

void FastTimerService::writeSummaryJSON	(	ResourcesPerJob const &	data,
		std::string const &	filename
	)		const

private

Definition at line 1383 of file FastTimerService.cc.

References mps_check::array, FastTimerService::ResourcesPerJob::events, mps_fire::i, dqmiolumiharvest::j, FastTimerService::ResourcesPerJob::modules, submitPVResolutionJobs::out, FastTimerService::ResourcesPerJob::overhead, and FastTimerService::ResourcesPerJob::total.

                                                                                                     {
   json j;
 
   // write a description of the resources
   j["resources"] = json::array({json{{"time_real", "real time"}},
                                 json{{"time_thread", "cpu time"}},
                                 json{{"mem_alloc", "allocated memory"}},
                                 json{{"mem_free", "deallocated memory"}}});
 
   // write the resources used by the job
   j["total"] = encodeToJSON("Job", callgraph_.processDescription(0).name_, data.events, data.total + data.overhead);
 
   // write the resources used by every module
   j["modules"] = json::array();
   for (unsigned int i = 0; i < callgraph_.size(); ++i) {
     auto const& module = callgraph_.module(i);
     auto const& data_m = data.modules[i];
     j["modules"].push_back(encodeToJSON(module, data_m));
   }
 
   // add an entry for the "overhead"
   j["modules"].push_back(encodeToJSON("other", "other", data.events, data.overhead));
 
   std::ofstream out(filename);
   out << std::setw(2) << j << std::flush;
 }

Member Data Documentation

ProcessCallGraph FastTimerService::callgraph_

private

Definition at line 441 of file FastTimerService.h.

unsigned int FastTimerService::concurrent_lumis_

private

Definition at line 496 of file FastTimerService.h.

unsigned int FastTimerService::concurrent_runs_

private

Definition at line 497 of file FastTimerService.h.

unsigned int FastTimerService::concurrent_streams_

private

Definition at line 498 of file FastTimerService.h.

unsigned int FastTimerService::concurrent_threads_

private

Definition at line 499 of file FastTimerService.h.

const PlotRanges FastTimerService::dqm_event_ranges_

private

Definition at line 521 of file FastTimerService.h.

const unsigned int FastTimerService::dqm_lumisections_range_

private

Definition at line 524 of file FastTimerService.h.

const PlotRanges FastTimerService::dqm_module_ranges_

private

Definition at line 523 of file FastTimerService.h.

std::string FastTimerService::dqm_path_

private

Definition at line 525 of file FastTimerService.h.

const PlotRanges FastTimerService::dqm_path_ranges_

private

Definition at line 522 of file FastTimerService.h.

bool FastTimerService::enable_dqm_

private

Definition at line 514 of file FastTimerService.h.

const bool FastTimerService::enable_dqm_byls_

private

Definition at line 517 of file FastTimerService.h.

const bool FastTimerService::enable_dqm_bymodule_

private

Definition at line 515 of file FastTimerService.h.

const bool FastTimerService::enable_dqm_bynproc_

private

Definition at line 518 of file FastTimerService.h.

const bool FastTimerService::enable_dqm_bypath_

private

Definition at line 516 of file FastTimerService.h.

const bool FastTimerService::enable_dqm_transitions_

private

Definition at line 519 of file FastTimerService.h.

ThreadGuard FastTimerService::guard_

private

Definition at line 485 of file FastTimerService.h.

Referenced by on_scheduler_entry(), and thread().

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

private

Definition at line 527 of file FastTimerService.h.

std::vector<GroupOfModules> FastTimerService::highlight_modules_

private

Definition at line 528 of file FastTimerService.h.

ResourcesPerJob FastTimerService::job_summary_

private

Definition at line 455 of file FastTimerService.h.

const std::string FastTimerService::json_filename_

private

Definition at line 511 of file FastTimerService.h.

std::vector<AtomicResources> FastTimerService::lumi_transition_

private

Definition at line 450 of file FastTimerService.h.

AtomicResources FastTimerService::overhead_

private

Definition at line 452 of file FastTimerService.h.

Referenced by FastTimerService::PlotsPerJob::book(), FastTimerService::PlotsPerJob::fill(), and on_scheduler_entry().

std::unique_ptr<PlotsPerJob> FastTimerService::plots_

private

Definition at line 447 of file FastTimerService.h.

const bool FastTimerService::print_event_summary_

private

Definition at line 502 of file FastTimerService.h.

const bool FastTimerService::print_job_summary_

private

Definition at line 504 of file FastTimerService.h.

const bool FastTimerService::print_run_summary_

private

Definition at line 503 of file FastTimerService.h.

std::vector<ResourcesPerJob> FastTimerService::run_summary_

private

Definition at line 456 of file FastTimerService.h.

std::vector<AtomicResources> FastTimerService::run_transition_

private

Definition at line 451 of file FastTimerService.h.

std::vector<ResourcesPerJob> FastTimerService::streams_

private

Definition at line 444 of file FastTimerService.h.

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

private

Definition at line 488 of file FastTimerService.h.

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

private

Definition at line 489 of file FastTimerService.h.

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

private

Definition at line 490 of file FastTimerService.h.

std::mutex FastTimerService::summary_mutex_

private

Definition at line 457 of file FastTimerService.h.

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

mutableprivate

Definition at line 531 of file FastTimerService.h.

const bool FastTimerService::write_json_summary_

private

Definition at line 510 of file FastTimerService.h.

Classes

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation