FastTimerService::Measurement Struct Reference

Public Member Functions
void	measure ()
void	measure_and_accumulate (Resources &store)
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 184 of file FastTimerService.h.

Constructor & Destructor Documentation

FastTimerService::Measurement::Measurement

(

)

Definition at line 266 of file FastTimerService.cc.

{ measure(); }

Member Function Documentation

void FastTimerService::Measurement::measure

(

)

Definition at line 268 of file FastTimerService.cc.

References memory_usage::allocated(), memory_usage::deallocated(), and fileCollector::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

(

Resources &

store

)

Definition at line 296 of file FastTimerService.cc.

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

Referenced by FastTimerService::on_scheduler_exit(), FastTimerService::postModuleEvent(), FastTimerService::postModuleGlobalBeginLumi(), FastTimerService::postModuleGlobalBeginRun(), FastTimerService::postModuleGlobalEndLumi(), FastTimerService::postModuleGlobalEndRun(), FastTimerService::postModuleStreamBeginLumi(), FastTimerService::postModuleStreamBeginRun(), FastTimerService::postModuleStreamEndLumi(), FastTimerService::postModuleStreamEndRun(), FastTimerService::postSourceLumi(), FastTimerService::postSourceRun(), FastTimerService::preModuleEvent(), FastTimerService::preModuleEventAcquire(), 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 += 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;
}

void FastTimerService::Measurement::measure_and_accumulate

(

AtomicResources &

store

)

Definition at line 314 of file FastTimerService.cc.

References memory_usage::allocated(), KineDebug3::count(), memory_usage::deallocated(), and fileCollector::now.

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

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

Referenced by FastTimerService::postModuleEvent(), FastTimerService::postModuleEventAcquire(), 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 201 of file FastTimerService.h.

uint64_t FastTimerService::Measurement::deallocated

Definition at line 202 of file FastTimerService.h.

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

Definition at line 200 of file FastTimerService.h.

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

Definition at line 199 of file FastTimerService.h.