Function wait_for_thread_status_interval

tests/DCPS/ThreadStatusManager/main.cpp:109–121

};

bool wait_for_thread_status_interval(const TimeDuration& expected)
{
  const MonotonicTimePoint deadline = MonotonicTimePoint::now() + TimeDuration(config_wait_time);
  while (MonotonicTimePoint::now() < deadline) {
    if (TheServiceParticipant->get_thread_status_manager().thread_status_interval() == expected) {
      return true;
    }
    ACE_OS::sleep(config_poll_interval);
  }
  ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: wait_for_thread_status_interval - timed out waiting for interval to become {%d sec, %u nsec}\n",
    expected.value().sec(), expected.value().usec() * 1000u));
  return false;
}

bool read_status(DDS::WaitSet_var ws, InternalThreadBuiltinTopicDataDataReader_var dr, MonotonicTimePoint& timestamp,
                 TestThread& task, TestThread::TestThreadState new_state, const char* status,