FastTimerService::Measurement Struct Reference

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

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 194 of file FastTimerService.h.

Constructor & Destructor Documentation

Measurement()

FastTimerService::Measurement::Measurement ( )

noexcept

Definition at line 312 of file FastTimerService.cc.

{ measure(); }

Member Function Documentation

measure()

void FastTimerService::Measurement::measure ( )

noexcept

Definition at line 314 of file FastTimerService.cc.

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

measure_and_accumulate() [1/2]

void FastTimerService::Measurement::measure_and_accumulate ( Resources &  store )

noexcept

Definition at line 342 of file FastTimerService.cc.

References memory_usage::allocated(), cms::cuda::assert(), memory_usage::deallocated(), and submitPVValidationJobs::now.

Referenced by FastTimerService::on_scheduler_exit().

                                                                                  {
#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;
}

measure_and_accumulate() [2/2]

void FastTimerService::Measurement::measure_and_accumulate ( AtomicResources &  store )

noexcept

Definition at line 360 of file FastTimerService.cc.

References memory_usage::allocated(), cms::cuda::assert(), submitPVResolutionJobs::count, memory_usage::deallocated(), and submitPVValidationJobs::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;
}

measure_and_store()

void FastTimerService::Measurement::measure_and_store ( Resources &  store )

noexcept

Definition at line 324 of file FastTimerService.cc.

References memory_usage::allocated(), cms::cuda::assert(), memory_usage::deallocated(), and submitPVValidationJobs::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 = 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

allocated

uint64_t FastTimerService::Measurement::allocated

Definition at line 211 of file FastTimerService.h.

deallocated

uint64_t FastTimerService::Measurement::deallocated

Definition at line 212 of file FastTimerService.h.

time_real

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

Definition at line 210 of file FastTimerService.h.

time_thread

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

Definition at line 209 of file FastTimerService.h.