| 11 | using concurrencpp::details::timer_state_base; |
| 12 | |
| 13 | timer_state_base::timer_state_base(size_t due_time, |
| 14 | size_t frequency, |
| 15 | std::shared_ptr<concurrencpp::executor> executor, |
| 16 | std::weak_ptr<concurrencpp::timer_queue> timer_queue, |
| 17 | bool is_oneshot) noexcept : |
| 18 | m_timer_queue(std::move(timer_queue)), |
| 19 | m_executor(std::move(executor)), m_due_time(due_time), m_frequency(frequency), m_deadline(make_deadline(milliseconds(due_time))), |
| 20 | m_cancelled(false), m_is_oneshot(is_oneshot) { |
| 21 | assert(static_cast<bool>(m_executor)); |
| 22 | } |
| 23 | |
| 24 | void timer_state_base::fire() { |
| 25 | const auto frequency = m_frequency.load(std::memory_order_relaxed); |
nothing calls this directly
no test coverage detected