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

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

97.1% Lines (66 / 68) -% Branches (0 / 0) 97.1% Functions (34 / 35)
[ ] prev/next file n p prev/next uncovered line
select_types.hpp
f(x) Functions (35)
Function Calls Lines Branches Blocks
boost::corosio::detail::select_tcp_socket::~select_tcp_socket() :50 3974x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::select_tcp_socket(boost::corosio::detail::select_tcp_service&) :69 3974x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::release_socket() :74 3x 100.0% – 100.0% boost::corosio::detail::select_local_stream_socket::~select_local_stream_socket() :81 326x 100.0% – 100.0% boost::corosio::detail::select_local_stream_socket::select_local_stream_socket(boost::corosio::detail::select_local_stream_service&) :100 326x 100.0% – 100.0% boost::corosio::detail::select_local_stream_socket::release_socket() :106 3x 100.0% – 100.0% boost::corosio::detail::select_udp_socket::~select_udp_socket() :115 326x 100.0% – 100.0% boost::corosio::detail::select_udp_socket::select_udp_socket(boost::corosio::detail::select_udp_service&) :134 326x 100.0% – 100.0% boost::corosio::detail::select_udp_socket::shutdown(boost::corosio::shutdown_type) :139 3x 100.0% – 100.0% boost::corosio::detail::select_udp_socket::release_socket() :144 2x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_socket::~select_local_datagram_socket() :150 242x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_socket::select_local_datagram_socket(boost::corosio::detail::select_local_datagram_service&) :169 242x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_socket::shutdown(boost::corosio::shutdown_type) :175 4x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_socket::bind(boost::corosio::local_endpoint) :180 0 0.0% – 0.0% boost::corosio::detail::select_local_datagram_socket::release_socket() :185 2x 100.0% – 100.0% boost::corosio::detail::select_tcp_acceptor::~select_tcp_acceptor() :193 1548x 100.0% – 100.0% boost::corosio::detail::select_tcp_acceptor::select_tcp_acceptor(boost::corosio::detail::select_tcp_acceptor_service&) :212 1548x 100.0% – 100.0% boost::corosio::detail::select_local_stream_acceptor::~select_local_stream_acceptor() :218 114x 100.0% – 100.0% boost::corosio::detail::select_local_stream_acceptor::select_local_stream_acceptor(boost::corosio::detail::select_local_stream_acceptor_service&) :237 114x 100.0% – 100.0% boost::corosio::detail::select_descriptor::~select_descriptor() :246 138x 100.0% – 100.0% boost::corosio::detail::select_descriptor::select_descriptor(boost::corosio::detail::select_descriptor_service&) :261 138x 100.0% – 100.0% boost::corosio::detail::select_tcp_service::~select_tcp_service() :269 1398x 100.0% – 100.0% boost::corosio::detail::select_tcp_service::select_tcp_service(boost::capy::execution_context&) :281 932x 100.0% – 100.0% boost::corosio::detail::select_local_stream_service::~select_local_stream_service() :286 324x 100.0% – 100.0% boost::corosio::detail::select_local_stream_service::select_local_stream_service(boost::capy::execution_context&) :298 216x 100.0% – 100.0% boost::corosio::detail::select_udp_service::~select_udp_service() :304 333x 100.0% – 100.0% boost::corosio::detail::select_udp_service::select_udp_service(boost::capy::execution_context&) :316 222x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_service::~select_local_datagram_service() :321 219x 100.0% – 100.0% boost::corosio::detail::select_local_datagram_service::select_local_datagram_service(boost::capy::execution_context&) :333 146x 100.0% – 100.0% boost::corosio::detail::select_tcp_acceptor_service::~select_tcp_acceptor_service() :339 1209x 100.0% – 100.0% boost::corosio::detail::select_tcp_acceptor_service::select_tcp_acceptor_service(boost::capy::execution_context&) :357 806x 100.0% – 100.0% boost::corosio::detail::select_local_stream_acceptor_service::~select_local_stream_acceptor_service() :363 153x 100.0% – 100.0% boost::corosio::detail::select_local_stream_acceptor_service::select_local_stream_acceptor_service(boost::capy::execution_context&) :381 102x 100.0% – 100.0% boost::corosio::detail::select_descriptor_service::~select_descriptor_service() :387 174x 100.0% – 100.0% boost::corosio::detail::select_descriptor_service::select_descriptor_service(boost::capy::execution_context&) :399 116x 100.0% – 100.0%
Line Branch TLA 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 #include <boost/corosio/native/detail/reactor/reactor_descriptor_service.hpp>
29
30 namespace boost::corosio::detail {
31
32 // Forward declarations for cross-references.
33 class select_tcp_socket;
34 class select_tcp_service;
35 class select_tcp_acceptor;
36 class select_tcp_acceptor_service;
37 class select_udp_socket;
38 class select_udp_service;
39 class select_local_stream_socket;
40 class select_local_stream_service;
41 class select_local_stream_acceptor;
42 class select_local_stream_acceptor_service;
43 class select_local_datagram_socket;
44 class select_local_datagram_service;
45 class select_descriptor;
46 class select_descriptor_service;
47
48 // --- Stream sockets ---
49
50 class select_tcp_socket final
51 : public reactor_stream_socket_impl<
52 select_tcp_socket,
53 select_traits,
54 select_tcp_service,
55 select_tcp_acceptor,
56 tcp_socket::implementation,
57 endpoint>
58 {
59 using base_type = reactor_stream_socket_impl<
60 select_tcp_socket,
61 select_traits,
62 select_tcp_service,
63 select_tcp_acceptor,
64 tcp_socket::implementation,
65 endpoint>;
66 friend select_tcp_service;
67
68 public:
69 3974x explicit select_tcp_socket(select_tcp_service& svc) noexcept
70 1987x : base_type(svc)
71 3974x {
72 3974x }
73
74 3x native_handle_type release_socket() noexcept override
75 {
76 hook_ = {};
77 3x return this->do_release_socket();
78 }
79 };
80
81 class select_local_stream_socket final
82 : public reactor_stream_socket_impl<
83 select_local_stream_socket,
84 select_traits,
85 select_local_stream_service,
86 select_local_stream_acceptor,
87 local_stream_socket::implementation,
88 corosio::local_endpoint>
89 {
90 using base_type = reactor_stream_socket_impl<
91 select_local_stream_socket,
92 select_traits,
93 select_local_stream_service,
94 select_local_stream_acceptor,
95 local_stream_socket::implementation,
96 corosio::local_endpoint>;
97 friend select_local_stream_service;
98
99 public:
100 326x explicit select_local_stream_socket(
101 select_local_stream_service& svc) noexcept
102 163x : base_type(svc)
103 326x {
104 326x }
105
106 3x native_handle_type release_socket() noexcept override
107 {
108 hook_ = {};
109 3x return this->do_release_socket();
110 }
111 };
112
113 // --- Datagram sockets ---
114
115 class select_udp_socket final
116 : public reactor_dgram_socket_impl<
117 select_udp_socket,
118 select_traits,
119 select_udp_service,
120 select_tcp_acceptor,
121 udp_socket::implementation,
122 endpoint>
123 {
124 using base_type = reactor_dgram_socket_impl<
125 select_udp_socket,
126 select_traits,
127 select_udp_service,
128 select_tcp_acceptor,
129 udp_socket::implementation,
130 endpoint>;
131 friend select_udp_service;
132
133 public:
134 326x explicit select_udp_socket(select_udp_service& svc) noexcept
135 163x : base_type(svc)
136 326x {
137 326x }
138
139 3x std::error_code shutdown(corosio::shutdown_type what) noexcept override
140 {
141 3x return this->do_shutdown(static_cast<int>(what));
142 }
143
144 2x native_handle_type release_socket() noexcept override
145 {
146 2x return this->do_release_socket();
147 }
148 };
149
150 class select_local_datagram_socket final
151 : public reactor_dgram_socket_impl<
152 select_local_datagram_socket,
153 select_traits,
154 select_local_datagram_service,
155 select_tcp_acceptor,
156 local_datagram_socket::implementation,
157 corosio::local_endpoint>
158 {
159 using base_type = reactor_dgram_socket_impl<
160 select_local_datagram_socket,
161 select_traits,
162 select_local_datagram_service,
163 select_tcp_acceptor,
164 local_datagram_socket::implementation,
165 corosio::local_endpoint>;
166 friend select_local_datagram_service;
167
168 public:
169 242x explicit select_local_datagram_socket(
170 select_local_datagram_service& svc) noexcept
171 121x : base_type(svc)
172 242x {
173 242x }
174
175 4x std::error_code shutdown(corosio::shutdown_type what) noexcept override
176 {
177 4x return this->do_shutdown(static_cast<int>(what));
178 }
179
180 ✗ std::error_code bind(corosio::local_endpoint ep) noexcept override
181 {
182 ✗ return this->do_bind(ep);
183 }
184
185 2x native_handle_type release_socket() noexcept override
186 {
187 2x return this->do_release_socket();
188 }
189 };
190
191 // --- Acceptors ---
192
193 class select_tcp_acceptor final
194 : public reactor_acceptor_impl<
195 select_tcp_acceptor,
196 select_traits,
197 select_tcp_acceptor_service,
198 select_tcp_socket,
199 tcp_acceptor::implementation,
200 endpoint>
201 {
202 using base_type = reactor_acceptor_impl<
203 select_tcp_acceptor,
204 select_traits,
205 select_tcp_acceptor_service,
206 select_tcp_socket,
207 tcp_acceptor::implementation,
208 endpoint>;
209 friend select_tcp_acceptor_service;
210
211 public:
212 1548x explicit select_tcp_acceptor(select_tcp_acceptor_service& svc) noexcept
213 774x : base_type(svc)
214 1548x {
215 1548x }
216 };
217
218 class select_local_stream_acceptor final
219 : public reactor_acceptor_impl<
220 select_local_stream_acceptor,
221 select_traits,
222 select_local_stream_acceptor_service,
223 select_local_stream_socket,
224 local_stream_acceptor::implementation,
225 corosio::local_endpoint>
226 {
227 using base_type = reactor_acceptor_impl<
228 select_local_stream_acceptor,
229 select_traits,
230 select_local_stream_acceptor_service,
231 select_local_stream_socket,
232 local_stream_acceptor::implementation,
233 corosio::local_endpoint>;
234 friend select_local_stream_acceptor_service;
235
236 public:
237 114x explicit select_local_stream_acceptor(
238 select_local_stream_acceptor_service& svc) noexcept
239 57x : base_type(svc)
240 114x {
241 114x }
242 };
243
244 // --- Descriptors ---
245
246 class select_descriptor final
247 : public reactor_descriptor<
248 select_descriptor,
249 select_traits,
250 select_descriptor_service,
251 select_tcp_acceptor>
252 {
253 using base_type = reactor_descriptor<
254 select_descriptor,
255 select_traits,
256 select_descriptor_service,
257 select_tcp_acceptor>;
258 friend select_descriptor_service;
259
260 public:
261 138x explicit select_descriptor(select_descriptor_service& svc) noexcept
262 69x : base_type(svc)
263 138x {
264 138x }
265 };
266
267 // --- Services ---
268
269 class BOOST_COROSIO_DECL select_tcp_service final
270 : public reactor_tcp_service_impl<
271 select_tcp_service,
272 select_traits,
273 select_tcp_socket>
274 {
275 using base_type = reactor_tcp_service_impl<
276 select_tcp_service,
277 select_traits,
278 select_tcp_socket>;
279
280 public:
281 932x explicit select_tcp_service(capy::execution_context& ctx) : base_type(ctx)
282 932x {
283 932x }
284 };
285
286 class BOOST_COROSIO_DECL select_local_stream_service final
287 : public reactor_local_stream_service_impl<
288 select_local_stream_service,
289 select_traits,
290 select_local_stream_socket>
291 {
292 using base_type = reactor_local_stream_service_impl<
293 select_local_stream_service,
294 select_traits,
295 select_local_stream_socket>;
296
297 public:
298 216x explicit select_local_stream_service(capy::execution_context& ctx)
299 108x : base_type(ctx)
300 216x {
301 216x }
302 };
303
304 class BOOST_COROSIO_DECL select_udp_service final
305 : public reactor_udp_service_impl<
306 select_udp_service,
307 select_traits,
308 select_udp_socket>
309 {
310 using base_type = reactor_udp_service_impl<
311 select_udp_service,
312 select_traits,
313 select_udp_socket>;
314
315 public:
316 222x explicit select_udp_service(capy::execution_context& ctx) : base_type(ctx)
317 222x {
318 222x }
319 };
320
321 class BOOST_COROSIO_DECL select_local_datagram_service final
322 : public reactor_local_dgram_service_impl<
323 select_local_datagram_service,
324 select_traits,
325 select_local_datagram_socket>
326 {
327 using base_type = reactor_local_dgram_service_impl<
328 select_local_datagram_service,
329 select_traits,
330 select_local_datagram_socket>;
331
332 public:
333 146x explicit select_local_datagram_service(capy::execution_context& ctx)
334 73x : base_type(ctx)
335 146x {
336 146x }
337 };
338
339 class BOOST_COROSIO_DECL select_tcp_acceptor_service final
340 : public reactor_acceptor_service_impl<
341 select_tcp_acceptor_service,
342 select_traits,
343 tcp_acceptor_service,
344 select_tcp_acceptor,
345 select_tcp_service,
346 endpoint>
347 {
348 using base_type = reactor_acceptor_service_impl<
349 select_tcp_acceptor_service,
350 select_traits,
351 tcp_acceptor_service,
352 select_tcp_acceptor,
353 select_tcp_service,
354 endpoint>;
355
356 public:
357 806x explicit select_tcp_acceptor_service(capy::execution_context& ctx)
358 403x : base_type(ctx)
359 806x {
360 806x }
361 };
362
363 class BOOST_COROSIO_DECL select_local_stream_acceptor_service final
364 : public reactor_acceptor_service_impl<
365 select_local_stream_acceptor_service,
366 select_traits,
367 local_stream_acceptor_service,
368 select_local_stream_acceptor,
369 select_local_stream_service,
370 corosio::local_endpoint>
371 {
372 using base_type = reactor_acceptor_service_impl<
373 select_local_stream_acceptor_service,
374 select_traits,
375 local_stream_acceptor_service,
376 select_local_stream_acceptor,
377 select_local_stream_service,
378 corosio::local_endpoint>;
379
380 public:
381 102x explicit select_local_stream_acceptor_service(capy::execution_context& ctx)
382 51x : base_type(ctx)
383 102x {
384 102x }
385 };
386
387 class BOOST_COROSIO_DECL select_descriptor_service final
388 : public reactor_descriptor_service<
389 select_descriptor_service,
390 select_traits,
391 select_descriptor>
392 {
393 using base_type = reactor_descriptor_service<
394 select_descriptor_service,
395 select_traits,
396 select_descriptor>;
397
398 public:
399 116x explicit select_descriptor_service(capy::execution_context& ctx)
400 58x : base_type(ctx)
401 116x {
402 116x }
403 };
404
405 } // namespace boost::corosio::detail
406
407 #endif // BOOST_COROSIO_HAS_SELECT
408
409 #endif // BOOST_COROSIO_NATIVE_DETAIL_SELECT_SELECT_TYPES_HPP
410