FastTimerService::Measurement Struct Reference

Public Member Functions
void	measure ()
void	measure_and_accumulate (AtomicResources &store)
void	measure_and_store (Resources &store)
	Measurement ()

Public Attributes
uint64_t	allocated
uint64_t	deallocated
boost::chrono::high_resolution_clock::time_point	time_real
boost::chrono::thread_clock::time_point	time_thread

Detailed Description

Definition at line 200 of file FastTimerService.h.

Constructor & Destructor Documentation

FastTimerService::Measurement::Measurement

(

)

Definition at line 302 of file FastTimerService.cc.

                                         {
  measure();
}

Member Function Documentation

void FastTimerService::Measurement::measure

(

)

Definition at line 307 of file FastTimerService.cc.

References memory_usage::allocated(), memory_usage::deallocated(), and cmsPerfSuiteHarvest::now.

Referenced by FastTimerService::on_scheduler_entry().

                                     {
  #ifdef DEBUG_THREAD_CONCURRENCY
  id = std::this_thread::get_id();
  #endif // DEBUG_THREAD_CONCURRENCY
  time_thread = boost::chrono::thread_clock::now();
  time_real   = boost::chrono::high_resolution_clock::now();
  allocated   = memory_usage::allocated();
  deallocated = memory_usage::deallocated();
}

void FastTimerService::Measurement::measure_and_accumulate

(

AtomicResources &

store

)

Definition at line 337 of file FastTimerService.cc.

References memory_usage::allocated(), FastTimerService::AtomicResources::allocated, KineDebug3::count(), memory_usage::deallocated(), FastTimerService::AtomicResources::deallocated, cmsPerfSuiteHarvest::now, FastTimerService::PlotsPerElement::PlotsPerElement(), FastTimerService::AtomicResources::time_real, and FastTimerService::AtomicResources::time_thread.

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

                                                                           {
  #ifdef DEBUG_THREAD_CONCURRENCY
  assert(std::this_thread::get_id() == id);
  #endif // DEBUG_THREAD_CONCURRENCY
  auto new_time_thread = boost::chrono::thread_clock::now();
  auto new_time_real   = boost::chrono::high_resolution_clock::now();
  auto new_allocated   = memory_usage::allocated();
  auto new_deallocated = memory_usage::deallocated();
  store.time_thread += boost::chrono::duration_cast<boost::chrono::nanoseconds>(new_time_thread - time_thread).count();
  store.time_real   += boost::chrono::duration_cast<boost::chrono::nanoseconds>(new_time_real   - time_real).count();
  store.allocated   += new_allocated   - allocated;
  store.deallocated += new_deallocated - deallocated;
  time_thread = new_time_thread;
  time_real   = new_time_real;
  allocated   = new_allocated;
  deallocated = new_deallocated;
}

void FastTimerService::Measurement::measure_and_store

(

Resources &

store

)

Definition at line 318 of file FastTimerService.cc.

References memory_usage::allocated(), FastTimerService::Resources::allocated, memory_usage::deallocated(), FastTimerService::Resources::deallocated, cmsPerfSuiteHarvest::now, FastTimerService::Resources::time_real, and FastTimerService::Resources::time_thread.

Referenced by FastTimerService::postModuleEvent(), and FastTimerService::postSourceEvent().

                                                                {
  #ifdef DEBUG_THREAD_CONCURRENCY
  assert(std::this_thread::get_id() == id);
  #endif // DEBUG_THREAD_CONCURRENCY
  auto new_time_thread = boost::chrono::thread_clock::now();
  auto new_time_real   = boost::chrono::high_resolution_clock::now();
  auto new_allocated   = memory_usage::allocated();
  auto new_deallocated = memory_usage::deallocated();
  store.time_thread = new_time_thread - time_thread;
  store.time_real   = new_time_real   - time_real;
  store.allocated   = new_allocated   - allocated;
  store.deallocated = new_deallocated - deallocated;
  time_thread = new_time_thread;
  time_real   = new_time_real;
  allocated   = new_allocated;
  deallocated = new_deallocated;
}

Member Data Documentation

uint64_t FastTimerService::Measurement::allocated

Definition at line 213 of file FastTimerService.h.

uint64_t FastTimerService::Measurement::deallocated

Definition at line 214 of file FastTimerService.h.

boost::chrono::high_resolution_clock::time_point FastTimerService::Measurement::time_real

Definition at line 212 of file FastTimerService.h.

boost::chrono::thread_clock::time_point FastTimerService::Measurement::time_thread

Definition at line 211 of file FastTimerService.h.