src/corosio/src/detail/timer_service.hpp
100.0% Lines (5/5)
100.0% Functions (4/4)
50.0% Branches (1/2)
src/corosio/src/detail/timer_service.hpp
| Line | Branch | Hits | Source Code |
|---|---|---|---|
| 1 | // | ||
| 2 | // Copyright (c) 2025 Vinnie Falco (vinnie.falco@gmail.com) | ||
| 3 | // | ||
| 4 | // Distributed under the Boost Software License, Version 1.0. (See accompanying | ||
| 5 | // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | ||
| 6 | // | ||
| 7 | // Official repository: https://github.com/cppalliance/corosio | ||
| 8 | // | ||
| 9 | |||
| 10 | #ifndef BOOST_COROSIO_SRC_DETAIL_TIMER_SERVICE_HPP | ||
| 11 | #define BOOST_COROSIO_SRC_DETAIL_TIMER_SERVICE_HPP | ||
| 12 | |||
| 13 | #include <boost/corosio/timer.hpp> | ||
| 14 | #include <boost/capy/ex/execution_context.hpp> | ||
| 15 | |||
| 16 | #include <chrono> | ||
| 17 | #include <cstddef> | ||
| 18 | |||
| 19 | namespace boost::corosio::detail { | ||
| 20 | |||
| 21 | struct scheduler; | ||
| 22 | |||
| 23 | class timer_service | ||
| 24 | : public capy::execution_context::service | ||
| 25 | , public io_object::io_service | ||
| 26 | { | ||
| 27 | public: | ||
| 28 | using clock_type = std::chrono::steady_clock; | ||
| 29 | using time_point = clock_type::time_point; | ||
| 30 | |||
| 31 | // Nested callback type - context + function pointer | ||
| 32 | class callback | ||
| 33 | { | ||
| 34 | void* ctx_ = nullptr; | ||
| 35 | void(*fn_)(void*) = nullptr; | ||
| 36 | |||
| 37 | public: | ||
| 38 | 336 | callback() = default; | |
| 39 | 336 | callback(void* ctx, void(*fn)(void*)) noexcept | |
| 40 | 336 | : ctx_(ctx), fn_(fn) {} | |
| 41 | |||
| 42 | explicit operator bool() const noexcept { return fn_ != nullptr; } | ||
| 43 |
1/2✓ Branch 0 taken 8566 times.
✗ Branch 1 not taken.
|
8566 | void operator()() const { if (fn_) fn_(ctx_); } |
| 44 | }; | ||
| 45 | |||
| 46 | // Query methods for scheduler | ||
| 47 | virtual bool empty() const noexcept = 0; | ||
| 48 | virtual time_point nearest_expiry() const noexcept = 0; | ||
| 49 | |||
| 50 | // Process expired timers - scheduler calls this after wait | ||
| 51 | virtual std::size_t process_expired() = 0; | ||
| 52 | |||
| 53 | // Callback for when earliest timer changes | ||
| 54 | virtual void set_on_earliest_changed(callback cb) = 0; | ||
| 55 | |||
| 56 | protected: | ||
| 57 | 336 | timer_service() = default; | |
| 58 | }; | ||
| 59 | |||
| 60 | // Get or create the timer service for the given context | ||
| 61 | timer_service& | ||
| 62 | get_timer_service( | ||
| 63 | capy::execution_context& ctx, scheduler& sched); | ||
| 64 | |||
| 65 | } // namespace boost::corosio::detail | ||
| 66 | |||
| 67 | #endif | ||
| 68 |