TrigSignatureMoni::RateHistogram Class Reference

Collaboration diagram for TrigSignatureMoni::RateHistogram:

Public Member Functions
	RateHistogram ()=default
	~RateHistogram ()
StatusCode	init (const std::string &histoName, const std::string &histoTitle, const int x, const int y, const std::string &registerPath, const ServiceHandle< ITHistSvc > &histSvc)
LockedHandle< TH2 > &getHistogram	ATLAS_NOT_CONST_THREAD_SAFE () const
LockedHandle< TH2 > &getBuffer	ATLAS_NOT_CONST_THREAD_SAFE () const
std::unique_ptr< Athena::AlgorithmTimer > &	getTimer ()
void	startTimer (unsigned int duration, unsigned int intervals)
void	stopTimer ()
void	fill (const double x, const double y) const

Private Member Functions
void	updatePublished (unsigned int duration) const
void	callback ()

Private Attributes
LockedHandle< TH2 > m_bufferHistogram	ATLAS_THREAD_SAFE
LockedHandle< TH2 > m_histogram	ATLAS_THREAD_SAFE
std::mutex	m_mutex
std::unique_ptr< Athena::AlgorithmTimer >	m_timer
std::unique_ptr< TimeDivider >	m_timeDivider
unsigned int	m_duration {0}

Detailed Description

Definition at line 50 of file TrigSignatureMoni.h.

Constructor & Destructor Documentation

RateHistogram()

TrigSignatureMoni::RateHistogram::RateHistogram ( )

default

~RateHistogram()

TrigSignatureMoni::RateHistogram::~RateHistogram

(

)

Definition at line 498 of file TrigSignatureMoni.cxx.

                                              {
  delete m_bufferHistogram.get();
}

Member Function Documentation

ATLAS_NOT_CONST_THREAD_SAFE() [1/2]

LockedHandle<TH2>& getHistogram TrigSignatureMoni::RateHistogram::ATLAS_NOT_CONST_THREAD_SAFE

(

)

const

ATLAS_NOT_CONST_THREAD_SAFE() [2/2]

LockedHandle<TH2>& getBuffer TrigSignatureMoni::RateHistogram::ATLAS_NOT_CONST_THREAD_SAFE

(

)

const

callback()

void TrigSignatureMoni::RateHistogram::callback ( )

private

Definition at line 554 of file TrigSignatureMoni.cxx.

                                              {
  // Ask time divider if we need to switch to new interval
  time_t t = time(0);
  unsigned int newinterval;
  unsigned int oldinterval;
 
  if (m_timeDivider->isPassed(t, newinterval, oldinterval)) {
    updatePublished(m_duration);
  }
 
  // Schedule itself in another 1/20 of the integration period in milliseconds
  if (m_timer) m_timer->start(m_duration*50);
}

fill()

void TrigSignatureMoni::RateHistogram::fill	(	const double	x,
		const double	y
	)		const

Definition at line 526 of file TrigSignatureMoni.cxx.

                                                                              {
  m_bufferHistogram->Fill(x, y);
}

getTimer()

std::unique_ptr< Athena::AlgorithmTimer > & TrigSignatureMoni::RateHistogram::getTimer

(

)

Definition at line 522 of file TrigSignatureMoni.cxx.

                                                                               {
  return m_timer;
}

init()

StatusCode TrigSignatureMoni::RateHistogram::init	(	const std::string &	histoName,
		const std::string &	histoTitle,
		const int	x,
		const int	y,
		const std::string &	registerPath,
		const ServiceHandle< ITHistSvc > &	histSvc
	)

Definition at line 502 of file TrigSignatureMoni.cxx.

                                                                                                    {
  std::unique_ptr<TH2> h = std::make_unique<TH2F>(histoName.c_str(), histoTitle.c_str(), x, 1, x + 1, y, 1, y + 1);
  ATH_CHECK( histSvc->regShared( registerPath.c_str(), std::move(h), m_histogram));
  
  TH2I * hB = new TH2I( (histoName + "Buffer").c_str(), histoTitle.c_str(), x, 1, x + 1, y, 1, y + 1);
  m_bufferHistogram.set(hB, &m_mutex);
  m_bufferHistogram->SetDirectory(0);
 
  return StatusCode::SUCCESS;
}

startTimer()

void TrigSignatureMoni::RateHistogram::startTimer	(	unsigned int	duration,
		unsigned int	intervals
	)

Definition at line 530 of file TrigSignatureMoni.cxx.

                                                                                             {
  m_duration = duration;
  m_timeDivider = std::make_unique<TimeDivider>(intervals, duration, TimeDivider::seconds);
  m_timer = std::make_unique<Athena::AlgorithmTimer>(duration*50, std::bind(&RateHistogram::callback, this));
}

stopTimer()

void TrigSignatureMoni::RateHistogram::stopTimer

(

)

Definition at line 536 of file TrigSignatureMoni.cxx.

                                               {
  if (m_timer) {
    m_timer->stop();
    time_t t = time(0);
    unsigned int interval;
    unsigned int duration = m_timeDivider->forcePassed(t, interval);
    updatePublished(duration); // Divide by time that really passed not by interval duration
  }
 
}

updatePublished()

void TrigSignatureMoni::RateHistogram::updatePublished ( unsigned int  duration ) const

private

Definition at line 547 of file TrigSignatureMoni.cxx.

                                                                                {
  m_histogram->Reset("ICES");
  m_histogram->Add(m_bufferHistogram.get(), 1./duration);
  m_bufferHistogram->Reset("ICES");
}

Member Data Documentation

ATLAS_THREAD_SAFE [1/2]

LockedHandle<TH2> m_bufferHistogram TrigSignatureMoni::RateHistogram::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 84 of file TrigSignatureMoni.h.

ATLAS_THREAD_SAFE [2/2]

LockedHandle<TH2> m_histogram TrigSignatureMoni::RateHistogram::ATLAS_THREAD_SAFE

mutableprivate

Definition at line 85 of file TrigSignatureMoni.h.

m_duration

unsigned int TrigSignatureMoni::RateHistogram::m_duration {0}

private

Definition at line 89 of file TrigSignatureMoni.h.

m_mutex

std::mutex TrigSignatureMoni::RateHistogram::m_mutex

private

Definition at line 86 of file TrigSignatureMoni.h.

m_timeDivider

std::unique_ptr<TimeDivider> TrigSignatureMoni::RateHistogram::m_timeDivider

private

Definition at line 88 of file TrigSignatureMoni.h.

m_timer

std::unique_ptr<Athena::AlgorithmTimer> TrigSignatureMoni::RateHistogram::m_timer

private

Definition at line 87 of file TrigSignatureMoni.h.

---

The documentation for this class was generated from the following files:

• TrigSignatureMoni.h
• TrigSignatureMoni.cxx