2
3
6
7
14#include <restinio/asio_include.hpp>
16#include <restinio/utils/suppress_exceptions.hpp>
18#include <restinio/timer_common.hpp>
19#include <restinio/compiler_features.hpp>
29class asio_timer_manager_t
final
30 :
public std::enable_shared_from_this< asio_timer_manager_t >
34 asio_ns::io_context & io_context,
35 std::chrono::steady_clock::duration check_period )
41 class timer_guard_t
final
45 asio_ns::io_context & io_context,
46 std::chrono::steady_clock::duration check_period )
noexcept
55 m_operation_timer.expires_after( m_check_period );
57 [ weak_handle = std::move( weak_handle ) ](
const auto & ec ){
60 if(
auto h = weak_handle.lock() )
62 h->check_timeout( h );
70
71
72
90 return timer_guard_t{ m_io_context, m_check_period };
96 void stop()
const noexcept {}
99 struct factory_t
final
102 const std::chrono::steady_clock::duration
106 factory_t( std::chrono::steady_clock::duration check_period )
noexcept
112 create( asio_ns::io_context & io_context )
const
114 return std::make_shared< asio_timer_manager_t >( io_context, m_check_period );
asio_ns::steady_timer m_operation_timer
timer_guard_t(asio_ns::io_context &io_context, std::chrono::steady_clock::duration check_period) noexcept
const std::chrono::steady_clock::duration m_check_period
void cancel() noexcept
Cancel timeout guard if any.
void schedule(tcp_connection_ctx_weak_handle_t weak_handle)
Schedule timeouts check invocation.
asio_timer_manager_t(asio_ns::io_context &io_context, std::chrono::steady_clock::duration check_period)
asio_ns::io_context & m_io_context
An instanse of io_context to work with.
timer_guard_t create_timer_guard() const
Create guard for connection.
const std::chrono::steady_clock::duration m_check_period
Check period for timer events.
void stop() const noexcept
void start() const noexcept
std::weak_ptr< tcp_connection_ctx_base_t > tcp_connection_ctx_weak_handle_t
Alias for http connection weak handle.
auto create(asio_ns::io_context &io_context) const
Create an instance of timer manager.
factory_t(std::chrono::steady_clock::duration check_period) noexcept
const std::chrono::steady_clock::duration m_check_period
Check period for timer events.