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

79.4% Lines (173/218) 78.1% List of functions (200/256) 14.5% Branches (44/304)

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

reactor_op.hpp

f(x) Functions (256)

Function Calls Lines Branches Blocks

Line	Branch	Hits	Source Code
1			//
2			// Copyright (c) 2026 Steve Gerbino
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_OP_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
12
13			#include <boost/corosio/native/detail/reactor/reactor_op_base.hpp>
14			#include <boost/corosio/io/io_object.hpp>
15			#include <boost/corosio/endpoint.hpp>
16			#include <boost/corosio/detail/continuation_op.hpp>
17			#include <boost/capy/ex/executor_ref.hpp>
18
19			#include <atomic>
20			#include <coroutine>
21			#include <cstddef>
22			#include <memory>
23			#include <optional>
24			#include <stop_token>
25			#include <system_error>
26
27			#include <errno.h>
28
29			#include <netinet/in.h>
30			#include <sys/socket.h>
31			#include <sys/uio.h>
32
33			namespace boost::corosio::detail {
34
35			/** Base operation for reactor-based backends.
36
37			Holds per-operation state that depends on the concrete backend
38			socket/acceptor types: coroutine handle, executor, output
39			pointers, file descriptor, stop_callback, and type-specific
40			impl pointers.
41
42			Fields shared across all backends (errn, bytes_transferred,
43			cancelled, impl_ptr, perform_io, complete) live in
44			reactor_op_base so the scheduler and descriptor_state can
45			access them without template instantiation.
46
47			@tparam Socket The backend socket impl type (forward-declared).
48			@tparam Acceptor The backend acceptor impl type (forward-declared).
49			*/
50			template<class Socket, class Acceptor>
51			struct reactor_op : reactor_op_base
52			{
53			/// Stop-token callback that invokes cancel() on the target op.
54			struct canceller
55			{
56			reactor_op* op;
57		655x	void operator()() const noexcept
58			{
59		655x	op->cancel();
60		655x	}
61			};
62
63			/// Caller's coroutine handle to resume on completion.
64			std::coroutine_handle<> h;
65
66			/// Scheduler-ready continuation for executor dispatch/post (wraps h).
67			detail::continuation_op cont_op;
68
69			/// Executor for dispatching the completion.
70			capy::executor_ref ex;
71
72			/// Output pointer for the error code.
73		115562x	std::error_code* ec_out = nullptr;
74
75			/// Output pointer for bytes transferred.
76		115562x	std::size_t* bytes_out = nullptr;
77
78			/// File descriptor this operation targets.
79		115562x	int fd = -1;
80
81			/// Stop-token callback registration.
82			std::optional<std::stop_callback<canceller>> stop_cb;
83
84			/// Owning socket impl (for stop_token cancellation).
85		115562x	Socket* socket_impl_ = nullptr;
86
87			/// Owning acceptor impl (for stop_token cancellation).
88		115562x	Acceptor* acceptor_impl_ = nullptr;
89
90		346686x	reactor_op() = default;
91
92			/// Reset operation state for reuse.
93		1600071x	void reset() noexcept
94			{
95		1600071x	fd = -1;
96		1600071x	errn = 0;
97		1600071x	bytes_transferred = 0;
98		1600071x	cancelled.store(false, std::memory_order_relaxed);
99		1600071x	impl_ptr.reset();
100		1600071x	socket_impl_ = nullptr;
101		1600071x	acceptor_impl_ = nullptr;
102		1600071x	}
103
104			/// Return true if this is a read-direction operation.
105		159349x	virtual bool is_read_operation() const noexcept
106			{
107		159349x	return false;
108			}
109
110			/// Cancel this operation via the owning impl.
111			virtual void cancel() noexcept = 0;
112
113			/// Destroy without invoking.
114		✗	void destroy() override
115			{
116		✗	stop_cb.reset();
117		✗	reactor_op_base::destroy();
118		✗	}
119
120			/// Arm the stop-token callback for a socket operation.
121		366389x	void start(std::stop_token const& token, Socket* impl)
122			{
123		366389x	cancelled.store(false, std::memory_order_release);
124		366389x	stop_cb.reset();
125		366389x	socket_impl_ = impl;
126		366389x	acceptor_impl_ = nullptr;
127
128	4/16 ✓ Branch 0 taken 178765 times. ✓ Branch 1 taken 43 times. ✓ Branch 2 taken 186468 times. ✓ Branch 3 taken 1113 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	366389x	if (token.stop_possible())
129		1156x	stop_cb.emplace(token, canceller{this});
130		366389x	}
131
132			/// Arm the stop-token callback for an acceptor operation.
133		5966x	void start(std::stop_token const& token, Acceptor* impl)
134			{
135		5966x	cancelled.store(false, std::memory_order_release);
136		5966x	stop_cb.reset();
137		5966x	socket_impl_ = nullptr;
138		5966x	acceptor_impl_ = impl;
139
140	4/8 ✓ Branch 0 taken 1626 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 4315 times. ✓ Branch 3 taken 23 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5966x	if (token.stop_possible())
141		25x	stop_cb.emplace(token, canceller{this});
142		5966x	}
143			};
144
145			/** Shared connect operation.
146
147			Checks SO_ERROR for connect completion status. The operator()()
148			and cancel() are provided by the concrete backend type.
149
150			@tparam Base The backend's base op type.
151			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
152			*/
153			template<class Base, class Endpoint = endpoint>
154			struct reactor_connect_op : Base
155			{
156			/// Endpoint to connect to.
157			Endpoint target_endpoint;
158
159			/// Reset operation state for reuse.
160		5987x	void reset() noexcept
161			{
162		5987x	Base::reset();
163		5987x	target_endpoint = Endpoint{};
164		5987x	}
165
166		5930x	void perform_io() noexcept override
167			{
168		5930x	int err = 0;
169		5930x	socklen_t len = sizeof(err);
170	4/32 ✓ Branch 0 taken 1620 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 1620 times. ✓ Branch 4 taken 4310 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 4310 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	5930x	if (::getsockopt(this->fd, SOL_SOCKET, SO_ERROR, &err, &len) < 0)
171		✗	err = errno;
172		5930x	this->complete(err, 0);
173		5930x	}
174			};
175
176			/** Readiness-only wait operation.
177
178			Does not perform any I/O syscall. Completion is signalled by
179			the reactor delivering the requested edge event; reactor_descriptor_state
180			calls complete() directly and never invokes perform_io().
181
182			@tparam Base The backend's base op type.
183			*/
184			template<class Base>
185		58623x	struct reactor_wait_op : Base
186			{
187			/* Mirror of reactor_event_read from reactor_descriptor_state.hpp.
188			Including that header from here would create an include cycle
189			(descriptor_state -> reactor_op_base; reactor_op -> reactor_op_base),
190			so we carry the value locally. Both must stay in sync. */
191			static constexpr std::uint32_t read_event = 0x001;
192
193			/// Which event bit this wait targets (reactor_event_read/write/error).
194		58623x	std::uint32_t wait_event = 0;
195
196		56x	void reset() noexcept
197			{
198		56x	Base::reset();
199		56x	wait_event = 0;
200		56x	}
201
202		✗	bool is_read_operation() const noexcept override
203			{
204		✗	return wait_event == read_event;
205			}
206
207			/* perform_io() should never be called for a wait op — readiness
208			IS the completion. Overridden here to satisfy the virtual and
209			produce a safe result if called defensively. */
210		✗	void perform_io() noexcept override
211			{
212		✗	this->complete(0, 0);
213		✗	}
214			};
215
216			/** Shared scatter-read operation.
217
218			Uses readv() with an EINTR retry loop.
219
220			@tparam Base The backend's base op type.
221			*/
222			template<class Base>
223		18083x	struct reactor_read_op : Base
224			{
225			/// Maximum scatter-gather buffer count.
226			static constexpr std::size_t max_buffers = 16;
227
228			/// Scatter-gather I/O vectors.
229			iovec iovecs[max_buffers];
230
231			/// Number of active I/O vectors.
232		18083x	int iovec_count = 0;
233
234			/// True for zero-length reads (completed immediately).
235		18083x	bool empty_buffer_read = false;
236
237			/// Return true (this is a read-direction operation).
238		200226x	bool is_read_operation() const noexcept override
239			{
240		200226x	return !empty_buffer_read;
241			}
242
243		739694x	void reset() noexcept
244			{
245		739694x	Base::reset();
246		739694x	iovec_count = 0;
247		739694x	empty_buffer_read = false;
248		739694x	}
249
250		75894x	void perform_io() noexcept override
251			{
252			ssize_t n;
253		75894x	do
254			{
255	2/8 ✓ Branch 0 taken 33295 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 42599 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	75894x	n = ::readv(this->fd, iovecs, iovec_count);
256		151788x	}
257	6/16 ✓ Branch 0 taken 2430 times. ✓ Branch 1 taken 30865 times. ✓ Branch 2 taken 2430 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 861 times. ✓ Branch 5 taken 41738 times. ✓ Branch 6 taken 861 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	75894x	while (n < 0 && errno == EINTR);
258
259	4/8 ✓ Branch 0 taken 2430 times. ✓ Branch 1 taken 30865 times. ✓ Branch 2 taken 861 times. ✓ Branch 3 taken 41738 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	75894x	if (n >= 0)
260		72603x	this->complete(0, static_cast<std::size_t>(n));
261			else
262	2/8 ✓ Branch 0 taken 2430 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 861 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	3291x	this->complete(errno, 0);
263		75894x	}
264			};
265
266			/** Shared gather-write operation.
267
268			Delegates the actual syscall to WritePolicy::write(fd, iovecs, count),
269			which returns ssize_t (bytes written or -1 with errno set).
270
271			@tparam Base The backend's base op type.
272			@tparam WritePolicy Provides `static ssize_t write(int, iovec*, int)`.
273			*/
274			template<class Base, class WritePolicy>
275		18083x	struct reactor_write_op : Base
276			{
277			/// The write syscall policy type.
278			using write_policy = WritePolicy;
279
280			/// Maximum scatter-gather buffer count.
281			static constexpr std::size_t max_buffers = 16;
282
283			/// Scatter-gather I/O vectors.
284			iovec iovecs[max_buffers];
285
286			/// Number of active I/O vectors.
287		18083x	int iovec_count = 0;
288
289		848228x	void reset() noexcept
290			{
291		848228x	Base::reset();
292		848228x	iovec_count = 0;
293		848228x	}
294
295		509x	void perform_io() noexcept override
296			{
297		509x	ssize_t n = WritePolicy::write(this->fd, iovecs, iovec_count);
298	3/8 ✓ Branch 0 taken 253 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 254 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	509x	if (n >= 0)
299		507x	this->complete(0, static_cast<std::size_t>(n));
300			else
301	1/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	this->complete(errno, 0);
302		509x	}
303			};
304
305			/** Shared accept operation.
306
307			Delegates the actual syscall to AcceptPolicy::do_accept(fd, peer_storage),
308			which returns the accepted fd or -1 with errno set.
309
310			@tparam Base The backend's base op type.
311			@tparam AcceptPolicy Provides `static int do_accept(int, sockaddr_storage&)`.
312			*/
313			template<class Base, class AcceptPolicy>
314		1150x	struct reactor_accept_op : Base
315			{
316			/// File descriptor of the accepted connection.
317		1150x	int accepted_fd = -1;
318
319			/// Pointer to the peer socket implementation.
320		1150x	io_object::implementation* peer_impl = nullptr;
321
322			/// Output pointer for the accepted implementation.
323		1150x	io_object::implementation** impl_out = nullptr;
324
325			/// Peer address storage filled by accept.
326		1150x	sockaddr_storage peer_storage{};
327
328			/// Peer address length returned by accept.
329		1150x	socklen_t peer_addrlen = 0;
330
331		5954x	void reset() noexcept
332			{
333		5954x	Base::reset();
334		5954x	accepted_fd = -1;
335		5954x	peer_impl = nullptr;
336		5954x	impl_out = nullptr;
337		5954x	peer_storage = {};
338		5954x	peer_addrlen = 0;
339		5954x	}
340
341		5932x	void perform_io() noexcept override
342			{
343		5932x	int new_fd = AcceptPolicy::do_accept(
344		5932x	this->fd, peer_storage, peer_addrlen);
345	2/8 ✓ Branch 0 taken 1616 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4316 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5932x	if (new_fd >= 0)
346			{
347		5932x	accepted_fd = new_fd;
348		5932x	this->complete(0, 0);
349		5932x	}
350			else
351			{
352		✗	this->complete(errno, 0);
353			}
354		5932x	}
355			};
356
357			/** Shared connected send operation for datagram sockets.
358
359			Uses sendmsg() with msg_name=nullptr (connected mode).
360
361			@tparam Base The backend's base op type.
362			*/
363			template<class Base>
364		308x	struct reactor_send_op : Base
365			{
366			/// Maximum scatter-gather buffer count.
367			static constexpr std::size_t max_buffers = 16;
368
369			/// Scatter-gather I/O vectors.
370			iovec iovecs[max_buffers];
371
372			/// Number of active I/O vectors.
373		308x	int iovec_count = 0;
374
375			/// User-supplied message flags.
376		308x	int msg_flags = 0;
377
378		28x	void reset() noexcept
379			{
380		28x	Base::reset();
381		28x	iovec_count = 0;
382		28x	msg_flags = 0;
383		28x	}
384
385		✗	void perform_io() noexcept override
386			{
387		✗	msghdr msg{};
388		✗	msg.msg_iov = iovecs;
389		✗	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
390
391			#ifdef MSG_NOSIGNAL
392		✗	int send_flags = msg_flags \| MSG_NOSIGNAL;
393			#else
394			int send_flags = msg_flags;
395			#endif
396
397			ssize_t n;
398		✗	do
399			{
400		✗	n = ::sendmsg(this->fd, &msg, send_flags);
401		✗	}
402		✗	while (n < 0 && errno == EINTR);
403
404		✗	if (n >= 0)
405		✗	this->complete(0, static_cast<std::size_t>(n));
406			else
407		✗	this->complete(errno, 0);
408		✗	}
409			};
410
411			/** Shared connected recv operation for datagram sockets.
412
413			Uses recvmsg() with msg_name=nullptr (connected mode).
414			Unlike reactor_read_op, does not map n==0 to EOF
415			(zero-length datagrams are valid).
416
417			@tparam Base The backend's base op type.
418			*/
419			template<class Base>
420		308x	struct reactor_recv_op : Base
421			{
422			/// Maximum scatter-gather buffer count.
423			static constexpr std::size_t max_buffers = 16;
424
425			/// Scatter-gather I/O vectors.
426			iovec iovecs[max_buffers];
427
428			/// Number of active I/O vectors.
429		308x	int iovec_count = 0;
430
431			/// User-supplied message flags.
432		308x	int msg_flags = 0;
433
434			/// Return true (this is a read-direction operation).
435		✗	bool is_read_operation() const noexcept override
436			{
437		✗	return true;
438			}
439
440		28x	void reset() noexcept
441			{
442		28x	Base::reset();
443		28x	iovec_count = 0;
444		28x	msg_flags = 0;
445		28x	}
446
447		3x	void perform_io() noexcept override
448			{
449		3x	msghdr msg{};
450		3x	msg.msg_iov = iovecs;
451		3x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
452
453			ssize_t n;
454		3x	do
455			{
456	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	3x	n = ::recvmsg(this->fd, &msg, msg_flags);
457		6x	}
458	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	3x	while (n < 0 && errno == EINTR);
459
460	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	3x	if (n >= 0)
461		3x	this->complete(0, static_cast<std::size_t>(n));
462			else
463		✗	this->complete(errno, 0);
464		3x	}
465			};
466
467			/** Shared send_to operation for datagram sockets.
468
469			Uses sendmsg() with the destination endpoint in msg_name.
470
471			@tparam Base The backend's base op type.
472			*/
473			template<class Base>
474		308x	struct reactor_send_to_op : Base
475			{
476			/// Maximum scatter-gather buffer count.
477			static constexpr std::size_t max_buffers = 16;
478
479			/// Scatter-gather I/O vectors.
480			iovec iovecs[max_buffers];
481
482			/// Number of active I/O vectors.
483		308x	int iovec_count = 0;
484
485			/// Destination address storage.
486		308x	sockaddr_storage dest_storage{};
487
488			/// Destination address length.
489		308x	socklen_t dest_len = 0;
490
491			/// User-supplied message flags.
492		308x	int msg_flags = 0;
493
494		42x	void reset() noexcept
495			{
496		42x	Base::reset();
497		42x	iovec_count = 0;
498		42x	dest_storage = {};
499		42x	dest_len = 0;
500		42x	msg_flags = 0;
501		42x	}
502
503		✗	void perform_io() noexcept override
504			{
505		✗	msghdr msg{};
506		✗	msg.msg_name = &dest_storage;
507		✗	msg.msg_namelen = dest_len;
508		✗	msg.msg_iov = iovecs;
509		✗	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
510
511			#ifdef MSG_NOSIGNAL
512		✗	int send_flags = msg_flags \| MSG_NOSIGNAL;
513			#else
514			int send_flags = msg_flags;
515			#endif
516
517			ssize_t n;
518		✗	do
519			{
520		✗	n = ::sendmsg(this->fd, &msg, send_flags);
521		✗	}
522		✗	while (n < 0 && errno == EINTR);
523
524		✗	if (n >= 0)
525		✗	this->complete(0, static_cast<std::size_t>(n));
526			else
527		✗	this->complete(errno, 0);
528		✗	}
529			};
530
531			/** Shared recv_from operation for datagram sockets.
532
533			Uses recvmsg() with msg_name to capture the source endpoint.
534
535			@tparam Base The backend's base op type.
536			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
537			*/
538			template<class Base, class Endpoint = endpoint>
539		308x	struct reactor_recv_from_op : Base
540			{
541			/// Maximum scatter-gather buffer count.
542			static constexpr std::size_t max_buffers = 16;
543
544			/// Scatter-gather I/O vectors.
545			iovec iovecs[max_buffers];
546
547			/// Number of active I/O vectors.
548		308x	int iovec_count = 0;
549
550			/// Source address storage filled by recvmsg.
551		308x	sockaddr_storage source_storage{};
552
553			/// Actual source address length returned by recvmsg.
554		308x	socklen_t source_addrlen = 0;
555
556			/// Output pointer for the source endpoint (set by do_recv_from).
557		308x	Endpoint* source_out = nullptr;
558
559			/// User-supplied message flags.
560		308x	int msg_flags = 0;
561
562			/// Return true (this is a read-direction operation).
563		✗	bool is_read_operation() const noexcept override
564			{
565		✗	return true;
566			}
567
568		54x	void reset() noexcept
569			{
570		54x	Base::reset();
571		54x	iovec_count = 0;
572		54x	source_storage = {};
573		54x	source_addrlen = 0;
574		54x	source_out = nullptr;
575		54x	msg_flags = 0;
576		54x	}
577
578		10x	void perform_io() noexcept override
579			{
580		10x	msghdr msg{};
581		10x	msg.msg_name = &source_storage;
582		10x	msg.msg_namelen = sizeof(source_storage);
583		10x	msg.msg_iov = iovecs;
584		10x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
585
586			ssize_t n;
587		10x	do
588			{
589	2/8 ✓ Branch 0 taken 6 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	10x	n = ::recvmsg(this->fd, &msg, msg_flags);
590		20x	}
591	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 6 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 4 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	10x	while (n < 0 && errno == EINTR);
592
593	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 6 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	10x	if (n >= 0)
594			{
595		10x	source_addrlen = msg.msg_namelen;
596		10x	this->complete(0, static_cast<std::size_t>(n));
597		10x	}
598			else
599		✗	this->complete(errno, 0);
600		10x	}
601			};
602
603			} // namespace boost::corosio::detail
604
605			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
606