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

97.5% Lines (237/247) 92.7% List of functions (278/308) 22.4% Branches (163/728)

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

reactor_op.hpp

f(x) Functions (308)

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_events.hpp>
14			#include <boost/corosio/native/detail/reactor/reactor_op_base.hpp>
15			#include <boost/corosio/io/io_object.hpp>
16			#include <boost/corosio/endpoint.hpp>
17			#include <boost/capy/ex/executor_ref.hpp>
18
19			#include <atomic>
20			#include <cstddef>
21			#include <optional>
22			#include <stop_token>
23
24			#include <errno.h>
25			#include <poll.h>
26
27			#include <netinet/in.h>
28			#include <sys/socket.h>
29			#include <sys/uio.h>
30
31			namespace boost::corosio::detail {
32
33			/** Base operation for reactor-based backends.
34
35			Holds per-operation state that depends on the concrete backend
36			socket/acceptor types: coroutine handle, executor, output
37			pointers, file descriptor, stop_callback, and type-specific
38			impl pointers.
39
40			Fields shared across all backends (errn, bytes_transferred,
41			cancelled, impl_ptr, perform_io, complete) live in
42			reactor_op_base so the scheduler and descriptor_state can
43			access them without template instantiation.
44
45			@tparam Socket The backend socket impl type (forward-declared).
46			@tparam Acceptor The backend acceptor impl type (forward-declared).
47			*/
48			template<class Socket, class Acceptor>
49			struct reactor_op : reactor_op_base
50			{
51			// The op envelope — coroutine handle h, cont, executor ex, ec_out,
52			// bytes_out, cancelled, stop_cb (+ its canceller), impl_ptr — lives in
53			// coro_op (via reactor_op_base) and is shared with io_uring/IOCP.
54			// reactor_op adds only the reactor-specific routing state below.
55
56			/// File descriptor this operation targets.
57		166827x	int fd = -1;
58
59			/// Owning socket impl (for stop_token cancellation routing).
60		166827x	Socket* socket_impl_ = nullptr;
61
62			/// Owning acceptor impl (for stop_token cancellation routing).
63		166827x	Acceptor* acceptor_impl_ = nullptr;
64
65		333654x	reactor_op() = default;
66
67			/// Reset operation state for reuse.
68		2013253x	void reset() noexcept
69			{
70		2013253x	fd = -1;
71		2013253x	errn = 0;
72		2013253x	bytes_transferred = 0;
73		2013253x	cancelled.store(false, std::memory_order_relaxed);
74		2013253x	impl_ptr.reset();
75		2013253x	socket_impl_ = nullptr;
76		2013253x	acceptor_impl_ = nullptr;
77		2013253x	}
78
79			/// Return true if this is a read-direction operation.
80		198099x	virtual bool is_read_operation() const noexcept
81			{
82		198099x	return false;
83			}
84
85			/// Cancel this operation via the owning impl.
86			virtual void cancel() noexcept = 0;
87
88			/// coro_op cancellation hook (fired by the shared canceller when the
89			/// stop_token requests cancellation): route to the impl-specific cancel().
90		1271x	void on_cancel() noexcept override
91			{
92		1271x	cancel();
93		1271x	}
94
95			/// Destroy without invoking.
96		67x	void destroy() override
97			{
98		67x	stop_cb.reset();
99		67x	reactor_op_base::destroy();
100		67x	}
101
102			/// Arm the stop-token callback for a socket operation.
103		471265x	void start(std::stop_token const& token, Socket* impl)
104			{
105		471265x	socket_impl_ = impl;
106		471265x	acceptor_impl_ = nullptr;
107		471265x	coro_op::start(token);
108		471265x	}
109
110			/// Arm the stop-token callback for an acceptor operation.
111		8262x	void start(std::stop_token const& token, Acceptor* impl)
112			{
113		8262x	socket_impl_ = nullptr;
114		8262x	acceptor_impl_ = impl;
115		8262x	coro_op::start(token);
116		8262x	}
117			};
118
119			/** Shared connect operation.
120
121			Checks SO_ERROR for connect completion status. The operator()()
122			and cancel() are provided by the concrete backend type.
123
124			@tparam Base The backend's base op type.
125			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
126			*/
127			template<class Base, class Endpoint = endpoint>
128			struct reactor_connect_op : Base
129			{
130			/// Endpoint to connect to.
131			Endpoint target_endpoint;
132
133			/// Reset operation state for reuse.
134		8223x	void reset() noexcept
135			{
136		8223x	Base::reset();
137		8223x	target_endpoint = Endpoint{};
138		8223x	}
139
140		8118x	void perform_io() noexcept override
141			{
142			// A readiness notification does not prove the handshake
143			// finished: fresh sockets raise a spurious writable event,
144			// and a cached edge can trigger this check while the connect
145			// is still in flight — where SO_ERROR also reads 0. Probe
146			// writability first and report EAGAIN to stay parked;
147			// SO_ERROR decides only once the socket is actually writable.
148		8118x	pollfd pfd{};
149		8118x	pfd.fd = this->fd;
150		8118x	pfd.events = POLLOUT;
151			int r;
152		8118x	do
153			{
154	2/16 ✓ Branch 0 taken 6479 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1639 times. ✗ Branch 3 not taken. ✗ 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.	8118x	r = ::poll(&pfd, 1, 0);
155		16236x	}
156	6/32 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 6478 times. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 1638 times. ✓ Branch 6 taken 1 time. ✗ 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. ✗ 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.	8118x	while (r < 0 && errno == EINTR);
157
158	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 6479 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 1639 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.	8118x	if (r == 0)
159			{
160		✗	this->complete(EAGAIN, 0);
161		✗	return;
162			}
163	4/16 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 6478 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 1638 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.	8118x	if (r < 0)
164			{
165			// EAGAIN must not escape: it is the stay-parked sentinel.
166		2x	this->complete(
167	10/80 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✓ Branch 18 taken 1 time. ✗ 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. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	2x	(errno == EAGAIN \|\| errno == EWOULDBLOCK) ? ENOMEM : errno, 0);
168		2x	return;
169			}
170
171		8116x	int err = 0;
172		8116x	socklen_t len = sizeof(err);
173	6/32 ✓ Branch 0 taken 6478 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 6477 times. ✓ Branch 4 taken 1638 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 1637 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.	8116x	if (::getsockopt(this->fd, SOL_SOCKET, SO_ERROR, &err, &len) < 0)
174	2/16 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ 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.	2x	err = errno;
175		8116x	this->complete(err, 0);
176		8118x	}
177			};
178
179			/** Readiness-only wait operation.
180
181			Completion is decided by probing the descriptor with a
182			zero-timeout `poll()`, never by the reactor's cached edge
183			events: a speculative read can drain the socket without
184			touching the reactor (stale edge), and a short read can
185			consume the edge while data remains buffered (missing edge).
186			`perform_io()` runs the probe and reports `EAGAIN` when the
187			condition does not currently hold, which keeps the op parked.
188
189			@tparam Base The backend's base op type.
190			*/
191			template<class Base>
192		85407x	struct reactor_wait_op : Base
193			{
194			/// Which event bit this wait targets (reactor_event_read/write/error).
195		85407x	std::uint32_t wait_event = 0;
196
197		202x	void reset() noexcept
198			{
199		202x	Base::reset();
200		202x	wait_event = 0;
201		202x	}
202
203		✗	bool is_read_operation() const noexcept override
204			{
205		✗	return wait_event == reactor_event_read;
206			}
207
208			/** Check whether the waited-for condition currently holds.
209
210			Zero-timeout `poll()` probe. `POLLERR`/`POLLHUP` count as
211			ready for every wait type: the wait must not park on a
212			socket whose next I/O would fail immediately. The probe is
213			side-effect free — in particular it never reads `SO_ERROR`,
214			which is consume-on-read and belongs to whichever operation
215			observes the failure next.
216
217			@param fd The descriptor to probe.
218			@param event The event bit to probe for (read/write/error).
219			@param err Receives the probe failure, if any.
220
221			@return `true` if the condition holds or the probe failed.
222			*/
223		358x	static bool probe(int fd, std::uint32_t event, int& err) noexcept
224			{
225			// poll() silently ignores negative fds; without this guard a
226			// wait on a never-opened or closed socket parks forever.
227	6/20 ✓ Branch 0 taken 150 times. ✓ Branch 1 taken 8 times. ✓ Branch 2 taken 166 times. ✓ Branch 3 taken 9 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 taken 24 times. ✓ Branch 13 taken 1 time. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	358x	if (fd < 0)
228			{
229		18x	err = EBADF;
230		18x	return true;
231			}
232
233		340x	pollfd pfd{};
234		340x	pfd.fd = fd;
235	6/20 ✓ Branch 0 taken 98 times. ✓ Branch 1 taken 52 times. ✓ Branch 2 taken 105 times. ✓ Branch 3 taken 61 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 taken 18 times. ✓ Branch 13 taken 6 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	340x	if (event == reactor_event_read)
236		221x	pfd.events = POLLIN;
237	6/20 ✓ Branch 0 taken 26 times. ✓ Branch 1 taken 26 times. ✓ Branch 2 taken 31 times. ✓ Branch 3 taken 30 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 taken 2 times. ✓ Branch 13 taken 4 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	119x	else if (event == reactor_event_write)
238		59x	pfd.events = POLLOUT;
239			else
240		60x	pfd.events = POLLPRI;
241
242			int r;
243		340x	do
244			{
245	3/20 ✓ Branch 0 taken 150 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 166 times. ✗ Branch 3 not taken. ✗ 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 taken 24 times. ✗ 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.	340x	r = ::poll(&pfd, 1, 0);
246		680x	}
247	7/40 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 149 times. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 165 times. ✓ Branch 6 taken 1 time. ✗ 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. ✗ 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 taken 24 times. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken.	340x	while (r < 0 && errno == EINTR);
248
249	5/20 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 149 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 165 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 taken 24 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	340x	if (r < 0)
250			{
251			// Complete with the probe failure rather than park forever.
252			// EAGAIN must not escape here: callers treat it as the
253			// stay-parked sentinel, and poll() can fail with it on
254			// BSD/macOS under transient resource pressure.
255	10/100 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✓ Branch 18 taken 1 time. ✗ 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. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken. ✗ Branch 80 not taken. ✗ Branch 81 not taken. ✗ Branch 82 not taken. ✗ Branch 83 not taken. ✗ Branch 84 not taken. ✗ Branch 85 not taken. ✗ Branch 86 not taken. ✗ Branch 87 not taken. ✗ Branch 88 not taken. ✗ Branch 89 not taken. ✗ Branch 90 not taken. ✗ Branch 91 not taken. ✗ Branch 92 not taken. ✗ Branch 93 not taken. ✗ Branch 94 not taken. ✗ Branch 95 not taken. ✗ Branch 96 not taken. ✗ Branch 97 not taken. ✗ Branch 98 not taken. ✗ Branch 99 not taken.	2x	err = (errno == EAGAIN \|\| errno == EWOULDBLOCK) ? ENOMEM : errno;
256		2x	return true;
257			}
258		338x	return r != 0;
259		358x	}
260
261		115x	void perform_io() noexcept override
262			{
263		115x	int err = 0;
264	6/20 ✓ Branch 0 taken 16 times. ✓ Branch 1 taken 32 times. ✓ Branch 2 taken 17 times. ✓ Branch 3 taken 39 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 taken 2 times. ✓ Branch 13 taken 9 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	115x	if (probe(this->fd, wait_event, err))
265		35x	this->complete(err, 0);
266			else
267		80x	this->complete(EAGAIN, 0);
268		115x	}
269			};
270
271			/** Shared scatter-read operation.
272
273			Uses readv() with an EINTR retry loop.
274
275			@tparam Base The backend's base op type.
276			*/
277			template<class Base>
278		25394x	struct reactor_read_op : Base
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		25394x	int iovec_count = 0;
288
289			/// True for zero-length reads (completed immediately).
290		25394x	bool empty_buffer_read = false;
291
292			/// Return true (this is a read-direction operation).
293		264635x	bool is_read_operation() const noexcept override
294			{
295		264635x	return !empty_buffer_read;
296			}
297
298		937328x	void reset() noexcept
299			{
300		937328x	Base::reset();
301		937328x	iovec_count = 0;
302		937328x	empty_buffer_read = false;
303		937328x	}
304
305		98534x	void perform_io() noexcept override
306			{
307			ssize_t n;
308		98534x	do
309			{
310	2/12 ✓ Branch 0 taken 53878 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 44656 times. ✗ Branch 3 not taken. ✗ 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.	98534x	n = ::readv(this->fd, iovecs, iovec_count);
311		197068x	}
312	6/24 ✓ Branch 0 taken 518 times. ✓ Branch 1 taken 53360 times. ✓ Branch 2 taken 518 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3 times. ✓ Branch 5 taken 44653 times. ✓ Branch 6 taken 3 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. ✗ 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.	98534x	while (n < 0 && errno == EINTR);
313
314	4/12 ✓ Branch 0 taken 518 times. ✓ Branch 1 taken 53360 times. ✓ Branch 2 taken 3 times. ✓ Branch 3 taken 44653 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.	98534x	if (n >= 0)
315		98013x	this->complete(0, static_cast<std::size_t>(n));
316			else
317	2/12 ✓ Branch 0 taken 518 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3 times. ✗ Branch 3 not taken. ✗ 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.	521x	this->complete(errno, 0);
318		98534x	}
319			};
320
321			/** Shared gather-write operation.
322
323			Delegates the actual syscall to WritePolicy::write(fd, iovecs, count),
324			which returns ssize_t (bytes written or -1 with errno set).
325
326			@tparam Base The backend's base op type.
327			@tparam WritePolicy Provides `static ssize_t write(int, iovec*, int)`.
328			*/
329			template<class Base, class WritePolicy>
330		25394x	struct reactor_write_op : Base
331			{
332			/// The write syscall policy type.
333			using write_policy = WritePolicy;
334
335			/// Maximum scatter-gather buffer count.
336			static constexpr std::size_t max_buffers = 16;
337
338			/// Scatter-gather I/O vectors.
339			iovec iovecs[max_buffers];
340
341			/// Number of active I/O vectors.
342		25394x	int iovec_count = 0;
343
344		1058952x	void reset() noexcept
345			{
346		1058952x	Base::reset();
347		1058952x	iovec_count = 0;
348		1058952x	}
349
350		1009x	void perform_io() noexcept override
351			{
352		1009x	ssize_t n = WritePolicy::write(this->fd, iovecs, iovec_count);
353	4/12 ✓ Branch 0 taken 510 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 495 times. ✓ Branch 3 taken 2 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.	1009x	if (n >= 0)
354		1005x	this->complete(0, static_cast<std::size_t>(n));
355			else
356	2/12 ✓ Branch 0 taken 2 times. ✗ 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. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken.	4x	this->complete(errno, 0);
357		1009x	}
358			};
359
360			/** Shared accept operation.
361
362			Delegates the actual syscall to AcceptPolicy::do_accept(fd, peer_storage),
363			which returns the accepted fd or -1 with errno set.
364
365			@tparam Base The backend's base op type.
366			@tparam AcceptPolicy Provides `static int do_accept(int, sockaddr_storage&)`.
367			*/
368			template<class Base, class AcceptPolicy>
369		2504x	struct reactor_accept_op : Base
370			{
371			/// File descriptor of the accepted connection.
372		2504x	int accepted_fd = -1;
373
374			/// Pointer to the peer socket implementation.
375		2504x	io_object::implementation* peer_impl = nullptr;
376
377			/// Output pointer for the accepted implementation.
378		2504x	io_object::implementation** impl_out = nullptr;
379
380			/// Peer address storage filled by accept.
381		2504x	sockaddr_storage peer_storage{};
382
383			/// Peer address length returned by accept.
384		2504x	socklen_t peer_addrlen = 0;
385
386		8221x	void reset() noexcept
387			{
388		8221x	Base::reset();
389		8221x	accepted_fd = -1;
390		8221x	peer_impl = nullptr;
391		8221x	impl_out = nullptr;
392		8221x	peer_storage = {};
393		8221x	peer_addrlen = 0;
394		8221x	}
395
396		8092x	void perform_io() noexcept override
397			{
398		8092x	int new_fd =
399		8092x	AcceptPolicy::do_accept(this->fd, peer_storage, peer_addrlen);
400	3/8 ✓ Branch 0 taken 6471 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 1620 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	8092x	if (new_fd >= 0)
401			{
402		8091x	accepted_fd = new_fd;
403		8091x	this->complete(0, 0);
404		8091x	}
405			else
406			{
407	1/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	1x	this->complete(errno, 0);
408			}
409		8092x	}
410			};
411
412			/** Shared connected send operation for datagram sockets.
413
414			Uses sendmsg() with msg_name=nullptr (connected mode).
415
416			@tparam Base The backend's base op type.
417			*/
418			template<class Base>
419		571x	struct reactor_send_op : Base
420			{
421			/// Maximum scatter-gather buffer count.
422			static constexpr std::size_t max_buffers = 16;
423
424			/// Scatter-gather I/O vectors.
425			iovec iovecs[max_buffers];
426
427			/// Number of active I/O vectors.
428		571x	int iovec_count = 0;
429
430			/// User-supplied message flags.
431		571x	int msg_flags = 0;
432
433		59x	void reset() noexcept
434			{
435		59x	Base::reset();
436		59x	iovec_count = 0;
437		59x	msg_flags = 0;
438		59x	}
439
440		2x	void perform_io() noexcept override
441			{
442		2x	msghdr msg{};
443		2x	msg.msg_iov = iovecs;
444		2x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
445
446			#ifdef MSG_NOSIGNAL
447		2x	int send_flags = msg_flags \| MSG_NOSIGNAL;
448			#else
449			int send_flags = msg_flags;
450			#endif
451
452			ssize_t n;
453		2x	do
454			{
455	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	n = ::sendmsg(this->fd, &msg, send_flags);
456		4x	}
457	4/16 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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.	2x	while (n < 0 && errno == EINTR);
458
459	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (n >= 0)
460		✗	this->complete(0, static_cast<std::size_t>(n));
461			else
462	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ 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);
463		2x	}
464			};
465
466			/** Shared connected recv operation for datagram sockets.
467
468			Uses recvmsg() with msg_name=nullptr (connected mode).
469			Unlike reactor_read_op, does not map n==0 to EOF
470			(zero-length datagrams are valid).
471
472			@tparam Base The backend's base op type.
473			*/
474			template<class Base>
475		571x	struct reactor_recv_op : Base
476			{
477			/// Maximum scatter-gather buffer count.
478			static constexpr std::size_t max_buffers = 16;
479
480			/// Scatter-gather I/O vectors.
481			iovec iovecs[max_buffers];
482
483			/// Number of active I/O vectors.
484		571x	int iovec_count = 0;
485
486			/// User-supplied message flags.
487		571x	int msg_flags = 0;
488
489			/// Return true (this is a read-direction operation).
490			// LCOV_EXCL_START: devirtualized and inlined at the templated
491			// completion call site; the out-of-line body is never entered.
492		−	bool is_read_operation() const noexcept override
493			{
494		−	return true;
495			}
496			// LCOV_EXCL_STOP
497
498		58x	void reset() noexcept
499			{
500		58x	Base::reset();
501		58x	iovec_count = 0;
502		58x	msg_flags = 0;
503		58x	}
504
505		15x	void perform_io() noexcept override
506			{
507		15x	msghdr msg{};
508		15x	msg.msg_iov = iovecs;
509		15x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
510
511			ssize_t n;
512		15x	do
513			{
514	3/8 ✓ Branch 0 taken 8 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 4 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	15x	n = ::recvmsg(this->fd, &msg, msg_flags);
515		30x	}
516	9/16 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 6 times. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 1 time. ✓ Branch 9 taken 3 times. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	15x	while (n < 0 && errno == EINTR);
517
518	6/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 6 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 3 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	15x	if (n >= 0)
519		11x	this->complete(0, static_cast<std::size_t>(n));
520			else
521	3/8 ✓ Branch 0 taken 2 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	4x	this->complete(errno, 0);
522		15x	}
523			};
524
525			/** Shared send_to operation for datagram sockets.
526
527			Uses sendmsg() with the destination endpoint in msg_name.
528
529			@tparam Base The backend's base op type.
530			*/
531			template<class Base>
532		571x	struct reactor_send_to_op : Base
533			{
534			/// Maximum scatter-gather buffer count.
535			static constexpr std::size_t max_buffers = 16;
536
537			/// Scatter-gather I/O vectors.
538			iovec iovecs[max_buffers];
539
540			/// Number of active I/O vectors.
541		571x	int iovec_count = 0;
542
543			/// Destination address storage.
544		571x	sockaddr_storage dest_storage{};
545
546			/// Destination address length.
547		571x	socklen_t dest_len = 0;
548
549			/// User-supplied message flags.
550		571x	int msg_flags = 0;
551
552		97x	void reset() noexcept
553			{
554		97x	Base::reset();
555		97x	iovec_count = 0;
556		97x	dest_storage = {};
557		97x	dest_len = 0;
558		97x	msg_flags = 0;
559		97x	}
560
561		2x	void perform_io() noexcept override
562			{
563		2x	msghdr msg{};
564		2x	msg.msg_name = &dest_storage;
565		2x	msg.msg_namelen = dest_len;
566		2x	msg.msg_iov = iovecs;
567		2x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
568
569			#ifdef MSG_NOSIGNAL
570		2x	int send_flags = msg_flags \| MSG_NOSIGNAL;
571			#else
572			int send_flags = msg_flags;
573			#endif
574
575			ssize_t n;
576		2x	do
577			{
578	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	n = ::sendmsg(this->fd, &msg, send_flags);
579		4x	}
580	4/16 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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.	2x	while (n < 0 && errno == EINTR);
581
582	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (n >= 0)
583		✗	this->complete(0, static_cast<std::size_t>(n));
584			else
585	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ 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);
586		2x	}
587			};
588
589			/** Shared recv_from operation for datagram sockets.
590
591			Uses recvmsg() with msg_name to capture the source endpoint.
592
593			@tparam Base The backend's base op type.
594			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
595			*/
596			template<class Base, class Endpoint = endpoint>
597		571x	struct reactor_recv_from_op : Base
598			{
599			/// Maximum scatter-gather buffer count.
600			static constexpr std::size_t max_buffers = 16;
601
602			/// Scatter-gather I/O vectors.
603			iovec iovecs[max_buffers];
604
605			/// Number of active I/O vectors.
606		571x	int iovec_count = 0;
607
608			/// Source address storage filled by recvmsg.
609		571x	sockaddr_storage source_storage{};
610
611			/// Actual source address length returned by recvmsg.
612		571x	socklen_t source_addrlen = 0;
613
614			/// Output pointer for the source endpoint (set by do_recv_from).
615		571x	Endpoint* source_out = nullptr;
616
617			/// User-supplied message flags.
618		571x	int msg_flags = 0;
619
620			/// Return true (this is a read-direction operation).
621			// LCOV_EXCL_START: devirtualized and inlined at the templated
622			// completion call site; the out-of-line body is never entered.
623		−	bool is_read_operation() const noexcept override
624			{
625		−	return true;
626			}
627			// LCOV_EXCL_STOP
628
629		113x	void reset() noexcept
630			{
631		113x	Base::reset();
632		113x	iovec_count = 0;
633		113x	source_storage = {};
634		113x	source_addrlen = 0;
635		113x	source_out = nullptr;
636		113x	msg_flags = 0;
637		113x	}
638
639		40x	void perform_io() noexcept override
640			{
641		40x	msghdr msg{};
642		40x	msg.msg_name = &source_storage;
643		40x	msg.msg_namelen = sizeof(source_storage);
644		40x	msg.msg_iov = iovecs;
645		40x	msg.msg_iovlen = static_cast<std::size_t>(iovec_count);
646
647			ssize_t n;
648		40x	do
649			{
650	3/8 ✓ Branch 0 taken 23 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 14 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	40x	n = ::recvmsg(this->fd, &msg, msg_flags);
651		80x	}
652	7/16 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 22 times. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✓ Branch 9 taken 14 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	40x	while (n < 0 && errno == EINTR);
653
654	5/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 22 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 14 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	40x	if (n >= 0)
655			{
656		38x	source_addrlen = msg.msg_namelen;
657		38x	this->complete(0, static_cast<std::size_t>(n));
658		38x	}
659			else
660	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ 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);
661		40x	}
662			};
663
664			} // namespace boost::corosio::detail
665
666			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_HPP
667