edm::CPUTimer Class Reference

#include <CPUTimer.h>

Classes
struct	Times

Public Member Functions
void	add (const Times &t)
double	cpuTime () const
	CPUTimer ()
	CPUTimer (const CPUTimer &)=delete
	CPUTimer (CPUTimer &&)=default
CPUTimer &	operator= (const CPUTimer &)=delete
double	realTime () const
void	reset ()
void	start ()
Times	stop ()
	~CPUTimer ()

Private Types
enum	State { kRunning, kStopped }

Private Member Functions
Times	calculateDeltaTime () const

Private Attributes
double	accumulatedCPUTime_
double	accumulatedRealTime_
struct timeval	startCPUTime_
struct timeval	startRealTime_
enum edm::CPUTimer::State	state_

Detailed Description

Definition at line 37 of file CPUTimer.h.

Member Enumeration Documentation

State

enum edm::CPUTimer::State

private

Enumerator
kRunning
kStopped

Definition at line 68 of file CPUTimer.h.

{ kRunning, kStopped } state_;

Constructor & Destructor Documentation

CPUTimer() [1/3]

CPUTimer::CPUTimer

(

)

Definition at line 33 of file CPUTimer.cc.

    : state_(kStopped), startRealTime_(), startCPUTime_(), accumulatedRealTime_(0), accumulatedCPUTime_(0) {
#ifdef USE_CLOCK_GETTIME
  startRealTime_.tv_sec = 0;
  startRealTime_.tv_nsec = 0;
  startCPUTime_.tv_sec = 0;
  startCPUTime_.tv_nsec = 0;
#else
  startRealTime_.tv_sec = 0;
  startRealTime_.tv_usec = 0;
  startCPUTime_.tv_sec = 0;
  startCPUTime_.tv_usec = 0;
#endif
}

References startCPUTime_, and startRealTime_.

~CPUTimer()

CPUTimer::~CPUTimer

(

)

Definition at line 52 of file CPUTimer.cc.

{}

CPUTimer() [2/3]

edm::CPUTimer::CPUTimer ( CPUTimer &&  )

default

CPUTimer() [3/3]

edm::CPUTimer::CPUTimer ( const CPUTimer &  )

delete

Member Function Documentation

add()

void CPUTimer::add

(

const Times &

t

)

Definition at line 104 of file CPUTimer.cc.

                                         {
  accumulatedCPUTime_ += t.cpu_;
  accumulatedRealTime_ += t.real_;
}

References accumulatedCPUTime_, accumulatedRealTime_, and submitPVValidationJobs::t.

Referenced by counter.Counter::register().

calculateDeltaTime()

CPUTimer::Times CPUTimer::calculateDeltaTime ( ) const

private

Definition at line 109 of file CPUTimer.cc.

                                                 {
  Times returnValue;
#ifdef USE_CLOCK_GETTIME
  double const nanosecToSec = 1E-9;
  struct timespec tp;
 
  clock_gettime(CLOCK_PROCESS_CPUTIME_ID, &tp);
  returnValue.cpu_ = tp.tv_sec - startCPUTime_.tv_sec + nanosecToSec * (tp.tv_nsec - startCPUTime_.tv_nsec);
 
  clock_gettime(CLOCK_MONOTONIC, &tp);
  returnValue.real_ = tp.tv_sec - startRealTime_.tv_sec + nanosecToSec * (tp.tv_nsec - startRealTime_.tv_nsec);
#else
  rusage theUsage;
  if (0 != getrusage(RUSAGE_SELF, &theUsage)) {
    throw cms::Exception("CPUTimerFailed") << errno;
  }
  double const microsecToSec = 1E-6;
 
  struct timeval tp;
  gettimeofday(&tp, 0);
 
  returnValue.cpu_ = theUsage.ru_stime.tv_sec + theUsage.ru_utime.tv_sec - startCPUTime_.tv_sec +
                     microsecToSec * (theUsage.ru_stime.tv_usec + theUsage.ru_utime.tv_usec - startCPUTime_.tv_usec);
  returnValue.real_ = tp.tv_sec - startRealTime_.tv_sec + microsecToSec * (tp.tv_usec - startRealTime_.tv_usec);
#endif
  return returnValue;
}

References edm::CPUTimer::Times::cpu_, Exception, edm::CPUTimer::Times::real_, startCPUTime_, startRealTime_, and cmsswSequenceInfo::tp.

Referenced by cpuTime(), realTime(), and stop().

cpuTime()

double CPUTimer::cpuTime

(

)

const

Definition at line 146 of file CPUTimer.cc.

                               {
  if (kStopped == state_) {
    return accumulatedCPUTime_;
  }
  return accumulatedCPUTime_ + calculateDeltaTime().cpu_;
}

References accumulatedCPUTime_, calculateDeltaTime(), edm::CPUTimer::Times::cpu_, kStopped, and state_.

Referenced by CastorMonitorModule::analyze(), and edm::SystemTimeKeeper::fillTriggerTimingReport().

operator=()

CPUTimer& edm::CPUTimer::operator= ( const CPUTimer &  )

delete

realTime()

double CPUTimer::realTime

(

)

const

Definition at line 139 of file CPUTimer.cc.

                                {
  if (kStopped == state_) {
    return accumulatedRealTime_;
  }
  return accumulatedRealTime_ + calculateDeltaTime().real_;
}

References accumulatedRealTime_, calculateDeltaTime(), kStopped, edm::CPUTimer::Times::real_, and state_.

Referenced by edm::service::ResourceEnforcer::check(), and edm::SystemTimeKeeper::fillTriggerTimingReport().

reset()

void CPUTimer::reset

(

void

)

Definition at line 99 of file CPUTimer.cc.

                     {
  accumulatedCPUTime_ = 0;
  accumulatedRealTime_ = 0;
}

References accumulatedCPUTime_, and accumulatedRealTime_.

Referenced by CastorMonitorModule::analyze().

start()

void CPUTimer::start

(

)

Definition at line 68 of file CPUTimer.cc.

                     {
  if (kStopped == state_) {
#ifdef USE_CLOCK_GETTIME
    clock_gettime(CLOCK_MONOTONIC, &startRealTime_);
    clock_gettime(CLOCK_PROCESS_CPUTIME_ID, &startCPUTime_);
#else
    gettimeofday(&startRealTime_, 0);
 
    rusage theUsage;
    if (0 != getrusage(RUSAGE_SELF, &theUsage)) {
      throw cms::Exception("CPUTimerFailed") << errno;
    }
    startCPUTime_.tv_sec = theUsage.ru_stime.tv_sec + theUsage.ru_utime.tv_sec;
    startCPUTime_.tv_usec = theUsage.ru_stime.tv_usec + theUsage.ru_utime.tv_usec;
#endif
    state_ = kRunning;
  }
}

References Exception, kRunning, kStopped, startCPUTime_, startRealTime_, and state_.

Referenced by progressbar.ProgressBar::__next__(), CastorMonitorModule::analyze(), XrdAdaptor::RequestManager::handle(), edm::service::ResourceEnforcer::ResourceEnforcer(), and edm::SystemTimeKeeper::startProcessingLoop().

stop()

CPUTimer::Times CPUTimer::stop

(

)

Definition at line 87 of file CPUTimer.cc.

                             {
  if (kRunning == state_) {
    Times t = calculateDeltaTime();
    accumulatedCPUTime_ += t.cpu_;
    accumulatedRealTime_ += t.real_;
 
    state_ = kStopped;
    return t;
  }
  return Times();
}

References accumulatedCPUTime_, accumulatedRealTime_, calculateDeltaTime(), kRunning, kStopped, state_, and submitPVValidationJobs::t.

Referenced by CastorMonitorModule::analyze(), XrdAdaptor::RequestManager::handle(), and edm::SystemTimeKeeper::stopProcessingLoop().

Member Data Documentation

accumulatedCPUTime_

double edm::CPUTimer::accumulatedCPUTime_

private

Definition at line 78 of file CPUTimer.h.

Referenced by add(), cpuTime(), reset(), and stop().

accumulatedRealTime_

double edm::CPUTimer::accumulatedRealTime_

private

Definition at line 77 of file CPUTimer.h.

Referenced by add(), realTime(), reset(), and stop().

startCPUTime_

struct timeval edm::CPUTimer::startCPUTime_

private

Definition at line 74 of file CPUTimer.h.

Referenced by calculateDeltaTime(), CPUTimer(), and start().

startRealTime_

struct timeval edm::CPUTimer::startRealTime_

private

Definition at line 73 of file CPUTimer.h.

Referenced by calculateDeltaTime(), CPUTimer(), and start().

state_

enum edm::CPUTimer::State edm::CPUTimer::state_

private

Referenced by cpuTime(), realTime(), start(), and stop().