|
|
|
#include <Timing.h>
Public Member Functions | |
| Timing (ParameterSet const &, ActivityRegistry &) | |
| ~Timing () | |
Static Public Member Functions | |
| static void | fillDescriptions (edm::ConfigurationDescriptions &descriptions) |
Private Member Functions | |
| void | postBeginJob () |
| void | postEndJob () |
| void | postEventProcessing (Event const &, EventSetup const &) |
| void | postModule (ModuleDescription const &) |
| void | preEventProcessing (EventID const &, Timestamp const &) |
| void | preModule (ModuleDescription const &) |
Private Attributes | |
| EventID | curr_event_ |
| double | curr_event_cpu_ |
| double | curr_event_time_ |
| double | curr_job_cpu_ |
| double | curr_job_time_ |
| double | curr_module_time_ |
| double | max_event_cpu_ |
| double | max_event_time_ |
| double | min_event_cpu_ |
| double | min_event_time_ |
| bool | report_summary_ |
| bool | summary_only_ |
| int | total_event_count_ |
| double | total_event_cpu_ |
| edm::service::Timing::Timing | ( | ParameterSet const & | iPS, |
| ActivityRegistry & | iRegistry | ||
| ) |
Definition at line 82 of file Timing.cc.
References postBeginJob(), postEndJob(), postEventProcessing(), postModule(), preEventProcessing(), preModule(), summary_only_, edm::ActivityRegistry::watchPostBeginJob(), edm::ActivityRegistry::watchPostEndJob(), edm::ActivityRegistry::watchPostModule(), edm::ActivityRegistry::watchPostProcessEvent(), edm::ActivityRegistry::watchPreModule(), and edm::ActivityRegistry::watchPreProcessEvent().
:
curr_event_(),
curr_job_time_(0.),
curr_job_cpu_(0.),
curr_event_time_(0.),
curr_event_cpu_(0.),
curr_module_time_(0.),
total_event_cpu_(0.),
summary_only_(iPS.getUntrackedParameter<bool>("summaryOnly")),
report_summary_(iPS.getUntrackedParameter<bool>("useJobReport")),
max_event_time_(0.),
max_event_cpu_(0.),
min_event_time_(0.),
min_event_cpu_(0.),
total_event_count_(0) {
iRegistry.watchPostBeginJob(this, &Timing::postBeginJob);
iRegistry.watchPostEndJob(this, &Timing::postEndJob);
iRegistry.watchPreProcessEvent(this, &Timing::preEventProcessing);
iRegistry.watchPostProcessEvent(this, &Timing::postEventProcessing);
if(not summary_only_) {
iRegistry.watchPreModule(this, &Timing::preModule);
iRegistry.watchPostModule(this, &Timing::postModule);
}
}
| void edm::service::Timing::fillDescriptions | ( | edm::ConfigurationDescriptions & | descriptions | ) | [static] |
Definition at line 112 of file Timing.cc.
References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::addUntracked(), and edm::ConfigurationDescriptions::setComment().
{
ParameterSetDescription desc;
desc.addUntracked<bool>("summaryOnly", false)->setComment(
"If 'true' do not report timing for each event");
desc.addUntracked<bool>("useJobReport", true)->setComment(
"If 'true' write summary information to JobReport");
descriptions.add("Timing", desc);
descriptions.setComment(
"This service reports the time it takes to run each module in a job.");
}
| void edm::service::Timing::postBeginJob | ( | ) | [private] |
Definition at line 123 of file Timing.cc.
References curr_job_cpu_, curr_job_time_, edm::service::getCPU(), edm::service::getTime(), summary_only_, and total_event_cpu_.
Referenced by Timing().
{
curr_job_time_ = getTime();
curr_job_cpu_ = getCPU();
total_event_cpu_ = 0.0;
//LogInfo("TimeReport")
if(not summary_only_) {
LogImportant("TimeReport") // ChangeLog 3
<< "TimeReport> Report activated" << "\n"
<< "TimeReport> Report columns headings for events: "
<< "eventnum runnum timetaken\n"
<< "TimeReport> Report columns headings for modules: "
<< "eventnum runnum modulelabel modulename timetakeni\n"
<< "TimeReport> JobTime=" << curr_job_time_ << " JobCPU=" << curr_job_cpu_ << "\n";
}
}
| void edm::service::Timing::postEndJob | ( | ) | [private] |
Definition at line 140 of file Timing.cc.
References curr_job_cpu_, curr_job_time_, edm::service::d2str(), edm::service::getCPU(), edm::service::getTime(), max_event_cpu_, max_event_time_, min_event_cpu_, min_event_time_, report_summary_, total_event_count_, and total_event_cpu_.
Referenced by Timing().
{
double total_job_time = getTime() - curr_job_time_;
double average_event_time = total_job_time / total_event_count_;
double total_job_cpu = getCPU() - curr_job_cpu_;
double average_event_cpu = total_event_cpu_ / total_event_count_;
//LogAbsolute("FwkJob")
//LogAbsolute("TimeReport") // Changelog 1
LogImportant("TimeReport") // Changelog 3
<< "TimeReport> Time report complete in "
<< total_job_time << " seconds"
<< "\n"
<< " Time Summary: \n"
<< " - Min event: " << min_event_time_ << "\n"
<< " - Max event: " << max_event_time_ << "\n"
<< " - Avg event: " << average_event_time << "\n"
<< " - Total job: " << total_job_time << "\n"
<< " CPU Summary: \n"
<< " - Min event: " << min_event_cpu_ << "\n"
<< " - Max event: " << max_event_cpu_ << "\n"
<< " - Avg event: " << average_event_cpu << "\n"
<< " - Total job: " << total_job_cpu << "\n"
<< " - Total event: " << total_event_cpu_ << "\n";
if(report_summary_) {
Service<JobReport> reportSvc;
// std::map<std::string, double> reportData;
std::map<std::string, std::string> reportData;
reportData.insert(std::make_pair("MinEventTime", d2str(min_event_time_)));
reportData.insert(std::make_pair("MaxEventTime", d2str(max_event_time_)));
reportData.insert(std::make_pair("AvgEventTime", d2str(average_event_time)));
reportData.insert(std::make_pair("TotalJobTime", d2str(total_job_time)));
reportData.insert(std::make_pair("MinEventCPU", d2str(min_event_cpu_)));
reportData.insert(std::make_pair("MaxEventCPU", d2str(max_event_cpu_)));
reportData.insert(std::make_pair("AvgEventCPU", d2str(average_event_cpu)));
reportData.insert(std::make_pair("TotalJobCPU", d2str(total_job_cpu)));
reportData.insert(std::make_pair("TotalEventCPU", d2str(total_event_cpu_)));
reportSvc->reportPerformanceSummary("Timing", reportData);
// reportSvc->reportTimingInfo(reportData);
}
}
| void edm::service::Timing::postEventProcessing | ( | Event const & | , |
| EventSetup const & | |||
| ) | [private] |
Definition at line 191 of file Timing.cc.
References curr_event_, curr_event_cpu_, curr_event_time_, edm::EventID::event(), edm::service::getCPU(), edm::service::getTime(), max_event_cpu_, max_event_time_, min_event_cpu_, min_event_time_, edm::EventID::run(), summary_only_, total_event_count_, and total_event_cpu_.
Referenced by Timing().
{
curr_event_cpu_ = getCPU() - curr_event_cpu_;
total_event_cpu_ += curr_event_cpu_;
curr_event_time_ = getTime() - curr_event_time_;
if(not summary_only_) {
LogPrint("TimeEvent") // ChangeLog 3
<< "TimeEvent> "
<< curr_event_.event() << " "
<< curr_event_.run() << " "
<< curr_event_time_ << " "
<< curr_event_cpu_ << " "
<< total_event_cpu_;
}
if(total_event_count_ == 0) {
max_event_time_ = curr_event_time_;
min_event_time_ = curr_event_time_;
max_event_cpu_ = curr_event_cpu_;
min_event_cpu_ = curr_event_cpu_;
}
if(curr_event_time_ > max_event_time_) max_event_time_ = curr_event_time_;
if(curr_event_time_ < min_event_time_) min_event_time_ = curr_event_time_;
if(curr_event_cpu_ > max_event_cpu_) max_event_cpu_ = curr_event_cpu_;
if(curr_event_cpu_ < min_event_cpu_) min_event_cpu_ = curr_event_cpu_;
total_event_count_ = total_event_count_ + 1;
}
| void edm::service::Timing::postModule | ( | ModuleDescription const & | desc | ) | [private] |
Definition at line 224 of file Timing.cc.
References curr_event_, curr_module_time_, edm::EventID::event(), edm::service::getTime(), edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::moduleName(), edm::EventID::run(), summary_only_, and lumiQTWidget::t.
Referenced by Timing().
{
double t = getTime() - curr_module_time_;
//LogInfo("TimeModule")
if(not summary_only_) {
LogPrint("TimeModule") << "TimeModule> " // ChangeLog 4
<< curr_event_.event() << " "
<< curr_event_.run() << " "
<< desc.moduleLabel() << " "
<< desc.moduleName() << " "
<< t;
}
}
Definition at line 185 of file Timing.cc.
References curr_event_, curr_event_cpu_, curr_event_time_, edm::service::getCPU(), and edm::service::getTime().
Referenced by Timing().
{
curr_event_ = iID;
curr_event_time_ = getTime();
curr_event_cpu_ = getCPU();
}
| void edm::service::Timing::preModule | ( | ModuleDescription const & | ) | [private] |
Definition at line 220 of file Timing.cc.
References curr_module_time_, and edm::service::getTime().
Referenced by Timing().
{
curr_module_time_ = getTime();
}
EventID edm::service::Timing::curr_event_ [private] |
Definition at line 47 of file Timing.h.
Referenced by postEventProcessing(), postModule(), and preEventProcessing().
double edm::service::Timing::curr_event_cpu_ [private] |
Definition at line 51 of file Timing.h.
Referenced by postEventProcessing(), and preEventProcessing().
double edm::service::Timing::curr_event_time_ [private] |
Definition at line 50 of file Timing.h.
Referenced by postEventProcessing(), and preEventProcessing().
double edm::service::Timing::curr_job_cpu_ [private] |
Definition at line 49 of file Timing.h.
Referenced by postBeginJob(), and postEndJob().
double edm::service::Timing::curr_job_time_ [private] |
Definition at line 48 of file Timing.h.
Referenced by postBeginJob(), and postEndJob().
double edm::service::Timing::curr_module_time_ [private] |
Definition at line 52 of file Timing.h.
Referenced by postModule(), and preModule().
double edm::service::Timing::max_event_cpu_ [private] |
Definition at line 61 of file Timing.h.
Referenced by postEndJob(), and postEventProcessing().
double edm::service::Timing::max_event_time_ [private] |
Definition at line 60 of file Timing.h.
Referenced by postEndJob(), and postEventProcessing().
double edm::service::Timing::min_event_cpu_ [private] |
Definition at line 63 of file Timing.h.
Referenced by postEndJob(), and postEventProcessing().
double edm::service::Timing::min_event_time_ [private] |
Definition at line 62 of file Timing.h.
Referenced by postEndJob(), and postEventProcessing().
bool edm::service::Timing::report_summary_ [private] |
Definition at line 55 of file Timing.h.
Referenced by postEndJob().
bool edm::service::Timing::summary_only_ [private] |
Definition at line 54 of file Timing.h.
Referenced by postBeginJob(), postEventProcessing(), postModule(), and Timing().
int edm::service::Timing::total_event_count_ [private] |
Definition at line 64 of file Timing.h.
Referenced by postEndJob(), and postEventProcessing().
double edm::service::Timing::total_event_cpu_ [private] |
Definition at line 53 of file Timing.h.
Referenced by postBeginJob(), postEndJob(), and postEventProcessing().
1.7.3