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

93.5% Lines (272/291) 94.6% List of functions (87/92) 33.0% Branches (235/712)

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

reactor_stream_socket.hpp

f(x) Functions (92)

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_STREAM_SOCKET_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_SOCKET_HPP
12
13			#include <boost/corosio/tcp_socket.hpp>
14			#include <boost/corosio/shutdown_type.hpp>
15			#include <boost/corosio/wait_type.hpp>
16			#include <boost/corosio/native/detail/reactor/reactor_basic_socket.hpp>
17			#include <boost/corosio/native/detail/reactor/reactor_descriptor_state.hpp>
18			#include <boost/corosio/detail/dispatch_coro.hpp>
19			#include <boost/capy/buffers.hpp>
20
21			#include <coroutine>
22
23			#include <errno.h>
24			#include <sys/socket.h>
25			#include <sys/uio.h>
26
27			namespace boost::corosio::detail {
28
29			/** CRTP base for reactor-backed stream socket implementations.
30
31			Inherits shared data members and cancel/close/register logic
32			from reactor_basic_socket. Adds the stream-specific remote
33			endpoint, shutdown, and I/O dispatch (connect, read, write, wait).
34
35			@tparam Derived The concrete socket type (CRTP).
36			@tparam Service The backend's socket service type.
37			@tparam ConnOp The backend's connect op type.
38			@tparam ReadOp The backend's read op type.
39			@tparam WriteOp The backend's write op type.
40			@tparam WaitOp The backend's wait op type.
41			@tparam DescState The backend's descriptor_state type.
42			@tparam ImplBase The public vtable base
43			(tcp_socket::implementation or
44			local_stream_socket::implementation).
45			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
46			*/
47			template<
48			class Derived,
49			class Service,
50			class ConnOp,
51			class ReadOp,
52			class WriteOp,
53			class WaitOp,
54			class DescState,
55			class ImplBase = tcp_socket::implementation,
56			class Endpoint = endpoint>
57			class reactor_stream_socket
58			: public reactor_basic_socket<
59			Derived,
60			ImplBase,
61			Service,
62			DescState,
63			Endpoint>
64			{
65			using base_type = reactor_basic_socket<
66			Derived,
67			ImplBase,
68			Service,
69			DescState,
70			Endpoint>;
71			using self_type = reactor_stream_socket<
72			Derived, Service, ConnOp, ReadOp, WriteOp, WaitOp,
73			DescState, ImplBase, Endpoint>;
74			friend base_type;
75			friend Derived;
76
77			protected:
78			// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
79		17454x	explicit reactor_stream_socket(Service& svc) noexcept : base_type(svc) {}
80
81			protected:
82			Endpoint remote_endpoint_;
83
84			public:
85			/// Pending connect operation slot.
86			ConnOp conn_;
87
88			/// Pending read operation slot.
89			ReadOp rd_;
90
91			/// Pending write operation slot.
92			WriteOp wr_;
93
94			/// Pending wait-for-read operation slot.
95			WaitOp wait_rd_;
96
97			/// Pending wait-for-write operation slot.
98			WaitOp wait_wr_;
99
100			/// Pending wait-for-error operation slot.
101			WaitOp wait_er_;
102
103		17454x	~reactor_stream_socket() override = default;
104
105			/// Return the cached remote endpoint.
106		50x	Endpoint remote_endpoint() const noexcept override
107			{
108		50x	return remote_endpoint_;
109			}
110
111			// --- Virtual method overrides (satisfy ImplBase pure virtuals) ---
112
113		5754x	std::coroutine_handle<> connect(
114			std::coroutine_handle<> h,
115			capy::executor_ref ex,
116			Endpoint ep,
117			std::stop_token token,
118			std::error_code* ec) override
119			{
120		5754x	return do_connect(h, ex, ep, token, ec);
121			}
122
123		521104x	std::coroutine_handle<> read_some(
124			std::coroutine_handle<> h,
125			capy::executor_ref ex,
126			buffer_param param,
127			std::stop_token token,
128			std::error_code* ec,
129			std::size_t* bytes_out) override
130			{
131		521104x	return do_read_some(h, ex, param, token, ec, bytes_out);
132			}
133
134		613916x	std::coroutine_handle<> write_some(
135			std::coroutine_handle<> h,
136			capy::executor_ref ex,
137			buffer_param param,
138			std::stop_token token,
139			std::error_code* ec,
140			std::size_t* bytes_out) override
141			{
142		613916x	return do_write_some(h, ex, param, token, ec, bytes_out);
143			}
144
145		26x	std::coroutine_handle<> wait(
146			std::coroutine_handle<> h,
147			capy::executor_ref ex,
148			wait_type w,
149			std::stop_token token,
150			std::error_code* ec) override
151			{
152		26x	return do_wait(h, ex, w, token, ec);
153			}
154
155			std::error_code
156		14x	shutdown(corosio::shutdown_type what) noexcept override
157			{
158		14x	return do_shutdown(static_cast<int>(what));
159			}
160
161		166x	void cancel() noexcept override
162			{
163		166x	this->do_cancel();
164		166x	}
165
166			// --- End virtual overrides ---
167
168			/// Close the socket (non-virtual, called by the service).
169			void close_socket() noexcept
170			{
171			this->do_close_socket();
172			}
173
174			/** Shut down part or all of the full-duplex connection.
175
176			@param what 0 = receive, 1 = send, 2 = both.
177			*/
178		14x	std::error_code do_shutdown(int what) noexcept
179			{
180			int how;
181	6/16 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 2 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.	14x	switch (what)
182			{
183			case 0: // shutdown_receive
184		4x	how = SHUT_RD;
185		4x	break;
186			case 1: // shutdown_send
187		6x	how = SHUT_WR;
188		6x	break;
189			case 2: // shutdown_both
190		4x	how = SHUT_RDWR;
191		4x	break;
192			default:
193		✗	return make_err(EINVAL);
194			}
195	4/16 ✓ Branch 0 taken 7 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 7 times. ✓ Branch 4 taken 7 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 7 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.	14x	if (::shutdown(this->fd_, how) != 0)
196		✗	return make_err(errno);
197		14x	return {};
198		14x	}
199
200			/// Cache local and remote endpoints.
201		11492x	void set_endpoints(Endpoint local, Endpoint remote) noexcept
202			{
203		11492x	this->local_endpoint_ = std::move(local);
204		11492x	remote_endpoint_ = std::move(remote);
205		11492x	}
206
207			/** Shared connect dispatch.
208
209			Tries the connect syscall speculatively. On synchronous
210			completion, returns via inline budget or posts through queue.
211			On EINPROGRESS, registers with the reactor.
212			*/
213			std::coroutine_handle<> do_connect(
214			std::coroutine_handle<>,
215			capy::executor_ref,
216			Endpoint const&,
217			std::stop_token const&,
218			std::error_code*);
219
220			/** Shared scatter-read dispatch.
221
222			Tries readv() speculatively. On success or hard error,
223			returns via inline budget or posts through queue.
224			On EAGAIN, registers with the reactor.
225			*/
226			std::coroutine_handle<> do_read_some(
227			std::coroutine_handle<>,
228			capy::executor_ref,
229			buffer_param,
230			std::stop_token const&,
231			std::error_code*,
232			std::size_t*);
233
234			/** Shared gather-write dispatch.
235
236			Tries the write via WriteOp::write_policy speculatively.
237			On success or hard error, returns via inline budget or
238			posts through queue. On EAGAIN, registers with the reactor.
239			*/
240			std::coroutine_handle<> do_write_some(
241			std::coroutine_handle<>,
242			capy::executor_ref,
243			buffer_param,
244			std::stop_token const&,
245			std::error_code*,
246			std::size_t*);
247
248			/** Shared readiness-wait dispatch.
249
250			Registers a wait op for the requested direction. Does not
251			perform any I/O syscall — completion is signalled when the
252			reactor delivers the matching edge event.
253			*/
254			std::coroutine_handle<> do_wait(
255			std::coroutine_handle<>,
256			capy::executor_ref,
257			wait_type,
258			std::stop_token const&,
259			std::error_code*);
260
261			/** Close the socket and cancel pending operations.
262
263			Extends the base do_close_socket() to also reset
264			the remote endpoint.
265			*/
266		52352x	void do_close_socket() noexcept
267			{
268		52352x	base_type::do_close_socket();
269		52352x	remote_endpoint_ = Endpoint{};
270		52352x	}
271
272			private:
273			// CRTP callbacks for reactor_basic_socket cancel/close
274
275			template<class Op>
276		513x	reactor_op_base** op_to_desc_slot(Op& op) noexcept
277			{
278	2/8 ✓ Branch 0 taken 472 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 41 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	513x	if (&op == static_cast<void*>(&conn_))
279		✗	return &this->desc_state_.connect_op;
280	4/8 ✓ Branch 0 taken 3 times. ✓ Branch 1 taken 469 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 39 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	513x	if (&op == static_cast<void*>(&rd_))
281		508x	return &this->desc_state_.read_op;
282	3/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 1 time. ✓ 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.	5x	if (&op == static_cast<void*>(&wr_))
283		1x	return &this->desc_state_.write_op;
284	4/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	4x	if (&op == static_cast<void*>(&wait_rd_))
285		2x	return &this->desc_state_.wait_read_op;
286	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 (&op == static_cast<void*>(&wait_wr_))
287		✗	return &this->desc_state_.wait_write_op;
288	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (&op == static_cast<void*>(&wait_er_))
289		2x	return &this->desc_state_.wait_error_op;
290		✗	return nullptr;
291		513x	}
292
293			template<class Op>
294		2x	bool* op_to_cancel_flag(Op& op) noexcept
295			{
296	1/8 ✓ Branch 0 taken 2 times. ✗ 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.	2x	if (&op == static_cast<void*>(&conn_))
297		✗	return &this->desc_state_.connect_cancel_pending;
298	2/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (&op == static_cast<void*>(&rd_))
299		1x	return &this->desc_state_.read_cancel_pending;
300	1/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ 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	if (&op == static_cast<void*>(&wr_))
301		1x	return &this->desc_state_.write_cancel_pending;
302		✗	if (&op == static_cast<void*>(&wait_rd_))
303		✗	return &this->desc_state_.wait_read_cancel_pending;
304		✗	if (&op == static_cast<void*>(&wait_wr_))
305		✗	return &this->desc_state_.wait_write_cancel_pending;
306		✗	if (&op == static_cast<void*>(&wait_er_))
307		✗	return &this->desc_state_.wait_error_cancel_pending;
308		✗	return nullptr;
309		2x	}
310
311			template<class Fn>
312		52520x	void for_each_op(Fn fn) noexcept
313			{
314	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(conn_);
315	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(rd_);
316	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wr_);
317	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_rd_);
318	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_wr_);
319	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_er_);
320		52520x	}
321
322			template<class Fn>
323		52520x	void for_each_desc_entry(Fn fn) noexcept
324			{
325	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(conn_, this->desc_state_.connect_op);
326	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(rd_, this->desc_state_.read_op);
327	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wr_, this->desc_state_.write_op);
328	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_rd_, this->desc_state_.wait_read_op);
329	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_wr_, this->desc_state_.wait_write_op);
330	6/20 ✓ Branch 0 taken 17070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 46 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 223 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 34958 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 222 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	52520x	fn(wait_er_, this->desc_state_.wait_error_op);
331		52520x	}
332			};
333
334			template<
335			class Derived,
336			class Service,
337			class ConnOp,
338			class ReadOp,
339			class WriteOp,
340			class WaitOp,
341			class DescState,
342			class ImplBase,
343			class Endpoint>
344			std::coroutine_handle<>
345			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, WaitOp, DescState, ImplBase, Endpoint>::
346		5754x	do_connect(
347			std::coroutine_handle<> h,
348			capy::executor_ref ex,
349			Endpoint const& ep,
350			std::stop_token const& token,
351			std::error_code* ec)
352			{
353		5754x	auto& op = conn_;
354
355		5754x	sockaddr_storage storage{};
356		5754x	socklen_t addrlen = to_sockaddr(ep, socket_family(this->fd_), storage);
357		5754x	int result =
358		5754x	::connect(this->fd_, reinterpret_cast<sockaddr*>(&storage), addrlen);
359
360	4/8 ✓ Branch 0 taken 3858 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 1878 times. ✓ Branch 3 taken 9 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5754x	if (result == 0)
361			{
362		18x	sockaddr_storage local_storage{};
363		18x	socklen_t local_len = sizeof(local_storage);
364	4/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 9 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 9 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 9 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 9 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.	36x	if (::getsockname(
365		18x	this->fd_, reinterpret_cast<sockaddr*>(&local_storage),
366		18x	&local_len) == 0)
367		18x	this->local_endpoint_ =
368		18x	from_sockaddr_as(local_storage, local_len, Endpoint{});
369		18x	remote_endpoint_ = ep;
370		18x	}
371
372	8/16 ✓ Branch 0 taken 3858 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 3856 times. ✓ Branch 4 taken 1878 times. ✓ Branch 5 taken 9 times. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 1876 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.	5754x	if (result == 0 \|\| errno != EINPROGRESS)
373			{
374	4/8 ✓ Branch 0 taken 9 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 9 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	22x	int err = (result < 0) ? errno : 0;
375	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 11 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 11 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	22x	if (this->svc_.scheduler().try_consume_inline_budget())
376			{
377		✗	*ec = err ? make_err(err) : std::error_code{};
378		✗	op.cont_op.cont.h = h;
379		✗	return dispatch_coro(ex, op.cont_op.cont);
380			}
381		22x	op.reset();
382		22x	op.h = h;
383		22x	op.ex = ex;
384		22x	op.ec_out = ec;
385		22x	op.fd = this->fd_;
386		22x	op.target_endpoint = ep;
387		22x	op.start(token, static_cast<Derived*>(this));
388	0/4 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken.	22x	op.impl_ptr = this->shared_from_this();
389		22x	op.complete(err, 0);
390		22x	this->svc_.post(&op);
391		22x	return std::noop_coroutine();
392			}
393
394			// EINPROGRESS — register with reactor
395		5732x	op.reset();
396		5732x	op.h = h;
397		5732x	op.ex = ex;
398		5732x	op.ec_out = ec;
399		5732x	op.fd = this->fd_;
400		5732x	op.target_endpoint = ep;
401		5732x	op.start(token, static_cast<Derived*>(this));
402	0/4 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken.	5732x	op.impl_ptr = this->shared_from_this();
403
404		5732x	this->register_op(
405		5732x	op, this->desc_state_.connect_op, this->desc_state_.write_ready,
406		5732x	this->desc_state_.connect_cancel_pending, true);
407		5732x	return std::noop_coroutine();
408		5754x	}
409
410			template<
411			class Derived,
412			class Service,
413			class ConnOp,
414			class ReadOp,
415			class WriteOp,
416			class WaitOp,
417			class DescState,
418			class ImplBase,
419			class Endpoint>
420			std::coroutine_handle<>
421			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, WaitOp, DescState, ImplBase, Endpoint>::
422		521104x	do_read_some(
423			std::coroutine_handle<> h,
424			capy::executor_ref ex,
425			buffer_param param,
426			std::stop_token const& token,
427			std::error_code* ec,
428			std::size_t* bytes_out)
429			{
430		521104x	auto& op = rd_;
431		521104x	op.reset();
432
433		521104x	capy::mutable_buffer bufs[ReadOp::max_buffers];
434		521104x	op.iovec_count = static_cast<int>(param.copy_to(bufs, ReadOp::max_buffers));
435
436	10/24 ✓ Branch 0 taken 235451 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 235449 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 235449 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 285651 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 285649 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 285649 times. ✗ 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.	521104x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
437			{
438		2x	op.empty_buffer_read = true;
439		2x	op.h = h;
440		2x	op.ex = ex;
441		2x	op.ec_out = ec;
442		2x	op.bytes_out = bytes_out;
443		2x	op.start(token, static_cast<Derived*>(this));
444	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	op.impl_ptr = this->shared_from_this();
445		2x	op.complete(0, 0);
446		2x	this->svc_.post(&op);
447		2x	return std::noop_coroutine();
448			}
449
450	4/8 ✓ Branch 0 taken 235455 times. ✓ Branch 1 taken 235451 times. ✓ Branch 2 taken 285655 times. ✓ Branch 3 taken 285651 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	1042212x	for (int i = 0; i < op.iovec_count; ++i)
451			{
452		521110x	op.iovecs[i].iov_base = bufs[i].data();
453		521110x	op.iovecs[i].iov_len = bufs[i].size();
454		521110x	}
455
456			// Speculative read; for the single-buffer case use recv() so the
457			// kernel skips the readv iov_iter setup.
458			ssize_t n;
459	4/8 ✓ Branch 0 taken 235449 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 285649 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	521102x	if (op.iovec_count == 1)
460			{
461		521098x	do
462			{
463		521098x	n = ::recv(this->fd_, bufs[0].data(), bufs[0].size(), 0);
464		1042196x	}
465	4/8 ✓ Branch 0 taken 192288 times. ✓ Branch 1 taken 43161 times. ✓ Branch 2 taken 255807 times. ✓ Branch 3 taken 29842 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	521098x	while (n < 0 && errno == EINTR);
466		521098x	}
467			else
468			{
469		4x	do
470			{
471		4x	n = ::readv(this->fd_, op.iovecs, op.iovec_count);
472		8x	}
473	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 2 times. ✗ 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.	4x	while (n < 0 && errno == EINTR);
474			}
475
476	8/24 ✓ Branch 0 taken 43163 times. ✓ Branch 1 taken 192288 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 43162 times. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 29844 times. ✓ Branch 7 taken 255807 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 29844 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. ✗ 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.	521102x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
477			{
478	3/8 ✓ Branch 0 taken 192288 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 255807 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	448096x	int err = (n < 0) ? errno : 0;
479	4/8 ✓ Branch 0 taken 192277 times. ✓ Branch 1 taken 12 times. ✓ Branch 2 taken 255802 times. ✓ Branch 3 taken 5 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	448096x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
480
481	4/8 ✓ Branch 0 taken 155304 times. ✓ Branch 1 taken 36985 times. ✓ Branch 2 taken 205336 times. ✓ Branch 3 taken 50471 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	448096x	if (this->svc_.scheduler().try_consume_inline_budget())
482			{
483	3/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 155303 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 205336 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	360640x	if (err)
484		1x	*ec = make_err(err);
485	4/8 ✓ Branch 0 taken 155294 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 205331 times. ✓ Branch 3 taken 5 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	360639x	else if (n == 0)
486		14x	*ec = capy::error::eof;
487			else
488		360625x	*ec = {};
489		360640x	*bytes_out = bytes;
490		360640x	op.cont_op.cont.h = h;
491		360640x	return dispatch_coro(ex, op.cont_op.cont);
492			}
493		87456x	op.h = h;
494		87456x	op.ex = ex;
495		87456x	op.ec_out = ec;
496		87456x	op.bytes_out = bytes_out;
497		87456x	op.start(token, static_cast<Derived*>(this));
498	2/8 ✓ Branch 0 taken 36985 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 50471 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	87456x	op.impl_ptr = this->shared_from_this();
499		87456x	op.complete(err, bytes);
500		87456x	this->svc_.post(&op);
501		87456x	return std::noop_coroutine();
502			}
503
504			// EAGAIN — register with reactor
505		73006x	op.h = h;
506		73006x	op.ex = ex;
507		73006x	op.ec_out = ec;
508		73006x	op.bytes_out = bytes_out;
509		73006x	op.fd = this->fd_;
510		73006x	op.start(token, static_cast<Derived*>(this));
511	2/8 ✓ Branch 0 taken 43162 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 29844 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	73006x	op.impl_ptr = this->shared_from_this();
512
513		73006x	this->register_op(
514		73006x	op, this->desc_state_.read_op, this->desc_state_.read_ready,
515		73006x	this->desc_state_.read_cancel_pending);
516		73006x	return std::noop_coroutine();
517		521104x	}
518
519			template<
520			class Derived,
521			class Service,
522			class ConnOp,
523			class ReadOp,
524			class WriteOp,
525			class WaitOp,
526			class DescState,
527			class ImplBase,
528			class Endpoint>
529			std::coroutine_handle<>
530			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, WaitOp, DescState, ImplBase, Endpoint>::
531		613916x	do_write_some(
532			std::coroutine_handle<> h,
533			capy::executor_ref ex,
534			buffer_param param,
535			std::stop_token const& token,
536			std::error_code* ec,
537			std::size_t* bytes_out)
538			{
539		613916x	auto& op = wr_;
540		613916x	op.reset();
541
542		613916x	capy::mutable_buffer bufs[WriteOp::max_buffers];
543		613916x	op.iovec_count =
544		613916x	static_cast<int>(param.copy_to(bufs, WriteOp::max_buffers));
545
546	10/24 ✓ Branch 0 taken 326554 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 326552 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 326552 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 287360 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 287358 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 287358 times. ✗ 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.	613916x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
547			{
548		2x	op.h = h;
549		2x	op.ex = ex;
550		2x	op.ec_out = ec;
551		2x	op.bytes_out = bytes_out;
552		2x	op.start(token, static_cast<Derived*>(this));
553		2x	op.impl_ptr = this->shared_from_this();
554		2x	op.complete(0, 0);
555		2x	this->svc_.post(&op);
556		2x	return std::noop_coroutine();
557			}
558
559	4/8 ✓ Branch 0 taken 326558 times. ✓ Branch 1 taken 326554 times. ✓ Branch 2 taken 287364 times. ✓ Branch 3 taken 287360 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	1227836x	for (int i = 0; i < op.iovec_count; ++i)
560			{
561		613922x	op.iovecs[i].iov_base = bufs[i].data();
562		613922x	op.iovecs[i].iov_len = bufs[i].size();
563		613922x	}
564
565			// Speculative write; the single-buffer case dispatches to a
566			// backend-specific fast path so the kernel skips msghdr/iov_iter
567			// setup (and so each backend can pick the right SIGPIPE strategy).
568			ssize_t n;
569	4/8 ✓ Branch 0 taken 326552 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 287358 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	613914x	if (op.iovec_count == 1)
570			{
571		613910x	n = WriteOp::write_policy::write_one(
572		613910x	this->fd_, bufs[0].data(), bufs[0].size());
573		613910x	}
574			else
575			{
576		4x	n = WriteOp::write_policy::write(
577		4x	this->fd_, op.iovecs, op.iovec_count);
578			}
579
580	10/24 ✓ Branch 0 taken 240 times. ✓ Branch 1 taken 326314 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 239 times. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 255 times. ✓ Branch 7 taken 287105 times. ✓ Branch 8 taken 1 time. ✓ Branch 9 taken 254 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. ✗ 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.	613914x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
581			{
582	4/8 ✓ Branch 0 taken 326314 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 287105 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	613421x	int err = (n < 0) ? errno : 0;
583	4/8 ✓ Branch 0 taken 326314 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 287105 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	613421x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
584
585	4/8 ✓ Branch 0 taken 266780 times. ✓ Branch 1 taken 59535 times. ✓ Branch 2 taken 235806 times. ✓ Branch 3 taken 51300 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	613421x	if (this->svc_.scheduler().try_consume_inline_budget())
586			{
587	4/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 266779 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 235805 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	502586x	*ec = err ? make_err(err) : std::error_code{};
588		502586x	*bytes_out = bytes;
589		502586x	op.cont_op.cont.h = h;
590		502586x	return dispatch_coro(ex, op.cont_op.cont);
591			}
592		110835x	op.h = h;
593		110835x	op.ex = ex;
594		110835x	op.ec_out = ec;
595		110835x	op.bytes_out = bytes_out;
596		110835x	op.start(token, static_cast<Derived*>(this));
597		110835x	op.impl_ptr = this->shared_from_this();
598		110835x	op.complete(err, bytes);
599		110835x	this->svc_.post(&op);
600		110835x	return std::noop_coroutine();
601			}
602
603			// EAGAIN — register with reactor
604		493x	op.h = h;
605		493x	op.ex = ex;
606		493x	op.ec_out = ec;
607		493x	op.bytes_out = bytes_out;
608		493x	op.fd = this->fd_;
609		493x	op.start(token, static_cast<Derived*>(this));
610		493x	op.impl_ptr = this->shared_from_this();
611
612		493x	this->register_op(
613		493x	op, this->desc_state_.write_op, this->desc_state_.write_ready,
614		493x	this->desc_state_.write_cancel_pending, true);
615		493x	return std::noop_coroutine();
616		613916x	}
617
618			template<
619			class Derived,
620			class Service,
621			class ConnOp,
622			class ReadOp,
623			class WriteOp,
624			class WaitOp,
625			class DescState,
626			class ImplBase,
627			class Endpoint>
628			std::coroutine_handle<>
629			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, WaitOp, DescState, ImplBase, Endpoint>::
630		26x	do_wait(
631			std::coroutine_handle<> h,
632			capy::executor_ref ex,
633			wait_type w,
634			std::stop_token const& token,
635			std::error_code* ec)
636			{
637			// wait_type::write completes immediately on a connected socket,
638			// matching asio's behavior on IOCP. Corosio's reactor backends use
639			// edge-triggered EPOLLOUT, which would never fire on an already-
640			// writable socket; an immediate completion is also a more useful
641			// contract than parking until a non-writable -> writable transition.
642	4/8 ✓ Branch 0 taken 4 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 4 times. ✓ Branch 3 taken 9 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	26x	if (w == wait_type::write)
643			{
644		8x	auto& op = wait_wr_;
645	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 4 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.	8x	if (this->svc_.scheduler().try_consume_inline_budget())
646			{
647		✗	*ec = std::error_code{};
648		✗	op.cont_op.cont.h = h;
649		✗	return dispatch_coro(ex, op.cont_op.cont);
650			}
651		8x	op.reset();
652		8x	op.wait_event = reactor_event_write;
653		8x	op.h = h;
654		8x	op.ex = ex;
655		8x	op.ec_out = ec;
656		8x	op.fd = this->fd_;
657		8x	op.start(token, static_cast<Derived*>(this));
658		8x	op.impl_ptr = this->shared_from_this();
659		8x	op.complete(0, 0);
660		8x	this->svc_.post(&op);
661		8x	return std::noop_coroutine();
662			}
663
664			// Pick refs up-front to avoid duplicating the register_op call.
665			WaitOp* op_ptr;
666			reactor_op_base** desc_slot_ptr;
667			bool* ready_flag_ptr;
668			bool* cancel_flag_ptr;
669			std::uint32_t event;
670
671		18x	bool dummy_ready = false; // placeholder for error waits (no cached edge)
672
673	4/8 ✓ Branch 0 taken 5 times. ✓ Branch 1 taken 4 times. ✓ Branch 2 taken 5 times. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	18x	if (w == wait_type::read)
674			{
675		8x	op_ptr = &wait_rd_;
676		8x	desc_slot_ptr = &this->desc_state_.wait_read_op;
677		8x	ready_flag_ptr = &this->desc_state_.read_ready;
678		8x	cancel_flag_ptr = &this->desc_state_.wait_read_cancel_pending;
679		8x	event = reactor_event_read;
680		8x	}
681			else // wait_type::error
682			{
683		10x	op_ptr = &wait_er_;
684		10x	desc_slot_ptr = &this->desc_state_.wait_error_op;
685		10x	ready_flag_ptr = &dummy_ready;
686		10x	cancel_flag_ptr = &this->desc_state_.wait_error_cancel_pending;
687		10x	event = reactor_event_error;
688			}
689
690		18x	auto& op = *op_ptr;
691		18x	op.reset();
692		18x	op.wait_event = event;
693		18x	op.h = h;
694		18x	op.ex = ex;
695		18x	op.ec_out = ec;
696		18x	op.fd = this->fd_;
697		18x	op.start(token, static_cast<Derived*>(this));
698		18x	op.impl_ptr = this->shared_from_this();
699
700		18x	this->register_op(op, desc_slot_ptr, ready_flag_ptr, *cancel_flag_ptr,
701			false);
702		18x	return std::noop_coroutine();
703		26x	}
704
705			} // namespace boost::corosio::detail
706
707			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_SOCKET_HPP
708