OpenDDS::DCPS::ThreadStatusManager Class Reference

#include <ThreadStatusManager.h>

Collaboration diagram for OpenDDS::DCPS::ThreadStatusManager:

Classes
class	Event
class	Sleeper
class	Start
class	Thread

Public Types
typedef String	ThreadId

Public Member Functions
typedef	OPENDDS_MAP (ThreadId, Thread) Map
typedef	OPENDDS_LIST (Thread) List
void	thread_status_interval (const TimeDuration &thread_status_interval)
const TimeDuration &	thread_status_interval () const
bool	update_thread_status () const
void	harvest (const MonotonicTimePoint &start, List &running, List &finished) const

Private Member Functions
void	add_thread (const String &name)
void	active (bool nested=false)
void	idle (bool nested=false)
void	finished ()
void	cleanup (const MonotonicTimePoint &now)

Static Private Member Functions
static ThreadId	get_thread_id ()

Private Attributes
TimeDuration	thread_status_interval_
TimeDuration	bucket_limit_
Map	map_
List	list_
ACE_Thread_Mutex	lock_

Detailed Description

Definition at line 19 of file ThreadStatusManager.h.

Member Typedef Documentation

ThreadId

typedef String OpenDDS::DCPS::ThreadStatusManager::ThreadId

Definition at line 29 of file ThreadStatusManager.h.

Member Function Documentation

active()

void OpenDDS::DCPS::ThreadStatusManager::active ( bool  nested = false )

private

Definition at line 117 of file ThreadStatusManager.cpp.

References ACE_GUARD, bucket_limit_, cleanup(), get_thread_id(), lock_, map_, OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OpenDDS::DCPS::ThreadStatusManager::Thread::ThreadStatus_Active, and update_thread_status().

{
  if (!update_thread_status()) {
    return;
  }

  ACE_GUARD(ACE_Thread_Mutex, g, lock_);

  const MonotonicTimePoint m_now = MonotonicTimePoint::now();
  const SystemTimePoint s_now = SystemTimePoint::now();
  const ThreadId thread_id = get_thread_id();

  const Map::iterator pos = map_.find(thread_id);
  if (pos != map_.end()) {
    pos->second.update(m_now, s_now, Thread::ThreadStatus_Active, bucket_limit_, nested);
  }

  cleanup(m_now);
}

add_thread()

void OpenDDS::DCPS::ThreadStatusManager::add_thread ( const String &  name )

private

Definition at line 94 of file ThreadStatusManager.cpp.

References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::ThreadStatusManager::Thread::bit_key(), OpenDDS::DCPS::DCPS_debug_level, get_thread_id(), LM_DEBUG, lock_, map_, OpenDDS::DCPS::ThreadStatusManager::Thread::Thread(), OpenDDS::DCPS::to_dds_string(), and update_thread_status().

{
  if (!update_thread_status()) {
    return;
  }

  const ThreadId thread_id = get_thread_id();

  String bit_key = to_dds_string(thread_id);

  if (name.length()) {
    bit_key += " (" + name + ")";
  }

  if (DCPS_debug_level > 4) {
    ACE_DEBUG((LM_DEBUG, "(%P|%t) ThreadStatusManager::add_thread: "
               "adding thread %C\n", bit_key.c_str()));
  }

  ACE_GUARD(ACE_Thread_Mutex, g, lock_);
  map_.insert(std::make_pair(thread_id, Thread(bit_key)));
}

cleanup()

void OpenDDS::DCPS::ThreadStatusManager::cleanup ( const MonotonicTimePoint &  now )

private

Definition at line 199 of file ThreadStatusManager.cpp.

References list_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and thread_status_interval_.

Referenced by active(), finished(), and idle().

{
  const MonotonicTimePoint cutoff = now - 10 * thread_status_interval_;

  while (!list_.empty() && list_.front().last_update() < cutoff) {
    list_.pop_front();
  }
}

finished()

void OpenDDS::DCPS::ThreadStatusManager::finished ( )

private

Definition at line 157 of file ThreadStatusManager.cpp.

References ACE_GUARD, bucket_limit_, cleanup(), get_thread_id(), list_, lock_, map_, OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OpenDDS::DCPS::ThreadStatusManager::Thread::ThreadStatus_Idle, and update_thread_status().

{
  if (!update_thread_status()) {
    return;
  }

  ACE_GUARD(ACE_Thread_Mutex, g, lock_);

  const MonotonicTimePoint m_now = MonotonicTimePoint::now();
  const SystemTimePoint s_now = SystemTimePoint::now();
  const ThreadId thread_id = get_thread_id();

  const Map::iterator pos = map_.find(thread_id);
  if (pos != map_.end()) {
    pos->second.update(m_now, s_now, Thread::ThreadStatus_Idle, bucket_limit_, false);

    list_.push_back(pos->second);
    map_.erase(pos);
  }

  cleanup(m_now);
}

get_thread_id()

ThreadStatusManager::ThreadId OpenDDS::DCPS::ThreadStatusManager::get_thread_id ( void  )

staticprivate

Definition at line 79 of file ThreadStatusManager.cpp.

References ACE_Thread::self(), ACE_OS::thr_gettid(), and ACE_OS::thr_id().

Referenced by active(), add_thread(), finished(), and idle().

{
#if defined (ACE_WIN32)
  return static_cast<unsigned>(ACE_Thread::self());
#else
#  ifdef ACE_HAS_GETTID
  return ACE_OS::thr_gettid();
#  else
  char buffer[32];
  const size_t len = ACE_OS::thr_id(buffer, 32);
  return String(buffer, len);
#  endif
#endif /* ACE_WIN32 */
}

harvest()

void OpenDDS::DCPS::ThreadStatusManager::harvest	(	const MonotonicTimePoint &	start,
		List &	running,
		List &	finished
	)		const

Copy active and idle threads to running and finished threads to finished. Only threads updated after start are considered.

Definition at line 180 of file ThreadStatusManager.cpp.

References ACE_GUARD, list_, lock_, and map_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, lock_);

  for (Map::const_iterator pos = map_.begin(), limit = map_.end(); pos != limit; ++pos) {
    if (pos->second.last_update() > start) {
      running.push_back(pos->second);
    }
  }

  for (List::const_iterator pos = list_.begin(), limit = list_.end(); pos != limit; ++pos) {
    if (pos->last_update() > start) {
      finished.push_back(*pos);
    }
  }
}

idle()

void OpenDDS::DCPS::ThreadStatusManager::idle ( bool  nested = false )

private

Definition at line 137 of file ThreadStatusManager.cpp.

References ACE_GUARD, bucket_limit_, cleanup(), get_thread_id(), lock_, map_, OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OpenDDS::DCPS::ThreadStatusManager::Thread::ThreadStatus_Idle, and update_thread_status().

{
  if (!update_thread_status()) {
    return;
  }

  ACE_GUARD(ACE_Thread_Mutex, g, lock_);

  const MonotonicTimePoint m_now = MonotonicTimePoint::now();
  const SystemTimePoint s_now = SystemTimePoint::now();
  const ThreadId thread_id = get_thread_id();

  const Map::iterator pos = map_.find(thread_id);
  if (pos != map_.end()) {
    pos->second.update(m_now, s_now, Thread::ThreadStatus_Idle, bucket_limit_, nested);
  }

  cleanup(m_now);
}

OPENDDS_LIST()

typedef OpenDDS::DCPS::ThreadStatusManager::OPENDDS_LIST

(

Thread

)

OPENDDS_MAP()

typedef OpenDDS::DCPS::ThreadStatusManager::OPENDDS_MAP	(	ThreadId	,
		Thread
	)

thread_status_interval() [1/2]

void OpenDDS::DCPS::ThreadStatusManager::thread_status_interval ( const TimeDuration &  thread_status_interval )

inline

Definition at line 80 of file ThreadStatusManager.h.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::enable_periodic_tasks(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), OpenDDS::DCPS::Service_Participant::parse_args(), OpenDDS::DCPS::DcpsUpcalls::svc(), OpenDDS::DCPS::ReactorTask::svc(), and OpenDDS::DCPS::QueueTaskBase< DataLink_rch >::svc().

  {
    thread_status_interval_ = thread_status_interval;
    bucket_limit_ = thread_status_interval / static_cast<double>(Thread::bucket_count);
  }

thread_status_interval() [2/2]

const TimeDuration& OpenDDS::DCPS::ThreadStatusManager::thread_status_interval ( ) const

inline

Definition at line 86 of file ThreadStatusManager.h.

  {
    return thread_status_interval_;
  }

update_thread_status()

bool OpenDDS::DCPS::ThreadStatusManager::update_thread_status ( ) const

inline

Definition at line 91 of file ThreadStatusManager.h.

References OpenDDS::DCPS::TimeDuration::zero_value.

Referenced by active(), add_thread(), OpenDDS::RTPS::Spdp::SpdpTransport::enable_periodic_tasks(), finished(), idle(), OpenDDS::DCPS::DcpsUpcalls::svc(), OpenDDS::DCPS::ReactorTask::svc(), and OpenDDS::DCPS::QueueTaskBase< DataLink_rch >::svc().

  {
    return thread_status_interval_ > TimeDuration::zero_value;
  }

Member Data Documentation

bucket_limit_

TimeDuration OpenDDS::DCPS::ThreadStatusManager::bucket_limit_

private

Definition at line 173 of file ThreadStatusManager.h.

Referenced by active(), finished(), and idle().

list_

List OpenDDS::DCPS::ThreadStatusManager::list_

private

Definition at line 175 of file ThreadStatusManager.h.

Referenced by cleanup(), finished(), and harvest().

lock_

ACE_Thread_Mutex OpenDDS::DCPS::ThreadStatusManager::lock_

mutableprivate

Definition at line 177 of file ThreadStatusManager.h.

Referenced by active(), add_thread(), finished(), harvest(), and idle().

map_

Map OpenDDS::DCPS::ThreadStatusManager::map_

private

Definition at line 174 of file ThreadStatusManager.h.

Referenced by active(), add_thread(), finished(), harvest(), and idle().

thread_status_interval_

TimeDuration OpenDDS::DCPS::ThreadStatusManager::thread_status_interval_

private

Definition at line 172 of file ThreadStatusManager.h.

Referenced by cleanup().

---

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

• ThreadStatusManager.h
• ThreadStatusManager.cpp