include/boost/corosio/native/detail/kqueue/kqueue_types.hpp

94.7% Lines (36/38) 96.8% List of functions (30/31) -% Branches (0/0)

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

kqueue_types.hpp

f(x) Functions (31)

Function Calls Lines Blocks

Line	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_KQUEUE_KQUEUE_TYPES_HPP
11		#define BOOST_COROSIO_NATIVE_DETAIL_KQUEUE_KQUEUE_TYPES_HPP
12
13		#include <boost/corosio/detail/platform.hpp>
14
15		#if BOOST_COROSIO_HAS_KQUEUE
16
17		/* Named per-backend types for the kqueue reactor.
18
19		Each class is a final, named wrapper around the parameterized
20		reactor_*_impl templates. Forward-declarable from backend.hpp
21		so the concrete layer never pulls in platform headers.
22		*/
23
24		#include <boost/corosio/detail/config.hpp>
25		#include <boost/corosio/native/detail/kqueue/kqueue_traits.hpp>
26		#include <boost/corosio/native/detail/kqueue/kqueue_scheduler.hpp>
27		#include <boost/corosio/native/detail/reactor/reactor_backend.hpp>
28
29		namespace boost::corosio::detail {
30
31		// Forward declarations for cross-references.
32		class kqueue_tcp_socket;
33		class kqueue_tcp_service;
34		class kqueue_tcp_acceptor;
35		class kqueue_tcp_acceptor_service;
36		class kqueue_udp_socket;
37		class kqueue_udp_service;
38		class kqueue_local_stream_socket;
39		class kqueue_local_stream_service;
40		class kqueue_local_stream_acceptor;
41		class kqueue_local_stream_acceptor_service;
42		class kqueue_local_datagram_socket;
43		class kqueue_local_datagram_service;
44
45		// --- Stream sockets ---
46
47		class kqueue_tcp_socket final
48		: public reactor_stream_socket_impl<
49		kqueue_tcp_socket, kqueue_traits, kqueue_tcp_service,
50		kqueue_tcp_acceptor, tcp_socket::implementation, endpoint>
51		{
52		using base_type = reactor_stream_socket_impl<
53		kqueue_tcp_socket, kqueue_traits, kqueue_tcp_service,
54		kqueue_tcp_acceptor, tcp_socket::implementation, endpoint>;
55		friend kqueue_tcp_service;
56		public:
57	35944x	explicit kqueue_tcp_socket(kqueue_tcp_service& svc) noexcept
58	35944x	: base_type(svc) {}
59
60	1x	native_handle_type release_socket() noexcept override
61		{
62		hook_ = {};
63	1x	return this->do_release_socket();
64		}
65		};
66
67		class kqueue_local_stream_socket final
68		: public reactor_stream_socket_impl<
69		kqueue_local_stream_socket, kqueue_traits,
70		kqueue_local_stream_service, kqueue_local_stream_acceptor,
71		local_stream_socket::implementation, corosio::local_endpoint>
72		{
73		using base_type = reactor_stream_socket_impl<
74		kqueue_local_stream_socket, kqueue_traits,
75		kqueue_local_stream_service, kqueue_local_stream_acceptor,
76		local_stream_socket::implementation, corosio::local_endpoint>;
77		friend kqueue_local_stream_service;
78		public:
79	248x	explicit kqueue_local_stream_socket(kqueue_local_stream_service& svc) noexcept
80	248x	: base_type(svc) {}
81
82	2x	native_handle_type release_socket() noexcept override
83		{
84		hook_ = {};
85	2x	return this->do_release_socket();
86		}
87		};
88
89		// --- Datagram sockets ---
90
91		class kqueue_udp_socket final
92		: public reactor_dgram_socket_impl<
93		kqueue_udp_socket, kqueue_traits, kqueue_udp_service,
94		kqueue_tcp_acceptor, udp_socket::implementation, endpoint>
95		{
96		using base_type = reactor_dgram_socket_impl<
97		kqueue_udp_socket, kqueue_traits, kqueue_udp_service,
98		kqueue_tcp_acceptor, udp_socket::implementation, endpoint>;
99		friend kqueue_udp_service;
100		public:
101	270x	explicit kqueue_udp_socket(kqueue_udp_service& svc) noexcept
102	270x	: base_type(svc) {}
103
104	1x	std::error_code shutdown(corosio::shutdown_type what) noexcept override
105		{
106	1x	return this->do_shutdown(static_cast<int>(what));
107		}
108
109	1x	native_handle_type release_socket() noexcept override
110		{
111	1x	return this->do_release_socket();
112		}
113		};
114
115		class kqueue_local_datagram_socket final
116		: public reactor_dgram_socket_impl<
117		kqueue_local_datagram_socket, kqueue_traits,
118		kqueue_local_datagram_service, kqueue_tcp_acceptor,
119		local_datagram_socket::implementation, corosio::local_endpoint>
120		{
121		using base_type = reactor_dgram_socket_impl<
122		kqueue_local_datagram_socket, kqueue_traits,
123		kqueue_local_datagram_service, kqueue_tcp_acceptor,
124		local_datagram_socket::implementation, corosio::local_endpoint>;
125		friend kqueue_local_datagram_service;
126		public:
127	204x	explicit kqueue_local_datagram_socket(kqueue_local_datagram_service& svc) noexcept
128	204x	: base_type(svc) {}
129
130	4x	std::error_code shutdown(corosio::shutdown_type what) noexcept override
131		{
132	4x	return this->do_shutdown(static_cast<int>(what));
133		}
134
135	✗	std::error_code bind(corosio::local_endpoint ep) noexcept override
136		{
137	✗	return this->do_bind(ep);
138		}
139
140	1x	native_handle_type release_socket() noexcept override
141		{
142	1x	return this->do_release_socket();
143		}
144		};
145
146		// --- Acceptors ---
147
148		class kqueue_tcp_acceptor final
149		: public reactor_acceptor_impl<
150		kqueue_tcp_acceptor, kqueue_traits,
151		kqueue_tcp_acceptor_service, kqueue_tcp_socket,
152		tcp_acceptor::implementation, endpoint>
153		{
154		using base_type = reactor_acceptor_impl<
155		kqueue_tcp_acceptor, kqueue_traits,
156		kqueue_tcp_acceptor_service, kqueue_tcp_socket,
157		tcp_acceptor::implementation, endpoint>;
158		friend kqueue_tcp_acceptor_service;
159		public:
160	3598x	explicit kqueue_tcp_acceptor(kqueue_tcp_acceptor_service& svc) noexcept
161	3598x	: base_type(svc) {}
162		};
163
164		class kqueue_local_stream_acceptor final
165		: public reactor_acceptor_impl<
166		kqueue_local_stream_acceptor, kqueue_traits,
167		kqueue_local_stream_acceptor_service,
168		kqueue_local_stream_socket,
169		local_stream_acceptor::implementation, corosio::local_endpoint>
170		{
171		using base_type = reactor_acceptor_impl<
172		kqueue_local_stream_acceptor, kqueue_traits,
173		kqueue_local_stream_acceptor_service,
174		kqueue_local_stream_socket,
175		local_stream_acceptor::implementation, corosio::local_endpoint>;
176		friend kqueue_local_stream_acceptor_service;
177		public:
178	94x	explicit kqueue_local_stream_acceptor(
179		kqueue_local_stream_acceptor_service& svc) noexcept
180	94x	: base_type(svc) {}
181		};
182
183		// --- Services ---
184
185		class BOOST_COROSIO_DECL kqueue_tcp_service final
186		: public reactor_tcp_service_impl<
187		kqueue_tcp_service, kqueue_traits, kqueue_tcp_socket>
188		{
189		using base_type = reactor_tcp_service_impl<
190		kqueue_tcp_service, kqueue_traits, kqueue_tcp_socket>;
191		public:
192	2484x	explicit kqueue_tcp_service(capy::execution_context& ctx)
193	2484x	: base_type(ctx) {}
194		};
195
196		class BOOST_COROSIO_DECL kqueue_local_stream_service final
197		: public reactor_local_stream_service_impl<
198		kqueue_local_stream_service, kqueue_traits,
199		kqueue_local_stream_socket>
200		{
201		using base_type = reactor_local_stream_service_impl<
202		kqueue_local_stream_service, kqueue_traits,
203		kqueue_local_stream_socket>;
204		public:
205	2484x	explicit kqueue_local_stream_service(capy::execution_context& ctx)
206	2484x	: base_type(ctx) {}
207		};
208
209		class BOOST_COROSIO_DECL kqueue_udp_service final
210		: public reactor_udp_service_impl<
211		kqueue_udp_service, kqueue_traits, kqueue_udp_socket>
212		{
213		using base_type = reactor_udp_service_impl<
214		kqueue_udp_service, kqueue_traits, kqueue_udp_socket>;
215		public:
216	2484x	explicit kqueue_udp_service(capy::execution_context& ctx)
217	2484x	: base_type(ctx) {}
218		};
219
220		class BOOST_COROSIO_DECL kqueue_local_datagram_service final
221		: public reactor_local_dgram_service_impl<
222		kqueue_local_datagram_service, kqueue_traits,
223		kqueue_local_datagram_socket>
224		{
225		using base_type = reactor_local_dgram_service_impl<
226		kqueue_local_datagram_service, kqueue_traits,
227		kqueue_local_datagram_socket>;
228		public:
229	2484x	explicit kqueue_local_datagram_service(capy::execution_context& ctx)
230	2484x	: base_type(ctx) {}
231		};
232
233		class BOOST_COROSIO_DECL kqueue_tcp_acceptor_service final
234		: public reactor_acceptor_service_impl<
235		kqueue_tcp_acceptor_service, kqueue_traits,
236		tcp_acceptor_service, kqueue_tcp_acceptor,
237		kqueue_tcp_service, endpoint>
238		{
239		using base_type = reactor_acceptor_service_impl<
240		kqueue_tcp_acceptor_service, kqueue_traits,
241		tcp_acceptor_service, kqueue_tcp_acceptor,
242		kqueue_tcp_service, endpoint>;
243		public:
244	2484x	explicit kqueue_tcp_acceptor_service(capy::execution_context& ctx)
245	2484x	: base_type(ctx) {}
246		};
247
248		class BOOST_COROSIO_DECL kqueue_local_stream_acceptor_service final
249		: public reactor_acceptor_service_impl<
250		kqueue_local_stream_acceptor_service, kqueue_traits,
251		local_stream_acceptor_service,
252		kqueue_local_stream_acceptor,
253		kqueue_local_stream_service, corosio::local_endpoint>
254		{
255		using base_type = reactor_acceptor_service_impl<
256		kqueue_local_stream_acceptor_service, kqueue_traits,
257		local_stream_acceptor_service,
258		kqueue_local_stream_acceptor,
259		kqueue_local_stream_service, corosio::local_endpoint>;
260		public:
261	2484x	explicit kqueue_local_stream_acceptor_service(capy::execution_context& ctx)
262	2484x	: base_type(ctx) {}
263		};
264
265		} // namespace boost::corosio::detail
266
267		#endif // BOOST_COROSIO_HAS_KQUEUE
268
269		#endif // BOOST_COROSIO_NATIVE_DETAIL_KQUEUE_KQUEUE_TYPES_HPP
270