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

93.1% Lines (121/130) 93.8% List of functions (30/32) 48.2% Branches (216/448)

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

reactor_op_complete.hpp

f(x) Functions (32)

Function Calls Lines Branches Blocks

Line	Branch	Hits	Source Code
1			//
2			// Copyright (c) 2026 Steve Gerbino
3			//
4			// Distributed under the Boost Software License, Version 1.0. (See accompanying
5			// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6			//
7			// Official repository: https://github.com/cppalliance/corosio
8			//
9
10			#ifndef BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_COMPLETE_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_COMPLETE_HPP
12
13			#include <boost/corosio/detail/dispatch_coro.hpp>
14			#include <boost/corosio/native/detail/endpoint_convert.hpp>
15			#include <boost/corosio/native/detail/make_err.hpp>
16			#include <boost/corosio/io/io_object.hpp>
17
18			#include <coroutine>
19			#include <mutex>
20			#include <utility>
21
22			#include <netinet/in.h>
23			#include <sys/socket.h>
24			#include <unistd.h>
25
26			namespace boost::corosio::detail {
27
28			/** Complete a base read/write operation.
29
30			Translates the recorded errno and cancellation state into
31			an error_code, stores the byte count, then resumes the
32			caller via symmetric transfer.
33
34			@tparam Op The concrete operation type.
35			@param op The operation to complete.
36			*/
37			template<typename Op>
38			void
39		189563x	complete_io_op(Op& op)
40			{
41		189563x	op.stop_cb.reset();
42		189563x	op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
43
44	9/16 ✓ Branch 0 taken 62 times. ✓ Branch 1 taken 91745 times. ✓ Branch 2 taken 464 times. ✓ Branch 3 taken 97266 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 5 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 10 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 3 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 5 times.	189563x	if (op.cancelled.load(std::memory_order_acquire))
45		526x	*op.ec_out = capy::error::canceled;
46	10/16 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 91744 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 97264 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 5 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 8 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 3 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 5 times.	189037x	else if (op.errn != 0)
47		5x	*op.ec_out = make_err(op.errn);
48	16/32 ✓ Branch 0 taken 54373 times. ✓ Branch 1 taken 37371 times. ✓ Branch 2 taken 54373 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 52846 times. ✓ Branch 5 taken 44418 times. ✓ Branch 6 taken 52839 times. ✓ Branch 7 taken 7 times. ✓ Branch 8 taken 1 time. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✓ Branch 13 taken 5 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✓ Branch 21 taken 8 times. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✓ Branch 24 taken 1 time. ✓ Branch 25 taken 2 times. ✓ Branch 26 taken 1 time. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✓ Branch 29 taken 5 times. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	189032x	else if (op.is_read_operation() && op.bytes_transferred == 0)
49		7x	*op.ec_out = capy::error::eof;
50			else
51		189025x	*op.ec_out = {};
52
53		189563x	*op.bytes_out = op.bytes_transferred;
54
55		189563x	op.cont_op.cont.h = op.h;
56		189563x	capy::executor_ref saved_ex(op.ex);
57		189563x	auto prevent = std::move(op.impl_ptr);
58	14/32 ✓ Branch 0 taken 91807 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 91807 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 97730 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 97730 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 3 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 3 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 5 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 5 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 10 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 10 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 3 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 3 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 5 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 5 times. ✗ Branch 31 not taken.	189563x	dispatch_coro(saved_ex, op.cont_op.cont).resume();
59		189563x	}
60
61			/** Complete a datagram recv operation (connected mode).
62
63			Like complete_io_op but does not translate zero bytes into
64			EOF. Zero-length datagrams are valid and should be reported
65			as success with 0 bytes transferred.
66
67			@param op The operation to complete.
68			*/
69			template<typename Op>
70			void
71			complete_dgram_recv_op(Op& op)
72			{
73			op.stop_cb.reset();
74			op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
75
76			if (op.cancelled.load(std::memory_order_acquire))
77			*op.ec_out = capy::error::canceled;
78			else if (op.errn != 0)
79			*op.ec_out = make_err(op.errn);
80			else
81			*op.ec_out = {};
82
83			*op.bytes_out = op.bytes_transferred;
84
85			op.cont_op.cont.h = op.h;
86			capy::executor_ref saved_ex(op.ex);
87			auto prevent = std::move(op.impl_ptr);
88			dispatch_coro(saved_ex, op.cont_op.cont).resume();
89			}
90
91			/** Complete a connect operation with endpoint caching.
92
93			On success, queries the local endpoint via getsockname and
94			caches both endpoints in the socket impl. Then resumes the
95			caller via symmetric transfer.
96
97			@tparam Op The concrete connect operation type.
98			@param op The operation to complete.
99			*/
100			template<typename Op>
101			void
102		5068x	complete_connect_op(Op& op)
103			{
104		5068x	op.stop_cb.reset();
105		5068x	op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
106
107		5068x	bool success =
108	7/16 ✓ Branch 0 taken 8 times. ✓ Branch 1 taken 1617 times. ✓ Branch 2 taken 7 times. ✓ Branch 3 taken 3427 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 2 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5068x	(op.errn == 0 && !op.cancelled.load(std::memory_order_acquire));
109
110	12/32 ✓ Branch 0 taken 1616 times. ✓ Branch 1 taken 9 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 1616 times. ✓ Branch 4 taken 3426 times. ✓ Branch 5 taken 8 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3426 times. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 2 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 5 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 5 times. ✓ Branch 24 taken 2 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 2 times. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	5068x	if (success && op.socket_impl_)
111			{
112			using ep_type = decltype(op.target_endpoint);
113		5051x	ep_type local_ep;
114		5051x	sockaddr_storage local_storage{};
115		5051x	socklen_t local_len = sizeof(local_storage);
116	10/32 ✗ Branch 0 not taken. ✓ Branch 1 taken 1616 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 1616 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3426 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 3426 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 2 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 2 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✓ Branch 21 taken 5 times. ✗ Branch 22 not taken. ✓ Branch 23 taken 5 times. ✗ Branch 24 not taken. ✓ Branch 25 taken 2 times. ✗ Branch 26 not taken. ✓ Branch 27 taken 2 times. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	10102x	if (::getsockname(
117		5051x	op.fd, reinterpret_cast<sockaddr*>(&local_storage),
118		5051x	&local_len) == 0)
119		5051x	local_ep =
120		5051x	from_sockaddr_as(local_storage, local_len, ep_type{});
121		5051x	op.socket_impl_->set_endpoints(local_ep, op.target_endpoint);
122		5051x	}
123
124	7/16 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1624 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 3433 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 2 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5068x	if (op.cancelled.load(std::memory_order_acquire))
125		2x	*op.ec_out = capy::error::canceled;
126	7/16 ✓ Branch 0 taken 8 times. ✓ Branch 1 taken 1616 times. ✓ Branch 2 taken 7 times. ✓ Branch 3 taken 3426 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 2 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 2 times. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5066x	else if (op.errn != 0)
127		15x	*op.ec_out = make_err(op.errn);
128			else
129		5051x	*op.ec_out = {};
130
131		5068x	op.cont_op.cont.h = op.h;
132		5068x	capy::executor_ref saved_ex(op.ex);
133		5068x	auto prevent = std::move(op.impl_ptr);
134	10/32 ✓ Branch 0 taken 1625 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1625 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3434 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 3434 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 5 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 5 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 2 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 2 times. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	5068x	dispatch_coro(saved_ex, op.cont_op.cont).resume();
135		5068x	}
136
137			/** Construct and register a peer socket from an accepted fd.
138
139			Creates a new socket impl via the acceptor's associated
140			socket service, registers it with the scheduler, and caches
141			the local and remote endpoints.
142
143			@tparam SocketImpl The concrete socket implementation type.
144			@tparam AcceptorImpl The concrete acceptor implementation type.
145			@param acceptor_impl The acceptor that accepted the connection.
146			@param accepted_fd The accepted file descriptor (set to -1 on success).
147			@param peer_storage The peer address from accept().
148			@param impl_out Output pointer for the new socket impl.
149			@param ec_out Output pointer for any error.
150			@return True on success, false on failure.
151			*/
152			template<typename SocketImpl, typename AcceptorImpl>
153			bool
154		5041x	setup_accepted_socket(
155			AcceptorImpl* acceptor_impl,
156			int& accepted_fd,
157			sockaddr_storage const& peer_storage,
158			socklen_t peer_addrlen,
159			io_object::implementation** impl_out,
160			std::error_code* ec_out)
161			{
162		5041x	auto* socket_svc = acceptor_impl->service().stream_service();
163	4/8 ✓ Branch 0 taken 1616 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3421 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	5041x	if (!socket_svc)
164			{
165		✗	*ec_out = make_err(ENOENT);
166		✗	return false;
167			}
168
169		5041x	auto& impl = static_cast<SocketImpl&>(*socket_svc->construct());
170		5041x	impl.set_socket(accepted_fd);
171
172		5041x	impl.desc_state_.fd = accepted_fd;
173			{
174		5041x	std::lock_guard lock(impl.desc_state_.mutex);
175		5041x	impl.desc_state_.read_op = nullptr;
176		5041x	impl.desc_state_.write_op = nullptr;
177		5041x	impl.desc_state_.connect_op = nullptr;
178		5041x	}
179		5041x	socket_svc->scheduler().register_descriptor(accepted_fd, &impl.desc_state_);
180
181			using ep_type = decltype(acceptor_impl->local_endpoint());
182		10082x	impl.set_endpoints(
183		5041x	acceptor_impl->local_endpoint(),
184		5041x	from_sockaddr_as(
185		5041x	peer_storage,
186		5041x	peer_addrlen,
187		5041x	ep_type{}));
188
189	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1616 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3421 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	5041x	if (impl_out)
190		5041x	*impl_out = &impl;
191		5041x	accepted_fd = -1;
192		5041x	return true;
193		5041x	}
194
195			/** Complete an accept operation.
196
197			Sets up the peer socket on success, or closes the accepted
198			fd on failure. Then resumes the caller via symmetric transfer.
199
200			@tparam SocketImpl The concrete socket implementation type.
201			@tparam Op The concrete accept operation type.
202			@param op The operation to complete.
203			*/
204			template<typename SocketImpl, typename Op>
205			void
206		5053x	complete_accept_op(Op& op)
207			{
208		5053x	op.stop_cb.reset();
209		5053x	op.acceptor_impl_->desc_state_.scheduler_->reset_inline_budget();
210
211		5053x	bool success =
212	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1619 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3430 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	5053x	(op.errn == 0 && !op.cancelled.load(std::memory_order_acquire));
213
214	6/8 ✓ Branch 0 taken 3 times. ✓ Branch 1 taken 1616 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 9 times. ✓ Branch 5 taken 3421 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	5053x	if (op.cancelled.load(std::memory_order_acquire))
215		12x	*op.ec_out = capy::error::canceled;
216	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1616 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 3421 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times.	5041x	else if (op.errn != 0)
217		✗	*op.ec_out = make_err(op.errn);
218			else
219		5041x	*op.ec_out = {};
220
221	14/24 ✓ Branch 0 taken 1616 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 1616 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 1616 times. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 2 times. ✓ Branch 12 taken 3421 times. ✓ Branch 13 taken 9 times. ✓ Branch 14 taken 3421 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✓ Branch 17 taken 3421 times. ✓ Branch 18 taken 2 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 2 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 2 times.	5053x	if (success && op.accepted_fd >= 0 && op.acceptor_impl_)
222			{
223	4/8 ✓ Branch 0 taken 1616 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3421 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken.	5041x	if (!setup_accepted_socket<SocketImpl>(
224		5041x	op.acceptor_impl_, op.accepted_fd, op.peer_storage,
225		5041x	op.peer_addrlen, op.impl_out, op.ec_out))
226		✗	success = false;
227		5041x	}
228
229	10/16 ✓ Branch 0 taken 1616 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 1616 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 2 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 3421 times. ✓ Branch 9 taken 9 times. ✓ Branch 10 taken 3421 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 2 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	5053x	if (!success \|\| !op.acceptor_impl_)
230			{
231	2/8 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 9 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	12x	if (op.accepted_fd >= 0)
232			{
233		✗	::close(op.accepted_fd);
234		✗	op.accepted_fd = -1;
235		✗	}
236	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 9 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	12x	if (op.impl_out)
237		12x	*op.impl_out = nullptr;
238		12x	}
239
240		5053x	op.cont_op.cont.h = op.h;
241		5053x	capy::executor_ref saved_ex(op.ex);
242		5053x	auto prevent = std::move(op.impl_ptr);
243	8/16 ✓ Branch 0 taken 1619 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1619 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 2 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 3430 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 3430 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 2 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	5053x	dispatch_coro(saved_ex, op.cont_op.cont).resume();
244		5053x	}
245
246			/** Complete a datagram operation (send_to or recv_from).
247
248			For recv_from operations, writes the source endpoint from the
249			recorded sockaddr_storage into the caller's endpoint pointer.
250			Then resumes the caller via symmetric transfer.
251
252			@tparam Op The concrete datagram operation type.
253			@param op The operation to complete.
254			*/
255			template<typename Op>
256			void
257		6x	complete_datagram_op(Op& op)
258			{
259		6x	op.stop_cb.reset();
260		6x	op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
261
262	6/8 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	6x	if (op.cancelled.load(std::memory_order_acquire))
263		2x	*op.ec_out = capy::error::canceled;
264	4/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 taken 1 time. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	4x	else if (op.errn != 0)
265		✗	*op.ec_out = make_err(op.errn);
266			else
267		4x	*op.ec_out = {};
268
269		6x	*op.bytes_out = op.bytes_transferred;
270
271		6x	op.cont_op.cont.h = op.h;
272		6x	capy::executor_ref saved_ex(op.ex);
273		6x	auto prevent = std::move(op.impl_ptr);
274	8/16 ✓ Branch 0 taken 2 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken.	6x	dispatch_coro(saved_ex, op.cont_op.cont).resume();
275		6x	}
276
277			/** Complete a datagram operation with source endpoint capture.
278
279			For recv_from operations, writes the source endpoint from the
280			recorded sockaddr_storage into the caller's endpoint pointer.
281			Then resumes the caller via symmetric transfer.
282
283			@tparam Op The concrete datagram operation type.
284			@param op The operation to complete.
285			@param source_out Optional pointer to store source endpoint
286			(non-null for recv_from, null for send_to).
287			*/
288			template<typename Op, typename Endpoint>
289			void
290		25x	complete_datagram_op(Op& op, Endpoint* source_out)
291			{
292		25x	op.stop_cb.reset();
293		25x	op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
294
295	6/8 ✓ Branch 0 taken 5 times. ✓ Branch 1 taken 8 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 5 times. ✓ Branch 5 taken 5 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	25x	if (op.cancelled.load(std::memory_order_acquire))
296		10x	*op.ec_out = capy::error::canceled;
297	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 8 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✓ Branch 5 taken 5 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	15x	else if (op.errn != 0)
298		✗	*op.ec_out = make_err(op.errn);
299			else
300		15x	*op.ec_out = {};
301
302		25x	*op.bytes_out = op.bytes_transferred;
303
304	16/24 ✓ Branch 0 taken 12 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 7 times. ✓ Branch 3 taken 5 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 7 times. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 1 time. ✓ Branch 12 taken 9 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 4 times. ✓ Branch 15 taken 5 times. ✗ Branch 16 not taken. ✓ Branch 17 taken 4 times. ✓ Branch 18 taken 1 time. ✗ Branch 19 not taken. ✓ Branch 20 taken 1 time. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 1 time.	25x	if (source_out && !op.cancelled.load(std::memory_order_acquire) &&
305		13x	op.errn == 0)
306		13x	*source_out = from_sockaddr_as(
307		13x	op.source_storage,
308		13x	op.source_addrlen,
309		13x	Endpoint{});
310
311		25x	op.cont_op.cont.h = op.h;
312		25x	capy::executor_ref saved_ex(op.ex);
313		25x	auto prevent = std::move(op.impl_ptr);
314	8/16 ✓ Branch 0 taken 13 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 13 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 10 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 10 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken.	25x	dispatch_coro(saved_ex, op.cont_op.cont).resume();
315		25x	}
316
317			} // namespace boost::corosio::detail
318
319			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_COMPLETE_HPP
320