include/boost/corosio/native/detail/select/select_types.hpp

96.0% Lines (48/0/50) 94.7% List of functions (18/0/19)

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

select_types.hpp

f(x) Functions (19)

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_SELECT_SELECT_TYPES_HPP
11		#define BOOST_COROSIO_NATIVE_DETAIL_SELECT_SELECT_TYPES_HPP
12
13		#include <boost/corosio/detail/platform.hpp>
14
15		#if BOOST_COROSIO_HAS_SELECT
16
17		/* Named per-backend types for the select 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/select/select_traits.hpp>
26		#include <boost/corosio/native/detail/select/select_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 select_tcp_socket;
33		class select_tcp_service;
34		class select_tcp_acceptor;
35		class select_tcp_acceptor_service;
36		class select_udp_socket;
37		class select_udp_service;
38		class select_local_stream_socket;
39		class select_local_stream_service;
40		class select_local_stream_acceptor;
41		class select_local_stream_acceptor_service;
42		class select_local_datagram_socket;
43		class select_local_datagram_service;
44
45		// --- Stream sockets ---
46
47		class select_tcp_socket final
48		: public reactor_stream_socket_impl<
49		select_tcp_socket,
50		select_traits,
51		select_tcp_service,
52		select_tcp_acceptor,
53		tcp_socket::implementation,
54		endpoint>
55		{
56		using base_type = reactor_stream_socket_impl<
57		select_tcp_socket,
58		select_traits,
59		select_tcp_service,
60		select_tcp_acceptor,
61		tcp_socket::implementation,
62		endpoint>;
63		friend select_tcp_service;
64
65		public:
66	6307x	explicit select_tcp_socket(select_tcp_service& svc) noexcept
67	6307x	: base_type(svc)
68		{
69	6307x	}
70
71	2x	native_handle_type release_socket() noexcept override
72		{
73	2x	hook_ = {};
74	2x	return this->do_release_socket();
75		}
76		};
77
78		class select_local_stream_socket final
79		: public reactor_stream_socket_impl<
80		select_local_stream_socket,
81		select_traits,
82		select_local_stream_service,
83		select_local_stream_acceptor,
84		local_stream_socket::implementation,
85		corosio::local_endpoint>
86		{
87		using base_type = reactor_stream_socket_impl<
88		select_local_stream_socket,
89		select_traits,
90		select_local_stream_service,
91		select_local_stream_acceptor,
92		local_stream_socket::implementation,
93		corosio::local_endpoint>;
94		friend select_local_stream_service;
95
96		public:
97	165x	explicit select_local_stream_socket(
98		select_local_stream_service& svc) noexcept
99	165x	: base_type(svc)
100		{
101	165x	}
102
103	2x	native_handle_type release_socket() noexcept override
104		{
105	2x	hook_ = {};
106	2x	return this->do_release_socket();
107		}
108		};
109
110		// --- Datagram sockets ---
111
112		class select_udp_socket final
113		: public reactor_dgram_socket_impl<
114		select_udp_socket,
115		select_traits,
116		select_udp_service,
117		select_tcp_acceptor,
118		udp_socket::implementation,
119		endpoint>
120		{
121		using base_type = reactor_dgram_socket_impl<
122		select_udp_socket,
123		select_traits,
124		select_udp_service,
125		select_tcp_acceptor,
126		udp_socket::implementation,
127		endpoint>;
128		friend select_udp_service;
129
130		public:
131	189x	explicit select_udp_socket(select_udp_service& svc) noexcept
132	189x	: base_type(svc)
133		{
134	189x	}
135
136	3x	std::error_code shutdown(corosio::shutdown_type what) noexcept override
137		{
138	3x	return this->do_shutdown(static_cast<int>(what));
139		}
140
141	2x	native_handle_type release_socket() noexcept override
142		{
143	2x	return this->do_release_socket();
144		}
145		};
146
147		class select_local_datagram_socket final
148		: public reactor_dgram_socket_impl<
149		select_local_datagram_socket,
150		select_traits,
151		select_local_datagram_service,
152		select_tcp_acceptor,
153		local_datagram_socket::implementation,
154		corosio::local_endpoint>
155		{
156		using base_type = reactor_dgram_socket_impl<
157		select_local_datagram_socket,
158		select_traits,
159		select_local_datagram_service,
160		select_tcp_acceptor,
161		local_datagram_socket::implementation,
162		corosio::local_endpoint>;
163		friend select_local_datagram_service;
164
165		public:
166	129x	explicit select_local_datagram_socket(
167		select_local_datagram_service& svc) noexcept
168	129x	: base_type(svc)
169		{
170	129x	}
171
172	4x	std::error_code shutdown(corosio::shutdown_type what) noexcept override
173		{
174	4x	return this->do_shutdown(static_cast<int>(what));
175		}
176
177	✗	std::error_code bind(corosio::local_endpoint ep) noexcept override
178		{
179	✗	return this->do_bind(ep);
180		}
181
182	2x	native_handle_type release_socket() noexcept override
183		{
184	2x	return this->do_release_socket();
185		}
186		};
187
188		// --- Acceptors ---
189
190		class select_tcp_acceptor final
191		: public reactor_acceptor_impl<
192		select_tcp_acceptor,
193		select_traits,
194		select_tcp_acceptor_service,
195		select_tcp_socket,
196		tcp_acceptor::implementation,
197		endpoint>
198		{
199		using base_type = reactor_acceptor_impl<
200		select_tcp_acceptor,
201		select_traits,
202		select_tcp_acceptor_service,
203		select_tcp_socket,
204		tcp_acceptor::implementation,
205		endpoint>;
206		friend select_tcp_acceptor_service;
207
208		public:
209	290x	explicit select_tcp_acceptor(select_tcp_acceptor_service& svc) noexcept
210	290x	: base_type(svc)
211		{
212	290x	}
213		};
214
215		class select_local_stream_acceptor final
216		: public reactor_acceptor_impl<
217		select_local_stream_acceptor,
218		select_traits,
219		select_local_stream_acceptor_service,
220		select_local_stream_socket,
221		local_stream_acceptor::implementation,
222		corosio::local_endpoint>
223		{
224		using base_type = reactor_acceptor_impl<
225		select_local_stream_acceptor,
226		select_traits,
227		select_local_stream_acceptor_service,
228		select_local_stream_socket,
229		local_stream_acceptor::implementation,
230		corosio::local_endpoint>;
231		friend select_local_stream_acceptor_service;
232
233		public:
234	53x	explicit select_local_stream_acceptor(
235		select_local_stream_acceptor_service& svc) noexcept
236	53x	: base_type(svc)
237		{
238	53x	}
239		};
240
241		// --- Services ---
242
243		class BOOST_COROSIO_DECL select_tcp_service final
244		: public reactor_tcp_service_impl<
245		select_tcp_service,
246		select_traits,
247		select_tcp_socket>
248		{
249		using base_type = reactor_tcp_service_impl<
250		select_tcp_service,
251		select_traits,
252		select_tcp_socket>;
253
254		public:
255	879x	explicit select_tcp_service(capy::execution_context& ctx) : base_type(ctx)
256		{
257	879x	}
258		};
259
260		class BOOST_COROSIO_DECL select_local_stream_service final
261		: public reactor_local_stream_service_impl<
262		select_local_stream_service,
263		select_traits,
264		select_local_stream_socket>
265		{
266		using base_type = reactor_local_stream_service_impl<
267		select_local_stream_service,
268		select_traits,
269		select_local_stream_socket>;
270
271		public:
272	879x	explicit select_local_stream_service(capy::execution_context& ctx)
273	879x	: base_type(ctx)
274		{
275	879x	}
276		};
277
278		class BOOST_COROSIO_DECL select_udp_service final
279		: public reactor_udp_service_impl<
280		select_udp_service,
281		select_traits,
282		select_udp_socket>
283		{
284		using base_type = reactor_udp_service_impl<
285		select_udp_service,
286		select_traits,
287		select_udp_socket>;
288
289		public:
290	879x	explicit select_udp_service(capy::execution_context& ctx) : base_type(ctx)
291		{
292	879x	}
293		};
294
295		class BOOST_COROSIO_DECL select_local_datagram_service final
296		: public reactor_local_dgram_service_impl<
297		select_local_datagram_service,
298		select_traits,
299		select_local_datagram_socket>
300		{
301		using base_type = reactor_local_dgram_service_impl<
302		select_local_datagram_service,
303		select_traits,
304		select_local_datagram_socket>;
305
306		public:
307	879x	explicit select_local_datagram_service(capy::execution_context& ctx)
308	879x	: base_type(ctx)
309		{
310	879x	}
311		};
312
313		class BOOST_COROSIO_DECL select_tcp_acceptor_service final
314		: public reactor_acceptor_service_impl<
315		select_tcp_acceptor_service,
316		select_traits,
317		tcp_acceptor_service,
318		select_tcp_acceptor,
319		select_tcp_service,
320		endpoint>
321		{
322		using base_type = reactor_acceptor_service_impl<
323		select_tcp_acceptor_service,
324		select_traits,
325		tcp_acceptor_service,
326		select_tcp_acceptor,
327		select_tcp_service,
328		endpoint>;
329
330		public:
331	879x	explicit select_tcp_acceptor_service(capy::execution_context& ctx)
332	879x	: base_type(ctx)
333		{
334	879x	}
335		};
336
337		class BOOST_COROSIO_DECL select_local_stream_acceptor_service final
338		: public reactor_acceptor_service_impl<
339		select_local_stream_acceptor_service,
340		select_traits,
341		local_stream_acceptor_service,
342		select_local_stream_acceptor,
343		select_local_stream_service,
344		corosio::local_endpoint>
345		{
346		using base_type = reactor_acceptor_service_impl<
347		select_local_stream_acceptor_service,
348		select_traits,
349		local_stream_acceptor_service,
350		select_local_stream_acceptor,
351		select_local_stream_service,
352		corosio::local_endpoint>;
353
354		public:
355	879x	explicit select_local_stream_acceptor_service(capy::execution_context& ctx)
356	879x	: base_type(ctx)
357		{
358	879x	}
359		};
360
361		} // namespace boost::corosio::detail
362
363		#endif // BOOST_COROSIO_HAS_SELECT
364
365		#endif // BOOST_COROSIO_NATIVE_DETAIL_SELECT_SELECT_TYPES_HPP
366