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

76.5% Lines (26/34) 86.2% List of functions (25/29) -% Branches (0/0)

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

kqueue_types.hpp

f(x) Functions (29)

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	32674x	explicit kqueue_tcp_socket(kqueue_tcp_service& svc) noexcept
58	32674x	: base_type(svc) {}
59		};
60
61		class kqueue_local_stream_socket final
62		: public reactor_stream_socket_impl<
63		kqueue_local_stream_socket, kqueue_traits,
64		kqueue_local_stream_service, kqueue_local_stream_acceptor,
65		local_stream_socket::implementation, corosio::local_endpoint>
66		{
67		using base_type = reactor_stream_socket_impl<
68		kqueue_local_stream_socket, kqueue_traits,
69		kqueue_local_stream_service, kqueue_local_stream_acceptor,
70		local_stream_socket::implementation, corosio::local_endpoint>;
71		friend kqueue_local_stream_service;
72		public:
73	34x	explicit kqueue_local_stream_socket(kqueue_local_stream_service& svc) noexcept
74	34x	: base_type(svc) {}
75
76	1x	native_handle_type release_socket() noexcept override
77		{
78	1x	hook_ = {};
79		return this->do_release_socket();
80		}
81		};
82
83		// --- Datagram sockets ---
84
85		class kqueue_udp_socket final
86		: public reactor_dgram_socket_impl<
87		kqueue_udp_socket, kqueue_traits, kqueue_udp_service,
88		kqueue_tcp_acceptor, udp_socket::implementation, endpoint>
89		{
90		using base_type = reactor_dgram_socket_impl<
91		kqueue_udp_socket, kqueue_traits, kqueue_udp_service,
92		kqueue_tcp_acceptor, udp_socket::implementation, endpoint>;
93		friend kqueue_udp_service;
94		public:
95	104x	explicit kqueue_udp_socket(kqueue_udp_service& svc) noexcept
96	104x	: base_type(svc) {}
97		};
98
99		class kqueue_local_datagram_socket final
100		: public reactor_dgram_socket_impl<
101		kqueue_local_datagram_socket, kqueue_traits,
102		kqueue_local_datagram_service, kqueue_tcp_acceptor,
103		local_datagram_socket::implementation, corosio::local_endpoint>
104		{
105		using base_type = reactor_dgram_socket_impl<
106		kqueue_local_datagram_socket, kqueue_traits,
107		kqueue_local_datagram_service, kqueue_tcp_acceptor,
108		local_datagram_socket::implementation, corosio::local_endpoint>;
109		friend kqueue_local_datagram_service;
110		public:
111	30x	explicit kqueue_local_datagram_socket(kqueue_local_datagram_service& svc) noexcept
112	30x	: base_type(svc) {}
113
114	✗	std::error_code shutdown(corosio::shutdown_type what) noexcept override
115		{
116	✗	return this->do_shutdown(static_cast<int>(what));
117		}
118
119	✗	std::error_code bind(corosio::local_endpoint ep) noexcept override
120		{
121	✗	return this->do_bind(ep);
122		}
123
124	✗	native_handle_type release_socket() noexcept override
125		{
126	✗	return this->do_release_socket();
127		}
128		};
129
130		// --- Acceptors ---
131
132		class kqueue_tcp_acceptor final
133		: public reactor_acceptor_impl<
134		kqueue_tcp_acceptor, kqueue_traits,
135		kqueue_tcp_acceptor_service, kqueue_tcp_socket,
136		tcp_acceptor::implementation, endpoint>
137		{
138		using base_type = reactor_acceptor_impl<
139		kqueue_tcp_acceptor, kqueue_traits,
140		kqueue_tcp_acceptor_service, kqueue_tcp_socket,
141		tcp_acceptor::implementation, endpoint>;
142		friend kqueue_tcp_acceptor_service;
143		public:
144	2188x	explicit kqueue_tcp_acceptor(kqueue_tcp_acceptor_service& svc) noexcept
145	2188x	: base_type(svc) {}
146		};
147
148		class kqueue_local_stream_acceptor final
149		: public reactor_acceptor_impl<
150		kqueue_local_stream_acceptor, kqueue_traits,
151		kqueue_local_stream_acceptor_service,
152		kqueue_local_stream_socket,
153		local_stream_acceptor::implementation, corosio::local_endpoint>
154		{
155		using base_type = reactor_acceptor_impl<
156		kqueue_local_stream_acceptor, kqueue_traits,
157		kqueue_local_stream_acceptor_service,
158		kqueue_local_stream_socket,
159		local_stream_acceptor::implementation, corosio::local_endpoint>;
160		friend kqueue_local_stream_acceptor_service;
161		public:
162	12x	explicit kqueue_local_stream_acceptor(
163		kqueue_local_stream_acceptor_service& svc) noexcept
164	12x	: base_type(svc) {}
165
166	✗	native_handle_type release_socket() noexcept override
167		{
168	✗	return this->do_release_socket();
169		}
170		};
171
172		// --- Services ---
173
174		class BOOST_COROSIO_DECL kqueue_tcp_service final
175		: public reactor_tcp_service_impl<
176		kqueue_tcp_service, kqueue_traits, kqueue_tcp_socket>
177		{
178		using base_type = reactor_tcp_service_impl<
179		kqueue_tcp_service, kqueue_traits, kqueue_tcp_socket>;
180		public:
181	938x	explicit kqueue_tcp_service(capy::execution_context& ctx)
182	938x	: base_type(ctx) {}
183		};
184
185		class BOOST_COROSIO_DECL kqueue_local_stream_service final
186		: public reactor_local_stream_service_impl<
187		kqueue_local_stream_service, kqueue_traits,
188		kqueue_local_stream_socket>
189		{
190		using base_type = reactor_local_stream_service_impl<
191		kqueue_local_stream_service, kqueue_traits,
192		kqueue_local_stream_socket>;
193		public:
194	938x	explicit kqueue_local_stream_service(capy::execution_context& ctx)
195	938x	: base_type(ctx) {}
196		};
197
198		class BOOST_COROSIO_DECL kqueue_udp_service final
199		: public reactor_udp_service_impl<
200		kqueue_udp_service, kqueue_traits, kqueue_udp_socket>
201		{
202		using base_type = reactor_udp_service_impl<
203		kqueue_udp_service, kqueue_traits, kqueue_udp_socket>;
204		public:
205	938x	explicit kqueue_udp_service(capy::execution_context& ctx)
206	938x	: base_type(ctx) {}
207		};
208
209		class BOOST_COROSIO_DECL kqueue_local_datagram_service final
210		: public reactor_local_dgram_service_impl<
211		kqueue_local_datagram_service, kqueue_traits,
212		kqueue_local_datagram_socket>
213		{
214		using base_type = reactor_local_dgram_service_impl<
215		kqueue_local_datagram_service, kqueue_traits,
216		kqueue_local_datagram_socket>;
217		public:
218	938x	explicit kqueue_local_datagram_service(capy::execution_context& ctx)
219	938x	: base_type(ctx) {}
220		};
221
222		class BOOST_COROSIO_DECL kqueue_tcp_acceptor_service final
223		: public reactor_acceptor_service_impl<
224		kqueue_tcp_acceptor_service, kqueue_traits,
225		tcp_acceptor_service, kqueue_tcp_acceptor,
226		kqueue_tcp_service, endpoint>
227		{
228		using base_type = reactor_acceptor_service_impl<
229		kqueue_tcp_acceptor_service, kqueue_traits,
230		tcp_acceptor_service, kqueue_tcp_acceptor,
231		kqueue_tcp_service, endpoint>;
232		public:
233	938x	explicit kqueue_tcp_acceptor_service(capy::execution_context& ctx)
234	938x	: base_type(ctx) {}
235		};
236
237		class BOOST_COROSIO_DECL kqueue_local_stream_acceptor_service final
238		: public reactor_acceptor_service_impl<
239		kqueue_local_stream_acceptor_service, kqueue_traits,
240		local_stream_acceptor_service,
241		kqueue_local_stream_acceptor,
242		kqueue_local_stream_service, corosio::local_endpoint>
243		{
244		using base_type = reactor_acceptor_service_impl<
245		kqueue_local_stream_acceptor_service, kqueue_traits,
246		local_stream_acceptor_service,
247		kqueue_local_stream_acceptor,
248		kqueue_local_stream_service, corosio::local_endpoint>;
249		public:
250	938x	explicit kqueue_local_stream_acceptor_service(capy::execution_context& ctx)
251	938x	: base_type(ctx) {}
252		};
253
254		} // namespace boost::corosio::detail
255
256		#endif // BOOST_COROSIO_HAS_KQUEUE
257
258		#endif // BOOST_COROSIO_NATIVE_DETAIL_KQUEUE_KQUEUE_TYPES_HPP
259