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

99.3% Lines (296/298) 100.0% List of functions (96/96) 51.5% Branches (387/752)

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

reactor_stream_socket.hpp

f(x) Functions (96)

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 =
66			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>;
67			using self_type = reactor_stream_socket<
68			Derived,
69			Service,
70			ConnOp,
71			ReadOp,
72			WriteOp,
73			WaitOp,
74			DescState,
75			ImplBase,
76			Endpoint>;
77			friend base_type;
78			friend Derived;
79
80			protected:
81			// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
82		19996x	explicit reactor_stream_socket(Service& svc) noexcept : base_type(svc) {}
83
84			protected:
85			Endpoint remote_endpoint_;
86
87			public:
88			/// Pending connect operation slot.
89			ConnOp conn_;
90
91			/// Pending read operation slot.
92			ReadOp rd_;
93
94			/// Pending write operation slot.
95			WriteOp wr_;
96
97			/// Pending wait-for-read operation slot.
98			WaitOp wait_rd_;
99
100			/// Pending wait-for-write operation slot.
101			WaitOp wait_wr_;
102
103			/// Pending wait-for-error operation slot.
104			WaitOp wait_er_;
105
106		19996x	~reactor_stream_socket() override = default;
107
108			/// Return the cached remote endpoint.
109		62x	Endpoint remote_endpoint() const noexcept override
110			{
111		62x	return remote_endpoint_;
112			}
113
114			// --- Virtual method overrides (satisfy ImplBase pure virtuals) ---
115
116		6435x	std::coroutine_handle<> connect(
117			std::coroutine_handle<> h,
118			capy::executor_ref ex,
119			Endpoint ep,
120			std::stop_token token,
121			std::error_code* ec) override
122			{
123		6435x	return do_connect(h, ex, ep, token, ec);
124			}
125
126		467456x	std::coroutine_handle<> read_some(
127			std::coroutine_handle<> h,
128			capy::executor_ref ex,
129			buffer_param param,
130			std::stop_token token,
131			std::error_code* ec,
132			std::size_t* bytes_out) override
133			{
134		467456x	return do_read_some(h, ex, param, token, ec, bytes_out);
135			}
136
137		502784x	std::coroutine_handle<> write_some(
138			std::coroutine_handle<> h,
139			capy::executor_ref ex,
140			buffer_param param,
141			std::stop_token token,
142			std::error_code* ec,
143			std::size_t* bytes_out) override
144			{
145		502784x	return do_write_some(h, ex, param, token, ec, bytes_out);
146			}
147
148		95x	std::coroutine_handle<> wait(
149			std::coroutine_handle<> h,
150			capy::executor_ref ex,
151			wait_type w,
152			std::stop_token token,
153			std::error_code* ec) override
154			{
155		95x	return do_wait(h, ex, w, token, ec);
156			}
157
158		26x	std::error_code shutdown(corosio::shutdown_type what) noexcept override
159			{
160		26x	return do_shutdown(static_cast<int>(what));
161			}
162
163		226x	void cancel() noexcept override
164			{
165		226x	this->do_cancel();
166		226x	}
167
168			// --- End virtual overrides ---
169
170			/// Close the socket (non-virtual, called by the service).
171			void close_socket() noexcept
172			{
173			this->do_close_socket();
174			}
175
176			/** Shut down part or all of the full-duplex connection.
177
178			@param what 0 = receive, 1 = send, 2 = both.
179			*/
180		26x	std::error_code do_shutdown(int what) noexcept
181			{
182			int how;
183	7/16 ✓ Branch 0 taken 14 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 taken 1 time. ✗ 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.	26x	switch (what)
184			{
185			case 0: // shutdown_receive
186		4x	how = SHUT_RD;
187		4x	break;
188			case 1: // shutdown_send
189		18x	how = SHUT_WR;
190		18x	break;
191			case 2: // shutdown_both
192		4x	how = SHUT_RDWR;
193		4x	break;
194			default:
195		✗	return make_err(EINVAL);
196			}
197	7/16 ✓ Branch 0 taken 18 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 17 times. ✓ Branch 4 taken 7 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 7 times. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✓ 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.	26x	if (::shutdown(this->fd_, how) != 0)
198	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	return make_err(errno);
199		24x	return {};
200		26x	}
201
202			/// Cache local and remote endpoints.
203		12897x	void set_endpoints(Endpoint local, Endpoint remote) noexcept
204			{
205		12897x	this->local_endpoint_ = std::move(local);
206		12897x	remote_endpoint_ = std::move(remote);
207		12897x	}
208
209			/** Shared connect dispatch.
210
211			Tries the connect syscall speculatively. On synchronous
212			completion, returns via inline budget or posts through queue.
213			On EINPROGRESS, registers with the reactor.
214			*/
215			std::coroutine_handle<> do_connect(
216			std::coroutine_handle<>,
217			capy::executor_ref,
218			Endpoint const&,
219			std::stop_token const&,
220			std::error_code*);
221
222			/** Shared scatter-read dispatch.
223
224			Tries readv() speculatively. On success or hard error,
225			returns via inline budget or posts through queue.
226			On EAGAIN, registers with the reactor.
227			*/
228			std::coroutine_handle<> do_read_some(
229			std::coroutine_handle<>,
230			capy::executor_ref,
231			buffer_param,
232			std::stop_token const&,
233			std::error_code*,
234			std::size_t*);
235
236			/** Shared gather-write dispatch.
237
238			Tries the write via WriteOp::write_policy speculatively.
239			On success or hard error, returns via inline budget or
240			posts through queue. On EAGAIN, registers with the reactor.
241			*/
242			std::coroutine_handle<> do_write_some(
243			std::coroutine_handle<>,
244			capy::executor_ref,
245			buffer_param,
246			std::stop_token const&,
247			std::error_code*,
248			std::size_t*);
249
250			/** Shared readiness-wait dispatch.
251
252			Every wait type probes the descriptor with a zero-timeout
253			`poll()` and completes at once if the condition already
254			holds; otherwise the op re-probes under the descriptor mutex
255			and parks, completing when a reactor event arrives and a
256			fresh probe confirms the condition. A write wait therefore
257			completes only while a non-blocking write can make progress.
258			*/
259			std::coroutine_handle<> do_wait(
260			std::coroutine_handle<>,
261			capy::executor_ref,
262			wait_type,
263			std::stop_token const&,
264			std::error_code*);
265
266			/** Close the socket and cancel pending operations.
267
268			Extends the base do_close_socket() to also reset
269			the remote endpoint.
270			*/
271		59673x	void do_close_socket() noexcept
272			{
273		59673x	base_type::do_close_socket();
274		59673x	remote_endpoint_ = Endpoint{};
275		59673x	}
276
277			/// Release ownership of the descriptor and drop the cached peer.
278		8x	native_handle_type do_release_socket() noexcept
279			{
280		8x	auto fd = base_type::do_release_socket();
281		8x	remote_endpoint_ = Endpoint{};
282		8x	return fd;
283			}
284
285			private:
286			// CRTP callbacks for reactor_basic_socket cancel/close
287
288			template<class Op>
289		714x	reactor_op_base** op_to_desc_slot(Op& op) noexcept
290			{
291	4/8 ✓ Branch 0 taken 650 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 59 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	714x	if (&op == static_cast<void*>(&conn_))
292		5x	return &this->desc_state_.connect_op;
293	4/8 ✓ Branch 0 taken 11 times. ✓ Branch 1 taken 639 times. ✓ Branch 2 taken 9 times. ✓ Branch 3 taken 50 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	709x	if (&op == static_cast<void*>(&rd_))
294		689x	return &this->desc_state_.read_op;
295	4/8 ✓ Branch 0 taken 8 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 7 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	20x	if (&op == static_cast<void*>(&wr_))
296		5x	return &this->desc_state_.write_op;
297	4/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 6 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 5 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	15x	if (&op == static_cast<void*>(&wait_rd_))
298		11x	return &this->desc_state_.wait_read_op;
299	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_wr_))
300		2x	return &this->desc_state_.wait_write_op;
301	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_))
302		2x	return &this->desc_state_.wait_error_op;
303		✗	return nullptr;
304		714x	}
305
306			template<class Fn>
307		59907x	void for_each_op(Fn fn) noexcept
308			{
309	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(conn_);
310	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(rd_);
311	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wr_);
312	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_rd_);
313	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_wr_);
314	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_er_);
315		59907x	}
316
317			template<class Fn>
318		59907x	void for_each_desc_entry(Fn fn) noexcept
319			{
320	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(conn_, this->desc_state_.connect_op);
321	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(rd_, this->desc_state_.read_op);
322	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wr_, this->desc_state_.write_op);
323	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_rd_, this->desc_state_.wait_read_op);
324	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_wr_, this->desc_state_.wait_write_op);
325	8/24 ✓ Branch 0 taken 238 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 160 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42547 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 34 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 66 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16191 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 627 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 44 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	59907x	fn(wait_er_, this->desc_state_.wait_error_op);
326		59907x	}
327			};
328
329			template<
330			class Derived,
331			class Service,
332			class ConnOp,
333			class ReadOp,
334			class WriteOp,
335			class WaitOp,
336			class DescState,
337			class ImplBase,
338			class Endpoint>
339			std::coroutine_handle<>
340			reactor_stream_socket<
341			Derived,
342			Service,
343			ConnOp,
344			ReadOp,
345			WriteOp,
346			WaitOp,
347			DescState,
348			ImplBase,
349			Endpoint>::
350		6435x	do_connect(
351			std::coroutine_handle<> h,
352			capy::executor_ref ex,
353			Endpoint const& ep,
354			std::stop_token const& token,
355			std::error_code* ec)
356			{
357		6435x	auto& op = conn_;
358
359		6435x	sockaddr_storage storage{};
360		6435x	socklen_t addrlen = to_sockaddr(ep, socket_family(this->fd_), storage);
361		6435x	int result =
362		6435x	::connect(this->fd_, reinterpret_cast<sockaddr*>(&storage), addrlen);
363
364	6/8 ✓ Branch 0 taken 4608 times. ✓ Branch 1 taken 15 times. ✓ Branch 2 taken 1725 times. ✓ Branch 3 taken 15 times. ✓ Branch 4 taken 71 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	6435x	if (result == 0)
365			{
366		31x	sockaddr_storage local_storage{};
367		31x	socklen_t local_len = sizeof(local_storage);
368	6/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 15 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 15 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 15 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 15 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✓ Branch 13 taken 1 time. ✗ Branch 14 not taken. ✓ Branch 15 taken 1 time.	62x	if (::getsockname(
369		31x	this->fd_, reinterpret_cast<sockaddr*>(&local_storage),
370		31x	&local_len) == 0)
371		31x	this->local_endpoint_ =
372		31x	from_sockaddr_as(local_storage, local_len, Endpoint{});
373		31x	remote_endpoint_ = ep;
374		31x	}
375
376	12/16 ✓ Branch 0 taken 4608 times. ✓ Branch 1 taken 15 times. ✓ Branch 2 taken 6 times. ✓ Branch 3 taken 4602 times. ✓ Branch 4 taken 1725 times. ✓ Branch 5 taken 15 times. ✓ Branch 6 taken 4 times. ✓ Branch 7 taken 1721 times. ✓ Branch 8 taken 71 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 69 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 1 time. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	6435x	if (result == 0 \|\| errno != EINPROGRESS)
377			{
378	6/8 ✓ Branch 0 taken 15 times. ✓ Branch 1 taken 6 times. ✓ Branch 2 taken 15 times. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	43x	int err = (result < 0) ? errno : 0;
379	6/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 19 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 17 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	43x	if (this->svc_.scheduler().try_consume_inline_budget())
380			{
381	2/8 ✓ 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.	4x	*ec = err ? make_err(err) : std::error_code{};
382		4x	op.cont.h = h;
383		4x	return dispatch_coro(ex, op.cont);
384			}
385		39x	op.reset();
386		39x	op.h = h;
387		39x	op.ex = ex;
388		39x	op.ec_out = ec;
389		39x	op.fd = this->fd_;
390		39x	op.target_endpoint = ep;
391		39x	op.start(token, static_cast<Derived*>(this));
392	0/4 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken.	39x	op.impl_ptr = this->shared_from_this();
393		39x	op.complete(err, 0);
394		39x	this->svc_.post(&op);
395		39x	return std::noop_coroutine();
396			}
397
398			// EINPROGRESS — register with reactor
399		6392x	op.reset();
400		6392x	op.h = h;
401		6392x	op.ex = ex;
402		6392x	op.ec_out = ec;
403		6392x	op.fd = this->fd_;
404		6392x	op.target_endpoint = ep;
405		6392x	op.start(token, static_cast<Derived*>(this));
406	0/4 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken.	6392x	op.impl_ptr = this->shared_from_this();
407
408		6392x	this->register_op(
409		6392x	op, this->desc_state_.connect_op, this->desc_state_.write_ready, true);
410		6392x	return std::noop_coroutine();
411		6435x	}
412
413			template<
414			class Derived,
415			class Service,
416			class ConnOp,
417			class ReadOp,
418			class WriteOp,
419			class WaitOp,
420			class DescState,
421			class ImplBase,
422			class Endpoint>
423			std::coroutine_handle<>
424			reactor_stream_socket<
425			Derived,
426			Service,
427			ConnOp,
428			ReadOp,
429			WriteOp,
430			WaitOp,
431			DescState,
432			ImplBase,
433			Endpoint>::
434		467456x	do_read_some(
435			std::coroutine_handle<> h,
436			capy::executor_ref ex,
437			buffer_param param,
438			std::stop_token const& token,
439			std::error_code* ec,
440			std::size_t* bytes_out)
441			{
442		467456x	auto& op = rd_;
443		467456x	op.reset();
444
445			// Closed-object contract: complete with bad_file_descriptor without
446			// touching the kernel or the unregistered descriptor state.
447	6/8 ✓ Branch 0 taken 229190 times. ✓ Branch 1 taken 93 times. ✓ Branch 2 taken 238103 times. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 65 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	467456x	if (this->fd_ < 0)
448			{
449		97x	op.h = h;
450		97x	op.ex = ex;
451		97x	op.ec_out = ec;
452		97x	op.bytes_out = bytes_out;
453		97x	op.start(token, static_cast<Derived*>(this));
454	2/8 ✓ Branch 0 taken 93 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.	97x	op.impl_ptr = this->shared_from_this();
455		97x	op.complete(EBADF, 0);
456		97x	this->svc_.post(&op);
457		97x	return std::noop_coroutine();
458			}
459
460		467359x	capy::mutable_buffer bufs[ReadOp::max_buffers];
461		467359x	op.iovec_count = static_cast<int>(param.copy_to(bufs, ReadOp::max_buffers));
462
463	17/24 ✓ Branch 0 taken 229188 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 229179 times. ✓ Branch 3 taken 9 times. ✓ Branch 4 taken 229179 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 238101 times. ✓ Branch 7 taken 2 times. ✓ Branch 8 taken 238099 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 238099 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 65 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 62 times. ✓ Branch 15 taken 3 times. ✓ Branch 16 taken 62 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 1 time. ✗ Branch 19 not taken. ✓ Branch 20 taken 1 time. ✗ Branch 21 not taken. ✓ Branch 22 taken 1 time. ✗ Branch 23 not taken.	467359x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
464			{
465		4x	op.empty_buffer_read = true;
466		4x	op.h = h;
467		4x	op.ex = ex;
468		4x	op.ec_out = ec;
469		4x	op.bytes_out = bytes_out;
470		4x	op.start(token, static_cast<Derived*>(this));
471	2/8 ✓ 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.	4x	op.impl_ptr = this->shared_from_this();
472		4x	op.complete(0, 0);
473		4x	this->svc_.post(&op);
474		4x	return std::noop_coroutine();
475			}
476
477	8/8 ✓ Branch 0 taken 229199 times. ✓ Branch 1 taken 229188 times. ✓ Branch 2 taken 238105 times. ✓ Branch 3 taken 238101 times. ✓ Branch 4 taken 68 times. ✓ Branch 5 taken 65 times. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 1 time.	934728x	for (int i = 0; i < op.iovec_count; ++i)
478			{
479		467373x	op.iovecs[i].iov_base = bufs[i].data();
480		467373x	op.iovecs[i].iov_len = bufs[i].size();
481		467373x	}
482
483			// Speculative read; for the single-buffer case use recv() so the
484			// kernel skips the readv iov_iter setup.
485			ssize_t n;
486	7/8 ✓ Branch 0 taken 229179 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 238099 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 62 times. ✓ Branch 5 taken 3 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	467355x	if (op.iovec_count == 1)
487			{
488		467341x	do
489			{
490		467343x	n = ::recv(this->fd_, bufs[0].data(), bufs[0].size(), 0);
491		934684x	}
492	7/8 ✓ Branch 0 taken 197148 times. ✓ Branch 1 taken 32032 times. ✓ Branch 2 taken 211909 times. ✓ Branch 3 taken 26190 times. ✓ Branch 4 taken 41 times. ✓ Branch 5 taken 22 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	467343x	while (n < 0 && errno == EINTR);
493		467341x	}
494			else
495			{
496		14x	do
497			{
498		16x	n = ::readv(this->fd_, op.iovecs, op.iovec_count);
499		30x	}
500	5/8 ✓ Branch 0 taken 5 times. ✓ Branch 1 taken 5 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 3 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	16x	while (n < 0 && errno == EINTR);
501			}
502
503	14/24 ✓ Branch 0 taken 32035 times. ✓ Branch 1 taken 197153 times. ✓ Branch 2 taken 9 times. ✓ Branch 3 taken 32026 times. ✓ Branch 4 taken 9 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 26192 times. ✓ Branch 7 taken 211909 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 26192 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✓ Branch 12 taken 23 times. ✓ Branch 13 taken 42 times. ✓ Branch 14 taken 9 times. ✓ Branch 15 taken 14 times. ✓ Branch 16 taken 9 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 1 time. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	467355x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
504			{
505	6/8 ✓ Branch 0 taken 197153 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 211909 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 42 times. ✓ Branch 5 taken 9 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	409123x	int err = (n < 0) ? errno : 0;
506	7/8 ✓ Branch 0 taken 197141 times. ✓ Branch 1 taken 21 times. ✓ Branch 2 taken 211906 times. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 39 times. ✓ Branch 5 taken 12 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	409123x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
507
508	7/8 ✓ Branch 0 taken 158456 times. ✓ Branch 1 taken 38706 times. ✓ Branch 2 taken 170566 times. ✓ Branch 3 taken 41343 times. ✓ Branch 4 taken 37 times. ✓ Branch 5 taken 14 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	409123x	if (this->svc_.scheduler().try_consume_inline_budget())
509			{
510	6/8 ✓ Branch 0 taken 7 times. ✓ Branch 1 taken 158449 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 170566 times. ✓ Branch 4 taken 9 times. ✓ Branch 5 taken 28 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	329060x	if (err)
511		16x	*ec = make_err(err);
512	7/8 ✓ Branch 0 taken 158437 times. ✓ Branch 1 taken 12 times. ✓ Branch 2 taken 170563 times. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 27 times. ✓ Branch 5 taken 1 time. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	329044x	else if (n == 0)
513		16x	*ec = capy::error::eof;
514			else
515		329028x	*ec = {};
516		329060x	*bytes_out = bytes;
517		329060x	op.cont.h = h;
518		329060x	return dispatch_coro(ex, op.cont);
519			}
520		80063x	op.h = h;
521		80063x	op.ex = ex;
522		80063x	op.ec_out = ec;
523		80063x	op.bytes_out = bytes_out;
524		80063x	op.start(token, static_cast<Derived*>(this));
525	3/8 ✓ Branch 0 taken 38706 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 41343 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 14 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	80063x	op.impl_ptr = this->shared_from_this();
526		80063x	op.complete(err, bytes);
527		80063x	this->svc_.post(&op);
528		80063x	return std::noop_coroutine();
529			}
530
531			// EAGAIN — register with reactor
532		58232x	op.h = h;
533		58232x	op.ex = ex;
534		58232x	op.ec_out = ec;
535		58232x	op.bytes_out = bytes_out;
536		58232x	op.fd = this->fd_;
537		58232x	op.start(token, static_cast<Derived*>(this));
538	3/8 ✓ Branch 0 taken 32026 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 26192 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 14 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	58232x	op.impl_ptr = this->shared_from_this();
539
540		58232x	this->register_op(
541		58232x	op, this->desc_state_.read_op, this->desc_state_.read_ready);
542		58232x	return std::noop_coroutine();
543		467456x	}
544
545			template<
546			class Derived,
547			class Service,
548			class ConnOp,
549			class ReadOp,
550			class WriteOp,
551			class WaitOp,
552			class DescState,
553			class ImplBase,
554			class Endpoint>
555			std::coroutine_handle<>
556			reactor_stream_socket<
557			Derived,
558			Service,
559			ConnOp,
560			ReadOp,
561			WriteOp,
562			WaitOp,
563			DescState,
564			ImplBase,
565			Endpoint>::
566		502784x	do_write_some(
567			std::coroutine_handle<> h,
568			capy::executor_ref ex,
569			buffer_param param,
570			std::stop_token const& token,
571			std::error_code* ec,
572			std::size_t* bytes_out)
573			{
574		502784x	auto& op = wr_;
575		502784x	op.reset();
576
577			// Closed-object contract: complete with bad_file_descriptor without
578			// touching the kernel or the unregistered descriptor state.
579	6/8 ✓ Branch 0 taken 263339 times. ✓ Branch 1 taken 8 times. ✓ Branch 2 taken 239396 times. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 35 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	502784x	if (this->fd_ < 0)
580			{
581		12x	op.h = h;
582		12x	op.ex = ex;
583		12x	op.ec_out = ec;
584		12x	op.bytes_out = bytes_out;
585		12x	op.start(token, static_cast<Derived*>(this));
586		12x	op.impl_ptr = this->shared_from_this();
587		12x	op.complete(EBADF, 0);
588		12x	this->svc_.post(&op);
589		12x	return std::noop_coroutine();
590			}
591
592		502772x	capy::mutable_buffer bufs[WriteOp::max_buffers];
593		502772x	op.iovec_count =
594		502772x	static_cast<int>(param.copy_to(bufs, WriteOp::max_buffers));
595
596	17/24 ✓ Branch 0 taken 263337 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 263330 times. ✓ Branch 3 taken 7 times. ✓ Branch 4 taken 263330 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 239394 times. ✓ Branch 7 taken 2 times. ✓ Branch 8 taken 239392 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 239392 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 35 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 32 times. ✓ Branch 15 taken 3 times. ✓ Branch 16 taken 32 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 2 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 2 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 2 times. ✗ Branch 23 not taken.	502772x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
597			{
598		4x	op.h = h;
599		4x	op.ex = ex;
600		4x	op.ec_out = ec;
601		4x	op.bytes_out = bytes_out;
602		4x	op.start(token, static_cast<Derived*>(this));
603		4x	op.impl_ptr = this->shared_from_this();
604		4x	op.complete(0, 0);
605		4x	this->svc_.post(&op);
606		4x	return std::noop_coroutine();
607			}
608
609	8/8 ✓ Branch 0 taken 263346 times. ✓ Branch 1 taken 263337 times. ✓ Branch 2 taken 239398 times. ✓ Branch 3 taken 239394 times. ✓ Branch 4 taken 38 times. ✓ Branch 5 taken 35 times. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 2 times.	1005552x	for (int i = 0; i < op.iovec_count; ++i)
610			{
611		502784x	op.iovecs[i].iov_base = bufs[i].data();
612		502784x	op.iovecs[i].iov_len = bufs[i].size();
613		502784x	}
614
615			// Speculative write; the single-buffer case dispatches to a
616			// backend-specific fast path so the kernel skips msghdr/iov_iter
617			// setup (and so each backend can pick the right SIGPIPE strategy).
618			ssize_t n;
619	7/8 ✓ Branch 0 taken 263330 times. ✓ Branch 1 taken 7 times. ✓ Branch 2 taken 239392 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 32 times. ✓ Branch 5 taken 3 times. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	502768x	if (op.iovec_count == 1)
620			{
621		502756x	n = WriteOp::write_policy::write_one(
622		502756x	this->fd_, bufs[0].data(), bufs[0].size());
623		502756x	}
624			else
625			{
626		12x	n = WriteOp::write_policy::write(this->fd_, op.iovecs, op.iovec_count);
627			}
628
629	16/24 ✓ Branch 0 taken 513 times. ✓ Branch 1 taken 262824 times. ✓ Branch 2 taken 5 times. ✓ Branch 3 taken 508 times. ✓ Branch 4 taken 5 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 513 times. ✓ Branch 7 taken 238881 times. ✓ Branch 8 taken 2 times. ✓ Branch 9 taken 511 times. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 3 times. ✓ Branch 13 taken 32 times. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 1 time. ✓ Branch 16 taken 2 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 2 times. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	502768x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
630			{
631	7/8 ✓ Branch 0 taken 262824 times. ✓ Branch 1 taken 5 times. ✓ Branch 2 taken 238881 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 32 times. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	501748x	int err = (n < 0) ? errno : 0;
632	7/8 ✓ Branch 0 taken 262824 times. ✓ Branch 1 taken 5 times. ✓ Branch 2 taken 238881 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 32 times. ✓ Branch 5 taken 2 times. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	501748x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
633
634	8/8 ✓ Branch 0 taken 214694 times. ✓ Branch 1 taken 48135 times. ✓ Branch 2 taken 196510 times. ✓ Branch 3 taken 42373 times. ✓ Branch 4 taken 18 times. ✓ Branch 5 taken 16 times. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 1 time.	501748x	if (this->svc_.scheduler().try_consume_inline_budget())
635			{
636	7/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 214692 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 196509 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 17 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	411223x	*ec = err ? make_err(err) : std::error_code{};
637		411223x	*bytes_out = bytes;
638		411223x	op.cont.h = h;
639		411223x	return dispatch_coro(ex, op.cont);
640			}
641		90525x	op.h = h;
642		90525x	op.ex = ex;
643		90525x	op.ec_out = ec;
644		90525x	op.bytes_out = bytes_out;
645		90525x	op.start(token, static_cast<Derived*>(this));
646		90525x	op.impl_ptr = this->shared_from_this();
647		90525x	op.complete(err, bytes);
648		90525x	this->svc_.post(&op);
649		90525x	return std::noop_coroutine();
650			}
651
652			// EAGAIN — register with reactor
653		1020x	op.h = h;
654		1020x	op.ex = ex;
655		1020x	op.ec_out = ec;
656		1020x	op.bytes_out = bytes_out;
657		1020x	op.fd = this->fd_;
658		1020x	op.start(token, static_cast<Derived*>(this));
659		1020x	op.impl_ptr = this->shared_from_this();
660
661		1020x	this->register_op(
662		1020x	op, this->desc_state_.write_op, this->desc_state_.write_ready, true);
663		1020x	return std::noop_coroutine();
664		502784x	}
665
666			template<
667			class Derived,
668			class Service,
669			class ConnOp,
670			class ReadOp,
671			class WriteOp,
672			class WaitOp,
673			class DescState,
674			class ImplBase,
675			class Endpoint>
676			std::coroutine_handle<>
677			reactor_stream_socket<
678			Derived,
679			Service,
680			ConnOp,
681			ReadOp,
682			WriteOp,
683			WaitOp,
684			DescState,
685			ImplBase,
686			Endpoint>::
687		95x	do_wait(
688			std::coroutine_handle<> h,
689			capy::executor_ref ex,
690			wait_type w,
691			std::stop_token const& token,
692			std::error_code* ec)
693			{
694			// Pick refs up-front to avoid duplicating the register_op call.
695			WaitOp* op_ptr;
696			reactor_op_base** desc_slot_ptr;
697			std::uint32_t event;
698
699	6/8 ✓ Branch 0 taken 20 times. ✓ Branch 1 taken 27 times. ✓ Branch 2 taken 22 times. ✓ Branch 3 taken 23 times. ✓ Branch 4 taken 2 times. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	95x	if (w == wait_type::read)
700			{
701		51x	op_ptr = &wait_rd_;
702		51x	desc_slot_ptr = &this->desc_state_.wait_read_op;
703		51x	event = reactor_event_read;
704		51x	}
705	6/8 ✓ Branch 0 taken 11 times. ✓ Branch 1 taken 9 times. ✓ Branch 2 taken 14 times. ✓ Branch 3 taken 8 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	44x	else if (w == wait_type::write)
706			{
707		26x	op_ptr = &wait_wr_;
708		26x	desc_slot_ptr = &this->desc_state_.wait_write_op;
709		26x	event = reactor_event_write;
710		26x	}
711			else // wait_type::error
712			{
713		18x	op_ptr = &wait_er_;
714		18x	desc_slot_ptr = &this->desc_state_.wait_error_op;
715		18x	event = reactor_event_error;
716			}
717
718		95x	auto& op = *op_ptr;
719
720			// Speculative probe, mirroring the speculative read: an
721			// edge-triggered reactor cannot report a condition that already
722			// holds, so a wait initiated on an already-ready socket would
723			// otherwise park forever.
724		95x	int perr = 0;
725	6/8 ✓ Branch 0 taken 15 times. ✓ Branch 1 taken 32 times. ✓ Branch 2 taken 21 times. ✓ Branch 3 taken 24 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	95x	if (WaitOp::probe(this->fd_, event, perr))
726			{
727	5/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 13 times. ✓ Branch 2 taken 6 times. ✓ Branch 3 taken 15 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	37x	if (this->svc_.scheduler().try_consume_inline_budget())
728			{
729	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 2 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 6 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	8x	*ec = perr ? make_err(perr) : std::error_code{};
730		8x	op.cont.h = h;
731		8x	return dispatch_coro(ex, op.cont);
732			}
733		29x	op.reset();
734		29x	op.wait_event = event;
735		29x	op.h = h;
736		29x	op.ex = ex;
737		29x	op.ec_out = ec;
738		29x	op.fd = this->fd_;
739		29x	op.start(token, static_cast<Derived*>(this));
740		29x	op.impl_ptr = this->shared_from_this();
741		29x	op.complete(perr, 0);
742		29x	this->svc_.post(&op);
743		29x	return std::noop_coroutine();
744			}
745
746		58x	op.reset();
747		58x	op.wait_event = event;
748		58x	op.h = h;
749		58x	op.ex = ex;
750		58x	op.ec_out = ec;
751		58x	op.fd = this->fd_;
752		58x	op.start(token, static_cast<Derived*>(this));
753		58x	op.impl_ptr = this->shared_from_this();
754
755			// Force register_op's ready path so the wait op re-probes under
756			// the descriptor mutex before parking. An edge consumed between
757			// the speculative probe above and the park (a concurrent short
758			// read, or an error event dispatched to an empty slot) would
759			// otherwise leave the wait parked on a ready socket.
760		58x	bool force_probe = true;
761		58x	this->register_op(
762		58x	op, *desc_slot_ptr, force_probe, event == reactor_event_write);
763		58x	return std::noop_coroutine();
764		95x	}
765
766			} // namespace boost::corosio::detail
767
768			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_SOCKET_HPP
769