Method schedule

dds/DCPS/ReactorTask.cpp:552–570

const ReactorWrapper::TimerId ReactorWrapper::InvalidTimerId = -1;

ReactorWrapper::TimerId ReactorWrapper::schedule(RcEventHandler& handler,
                                                 const void* arg,
                                                 const TimeDuration& delay,
                                                 const TimeDuration& interval)
{
#if OPENDDS_CONFIG_BOOTTIME_TIMERS
  const ACE_Time_Value earliest_before = timer_heap_.is_empty() ? ACE_Time_Value::max_time : timer_heap_.earliest_time();
  const TimerId tid = timer_heap_.schedule(&handler, arg, MonotonicTimePoint::now().value() + delay.value(), interval.value());
  const ACE_Time_Value earliest_after = timer_heap_.earliest_time();
  if (earliest_after < earliest_before) {
    if (!arm()) {
      return InvalidTimerId;
    }
  }
  return tid;
#else
  return reactor_->schedule_timer(&handler, arg, delay.value(), interval.value());
#endif
}

void ReactorWrapper::cancel(TimerId timer)
{