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

100.0% Lines (35 / 35, 1 excl) 25.0% Branches (8 / 32) 100.0% Functions (92 / 92)

[ ] prev/next file n p prev/next uncovered line

reactor_socket_service.hpp

f(x) Functions (92)

Function Calls Lines Branches Blocks

Line	Branch	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		2145x	explicit reactor_socket_service(capy::execution_context& ctx)
53		2145x	: state_(
54	4/16 ✓ Branch 0 taken 1283 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 758 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 104 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	2146x	std::make_unique<state_type>(
55	4/16 ✓ Branch 0 taken 1284 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 758 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 104 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	2145x	ctx.template use_service<Scheduler>()))
56		2145x	{
57		2147x	}
58
59			public:
60		2145x	~reactor_socket_service() override = default;
61
62		2146x	void shutdown() override
63			{
64		4292x	state_->pool_.shutdown(
65		3951x	[this](Impl* impl)
66			{
67		1805x	static_cast<Derived*>(this)->pre_shutdown(impl);
68		1805x	impl->close_socket();
69		1805x	});
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		2146x	}
77
78		41079x	io_object::implementation* construct() override
79			{
80		41079x	return state_->pool_.acquire(static_cast<Derived&>(*this));
81			}
82
83		41083x	void destroy(io_object::implementation* impl) override
84			{
85		41083x	auto* typed = static_cast<Impl*>(impl);
86		41083x	static_cast<Derived*>(this)->pre_destroy(typed);
87		41083x	typed->close_socket();
88		41083x	release(typed);
89		41083x	}
90
91		72211x	void close(io_object::handle& h) override
92			{
93		72211x	static_cast<Impl*>(h.get())->close_socket();
94		72211x	}
95
96		1446119x	Scheduler& scheduler() const noexcept
97			{
98		1446119x	return state_->sched_;
99			}
100
101		247522x	void post(scheduler_op* op)
102			{
103		247522x	state_->sched_.post(op);
104		247522x	}
105
106		105689x	void work_started() noexcept
107			{
108		105689x	state_->sched_.work_started();
109		105689x	}
110
111			protected:
112			// Override in derived to add pre-close logic. No backend currently needs
113			// it; the hooks exist so a trait can run fd-level teardown before close.
114		38x	void pre_shutdown(Impl*) noexcept {
115		−	} // LCOV_EXCL_LINE optional CRTP hook; no backend overrides it today
116		1125x	void pre_destroy(Impl*) noexcept {}
117
118			std::unique_ptr<state_type> state_;
119
120			private:
121			reactor_socket_service(reactor_socket_service const&) = delete;
122			reactor_socket_service& operator=(reactor_socket_service const&) = delete;
123			};
124
125			} // namespace boost::corosio::detail
126
127			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
128