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

79.3% Lines (161/203) 78.9% List of functions (30/38) 44.3% Branches (124/280)

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

f(x) Functions (38)

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/native/detail/reactor/reactor_basic_socket.hpp>
15			#include <boost/corosio/detail/dispatch_coro.hpp>
16			#include <boost/capy/buffers.hpp>
17
18			#include <coroutine>
19
20			#include <errno.h>
21			#include <sys/socket.h>
22			#include <sys/uio.h>
23
24			namespace boost::corosio::detail {
25
26			/** CRTP base for reactor-backed stream socket implementations.
27
28			Inherits shared data members and cancel/close/register logic
29			from reactor_basic_socket. Adds the TCP-specific remote
30			endpoint, shutdown, and I/O dispatch (connect, read, write).
31
32			@tparam Derived The concrete socket type (CRTP).
33			@tparam Service The backend's socket service type.
34			@tparam ConnOp The backend's connect op type.
35			@tparam ReadOp The backend's read op type.
36			@tparam WriteOp The backend's write op type.
37			@tparam DescState The backend's descriptor_state type.
38			*/
39			template<
40			class Derived,
41			class Service,
42			class ConnOp,
43			class ReadOp,
44			class WriteOp,
45			class DescState>
46			class reactor_stream_socket
47			: public reactor_basic_socket<
48			Derived,
49			tcp_socket::implementation,
50			Service,
51			DescState>
52			{
53			using base_type = reactor_basic_socket<
54			Derived,
55			tcp_socket::implementation,
56			Service,
57			DescState>;
58			friend base_type;
59			friend Derived;
60
61		22345x	explicit reactor_stream_socket(Service& svc) noexcept : base_type(svc) {}
62
63			protected:
64			endpoint remote_endpoint_;
65
66			public:
67			/// Pending connect operation slot.
68			ConnOp conn_;
69
70			/// Pending read operation slot.
71			ReadOp rd_;
72
73			/// Pending write operation slot.
74			WriteOp wr_;
75
76		22345x	~reactor_stream_socket() override = default;
77
78			/// Return the cached remote endpoint.
79		42x	endpoint remote_endpoint() const noexcept override
80			{
81		42x	return remote_endpoint_;
82			}
83
84			/// Shut down part or all of the full-duplex connection.
85		6x	std::error_code shutdown(tcp_socket::shutdown_type what) noexcept override
86			{
87			int how;
88	6/8 ✓ 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.	6x	switch (what)
89			{
90			case tcp_socket::shutdown_receive:
91		2x	how = SHUT_RD;
92		2x	break;
93			case tcp_socket::shutdown_send:
94		2x	how = SHUT_WR;
95		2x	break;
96			case tcp_socket::shutdown_both:
97		2x	how = SHUT_RDWR;
98		2x	break;
99			default:
100		✗	return make_err(EINVAL);
101			}
102	4/8 ✓ 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.	6x	if (::shutdown(this->fd_, how) != 0)
103		✗	return make_err(errno);
104		6x	return {};
105		6x	}
106
107			/// Cache local and remote endpoints.
108		14804x	void set_endpoints(endpoint local, endpoint remote) noexcept
109			{
110		14804x	this->local_endpoint_ = local;
111		14804x	remote_endpoint_ = remote;
112		14804x	}
113
114			/** Shared connect dispatch.
115
116			Tries the connect syscall speculatively. On synchronous
117			completion, returns via inline budget or posts through queue.
118			On EINPROGRESS, registers with the reactor.
119			*/
120			std::coroutine_handle<> do_connect(
121			std::coroutine_handle<>,
122			capy::executor_ref,
123			endpoint,
124			std::stop_token const&,
125			std::error_code*);
126
127			/** Shared scatter-read dispatch.
128
129			Tries readv() speculatively. On success or hard error,
130			returns via inline budget or posts through queue.
131			On EAGAIN, registers with the reactor.
132			*/
133			std::coroutine_handle<> do_read_some(
134			std::coroutine_handle<>,
135			capy::executor_ref,
136			buffer_param,
137			std::stop_token const&,
138			std::error_code*,
139			std::size_t*);
140
141			/** Shared gather-write dispatch.
142
143			Tries the write via WriteOp::write_policy speculatively.
144			On success or hard error, returns via inline budget or
145			posts through queue. On EAGAIN, registers with the reactor.
146			*/
147			std::coroutine_handle<> do_write_some(
148			std::coroutine_handle<>,
149			capy::executor_ref,
150			buffer_param,
151			std::stop_token const&,
152			std::error_code*,
153			std::size_t*);
154
155			/** Close the socket and cancel pending operations.
156
157			Extends the base do_close_socket() to also reset
158			the remote endpoint.
159			*/
160		66974x	void do_close_socket() noexcept
161			{
162		66974x	base_type::do_close_socket();
163		66974x	remote_endpoint_ = endpoint{};
164		66974x	}
165
166			private:
167			// CRTP callbacks for reactor_basic_socket cancel/close
168
169			template<class Op>
170		796x	reactor_op_base** op_to_desc_slot(Op& op) noexcept
171			{
172	3/12 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 38 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 757 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	796x	if (&op == static_cast<void*>(&conn_))
173		✗	return &this->desc_state_.connect_op;
174	3/12 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 38 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✓ Branch 9 taken 757 times. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	796x	if (&op == static_cast<void*>(&rd_))
175		795x	return &this->desc_state_.read_op;
176	1/12 ✗ Branch 0 not taken. ✗ 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. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 1 time.	1x	if (&op == static_cast<void*>(&wr_))
177		1x	return &this->desc_state_.write_op;
178		✗	return nullptr;
179		796x	}
180
181			template<class Op>
182		1x	bool* op_to_cancel_flag(Op& op) noexcept
183			{
184	1/12 ✗ Branch 0 not taken. ✗ 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. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	1x	if (&op == static_cast<void*>(&conn_))
185		✗	return &this->desc_state_.connect_cancel_pending;
186	1/12 ✗ Branch 0 not taken. ✗ 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. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	1x	if (&op == static_cast<void*>(&rd_))
187		✗	return &this->desc_state_.read_cancel_pending;
188	1/12 ✗ Branch 0 not taken. ✗ 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. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 1 time.	1x	if (&op == static_cast<void*>(&wr_))
189		1x	return &this->desc_state_.write_cancel_pending;
190		✗	return nullptr;
191		1x	}
192
193			template<class Fn>
194		67136x	void for_each_op(Fn fn) noexcept
195			{
196	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(conn_);
197	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(rd_);
198	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(wr_);
199		67136x	}
200
201			template<class Fn>
202		67136x	void for_each_desc_entry(Fn fn) noexcept
203			{
204	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(conn_, this->desc_state_.connect_op);
205	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(rd_, this->desc_state_.read_op);
206	3/8 ✓ Branch 0 taken 16220 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 118 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50798 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	67136x	fn(wr_, this->desc_state_.write_op);
207		67136x	}
208			};
209
210			template<
211			class Derived,
212			class Service,
213			class ConnOp,
214			class ReadOp,
215			class WriteOp,
216			class DescState>
217			std::coroutine_handle<>
218			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState>::
219		7407x	do_connect(
220			std::coroutine_handle<> h,
221			capy::executor_ref ex,
222			endpoint ep,
223			std::stop_token const& token,
224			std::error_code* ec)
225			{
226		7407x	auto& op = conn_;
227
228		7407x	sockaddr_storage storage{};
229		7407x	socklen_t addrlen = to_sockaddr(ep, socket_family(this->fd_), storage);
230		7407x	int result =
231		7407x	::connect(this->fd_, reinterpret_cast<sockaddr*>(&storage), addrlen);
232
233	2/4 ✓ Branch 0 taken 1789 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 5618 times. ✗ Branch 3 not taken.	7407x	if (result == 0)
234			{
235		✗	sockaddr_storage local_storage{};
236		✗	socklen_t local_len = sizeof(local_storage);
237		✗	if (::getsockname(
238		✗	this->fd_, reinterpret_cast<sockaddr*>(&local_storage),
239		✗	&local_len) == 0)
240		✗	this->local_endpoint_ = from_sockaddr(local_storage);
241		✗	remote_endpoint_ = ep;
242		✗	}
243
244	4/8 ✓ Branch 0 taken 1789 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 1789 times. ✓ Branch 4 taken 5618 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 5618 times.	7407x	if (result == 0 \|\| errno != EINPROGRESS)
245			{
246		✗	int err = (result < 0) ? errno : 0;
247		✗	if (this->svc_.scheduler().try_consume_inline_budget())
248			{
249		✗	*ec = err ? make_err(err) : std::error_code{};
250		✗	return dispatch_coro(ex, h);
251			}
252		✗	op.reset();
253		✗	op.h = h;
254		✗	op.ex = ex;
255		✗	op.ec_out = ec;
256		✗	op.fd = this->fd_;
257		✗	op.target_endpoint = ep;
258		✗	op.start(token, static_cast<Derived*>(this));
259		✗	op.impl_ptr = this->shared_from_this();
260		✗	op.complete(err, 0);
261		✗	this->svc_.post(&op);
262		✗	return std::noop_coroutine();
263			}
264
265			// EINPROGRESS — register with reactor
266		7407x	op.reset();
267		7407x	op.h = h;
268		7407x	op.ex = ex;
269		7407x	op.ec_out = ec;
270		7407x	op.fd = this->fd_;
271		7407x	op.target_endpoint = ep;
272		7407x	op.start(token, static_cast<Derived*>(this));
273		7407x	op.impl_ptr = this->shared_from_this();
274
275		7407x	this->register_op(
276		7407x	op, this->desc_state_.connect_op, this->desc_state_.write_ready,
277		7407x	this->desc_state_.connect_cancel_pending);
278		7407x	return std::noop_coroutine();
279		7407x	}
280
281			template<
282			class Derived,
283			class Service,
284			class ConnOp,
285			class ReadOp,
286			class WriteOp,
287			class DescState>
288			std::coroutine_handle<>
289			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState>::
290		850411x	do_read_some(
291			std::coroutine_handle<> h,
292			capy::executor_ref ex,
293			buffer_param param,
294			std::stop_token const& token,
295			std::error_code* ec,
296			std::size_t* bytes_out)
297			{
298		850411x	auto& op = rd_;
299		850411x	op.reset();
300
301		850411x	capy::mutable_buffer bufs[ReadOp::max_buffers];
302		850411x	op.iovec_count = static_cast<int>(param.copy_to(bufs, ReadOp::max_buffers));
303
304	8/12 ✓ Branch 0 taken 465398 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 465398 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 465398 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 385011 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 385011 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 385011 times. ✗ Branch 11 not taken.	850411x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
305			{
306		2x	op.empty_buffer_read = true;
307		2x	op.h = h;
308		2x	op.ex = ex;
309		2x	op.ec_out = ec;
310		2x	op.bytes_out = bytes_out;
311		2x	op.start(token, static_cast<Derived*>(this));
312	2/4 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken.	2x	op.impl_ptr = this->shared_from_this();
313		2x	op.complete(0, 0);
314		2x	this->svc_.post(&op);
315		2x	return std::noop_coroutine();
316			}
317
318	4/4 ✓ Branch 0 taken 465398 times. ✓ Branch 1 taken 465398 times. ✓ Branch 2 taken 385011 times. ✓ Branch 3 taken 385011 times.	1700818x	for (int i = 0; i < op.iovec_count; ++i)
319			{
320		850409x	op.iovecs[i].iov_base = bufs[i].data();
321		850409x	op.iovecs[i].iov_len = bufs[i].size();
322		850409x	}
323
324			// Speculative read
325			ssize_t n;
326		850409x	do
327			{
328		850409x	n = ::readv(this->fd_, op.iovecs, op.iovec_count);
329		1700818x	}
330	4/4 ✓ Branch 0 taken 417249 times. ✓ Branch 1 taken 48149 times. ✓ Branch 2 taken 319268 times. ✓ Branch 3 taken 65743 times.	850409x	while (n < 0 && errno == EINTR);
331
332	6/12 ✓ Branch 0 taken 48149 times. ✓ Branch 1 taken 417249 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 48149 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 65743 times. ✓ Branch 7 taken 319268 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 65743 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken.	850409x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
333			{
334	2/4 ✓ Branch 0 taken 417249 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 319268 times. ✗ Branch 3 not taken.	736517x	int err = (n < 0) ? errno : 0;
335	4/4 ✓ Branch 0 taken 417246 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 319260 times. ✓ Branch 3 taken 8 times.	736517x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
336
337	4/4 ✓ Branch 0 taken 334999 times. ✓ Branch 1 taken 82250 times. ✓ Branch 2 taken 257738 times. ✓ Branch 3 taken 61530 times.	736517x	if (this->svc_.scheduler().try_consume_inline_budget())
338			{
339	2/4 ✗ Branch 0 not taken. ✓ Branch 1 taken 334999 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 257738 times.	592737x	if (err)
340		✗	*ec = make_err(err);
341	4/4 ✓ Branch 0 taken 334996 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 257730 times. ✓ Branch 3 taken 8 times.	592737x	else if (n == 0)
342		11x	*ec = capy::error::eof;
343			else
344		592726x	*ec = {};
345		592737x	*bytes_out = bytes;
346		592737x	return dispatch_coro(ex, h);
347			}
348		143780x	op.h = h;
349		143780x	op.ex = ex;
350		143780x	op.ec_out = ec;
351		143780x	op.bytes_out = bytes_out;
352		143780x	op.start(token, static_cast<Derived*>(this));
353	2/4 ✓ Branch 0 taken 82250 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 61530 times. ✗ Branch 3 not taken.	143780x	op.impl_ptr = this->shared_from_this();
354		143780x	op.complete(err, bytes);
355		143780x	this->svc_.post(&op);
356		143780x	return std::noop_coroutine();
357			}
358
359			// EAGAIN — register with reactor
360		113892x	op.h = h;
361		113892x	op.ex = ex;
362		113892x	op.ec_out = ec;
363		113892x	op.bytes_out = bytes_out;
364		113892x	op.fd = this->fd_;
365		113892x	op.start(token, static_cast<Derived*>(this));
366	2/4 ✓ Branch 0 taken 48149 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 65743 times. ✗ Branch 3 not taken.	113892x	op.impl_ptr = this->shared_from_this();
367
368		113892x	this->register_op(
369		113892x	op, this->desc_state_.read_op, this->desc_state_.read_ready,
370		113892x	this->desc_state_.read_cancel_pending);
371		113892x	return std::noop_coroutine();
372		850411x	}
373
374			template<
375			class Derived,
376			class Service,
377			class ConnOp,
378			class ReadOp,
379			class WriteOp,
380			class DescState>
381			std::coroutine_handle<>
382			reactor_stream_socket<Derived, Service, ConnOp, ReadOp, WriteOp, DescState>::
383		983049x	do_write_some(
384			std::coroutine_handle<> h,
385			capy::executor_ref ex,
386			buffer_param param,
387			std::stop_token const& token,
388			std::error_code* ec,
389			std::size_t* bytes_out)
390			{
391		983049x	auto& op = wr_;
392		983049x	op.reset();
393
394		983049x	capy::mutable_buffer bufs[WriteOp::max_buffers];
395		983049x	op.iovec_count =
396		983049x	static_cast<int>(param.copy_to(bufs, WriteOp::max_buffers));
397
398	8/12 ✓ Branch 0 taken 466290 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 466290 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 466290 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 516757 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 516757 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 516757 times. ✗ Branch 11 not taken.	983049x	if (op.iovec_count == 0 \|\| (op.iovec_count == 1 && bufs[0].size() == 0))
399			{
400		2x	op.h = h;
401		2x	op.ex = ex;
402		2x	op.ec_out = ec;
403		2x	op.bytes_out = bytes_out;
404		2x	op.start(token, static_cast<Derived*>(this));
405		2x	op.impl_ptr = this->shared_from_this();
406		2x	op.complete(0, 0);
407		2x	this->svc_.post(&op);
408		2x	return std::noop_coroutine();
409			}
410
411	4/4 ✓ Branch 0 taken 466290 times. ✓ Branch 1 taken 466290 times. ✓ Branch 2 taken 516757 times. ✓ Branch 3 taken 516757 times.	1966094x	for (int i = 0; i < op.iovec_count; ++i)
412			{
413		983047x	op.iovecs[i].iov_base = bufs[i].data();
414		983047x	op.iovecs[i].iov_len = bufs[i].size();
415		983047x	}
416
417			// Speculative write via backend-specific write policy
418		983047x	ssize_t n =
419		983047x	WriteOp::write_policy::write(this->fd_, op.iovecs, op.iovec_count);
420
421	8/12 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 466289 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 516756 times. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	983047x	if (n >= 0 \|\| (errno != EAGAIN && errno != EWOULDBLOCK))
422			{
423	4/4 ✓ Branch 0 taken 466289 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 516756 times. ✓ Branch 3 taken 1 time.	983047x	int err = (n < 0) ? errno : 0;
424	4/4 ✓ Branch 0 taken 466289 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 516756 times. ✓ Branch 3 taken 1 time.	983047x	auto bytes = (n > 0) ? static_cast<std::size_t>(n) : std::size_t(0);
425
426	4/4 ✓ Branch 0 taken 382800 times. ✓ Branch 1 taken 83490 times. ✓ Branch 2 taken 421916 times. ✓ Branch 3 taken 94841 times.	983047x	if (this->svc_.scheduler().try_consume_inline_budget())
427			{
428	4/4 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 382799 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 421915 times.	804716x	*ec = err ? make_err(err) : std::error_code{};
429		804716x	*bytes_out = bytes;
430		804716x	return dispatch_coro(ex, h);
431			}
432		178331x	op.h = h;
433		178331x	op.ex = ex;
434		178331x	op.ec_out = ec;
435		178331x	op.bytes_out = bytes_out;
436		178331x	op.start(token, static_cast<Derived*>(this));
437		178331x	op.impl_ptr = this->shared_from_this();
438		178331x	op.complete(err, bytes);
439		178331x	this->svc_.post(&op);
440		178331x	return std::noop_coroutine();
441			}
442
443			// EAGAIN — register with reactor
444		✗	op.h = h;
445		✗	op.ex = ex;
446		✗	op.ec_out = ec;
447		✗	op.bytes_out = bytes_out;
448		✗	op.fd = this->fd_;
449		✗	op.start(token, static_cast<Derived*>(this));
450		✗	op.impl_ptr = this->shared_from_this();
451
452		✗	this->register_op(
453		✗	op, this->desc_state_.write_op, this->desc_state_.write_ready,
454		✗	this->desc_state_.write_cancel_pending);
455		✗	return std::noop_coroutine();
456		983049x	}
457
458			} // namespace boost::corosio::detail
459
460			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_SOCKET_HPP
461