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

88.6% Lines (202/228) 79.8% List of functions (67/84) 36.9% Branches (189/512)

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

reactor_stream_socket.hpp

f(x) Functions (84)

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/native/detail/reactor/reactor_basic_socket.hpp>
16			#include <boost/corosio/detail/dispatch_coro.hpp>
17			#include <boost/capy/buffers.hpp>
18
19			#include <coroutine>
20
21			#include <errno.h>
22			#include <sys/socket.h>
23			#include <sys/uio.h>
24
25			namespace boost::corosio::detail {
26
27			/** CRTP base for reactor-backed stream socket implementations.
28
29			Inherits shared data members and cancel/close/register logic
30			from reactor_basic_socket. Adds the stream-specific remote
31			endpoint, shutdown, and I/O dispatch (connect, read, write).
32
33			@tparam Derived The concrete socket type (CRTP).
34			@tparam Service The backend's socket service type.
35			@tparam ConnOp The backend's connect op type.
36			@tparam ReadOp The backend's read op type.
37			@tparam WriteOp The backend's write op type.
38			@tparam DescState The backend's descriptor_state type.
39			@tparam ImplBase The public vtable base
40			(tcp_socket::implementation or
41			local_stream_socket::implementation).
42			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
43			*/
44			template<
45			class Derived,
46			class Service,
47			class ConnOp,
48			class ReadOp,
49			class WriteOp,
50			class DescState,
51			class ImplBase = tcp_socket::implementation,
52			class Endpoint = endpoint>
53			class reactor_stream_socket
54			: public reactor_basic_socket<
55			Derived,
56			ImplBase,
57			Service,
58			DescState,
59			Endpoint>
60			{
61			using base_type = reactor_basic_socket<
62			Derived,
63			ImplBase,
64			Service,
65			DescState,
66			Endpoint>;
67			friend base_type;
68			friend Derived;
69
70			protected:
71			// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
72		15306x	explicit reactor_stream_socket(Service& svc) noexcept : base_type(svc) {}
73
74			protected:
75			Endpoint remote_endpoint_;
76
77			public:
78			/// Pending connect operation slot.
79			ConnOp conn_;
80
81			/// Pending read operation slot.
82			ReadOp rd_;
83
84			/// Pending write operation slot.
85			WriteOp wr_;
86
87		15306x	~reactor_stream_socket() override = default;
88
89			/// Return the cached remote endpoint.
90		46x	Endpoint remote_endpoint() const noexcept override
91			{
92		46x	return remote_endpoint_;
93			}
94
95			// --- Virtual method overrides (satisfy ImplBase pure virtuals) ---
96
97		5058x	std::coroutine_handle<> connect(
98			std::coroutine_handle<> h,
99			capy::executor_ref ex,
100			Endpoint ep,
101			std::stop_token token,
102			std::error_code* ec) override
103			{
104		5058x	return do_connect(h, ex, ep, token, ec);
105			}
106
107		366392x	std::coroutine_handle<> read_some(
108			std::coroutine_handle<> h,
109			capy::executor_ref ex,
110			buffer_param param,
111			std::stop_token token,
112			std::error_code* ec,
113			std::size_t* bytes_out) override
114			{
115		366392x	return do_read_some(h, ex, param, token, ec, bytes_out);
116			}
117
118		442017x	std::coroutine_handle<> write_some(
119			std::coroutine_handle<> h,
120			capy::executor_ref ex,
121			buffer_param param,
122			std::stop_token token,
123			std::error_code* ec,
124			std::size_t* bytes_out) override
125			{
126		442017x	return do_write_some(h, ex, param, token, ec, bytes_out);
127			}
128
129			std::error_code
130		6x	shutdown(corosio::shutdown_type what) noexcept override
131			{
132		6x	return do_shutdown(static_cast<int>(what));
133			}
134
135		150x	void cancel() noexcept override
136			{
137		150x	this->do_cancel();
138		150x	}
139
140			// --- End virtual overrides ---
141
142			/// Close the socket (non-virtual, called by the service).
143			void close_socket() noexcept
144			{
145			this->do_close_socket();
146			}
147
148			/** Shut down part or all of the full-duplex connection.
149
150			@param what 0 = receive, 1 = send, 2 = both.
151			*/
152		6x	std::error_code do_shutdown(int what) noexcept
153			{
154			int how;
155	6/16 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 1 time. ✗ 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.	6x	switch (what)
156			{
157			case 0: // shutdown_receive
158		2x	how = SHUT_RD;
159		2x	break;
160			case 1: // shutdown_send
161		2x	how = SHUT_WR;
162		2x	break;
163			case 2: // shutdown_both
164		2x	how = SHUT_RDWR;
165		2x	break;
166			default:
167		✗	return make_err(EINVAL);
168			}
169	4/16 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 3 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.	6x	if (::shutdown(this->fd_, how) != 0)
170		✗	return make_err(errno);
171		6x	return {};
172		6x	}
173
174			/// Cache local and remote endpoints.
175		10098x	void set_endpoints(Endpoint local, Endpoint remote) noexcept
176			{
177		10098x	this->local_endpoint_ = std::move(local);
178		10098x	remote_endpoint_ = std::move(remote);
179		10098x	}
180
181			/** Shared connect dispatch.
182
183			Tries the connect syscall speculatively. On synchronous
184			completion, returns via inline budget or posts through queue.
185			On EINPROGRESS, registers with the reactor.
186			*/
187			std::coroutine_handle<> do_connect(
188			std::coroutine_handle<>,
189			capy::executor_ref,
190			Endpoint const&,
191			std::stop_token const&,
192			std::error_code*);
193
194			/** Shared scatter-read dispatch.
195
196			Tries readv() speculatively. On success or hard error,
197			returns via inline budget or posts through queue.
198			On EAGAIN, registers with the reactor.
199			*/
200			std::coroutine_handle<> do_read_some(
201			std::coroutine_handle<>,
202			capy::executor_ref,
203			buffer_param,
204			std::stop_token const&,
205			std::error_code*,
206			std::size_t*);
207
208			/** Shared gather-write dispatch.
209
210			Tries the write via WriteOp::write_policy speculatively.
211			On success or hard error, returns via inline budget or
212			posts through queue. On EAGAIN, registers with the reactor.
213			*/
214			std::coroutine_handle<> do_write_some(
215			std::coroutine_handle<>,
216			capy::executor_ref,
217			buffer_param,
218			std::stop_token const&,
219			std::error_code*,
220			std::size_t*);
221
222			/** Close the socket and cancel pending operations.
223
224			Extends the base do_close_socket() to also reset
225			the remote endpoint.
226			*/
227		45895x	void do_close_socket() noexcept
228			{
229		45895x	base_type::do_close_socket();
230		45895x	remote_endpoint_ = Endpoint{};
231		45895x	}
232
233			private:
234			// CRTP callbacks for reactor_basic_socket cancel/close
235
236			template<class Op>
237		431x	reactor_op_base** op_to_desc_slot(Op& op) noexcept
238			{
239	2/8 ✓ Branch 0 taken 34 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 397 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	431x	if (&op == static_cast<void*>(&conn_))
240		✗	return &this->desc_state_.connect_op;
241	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 34 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 396 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	431x	if (&op == static_cast<void*>(&rd_))
242		430x	return &this->desc_state_.read_op;
243	1/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ 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.	1x	if (&op == static_cast<void*>(&wr_))
244		1x	return &this->desc_state_.write_op;
245		✗	return nullptr;
246		431x	}
247
248			template<class Op>
249		2x	bool* op_to_cancel_flag(Op& op) noexcept
250			{
251	1/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (&op == static_cast<void*>(&conn_))
252		✗	return &this->desc_state_.connect_cancel_pending;
253	2/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ 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.	2x	if (&op == static_cast<void*>(&rd_))
254		1x	return &this->desc_state_.read_cancel_pending;
255	1/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ 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.	1x	if (&op == static_cast<void*>(&wr_))
256		1x	return &this->desc_state_.write_cancel_pending;
257		✗	return nullptr;
258		2x	}
259
260			template<class Fn>
261		46047x	void for_each_op(Fn fn) noexcept
262			{
263	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(conn_);
264	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(rd_);
265	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(wr_);
266		46047x	}
267
268			template<class Fn>
269		46047x	void for_each_desc_entry(Fn fn) noexcept
270			{
271	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(conn_, this->desc_state_.connect_op);
272	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(rd_, this->desc_state_.read_op);
273	7/20 ✓ Branch 0 taken 14726 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 114 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 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 31087 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 59 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	46047x	fn(wr_, this->desc_state_.write_op);
274		46047x	}
275			};
276
277			template<
278			class Derived,
279			class Service,
280			class ConnOp,
281			class ReadOp,
282			class WriteOp,
283			class DescState,
284			class ImplBase,
285			class Endpoint>
286			std::coroutine_handle<>
287			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState, ImplBase, Endpoint>::
288		5058x	do_connect(
289			std::coroutine_handle<> h,
290			capy::executor_ref ex,
291			Endpoint const& ep,
292			std::stop_token const& token,
293			std::error_code* ec)
294			{
295		5058x	auto& op = conn_;
296
297		5058x	sockaddr_storage storage{};
298		5058x	socklen_t addrlen = to_sockaddr(ep, socket_family(this->fd_), storage);
299		5058x	int result =
300		5058x	::connect(this->fd_, reinterpret_cast<sockaddr*>(&storage), addrlen);
301
302	4/8 ✓ Branch 0 taken 1625 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3429 times. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	5058x	if (result == 0)
303			{
304		4x	sockaddr_storage local_storage{};
305		4x	socklen_t local_len = sizeof(local_storage);
306	4/16 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✓ 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 taken 2 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 2 times.	8x	if (::getsockname(
307		4x	this->fd_, reinterpret_cast<sockaddr*>(&local_storage),
308		4x	&local_len) == 0)
309		4x	this->local_endpoint_ =
310		4x	from_sockaddr_as(local_storage, local_len, Endpoint{});
311		4x	remote_endpoint_ = ep;
312		4x	}
313
314	6/16 ✓ Branch 0 taken 1625 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 1625 times. ✓ Branch 4 taken 3429 times. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3429 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✓ Branch 13 taken 2 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5058x	if (result == 0 \|\| errno != EINPROGRESS)
315			{
316	2/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	4x	int err = (result < 0) ? errno : 0;
317	2/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	4x	if (this->svc_.scheduler().try_consume_inline_budget())
318			{
319		✗	*ec = err ? make_err(err) : std::error_code{};
320		✗	op.cont_op.cont.h = h;
321		✗	return dispatch_coro(ex, op.cont_op.cont);
322			}
323		4x	op.reset();
324		4x	op.h = h;
325		4x	op.ex = ex;
326		4x	op.ec_out = ec;
327		4x	op.fd = this->fd_;
328		4x	op.target_endpoint = ep;
329		4x	op.start(token, static_cast<Derived*>(this));
330		4x	op.impl_ptr = this->shared_from_this();
331		4x	op.complete(err, 0);
332		4x	this->svc_.post(&op);
333		4x	return std::noop_coroutine();
334			}
335
336			// EINPROGRESS — register with reactor
337		5054x	op.reset();
338		5054x	op.h = h;
339		5054x	op.ex = ex;
340		5054x	op.ec_out = ec;
341		5054x	op.fd = this->fd_;
342		5054x	op.target_endpoint = ep;
343		5054x	op.start(token, static_cast<Derived*>(this));
344		5054x	op.impl_ptr = this->shared_from_this();
345
346		5054x	this->register_op(
347		5054x	op, this->desc_state_.connect_op, this->desc_state_.write_ready,
348		5054x	this->desc_state_.connect_cancel_pending, true);
349		5054x	return std::noop_coroutine();
350		5058x	}
351
352			template<
353			class Derived,
354			class Service,
355			class ConnOp,
356			class ReadOp,
357			class WriteOp,
358			class DescState,
359			class ImplBase,
360			class Endpoint>
361			std::coroutine_handle<>
362			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState, ImplBase, Endpoint>::
363		366392x	do_read_some(
364			std::coroutine_handle<> h,
365			capy::executor_ref ex,
366			buffer_param param,
367			std::stop_token const& token,
368			std::error_code* ec,
369			std::size_t* bytes_out)
370			{
371		366392x	auto& op = rd_;
372		366392x	op.reset();
373
374		366392x	capy::mutable_buffer bufs[ReadOp::max_buffers];
375		366392x	op.iovec_count = static_cast<int>(param.copy_to(bufs, ReadOp::max_buffers));
376
377	11/24 ✓ Branch 0 taken 204437 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 204437 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 204437 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 161952 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 161952 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 161952 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 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.	366392x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
378			{
379		2x	op.empty_buffer_read = true;
380		2x	op.h = h;
381		2x	op.ex = ex;
382		2x	op.ec_out = ec;
383		2x	op.bytes_out = bytes_out;
384		2x	op.start(token, static_cast<Derived*>(this));
385	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();
386		2x	op.complete(0, 0);
387		2x	this->svc_.post(&op);
388		2x	return std::noop_coroutine();
389			}
390
391	6/8 ✓ Branch 0 taken 204437 times. ✓ Branch 1 taken 204437 times. ✓ Branch 2 taken 161952 times. ✓ Branch 3 taken 161952 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 1 time.	732780x	for (int i = 0; i < op.iovec_count; ++i)
392			{
393		366390x	op.iovecs[i].iov_base = bufs[i].data();
394		366390x	op.iovecs[i].iov_len = bufs[i].size();
395		366390x	}
396
397			// Speculative read; for the single-buffer case use recv() so the
398			// kernel skips the readv iov_iter setup.
399			ssize_t n;
400	3/8 ✓ Branch 0 taken 204437 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 161952 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	366390x	if (op.iovec_count == 1)
401			{
402		366390x	do
403			{
404		366390x	n = ::recv(this->fd_, bufs[0].data(), bufs[0].size(), 0);
405		732780x	}
406	5/8 ✓ Branch 0 taken 186477 times. ✓ Branch 1 taken 17960 times. ✓ Branch 2 taken 134293 times. ✓ Branch 3 taken 27659 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	366390x	while (n < 0 && errno == EINTR);
407		366390x	}
408			else
409			{
410		✗	do
411			{
412		✗	n = ::readv(this->fd_, op.iovecs, op.iovec_count);
413		✗	}
414		✗	while (n < 0 && errno == EINTR);
415			}
416
417	9/24 ✓ Branch 0 taken 17960 times. ✓ Branch 1 taken 186477 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 17960 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 27659 times. ✓ Branch 7 taken 134293 times. ✓ Branch 8 taken 1 time. ✓ Branch 9 taken 27658 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 taken 1 time. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken.	366390x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
418			{
419	4/8 ✓ Branch 0 taken 186477 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 134293 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	320772x	int err = (n < 0) ? errno : 0;
420	5/8 ✓ Branch 0 taken 186472 times. ✓ Branch 1 taken 5 times. ✓ Branch 2 taken 134283 times. ✓ Branch 3 taken 11 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	320772x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
421
422	5/8 ✓ Branch 0 taken 150006 times. ✓ Branch 1 taken 36471 times. ✓ Branch 2 taken 108648 times. ✓ Branch 3 taken 25646 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	320772x	if (this->svc_.scheduler().try_consume_inline_budget())
423			{
424	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 150006 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 108647 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	258654x	if (err)
425		1x	*ec = make_err(err);
426	4/8 ✓ Branch 0 taken 150001 times. ✓ Branch 1 taken 5 times. ✓ Branch 2 taken 108639 times. ✓ Branch 3 taken 8 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	258653x	else if (n == 0)
427		13x	*ec = capy::error::eof;
428			else
429		258640x	*ec = {};
430		258654x	*bytes_out = bytes;
431		258654x	op.cont_op.cont.h = h;
432		258654x	return dispatch_coro(ex, op.cont_op.cont);
433			}
434		62118x	op.h = h;
435		62118x	op.ex = ex;
436		62118x	op.ec_out = ec;
437		62118x	op.bytes_out = bytes_out;
438		62118x	op.start(token, static_cast<Derived*>(this));
439	3/8 ✓ Branch 0 taken 36471 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 25646 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	62118x	op.impl_ptr = this->shared_from_this();
440		62118x	op.complete(err, bytes);
441		62118x	this->svc_.post(&op);
442		62118x	return std::noop_coroutine();
443			}
444
445			// EAGAIN — register with reactor
446		45618x	op.h = h;
447		45618x	op.ex = ex;
448		45618x	op.ec_out = ec;
449		45618x	op.bytes_out = bytes_out;
450		45618x	op.fd = this->fd_;
451		45618x	op.start(token, static_cast<Derived*>(this));
452	2/8 ✓ Branch 0 taken 17960 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 27658 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	45618x	op.impl_ptr = this->shared_from_this();
453
454		45618x	this->register_op(
455		45618x	op, this->desc_state_.read_op, this->desc_state_.read_ready,
456		45618x	this->desc_state_.read_cancel_pending);
457		45618x	return std::noop_coroutine();
458		366392x	}
459
460			template<
461			class Derived,
462			class Service,
463			class ConnOp,
464			class ReadOp,
465			class WriteOp,
466			class DescState,
467			class ImplBase,
468			class Endpoint>
469			std::coroutine_handle<>
470			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState, ImplBase, Endpoint>::
471		442017x	do_write_some(
472			std::coroutine_handle<> h,
473			capy::executor_ref ex,
474			buffer_param param,
475			std::stop_token const& token,
476			std::error_code* ec,
477			std::size_t* bytes_out)
478			{
479		442017x	auto& op = wr_;
480		442017x	op.reset();
481
482		442017x	capy::mutable_buffer bufs[WriteOp::max_buffers];
483		442017x	op.iovec_count =
484		442017x	static_cast<int>(param.copy_to(bufs, WriteOp::max_buffers));
485
486	11/24 ✓ Branch 0 taken 204991 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 204991 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 204991 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 237022 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 237022 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 237022 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 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.	442017x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
487			{
488		2x	op.h = h;
489		2x	op.ex = ex;
490		2x	op.ec_out = ec;
491		2x	op.bytes_out = bytes_out;
492		2x	op.start(token, static_cast<Derived*>(this));
493		2x	op.impl_ptr = this->shared_from_this();
494		2x	op.complete(0, 0);
495		2x	this->svc_.post(&op);
496		2x	return std::noop_coroutine();
497			}
498
499	6/8 ✓ Branch 0 taken 204991 times. ✓ Branch 1 taken 204991 times. ✓ Branch 2 taken 237022 times. ✓ Branch 3 taken 237022 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 2 times.	884030x	for (int i = 0; i < op.iovec_count; ++i)
500			{
501		442015x	op.iovecs[i].iov_base = bufs[i].data();
502		442015x	op.iovecs[i].iov_len = bufs[i].size();
503		442015x	}
504
505			// Speculative write; the single-buffer case dispatches to a
506			// backend-specific fast path so the kernel skips msghdr/iov_iter
507			// setup (and so each backend can pick the right SIGPIPE strategy).
508			ssize_t n;
509	3/8 ✓ Branch 0 taken 204991 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 237022 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	442015x	if (op.iovec_count == 1)
510			{
511		442015x	n = WriteOp::write_policy::write_one(
512		442015x	this->fd_, bufs[0].data(), bufs[0].size());
513		442015x	}
514			else
515			{
516		✗	n = WriteOp::write_policy::write(
517		✗	this->fd_, op.iovecs, op.iovec_count);
518			}
519
520	9/24 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 204990 times. ✓ 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 taken 237021 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. ✗ Branch 16 not taken. ✗ 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.	442015x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
521			{
522	5/8 ✓ Branch 0 taken 204990 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 237021 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	442015x	int err = (n < 0) ? errno : 0;
523	5/8 ✓ Branch 0 taken 204990 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 237021 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	442015x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
524
525	5/8 ✓ Branch 0 taken 167617 times. ✓ Branch 1 taken 37374 times. ✓ Branch 2 taken 192605 times. ✓ Branch 3 taken 44417 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	442015x	if (this->svc_.scheduler().try_consume_inline_budget())
526			{
527	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 167617 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 192604 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	360222x	*ec = err ? make_err(err) : std::error_code{};
528		360222x	*bytes_out = bytes;
529		360222x	op.cont_op.cont.h = h;
530		360222x	return dispatch_coro(ex, op.cont_op.cont);
531			}
532		81793x	op.h = h;
533		81793x	op.ex = ex;
534		81793x	op.ec_out = ec;
535		81793x	op.bytes_out = bytes_out;
536		81793x	op.start(token, static_cast<Derived*>(this));
537		81793x	op.impl_ptr = this->shared_from_this();
538		81793x	op.complete(err, bytes);
539		81793x	this->svc_.post(&op);
540		81793x	return std::noop_coroutine();
541			}
542
543			// EAGAIN — register with reactor
544		✗	op.h = h;
545		✗	op.ex = ex;
546		✗	op.ec_out = ec;
547		✗	op.bytes_out = bytes_out;
548		✗	op.fd = this->fd_;
549		✗	op.start(token, static_cast<Derived*>(this));
550		✗	op.impl_ptr = this->shared_from_this();
551
552		✗	this->register_op(
553		✗	op, this->desc_state_.write_op, this->desc_state_.write_ready,
554		✗	this->desc_state_.write_cancel_pending, true);
555		✗	return std::noop_coroutine();
556		442017x	}
557
558			} // namespace boost::corosio::detail
559
560			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_SOCKET_HPP
561