| 19 | } |
| 20 | |
| 21 | OpenDDS::DCPS::MonotonicTimePoint TimingChecker::wait_timeout() |
| 22 | { |
| 23 | OpenDDS::DCPS::ThreadStatusManager tsm; |
| 24 | ACE_Guard<ACE_Thread_Mutex> guard(mutex_); |
| 25 | while (timeout_ == OpenDDS::DCPS::MonotonicTimePoint::zero_value) { |
| 26 | cv_.wait(tsm); |
| 27 | } |
| 28 | return timeout_; |
| 29 | } |
| 30 | |
| 31 | bool TimingChecker::check_timing(const OpenDDS::DCPS::TimeDuration& epsilon, const OpenDDS::DCPS::TimeDuration& requested) |
| 32 | { |