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

89.2% Lines (124/139) 97.8% List of functions (88/90) 48.3% Branches (170/352)

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

reactor_service_finals.hpp

f(x) Functions (90)

Function Calls Lines Branches Blocks

Line	Branch	Hits	Source Code
1			//
2			// Copyright (c) 2026 Michael Vandeberg
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_SERVICE_FINALS_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SERVICE_FINALS_HPP
12
13			/* Parameterized service implementation bases for reactor backends.
14
15			One template per protocol (TCP, local stream, UDP, local datagram,
16			acceptor). Named per-backend classes (e.g. epoll_tcp_service) inherit
17			from these as final. The Derived parameter (CRTP) flows through to
18			reactor_socket_service so construct() creates the correct named type.
19			*/
20
21			#include <boost/corosio/native/detail/reactor/reactor_socket_finals.hpp>
22			#include <boost/corosio/native/detail/reactor/reactor_socket_service.hpp>
23			#include <boost/corosio/native/detail/reactor/reactor_acceptor_service.hpp>
24			#include <boost/corosio/detail/tcp_service.hpp>
25			#include <boost/corosio/detail/tcp_acceptor_service.hpp>
26			#include <boost/corosio/detail/udp_service.hpp>
27			#include <boost/corosio/detail/local_stream_service.hpp>
28			#include <boost/corosio/detail/local_stream_acceptor_service.hpp>
29			#include <boost/corosio/detail/local_datagram_service.hpp>
30
31			#include <boost/corosio/native/detail/endpoint_convert.hpp>
32			#include <boost/corosio/native/detail/make_err.hpp>
33			#include <boost/corosio/native/detail/validate_fd.hpp>
34
35			#include <system_error>
36			#include <type_traits>
37
38			#include <sys/socket.h>
39			#include <unistd.h>
40
41			namespace boost::corosio::detail {
42
43			// ============================================================
44			// Shared socket creation helpers
45			// ============================================================
46
47			template<class Traits, class SocketFinal>
48			std::error_code
49		7950x	do_open_socket(
50			SocketFinal* socket_impl,
51			int family, int type, int protocol,
52			bool is_ip) noexcept
53			{
54		7950x	socket_impl->close_socket();
55
56		7950x	int fd = Traits::create_socket(family, type, protocol);
57	8/16 ✓ Branch 0 taken 1717 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 110 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 22 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 33 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 5889 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 121 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 23 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 35 times. ✗ Branch 15 not taken.	7950x	if (fd < 0)
58		✗	return make_err(errno);
59
60	8/16 ✓ Branch 0 taken 1717 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 110 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 22 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 33 times. ✓ Branch 8 taken 5889 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 121 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✓ Branch 13 taken 23 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 35 times.	7950x	std::error_code ec = is_ip
61		7837x	? Traits::configure_ip_socket(fd, family)
62		113x	: Traits::configure_local_socket(fd);
63
64	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 1717 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 110 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 22 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 33 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 5889 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 121 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 23 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 35 times.	7950x	if (ec)
65			{
66		✗	::close(fd);
67		✗	return ec;
68			}
69
70	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 1717 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 110 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 22 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 33 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 5889 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 121 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 23 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 35 times.	7950x	if (auto ec = socket_impl->init_and_register(fd))
71			{
72		✗	::close(fd);
73		✗	return ec;
74			}
75		7950x	return {};
76		7950x	}
77
78			template<class Traits, class SocketFinal>
79			std::error_code
80		254x	do_assign_fd(
81			SocketFinal* socket_impl,
82			int fd,
83			int expected_type,
84			bool is_ip) noexcept
85			{
86			// fd >= 0 guard: an unset socket_impl reports native_handle() == -1,
87			// and a caller-supplied -1 must fail as a bad fd, not a self-assign.
88	28/32 ✓ Branch 0 taken 7 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 6 times. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 7 times. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 6 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 54 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 54 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 51 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 51 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 7 times. ✓ Branch 17 taken 2 times. ✓ Branch 18 taken 6 times. ✓ Branch 19 taken 1 time. ✓ Branch 20 taken 7 times. ✓ Branch 21 taken 2 times. ✓ Branch 22 taken 6 times. ✓ Branch 23 taken 1 time. ✓ Branch 24 taken 56 times. ✓ Branch 25 taken 1 time. ✓ Branch 26 taken 56 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 53 times. ✓ Branch 29 taken 1 time. ✓ Branch 30 taken 53 times. ✗ Branch 31 not taken.	254x	if (fd >= 0 && fd == socket_impl->native_handle())
89		4x	return std::make_error_code(std::errc::invalid_argument);
90
91			// Validate before touching the held socket: a failed assign must
92			// leave the object unchanged and the caller owning the fd.
93	16/16 ✓ Branch 0 taken 5 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 5 times. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 4 times. ✓ Branch 5 taken 51 times. ✓ Branch 6 taken 3 times. ✓ Branch 7 taken 49 times. ✓ Branch 8 taken 5 times. ✓ Branch 9 taken 3 times. ✓ Branch 10 taken 5 times. ✓ Branch 11 taken 3 times. ✓ Branch 12 taken 4 times. ✓ Branch 13 taken 53 times. ✓ Branch 14 taken 3 times. ✓ Branch 15 taken 51 times.	250x	if (auto ec = validate_socket_fd(fd, expected_type, is_ip))
94		34x	return ec;
95
96			// Adopt-only: do not mutate the caller's fd flags. Callers
97			// pass fds they have already configured (e.g., from socketpair
98			// or SCM_RIGHTS). Only non-mutating validation is performed.
99	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 51 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 49 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 3 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 3 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 53 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 51 times.	216x	if (auto ec = Traits::validate_assigned_fd(fd))
100		✗	return ec;
101
102		216x	socket_impl->close_socket();
103
104	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 51 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 49 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 3 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 3 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 53 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 51 times.	216x	if (auto ec = socket_impl->init_and_register(fd))
105		✗	return ec;
106
107			// Best-effort: refresh endpoint caches.
108			using endpoint_type = std::remove_cvref_t<
109			decltype(socket_impl->local_endpoint())>;
110
111		216x	endpoint_type local_ep{};
112		216x	sockaddr_storage local_storage{};
113		216x	socklen_t local_len = sizeof(local_storage);
114	16/32 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 times. ✓ Branch 8 taken 51 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 51 times. ✓ Branch 12 taken 49 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 49 times. ✓ Branch 16 taken 3 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 3 times. ✓ Branch 20 taken 3 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 3 times. ✓ Branch 24 taken 53 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 53 times. ✓ Branch 28 taken 51 times. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✓ Branch 31 taken 51 times.	216x	if (::getsockname(
115		216x	fd, reinterpret_cast<sockaddr*>(&local_storage), &local_len) == 0)
116		216x	local_ep = from_sockaddr_as(local_storage, local_len, endpoint_type{});
117
118		216x	endpoint_type remote_ep{};
119		216x	sockaddr_storage peer_storage{};
120		216x	socklen_t peer_len = sizeof(peer_storage);
121	16/32 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 51 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 51 times. ✓ Branch 12 taken 49 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 49 times. ✓ Branch 16 taken 3 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 3 times. ✓ Branch 20 taken 3 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 3 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 53 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 53 times. ✓ Branch 28 taken 51 times. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✓ Branch 31 taken 51 times.	216x	if (::getpeername(
122		216x	fd, reinterpret_cast<sockaddr*>(&peer_storage), &peer_len) == 0)
123		210x	remote_ep = from_sockaddr_as(peer_storage, peer_len, endpoint_type{});
124
125		216x	socket_impl->set_endpoints(local_ep, remote_ep);
126
127		216x	return {};
128		254x	}
129
130			template<class Traits, class AccFinal>
131			std::error_code
132		2026x	do_open_acceptor(
133			AccFinal* acc_impl,
134			int family, int type, int protocol,
135			bool is_ip) noexcept
136			{
137		2026x	acc_impl->close_socket();
138
139		2026x	int fd = Traits::create_socket(family, type, protocol);
140	4/8 ✓ Branch 0 taken 173 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 34 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1783 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 36 times. ✗ Branch 7 not taken.	2026x	if (fd < 0)
141		✗	return make_err(errno);
142
143	4/8 ✓ Branch 0 taken 173 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 34 times. ✓ Branch 4 taken 1783 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 36 times.	2026x	std::error_code ec = is_ip
144		1956x	? Traits::configure_ip_acceptor(fd, family)
145		70x	: Traits::configure_local_socket(fd);
146
147	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 173 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 34 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 1783 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 36 times.	2026x	if (ec)
148			{
149		✗	::close(fd);
150		✗	return ec;
151			}
152
153		2026x	acc_impl->init_acceptor_fd(fd);
154		2026x	return {};
155		2026x	}
156
157			// Acceptor twin of do_assign_fd: always SOCK_STREAM, and refreshes
158			// only the local endpoint because listeners have no peer. Listen
159			// state is not verified; accept() surfaces the error naturally if
160			// the descriptor is not listening.
161			template<class Traits, class AccFinal>
162			std::error_code
163		24x	do_assign_acceptor_fd(AccFinal* acc_impl, int fd, bool is_ip) noexcept
164			{
165	12/16 ✓ Branch 0 taken 8 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 7 times. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 8 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 7 times. ✓ Branch 11 taken 1 time. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 3 times. ✗ Branch 15 not taken.	24x	if (fd >= 0 && fd == acc_impl->native_handle())
166		2x	return std::make_error_code(std::errc::invalid_argument);
167
168	6/8 ✓ Branch 0 taken 3 times. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 3 times. ✓ Branch 5 taken 5 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 times.	22x	if (auto ec = validate_socket_fd(fd, SOCK_STREAM, is_ip))
169		6x	return ec;
170
171	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 5 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 times.	16x	if (auto ec = Traits::validate_assigned_fd(fd))
172		✗	return ec;
173
174		16x	acc_impl->close_socket();
175
176	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 5 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 times.	16x	if (auto ec = acc_impl->init_and_register(fd))
177		✗	return ec;
178
179			using endpoint_type = std::remove_cvref_t<
180			decltype(acc_impl->local_endpoint())>;
181
182		16x	endpoint_type local_ep{};
183		16x	sockaddr_storage local_storage{};
184		16x	socklen_t local_len = sizeof(local_storage);
185	8/16 ✓ Branch 0 taken 5 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 5 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 times. ✓ Branch 8 taken 5 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 5 times. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 3 times.	16x	if (::getsockname(
186		16x	fd, reinterpret_cast<sockaddr*>(&local_storage), &local_len) == 0)
187		16x	local_ep = from_sockaddr_as(local_storage, local_len, endpoint_type{});
188
189		16x	acc_impl->set_local_endpoint(local_ep);
190
191		16x	return {};
192		24x	}
193
194			// ============================================================
195			// TCP service
196			// ============================================================
197
198			template<class Derived, class Traits, class SocketFinal>
199			class reactor_tcp_service_impl
200			: public reactor_socket_service<
201			Derived,
202			tcp_service,
203			typename Traits::scheduler_type,
204			SocketFinal>
205			{
206			using base_service = reactor_socket_service<
207			Derived, tcp_service,
208			typename Traits::scheduler_type, SocketFinal>;
209			friend Derived;
210			friend base_service;
211
212		1944x	explicit reactor_tcp_service_impl(capy::execution_context& ctx)
213		1944x	: base_service(ctx) {}
214
215			public:
216			static constexpr bool needs_write_notification =
217			Traits::needs_write_notification;
218
219		7606x	std::error_code open_socket(
220			tcp_socket::implementation& impl,
221			int family, int type, int protocol) override
222			{
223		7606x	return do_open_socket<Traits>(
224		7606x	static_cast<SocketFinal*>(&impl),
225		7606x	family, type, protocol, true);
226			}
227
228		18x	std::error_code assign_socket(
229			tcp_socket::implementation& impl, native_handle_type fd) override
230			{
231		18x	return do_assign_fd<Traits>(
232		18x	static_cast<SocketFinal*>(&impl), fd, SOCK_STREAM, true);
233			}
234
235		14x	std::error_code bind_socket(
236			tcp_socket::implementation& impl, endpoint ep) override
237			{
238		14x	return static_cast<SocketFinal*>(&impl)->do_bind(ep);
239			}
240
241		✗	void pre_shutdown(SocketFinal* impl) noexcept
242			{
243		✗	impl->hook_.pre_shutdown(impl->native_handle());
244		✗	}
245
246		23126x	void pre_destroy(SocketFinal* impl) noexcept
247			{
248		23126x	impl->hook_.pre_destroy(impl->native_handle());
249		23126x	}
250			};
251
252			// ============================================================
253			// Local stream service
254			// ============================================================
255
256			template<class Derived, class Traits, class SocketFinal>
257			class reactor_local_stream_service_impl
258			: public reactor_socket_service<
259			Derived,
260			local_stream_service,
261			typename Traits::scheduler_type,
262			SocketFinal>
263			{
264			using base_service = reactor_socket_service<
265			Derived, local_stream_service,
266			typename Traits::scheduler_type, SocketFinal>;
267			friend Derived;
268			friend base_service;
269
270		1944x	explicit reactor_local_stream_service_impl(capy::execution_context& ctx)
271		1944x	: base_service(ctx) {}
272
273			public:
274			static constexpr bool needs_write_notification =
275			Traits::needs_write_notification;
276
277		45x	std::error_code open_socket(
278			local_stream_socket::implementation& impl,
279			int family, int type, int protocol) override
280			{
281		45x	return do_open_socket<Traits>(
282		45x	static_cast<SocketFinal*>(&impl),
283		45x	family, type, protocol, false);
284			}
285
286		112x	std::error_code assign_socket(
287			local_stream_socket::implementation& impl,
288			native_handle_type fd) override
289			{
290		112x	return do_assign_fd<Traits>(
291		112x	static_cast<SocketFinal*>(&impl), fd, SOCK_STREAM, false);
292			}
293			};
294
295			// ============================================================
296			// UDP service
297			// ============================================================
298
299			template<class Derived, class Traits, class SocketFinal>
300			class reactor_udp_service_impl
301			: public reactor_socket_service<
302			Derived,
303			udp_service,
304			typename Traits::scheduler_type,
305			SocketFinal>
306			{
307			using base_service = reactor_socket_service<
308			Derived, udp_service,
309			typename Traits::scheduler_type, SocketFinal>;
310			friend Derived;
311			friend base_service;
312
313		1944x	explicit reactor_udp_service_impl(capy::execution_context& ctx)
314		1944x	: base_service(ctx) {}
315
316			public:
317			static constexpr bool needs_write_notification =
318			Traits::needs_write_notification;
319
320		231x	std::error_code open_datagram_socket(
321			udp_socket::implementation& impl,
322			int family, int type, int protocol) override
323			{
324		231x	return do_open_socket<Traits>(
325		231x	static_cast<SocketFinal*>(&impl),
326		231x	family, type, protocol, true);
327			}
328
329		18x	std::error_code assign_socket(
330			udp_socket::implementation& impl, native_handle_type fd) override
331			{
332		18x	return do_assign_fd<Traits>(
333		18x	static_cast<SocketFinal*>(&impl), fd, SOCK_DGRAM, true);
334			}
335
336		137x	std::error_code bind_datagram(
337			udp_socket::implementation& impl, endpoint ep) override
338			{
339		137x	return static_cast<SocketFinal*>(&impl)->do_bind(ep);
340			}
341			};
342
343			// ============================================================
344			// Local datagram service
345			// ============================================================
346
347			template<class Derived, class Traits, class SocketFinal>
348			class reactor_local_dgram_service_impl
349			: public reactor_socket_service<
350			Derived,
351			local_datagram_service,
352			typename Traits::scheduler_type,
353			SocketFinal>
354			{
355			using base_service = reactor_socket_service<
356			Derived, local_datagram_service,
357			typename Traits::scheduler_type, SocketFinal>;
358			friend Derived;
359			friend base_service;
360
361		1944x	explicit reactor_local_dgram_service_impl(capy::execution_context& ctx)
362		1944x	: base_service(ctx) {}
363
364			public:
365			static constexpr bool needs_write_notification =
366			Traits::needs_write_notification;
367
368		68x	std::error_code open_socket(
369			local_datagram_socket::implementation& impl,
370			int family, int type, int protocol) override
371			{
372		68x	return do_open_socket<Traits>(
373		68x	static_cast<SocketFinal*>(&impl),
374		68x	family, type, protocol, false);
375			}
376
377		106x	std::error_code assign_socket(
378			local_datagram_socket::implementation& impl,
379			native_handle_type fd) override
380			{
381		106x	return do_assign_fd<Traits>(
382		106x	static_cast<SocketFinal*>(&impl), fd, SOCK_DGRAM, false);
383			}
384
385		48x	std::error_code bind_socket(
386			local_datagram_socket::implementation& impl,
387			corosio::local_endpoint ep) override
388			{
389		48x	return static_cast<SocketFinal*>(&impl)->do_bind(ep);
390			}
391			};
392
393			// ============================================================
394			// Acceptor service
395			// ============================================================
396
397			template<class Derived, class Traits, class ServiceBase, class AccFinal,
398			class StreamServiceFinal, class Endpoint>
399			class reactor_acceptor_service_impl
400			: public reactor_acceptor_service<
401			Derived,
402			ServiceBase,
403			typename Traits::scheduler_type,
404			AccFinal,
405			StreamServiceFinal>
406			{
407			using base_service = reactor_acceptor_service<
408			Derived,
409			ServiceBase,
410			typename Traits::scheduler_type,
411			AccFinal,
412			StreamServiceFinal>;
413			friend Derived;
414			friend base_service;
415
416		3888x	explicit reactor_acceptor_service_impl(capy::execution_context& ctx)
417		3888x	: base_service(ctx)
418		3888x	{
419			// Look up the concrete stream service directly by its type.
420		3888x	this->stream_svc_ =
421		3888x	this->ctx_.template find_service<StreamServiceFinal>();
422		3888x	}
423
424			public:
425		2026x	std::error_code open_acceptor_socket(
426			typename AccFinal::impl_base_type& impl,
427			int family, int type, int protocol) override
428			{
429		2026x	return do_open_acceptor<Traits>(
430		2026x	static_cast<AccFinal*>(&impl),
431		2026x	family, type, protocol,
432			std::is_same_v<Endpoint, endpoint>);
433			}
434
435		24x	std::error_code assign_socket(
436			typename AccFinal::impl_base_type& impl,
437			native_handle_type fd) override
438			{
439		24x	return do_assign_acceptor_fd<Traits>(
440		24x	static_cast<AccFinal*>(&impl), fd,
441			std::is_same_v<Endpoint, endpoint>);
442			}
443
444		2008x	std::error_code bind_acceptor(
445			typename AccFinal::impl_base_type& impl,
446			Endpoint ep) override
447			{
448		2008x	return static_cast<AccFinal*>(&impl)->do_bind(ep);
449			}
450
451		1963x	std::error_code listen_acceptor(
452			typename AccFinal::impl_base_type& impl,
453			int backlog) override
454			{
455		1963x	return static_cast<AccFinal*>(&impl)->do_listen(backlog);
456			}
457			};
458
459			} // namespace boost::corosio::detail
460
461			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SERVICE_FINALS_HPP
462