Method thread_status_task

dds/DCPS/RTPS/Spdp.cpp:4558–4590

#ifndef DDS_HAS_MINIMUM_BIT
void Spdp::SpdpTransport::thread_status_task()
{
  DCPS::RcHandle<Spdp> outer = outer_.lock();
  if (!outer) return;

  if (DCPS::DCPS_debug_level > 4) {
    ACE_DEBUG((LM_DEBUG,
               "(%P|%t) Spdp::SpdpTransport::thread_status_task(): Updating internal thread status BIT.\n"));
  }

  ACE_GUARD(ACE_Thread_Mutex, g, outer->lock_);

  typedef DCPS::ThreadStatusManager::List List;
  List running;
  List removed;
  TheServiceParticipant->get_thread_status_manager().harvest(last_thread_status_harvest_, running, removed);
  const MonotonicTimePoint now = MonotonicTimePoint::now();
  last_thread_status_harvest_ = now;
  for (List::const_iterator i = removed.begin(); i != removed.end(); ++i) {
    DCPS::InternalThreadBuiltinTopicData data;
    data.thread_id = i->bit_key().c_str();
    outer->bit_subscriber_->remove_thread_status(data);
  }
  for (List::const_iterator i = running.begin(); i != running.end(); ++i) {
    DCPS::InternalThreadBuiltinTopicData data;
    data.thread_id = i->bit_key().c_str();
    data.utilization = i->utilization(now);
    data.monotonic_timestamp = i->last_update().to_idl_struct();
    data.detail1 = i->detail1();
    data.detail2 = i->detail2();
    outer->bit_subscriber_->add_thread_status(data, DDS::NEW_VIEW_STATE, i->timestamp());
  }
}
#endif

#if OPENDDS_CONFIG_SECURITY