OpenDDS::DCPS::ThreadStatusManager::Thread Class Reference

#include <ThreadStatusManager.h>

Collaboration diagram for OpenDDS::DCPS::ThreadStatusManager::Thread:

Classes
struct	Bucket

Public Types
enum	ThreadStatus { ThreadStatus_Active, ThreadStatus_Idle }

Public Member Functions
	Thread (const String &bit_key)
const String &	bit_key () const
const SystemTimePoint &	timestamp () const
const MonotonicTimePoint &	last_update () const
void	update (const MonotonicTimePoint &m_now, const SystemTimePoint &s_now, ThreadStatus next_status, const TimeDuration &bucket_limit, bool nested)
double	utilization (const MonotonicTimePoint &now) const

Static Public Attributes
static const size_t	bucket_count = 8

Private Attributes
const String	bit_key_
SystemTimePoint	timestamp_
ThreadStatus	status_
MonotonicTimePoint	last_update_
Bucket	total_
Bucket	bucket_ [bucket_count]
size_t	current_bucket_
size_t	nesting_depth_

Detailed Description

Definition at line 33 of file ThreadStatusManager.h.

Member Enumeration Documentation

ThreadStatus

enum OpenDDS::DCPS::ThreadStatusManager::Thread::ThreadStatus

Enumerator
ThreadStatus_Active
ThreadStatus_Idle

Definition at line 35 of file ThreadStatusManager.h.

                      {
      ThreadStatus_Active,
      ThreadStatus_Idle,
    };

Constructor & Destructor Documentation

Thread()

OpenDDS::DCPS::ThreadStatusManager::Thread::Thread ( const String &  bit_key )

inline

Definition at line 40 of file ThreadStatusManager.h.

Referenced by OpenDDS::DCPS::ThreadStatusManager::add_thread().

      : bit_key_(bit_key)
      , timestamp_(SystemTimePoint::now())
      , status_(ThreadStatus_Active)
      , last_update_(MonotonicTimePoint::now())
      , current_bucket_(0)
      , nesting_depth_(0)
    {}

Member Function Documentation

bit_key()

const String& OpenDDS::DCPS::ThreadStatusManager::Thread::bit_key ( ) const

inline

Definition at line 49 of file ThreadStatusManager.h.

Referenced by OpenDDS::DCPS::ThreadStatusManager::add_thread().

{ return bit_key_; }

last_update()

const MonotonicTimePoint& OpenDDS::DCPS::ThreadStatusManager::Thread::last_update ( ) const

inline

Definition at line 51 of file ThreadStatusManager.h.

{ return last_update_; }

timestamp()

const SystemTimePoint& OpenDDS::DCPS::ThreadStatusManager::Thread::timestamp ( void  ) const

inline

Definition at line 50 of file ThreadStatusManager.h.

{ return timestamp_; }

update()

void OpenDDS::DCPS::ThreadStatusManager::Thread::update	(	const MonotonicTimePoint &	m_now,
		const SystemTimePoint &	s_now,
		ThreadStatus	next_status,
		const TimeDuration &	bucket_limit,
		bool	nested
	)

Definition at line 19 of file ThreadStatusManager.cpp.

References OpenDDS::DCPS::ThreadStatusManager::Thread::Bucket::active_time, bucket_, bucket_count, current_bucket_, OpenDDS::DCPS::ThreadStatusManager::Thread::Bucket::idle_time, last_update_, nesting_depth_, status_, ThreadStatus_Active, ThreadStatus_Idle, timestamp_, and total_.

{
  timestamp_ = s_now;

  if (nested) {
    switch(next_status) {
    case ThreadStatus_Active:
      ++nesting_depth_;
      break;
    case ThreadStatus_Idle:
      --nesting_depth_;
      break;
    }
  }

  if (!nested ||
      (next_status == ThreadStatus_Active && nesting_depth_ == 1) ||
      (next_status == ThreadStatus_Idle && nesting_depth_ == 0)) {
    if (bucket_[current_bucket_].active_time + bucket_[current_bucket_].idle_time > bucket_limit) {
      current_bucket_ = (current_bucket_ + 1) % bucket_count;
      total_.active_time -= bucket_[current_bucket_].active_time;
      bucket_[current_bucket_].active_time = 0;
      total_.idle_time -= bucket_[current_bucket_].idle_time;
      bucket_[current_bucket_].idle_time = 0;
    }

    const TimeDuration t = m_now - last_update_;

    switch (status_) {
    case ThreadStatus_Active:
      bucket_[current_bucket_].active_time += t;
      total_.active_time += t;
      break;
    case ThreadStatus_Idle:
      bucket_[current_bucket_].idle_time += t;
      total_.idle_time += t;
      break;
    }

    last_update_ = m_now;
    status_ = next_status;
  }
}

utilization()

double OpenDDS::DCPS::ThreadStatusManager::Thread::utilization

(

const MonotonicTimePoint &

now

)

const

Definition at line 67 of file ThreadStatusManager.cpp.

References OpenDDS::DCPS::ThreadStatusManager::Thread::Bucket::active_time, OpenDDS::DCPS::ThreadStatusManager::Thread::Bucket::idle_time, OpenDDS::DCPS::TimeDuration::is_zero(), last_update_, status_, ThreadStatus_Active, ThreadStatus_Idle, total_, and OpenDDS::DCPS::TimeDuration::zero_value.

{
  const TimeDuration active_bonus = (now > last_update_ && status_ == ThreadStatus_Active) ? (now - last_update_) : TimeDuration::zero_value;
  const TimeDuration idle_bonus = (now > last_update_ && status_ == ThreadStatus_Idle) ? (now - last_update_) : TimeDuration::zero_value;
  const TimeDuration denom = total_.active_time + active_bonus + total_.idle_time + idle_bonus;

  if (!denom.is_zero()) {
    return (total_.active_time + active_bonus) / denom;
  }
  return 0;
}

Member Data Documentation

bit_key_

const String OpenDDS::DCPS::ThreadStatusManager::Thread::bit_key_

private

Definition at line 63 of file ThreadStatusManager.h.

bucket_

Bucket OpenDDS::DCPS::ThreadStatusManager::Thread::bucket_[bucket_count]

private

Definition at line 73 of file ThreadStatusManager.h.

Referenced by update().

bucket_count

const size_t OpenDDS::DCPS::ThreadStatusManager::Thread::bucket_count = 8

static

Definition at line 60 of file ThreadStatusManager.h.

Referenced by update().

current_bucket_

size_t OpenDDS::DCPS::ThreadStatusManager::Thread::current_bucket_

private

Definition at line 74 of file ThreadStatusManager.h.

Referenced by update().

last_update_

MonotonicTimePoint OpenDDS::DCPS::ThreadStatusManager::Thread::last_update_

private

Definition at line 71 of file ThreadStatusManager.h.

Referenced by update(), and utilization().

nesting_depth_

size_t OpenDDS::DCPS::ThreadStatusManager::Thread::nesting_depth_

private

Definition at line 75 of file ThreadStatusManager.h.

Referenced by update().

status_

ThreadStatus OpenDDS::DCPS::ThreadStatusManager::Thread::status_

private

Definition at line 65 of file ThreadStatusManager.h.

Referenced by update(), and utilization().

timestamp_

SystemTimePoint OpenDDS::DCPS::ThreadStatusManager::Thread::timestamp_

private

Definition at line 64 of file ThreadStatusManager.h.

Referenced by update().

total_

Bucket OpenDDS::DCPS::ThreadStatusManager::Thread::total_

private

Definition at line 72 of file ThreadStatusManager.h.

Referenced by update(), and utilization().

---

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

• ThreadStatusManager.h
• ThreadStatusManager.cpp