include/boost/corosio/native/detail/reactor/reactor_socket_service.hpp

100.0% Lines (35 / 35, 1 excl) 100.0% Functions (93 / 93)

[ ] prev/next file

reactor_socket_service.hpp

f(x) Functions (93)

Function Calls Lines Blocks

Line	Hits	Source Code
1		//
2		// Copyright (c) 2026 Steve Gerbino
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_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
11		#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
12
13		#include <boost/corosio/io/io_object.hpp>
14		#include <boost/corosio/detail/object_ref.hpp>
15		#include <boost/corosio/detail/scheduler_op.hpp>
16		#include <boost/corosio/native/detail/reactor/reactor_service_state.hpp>
17		#include <boost/capy/ex/execution_context.hpp>
18
19		#include <memory>
20
21		namespace boost::corosio::detail {
22
23		/** CRTP base for reactor-backed socket/datagram service implementations.
24
25		Provides the shared construct/destroy/shutdown/close/post/work
26		logic that is identical across all reactor backends and socket
27		types. Derived classes add only protocol-specific open/bind.
28
29		@tparam Derived The concrete service type (CRTP).
30		@tparam ServiceBase The abstract service base (tcp_service
31		or udp_service).
32		@tparam Scheduler The backend's scheduler type.
33		@tparam Impl The backend's socket/datagram impl type.
34		*/
35		template<class Derived, class ServiceBase, class Scheduler, class Impl>
36		class reactor_socket_service : public ServiceBase
37		{
38		friend Derived;
39
40		// The intermediate CRTP templates below (not Impl itself) are what
41		// actually reach into state_->pool_ from retire() -- see
42		// reactor_socket_finals.hpp.
43		template<class, class, class, class, class, class>
44		friend class reactor_stream_socket_impl;
45		template<class, class, class, class, class, class>
46		friend class reactor_dgram_socket_impl;
47
48		using state_type = reactor_service_state<Scheduler, Impl>;
49
50		protected:
51		// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
52	1407x	explicit reactor_socket_service(capy::execution_context& ctx)
53	1407x	: state_(
54		std::make_unique<state_type>(
55	1407x	ctx.template use_service<Scheduler>()))
56		{
57	1407x	}
58
59		public:
60	1407x	~reactor_socket_service() override = default;
61
62	1407x	void shutdown() override
63		{
64	1407x	state_->pool_.shutdown(
65	1407x	[this](Impl* impl)
66		{
67	39x	static_cast<Derived*>(this)->pre_shutdown(impl);
68	39x	impl->close_socket();
69		});
70
71		// Queued ops still hold references (their own object_ref copy);
72		// the scheduler shuts down after us and drains completed_ops_,
73		// each op's destroy() releasing its reference. Shutting-down
74		// mode makes that final release() delete instead of recycle,
75		// so every impl stays alive until its ops are gone, then frees.
76	1407x	}
77
78	16052x	io_object::implementation* construct() override
79		{
80	16052x	return state_->pool_.acquire(static_cast<Derived&>(*this));
81		}
82
83	16047x	void destroy(io_object::implementation* impl) override
84		{
85	16047x	auto* typed = static_cast<Impl*>(impl);
86	16047x	static_cast<Derived*>(this)->pre_destroy(typed);
87	16047x	typed->close_socket();
88	16047x	release(typed);
89	16047x	}
90
91	26637x	void close(io_object::handle& h) override
92		{
93	26637x	static_cast<Impl*>(h.get())->close_socket();
94	26637x	}
95
96	480728x	Scheduler& scheduler() const noexcept
97		{
98	480728x	return state_->sched_;
99		}
100
101	92173x	void post(scheduler_op* op)
102		{
103	92173x	state_->sched_.post(op);
104	92173x	}
105
106	6140x	void work_started() noexcept
107		{
108	6140x	state_->sched_.work_started();
109	6140x	}
110
111	501x	void work_finished() noexcept
112		{
113	501x	state_->sched_.work_finished();
114	501x	}
115
116		protected:
117		// Override in derived to add pre-close logic. No backend currently needs
118		// it; the hooks exist so a trait can run fd-level teardown before close.
119	157x	void pre_shutdown(Impl*) noexcept {
120	−	} // LCOV_EXCL_LINE optional CRTP hook; no backend overrides it today
121	1196x	void pre_destroy(Impl*) noexcept {}
122
123		std::unique_ptr<state_type> state_;
124
125		private:
126		reactor_socket_service(reactor_socket_service const&) = delete;
127		reactor_socket_service& operator=(reactor_socket_service const&) = delete;
128		};
129
130		} // namespace boost::corosio::detail
131
132		#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
133