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

93.3% Lines (195/209) 91.0% List of functions (322/354) 26.9% Branches (401/1492)

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

reactor_basic_socket.hpp

f(x) Functions (354)

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_BASIC_SOCKET_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
12
13			#include <boost/corosio/detail/intrusive.hpp>
14			#include <boost/corosio/detail/native_handle.hpp>
15			#include <boost/corosio/endpoint.hpp>
16			#include <boost/corosio/native/detail/reactor/reactor_op_base.hpp>
17			#include <boost/corosio/native/detail/make_err.hpp>
18			#include <boost/corosio/native/detail/endpoint_convert.hpp>
19
20			#include <memory>
21			#include <mutex>
22			#include <utility>
23
24			#include <errno.h>
25			#include <netinet/in.h>
26			#include <sys/socket.h>
27			#include <unistd.h>
28
29			namespace boost::corosio::detail {
30
31			/** CRTP base for reactor-backed socket implementations.
32
33			Extracts the shared data members, virtual overrides, and
34			cancel/close/register logic that is identical across TCP
35			(reactor_stream_socket) and UDP (reactor_datagram_socket).
36
37			Derived classes provide CRTP callbacks that enumerate their
38			specific op slots so cancel/close can iterate them generically.
39
40			@tparam Derived The concrete socket type (CRTP).
41			@tparam ImplBase The public vtable base (tcp_socket::implementation
42			or udp_socket::implementation).
43			@tparam Service The backend's service type.
44			@tparam DescState The backend's descriptor_state type.
45			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
46			*/
47			template<
48			class Derived,
49			class ImplBase,
50			class Service,
51			class DescState,
52			class Endpoint = endpoint>
53			class reactor_basic_socket
54			: public ImplBase
55			, public std::enable_shared_from_this<Derived>
56			, public intrusive_list<Derived>::node
57			{
58			friend Derived;
59
60			template<class, class, class, class, class, class, class, class, class>
61			friend class reactor_stream_socket;
62
63			template<class, class, class, class, class, class, class, class, class, class, class>
64			friend class reactor_datagram_socket;
65
66		36782x	explicit reactor_basic_socket(Service& svc) noexcept : svc_(svc) {}
67
68			protected:
69			Service& svc_;
70		18391x	int fd_ = -1;
71			Endpoint local_endpoint_;
72
73			public:
74			/// Per-descriptor state for persistent reactor registration.
75			DescState desc_state_;
76
77		18391x	~reactor_basic_socket() override = default;
78
79			/// Return the underlying file descriptor.
80		58732x	native_handle_type native_handle() const noexcept override
81			{
82		58732x	return fd_;
83			}
84
85			/// Return the cached local endpoint.
86		106x	Endpoint local_endpoint() const noexcept override
87			{
88		106x	return local_endpoint_;
89			}
90
91			/// Return true if the socket has an open file descriptor.
92			bool is_open() const noexcept
93			{
94			return fd_ >= 0;
95			}
96
97			/// Set a socket option.
98		62x	std::error_code set_option(
99			int level,
100			int optname,
101			void const* data,
102			std::size_t size) noexcept override
103			{
104	6/32 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 31 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 7 times. ✓ Branch 7 taken 24 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. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 31 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 7 times. ✓ Branch 23 taken 24 times. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	62x	if (::setsockopt(
105		62x	fd_, level, optname, data, static_cast<socklen_t>(size)) != 0)
106	2/16 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 7 times. ✗ 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 7 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	14x	return make_err(errno);
107		48x	return {};
108		62x	}
109
110			/// Get a socket option.
111			std::error_code
112		94x	get_option(int level, int optname, void* data, std::size_t* size)
113			const noexcept override
114			{
115		94x	socklen_t len = static_cast<socklen_t>(*size);
116	6/32 ✓ Branch 0 taken 33 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 33 times. ✓ Branch 4 taken 47 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 47 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. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 14 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 14 times. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken.	94x	if (::getsockopt(fd_, level, optname, data, &len) != 0)
117		✗	return make_err(errno);
118		94x	*size = static_cast<std::size_t>(len);
119		94x	return {};
120		94x	}
121
122			/// Assign the file descriptor.
123		5934x	void set_socket(int fd) noexcept
124			{
125		5934x	fd_ = fd;
126		5934x	}
127
128			/// Cache the local endpoint.
129			void set_local_endpoint(Endpoint ep) noexcept
130			{
131			local_endpoint_ = ep;
132			}
133
134			/** Bind the socket to a local endpoint.
135
136			Calls ::bind() and caches the resulting local endpoint
137			via getsockname().
138
139			@param ep The endpoint to bind to.
140			@return Error code on failure, empty on success.
141			*/
142		132x	std::error_code do_bind(Endpoint const& ep) noexcept
143			{
144		132x	sockaddr_storage storage{};
145		132x	socklen_t addrlen = to_sockaddr(ep, socket_family(fd_), storage);
146	18/24 ✓ Branch 0 taken 6 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 46 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 44 times. ✓ Branch 8 taken 14 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✓ Branch 11 taken 13 times. ✓ Branch 12 taken 6 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 4 times. ✓ Branch 16 taken 46 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 2 times. ✓ Branch 19 taken 44 times. ✓ Branch 20 taken 14 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 1 time. ✓ Branch 23 taken 13 times.	132x	if (::bind(fd_, reinterpret_cast<sockaddr*>(&storage), addrlen) != 0)
147	6/12 ✓ 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 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken.	10x	return make_err(errno);
148
149		122x	sockaddr_storage local_storage{};
150		122x	socklen_t local_len = sizeof(local_storage);
151	12/24 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 44 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 44 times. ✓ Branch 8 taken 13 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 13 times. ✓ Branch 12 taken 4 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 4 times. ✓ Branch 16 taken 44 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 44 times. ✓ Branch 20 taken 13 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 13 times.	122x	if (::getsockname(
152		122x	fd_, reinterpret_cast<sockaddr*>(&local_storage), &local_len) ==
153			0)
154		122x	local_endpoint_ =
155		122x	from_sockaddr_as(local_storage, local_len, Endpoint{});
156
157		122x	return {};
158		132x	}
159
160			/// Assign the fd, initialize descriptor state, and register with the reactor.
161		6331x	void init_and_register(int fd) noexcept
162			{
163		6331x	fd_ = fd;
164		6331x	desc_state_.fd = fd;
165			{
166	8/16 ✓ Branch 0 taken 1646 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 80 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 39 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 51 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4345 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 80 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 39 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 51 times. ✗ Branch 15 not taken.	6331x	std::lock_guard lock(desc_state_.mutex);
167		6331x	desc_state_.read_op = nullptr;
168		6331x	desc_state_.write_op = nullptr;
169		6331x	desc_state_.connect_op = nullptr;
170		6331x	}
171	8/16 ✓ Branch 0 taken 1646 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 80 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 39 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 51 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4345 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 80 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 39 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 51 times. ✗ Branch 15 not taken.	6331x	svc_.scheduler().register_descriptor(fd, &desc_state_);
172		6331x	}
173
174			/** Register an op with the reactor.
175
176			Handles cached edge events and deferred cancellation.
177			Called on the EAGAIN/EINPROGRESS path when speculative
178			I/O failed.
179			*/
180			template<class Op>
181			void register_op(
182			Op& op,
183			reactor_op_base*& desc_slot,
184			bool& ready_flag,
185			bool& cancel_flag,
186			bool is_write_direction = false) noexcept;
187
188			/** Cancel a single pending operation.
189
190			Claims the operation from its descriptor_state slot under
191			the mutex and posts it to the scheduler as cancelled.
192			Derived must implement:
193			op_to_desc_slot(Op&) -> reactor_op_base**
194			op_to_cancel_flag(Op&) -> bool*
195			*/
196			template<class Op>
197			void cancel_single_op(Op& op) noexcept;
198
199			/** Cancel all pending operations.
200
201			Invoked by the derived class's cancel() override.
202			Derived must implement:
203			for_each_op(auto fn)
204			for_each_desc_entry(auto fn)
205			*/
206			void do_cancel() noexcept;
207
208			/** Close the socket and cancel pending operations.
209
210			Invoked by the derived class's close_socket(). The
211			derived class may add backend-specific cleanup after
212			calling this method.
213			Derived must implement:
214			for_each_op(auto fn)
215			for_each_desc_entry(auto fn)
216			*/
217			void do_close_socket() noexcept;
218
219			/** Release the socket without closing the fd.
220
221			Like do_close_socket() but does not call ::close().
222			Returns the fd so the caller can take ownership.
223			*/
224			native_handle_type do_release_socket() noexcept;
225			};
226
227			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
228			template<class Op>
229			void
230		79820x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::register_op(
231			Op& op,
232			reactor_op_base*& desc_slot,
233			bool& ready_flag,
234			bool& cancel_flag,
235			bool is_write_direction) noexcept
236			{
237		79820x	svc_.work_started();
238
239	10/80 ✓ Branch 0 taken 30922 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 265 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1621 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 42391 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 261 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 4320 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 19 times. ✗ 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 7 times. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	79820x	std::lock_guard lock(desc_state_.mutex);
240		79820x	bool io_done = false;
241	13/80 ✓ Branch 0 taken 29491 times. ✓ Branch 1 taken 1431 times. ✓ Branch 2 taken 265 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1621 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 41823 times. ✓ Branch 9 taken 568 times. ✓ Branch 10 taken 260 times. ✓ Branch 11 taken 1 time. ✓ Branch 12 taken 4320 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 19 times. ✗ 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 7 times. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	79820x	if (ready_flag)
242			{
243		2000x	ready_flag = false;
244		2000x	op.perform_io();
245	5/80 ✓ Branch 0 taken 1388 times. ✓ Branch 1 taken 43 times. ✗ 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 taken 526 times. ✓ Branch 9 taken 42 times. ✓ Branch 10 taken 1 time. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	2000x	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
246	5/80 ✓ Branch 0 taken 43 times. ✓ Branch 1 taken 1388 times. ✗ 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 taken 42 times. ✓ Branch 9 taken 526 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 1 time. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	2000x	if (!io_done)
247		1915x	op.errn = 0;
248		2000x	}
249
250	10/80 ✓ Branch 0 taken 30922 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 265 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1621 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 42391 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 261 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 4320 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 19 times. ✗ 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 7 times. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	79820x	if (cancel_flag)
251			{
252		✗	cancel_flag = false;
253		✗	op.cancelled.store(true, std::memory_order_relaxed);
254		✗	}
255
256	22/160 ✓ Branch 0 taken 30879 times. ✓ Branch 1 taken 43 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 30879 times. ✓ Branch 4 taken 265 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 265 times. ✓ Branch 8 taken 1621 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 1621 times. ✓ Branch 12 taken 9 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 9 times. ✓ Branch 16 taken 42349 times. ✓ Branch 17 taken 42 times. ✗ Branch 18 not taken. ✓ Branch 19 taken 42349 times. ✓ Branch 20 taken 261 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 261 times. ✓ Branch 24 taken 4320 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 4320 times. ✓ Branch 28 taken 19 times. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✓ Branch 31 taken 19 times. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✓ Branch 40 taken 5 times. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✓ Branch 43 taken 5 times. ✓ Branch 44 taken 7 times. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✓ Branch 47 taken 7 times. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken. ✗ Branch 80 not taken. ✗ Branch 81 not taken. ✗ Branch 82 not taken. ✗ Branch 83 not taken. ✗ Branch 84 not taken. ✗ Branch 85 not taken. ✗ Branch 86 not taken. ✗ Branch 87 not taken. ✗ Branch 88 not taken. ✗ Branch 89 not taken. ✗ Branch 90 not taken. ✗ Branch 91 not taken. ✗ Branch 92 not taken. ✗ Branch 93 not taken. ✗ Branch 94 not taken. ✗ Branch 95 not taken. ✗ Branch 96 not taken. ✗ Branch 97 not taken. ✗ Branch 98 not taken. ✗ Branch 99 not taken. ✗ Branch 100 not taken. ✗ Branch 101 not taken. ✗ Branch 102 not taken. ✗ Branch 103 not taken. ✗ Branch 104 not taken. ✗ Branch 105 not taken. ✗ Branch 106 not taken. ✗ Branch 107 not taken. ✗ Branch 108 not taken. ✗ Branch 109 not taken. ✗ Branch 110 not taken. ✗ Branch 111 not taken. ✗ Branch 112 not taken. ✗ Branch 113 not taken. ✗ Branch 114 not taken. ✗ Branch 115 not taken. ✗ Branch 116 not taken. ✗ Branch 117 not taken. ✗ Branch 118 not taken. ✗ Branch 119 not taken. ✗ Branch 120 not taken. ✗ Branch 121 not taken. ✗ Branch 122 not taken. ✗ Branch 123 not taken. ✗ Branch 124 not taken. ✗ Branch 125 not taken. ✗ Branch 126 not taken. ✗ Branch 127 not taken. ✗ Branch 128 not taken. ✗ Branch 129 not taken. ✗ Branch 130 not taken. ✗ Branch 131 not taken. ✗ Branch 132 not taken. ✗ Branch 133 not taken. ✗ Branch 134 not taken. ✗ Branch 135 not taken. ✗ Branch 136 not taken. ✗ Branch 137 not taken. ✗ Branch 138 not taken. ✗ Branch 139 not taken. ✗ Branch 140 not taken. ✗ Branch 141 not taken. ✗ Branch 142 not taken. ✗ Branch 143 not taken. ✗ Branch 144 not taken. ✗ Branch 145 not taken. ✗ Branch 146 not taken. ✗ Branch 147 not taken. ✗ Branch 148 not taken. ✗ Branch 149 not taken. ✗ Branch 150 not taken. ✗ Branch 151 not taken. ✗ Branch 152 not taken. ✗ Branch 153 not taken. ✗ Branch 154 not taken. ✗ Branch 155 not taken. ✗ Branch 156 not taken. ✗ Branch 157 not taken. ✗ Branch 158 not taken. ✗ Branch 159 not taken.	79820x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
257			{
258	2/80 ✓ Branch 0 taken 43 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 42 times. ✗ 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. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	85x	svc_.post(&op);
259		85x	svc_.work_finished();
260		85x	}
261			else
262			{
263		79735x	desc_slot = &op;
264
265			// Select must rebuild its fd_sets when a write-direction op
266			// is parked, so select() watches for writability. Compiled
267			// away to nothing for epoll and kqueue.
268			if constexpr (requires { Service::needs_write_notification; })
269			{
270			if constexpr (Service::needs_write_notification)
271			{
272	7/40 ✗ Branch 0 not taken. ✓ Branch 1 taken 30879 times. ✓ Branch 2 taken 253 times. ✓ Branch 3 taken 12 times. ✓ Branch 4 taken 1621 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 9 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 4 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 7 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 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken.	32785x	if (is_write_direction)
273	2/40 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 253 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1621 times. ✗ 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 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken.	1874x	svc_.scheduler().notify_reactor();
274			}
275			}
276			}
277		79820x	}
278
279			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
280			template<class Op>
281			void
282		641x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::cancel_single_op(
283			Op& op) noexcept
284			{
285		641x	auto self = this->weak_from_this().lock();
286	3/16 ✓ Branch 0 taken 38 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 600 times. ✗ 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 3 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	641x	if (!self)
287		✗	return;
288
289		641x	op.request_cancel();
290
291		641x	auto* d = static_cast<Derived*>(this);
292		641x	reactor_op_base** desc_op_ptr = d->op_to_desc_slot(op);
293
294	3/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 38 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 600 times. ✗ 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 3 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	641x	if (desc_op_ptr)
295			{
296		641x	reactor_op_base* claimed = nullptr;
297			{
298	3/16 ✓ Branch 0 taken 38 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 600 times. ✗ 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 3 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	641x	std::lock_guard lock(desc_state_.mutex);
299	4/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 38 times. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 599 times. ✗ 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 3 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	641x	if (*desc_op_ptr == &op)
300		640x	claimed = std::exchange(*desc_op_ptr, nullptr);
301			else
302			{
303		1x	bool* cflag = d->op_to_cancel_flag(op);
304	1/16 ✗ 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. ✗ 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.	1x	if (cflag)
305		1x	*cflag = true;
306			}
307		641x	}
308	4/16 ✓ Branch 0 taken 38 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 599 times. ✓ Branch 3 taken 1 time. ✗ 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 3 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	641x	if (claimed)
309			{
310		640x	op.impl_ptr = self;
311	3/16 ✓ Branch 0 taken 38 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 599 times. ✗ 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 3 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	640x	svc_.post(&op);
312		640x	svc_.work_finished();
313		640x	}
314		641x	}
315		641x	}
316
317			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
318			void
319			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
320		171x	do_cancel() noexcept
321			{
322		171x	auto self = this->weak_from_this().lock();
323	5/16 ✓ Branch 0 taken 42 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 120 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	171x	if (!self)
324		✗	return;
325
326		171x	auto* d = static_cast<Derived*>(this);
327
328		1225x	d->for_each_op([](auto& op) { op.request_cancel(); });
329
330			// Claim ops under a single lock acquisition
331		1368x	struct claimed_entry
332			{
333		1368x	reactor_op_base* op = nullptr;
334		1368x	reactor_op_base* base = nullptr;
335			};
336			// Max 8 ops: conn, rd, wr, wait_rd, wait_wr, wait_er, recv_rd, send_wr
337		171x	claimed_entry claimed[8];
338		171x	int count = 0;
339
340			{
341	5/16 ✓ Branch 0 taken 42 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 120 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	171x	std::lock_guard lock(desc_state_.mutex);
342		1225x	d->for_each_desc_entry([&](auto& op, reactor_op_base*& desc_slot) {
343	42/80 ✓ Branch 0 taken 41 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 22 times. ✓ Branch 3 taken 20 times. ✓ Branch 4 taken 42 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 121 times. ✓ Branch 7 taken 5 times. ✓ Branch 8 taken 119 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 66 times. ✓ Branch 11 taken 54 times. ✓ Branch 12 taken 120 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 345 times. ✓ Branch 15 taken 5 times. ✓ Branch 16 taken 5 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 13 times. ✓ Branch 19 taken 2 times. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✓ Branch 28 taken 2 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 2 times. ✗ Branch 31 not taken. ✓ Branch 32 taken 2 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 1 time. ✓ Branch 35 taken 1 time. ✓ Branch 36 taken 2 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 5 times. ✓ Branch 39 taken 1 time. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✓ Branch 48 taken 5 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 3 times. ✓ Branch 51 taken 2 times. ✓ Branch 52 taken 5 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 4 times. ✓ Branch 55 taken 1 time. ✓ Branch 56 taken 5 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 13 times. ✓ Branch 59 taken 2 times. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✓ Branch 68 taken 2 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 2 times. ✗ Branch 71 not taken. ✓ Branch 72 taken 2 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 1 time. ✓ Branch 75 taken 1 time. ✓ Branch 76 taken 2 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 5 times. ✓ Branch 79 taken 1 time.	1054x	if (desc_slot == &op)
344			{
345		97x	claimed[count].op = std::exchange(desc_slot, nullptr);
346		97x	claimed[count].base = &op;
347		97x	++count;
348		97x	}
349		1054x	});
350		171x	}
351
352	10/16 ✓ Branch 0 taken 42 times. ✓ Branch 1 taken 26 times. ✓ Branch 2 taken 120 times. ✓ Branch 3 taken 62 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 2 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 2 times.	268x	for (int i = 0; i < count; ++i)
353			{
354		97x	claimed[i].base->impl_ptr = self;
355	5/16 ✓ Branch 0 taken 26 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 62 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	97x	svc_.post(claimed[i].base);
356		97x	svc_.work_finished();
357		97x	}
358		171x	}
359
360			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
361			void
362			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
363		55378x	do_close_socket() noexcept
364			{
365		55378x	auto self = this->weak_from_this().lock();
366	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 14655 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 342 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 222 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 228 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 39139 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 342 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 222 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 228 times.	55378x	if (self)
367			{
368		55378x	auto* d = static_cast<Derived*>(this);
369
370		389926x	d->for_each_op([](auto& op) { op.request_cancel(); });
371
372		443024x	struct claimed_entry
373			{
374		443024x	reactor_op_base* base = nullptr;
375			};
376		55378x	claimed_entry claimed[8];
377		55378x	int count = 0;
378
379			{
380	8/16 ✓ Branch 0 taken 14655 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 342 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 222 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 228 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 39139 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 342 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 222 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 228 times. ✗ Branch 15 not taken.	55378x	std::lock_guard lock(desc_state_.mutex);
381		110756x	d->for_each_desc_entry(
382		389926x	[&](auto& /op/, reactor_op_base*& desc_slot) {
383		334548x	auto* c = std::exchange(desc_slot, nullptr);
384	46/80 ✓ Branch 0 taken 14655 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 14654 times. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 14655 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 43965 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 342 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 340 times. ✓ Branch 11 taken 2 times. ✓ Branch 12 taken 342 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 342 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 342 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 1025 times. ✓ Branch 19 taken 1 time. ✓ Branch 20 taken 222 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 222 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 222 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 666 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 228 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 228 times. ✗ Branch 31 not taken. ✓ Branch 32 taken 228 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 228 times. ✗ Branch 35 not taken. ✓ Branch 36 taken 228 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 684 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 39139 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 39136 times. ✓ Branch 43 taken 3 times. ✓ Branch 44 taken 39139 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 117417 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 342 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 340 times. ✓ Branch 51 taken 2 times. ✓ Branch 52 taken 342 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 342 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 342 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 1025 times. ✓ Branch 59 taken 1 time. ✓ Branch 60 taken 222 times. ✗ Branch 61 not taken. ✓ Branch 62 taken 222 times. ✗ Branch 63 not taken. ✓ Branch 64 taken 222 times. ✗ Branch 65 not taken. ✓ Branch 66 taken 666 times. ✗ Branch 67 not taken. ✓ Branch 68 taken 228 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 228 times. ✗ Branch 71 not taken. ✓ Branch 72 taken 228 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 228 times. ✗ Branch 75 not taken. ✓ Branch 76 taken 228 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 684 times. ✗ Branch 79 not taken.	334548x	if (c)
385			{
386		10x	claimed[count].base = c;
387		10x	++count;
388		10x	}
389		334548x	});
390		55378x	desc_state_.read_ready = false;
391		55378x	desc_state_.write_ready = false;
392		55378x	desc_state_.read_cancel_pending = false;
393		55378x	desc_state_.write_cancel_pending = false;
394		55378x	desc_state_.connect_cancel_pending = false;
395		55378x	desc_state_.wait_read_cancel_pending = false;
396		55378x	desc_state_.wait_write_cancel_pending = false;
397		55378x	desc_state_.wait_error_cancel_pending = false;
398
399	16/16 ✓ Branch 0 taken 14615 times. ✓ Branch 1 taken 40 times. ✓ Branch 2 taken 339 times. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 219 times. ✓ Branch 5 taken 3 times. ✓ Branch 6 taken 210 times. ✓ Branch 7 taken 18 times. ✓ Branch 8 taken 37474 times. ✓ Branch 9 taken 1665 times. ✓ Branch 10 taken 321 times. ✓ Branch 11 taken 21 times. ✓ Branch 12 taken 189 times. ✓ Branch 13 taken 33 times. ✓ Branch 14 taken 174 times. ✓ Branch 15 taken 54 times.	55378x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
400		1837x	desc_state_.impl_ref_ = self;
401		55378x	}
402
403	12/16 ✓ Branch 0 taken 14655 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 342 times. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 222 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 228 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 39139 times. ✓ Branch 9 taken 3 times. ✓ Branch 10 taken 342 times. ✓ Branch 11 taken 3 times. ✓ Branch 12 taken 222 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 228 times. ✗ Branch 15 not taken.	55388x	for (int i = 0; i < count; ++i)
404			{
405		10x	claimed[i].base->impl_ptr = self;
406	4/16 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 3 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 3 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 3 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	10x	svc_.post(claimed[i].base);
407		10x	svc_.work_finished();
408		10x	}
409		55378x	}
410
411	16/16 ✓ Branch 0 taken 3255 times. ✓ Branch 1 taken 11400 times. ✓ Branch 2 taken 80 times. ✓ Branch 3 taken 262 times. ✓ Branch 4 taken 46 times. ✓ Branch 5 taken 176 times. ✓ Branch 6 taken 50 times. ✓ Branch 7 taken 178 times. ✓ Branch 8 taken 8654 times. ✓ Branch 9 taken 30485 times. ✓ Branch 10 taken 80 times. ✓ Branch 11 taken 262 times. ✓ Branch 12 taken 46 times. ✓ Branch 13 taken 176 times. ✓ Branch 14 taken 50 times. ✓ Branch 15 taken 178 times.	55378x	if (fd_ >= 0)
412			{
413	8/16 ✓ Branch 0 taken 3255 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 80 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 46 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 50 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 8654 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 80 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 46 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 50 times. ✗ Branch 15 not taken.	12261x	if (desc_state_.registered_events != 0)
414	8/16 ✓ Branch 0 taken 3255 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 80 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 46 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 50 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 8654 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 80 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 46 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 50 times. ✗ Branch 15 not taken.	12261x	svc_.scheduler().deregister_descriptor(fd_);
415	8/16 ✓ Branch 0 taken 3255 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 80 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 46 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 50 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 8654 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 80 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 46 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 50 times. ✗ Branch 15 not taken.	12261x	::close(fd_);
416		12261x	fd_ = -1;
417		12261x	}
418
419		55378x	desc_state_.fd = -1;
420		55378x	desc_state_.registered_events = 0;
421
422		55378x	local_endpoint_ = Endpoint{};
423		55378x	}
424
425			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
426			native_handle_type
427			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
428		4x	do_release_socket() noexcept
429			{
430			// Cancel pending ops (same as do_close_socket)
431		4x	auto self = this->weak_from_this().lock();
432	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	4x	if (self)
433			{
434		4x	auto* d = static_cast<Derived*>(this);
435
436		32x	d->for_each_op([](auto& op) { op.request_cancel(); });
437
438		32x	struct claimed_entry
439			{
440		32x	reactor_op_base* base = nullptr;
441			};
442		4x	claimed_entry claimed[8];
443		4x	int count = 0;
444
445			{
446	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	std::lock_guard lock(desc_state_.mutex);
447		8x	d->for_each_desc_entry(
448		32x	[&](auto& /op/, reactor_op_base*& desc_slot) {
449		28x	auto* c = std::exchange(desc_slot, nullptr);
450	16/40 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 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 taken 2 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✓ Branch 18 taken 3 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✓ Branch 28 taken 1 time. ✗ Branch 29 not taken. ✓ Branch 30 taken 1 time. ✗ Branch 31 not taken. ✓ Branch 32 taken 1 time. ✗ Branch 33 not taken. ✓ Branch 34 taken 1 time. ✗ Branch 35 not taken. ✓ Branch 36 taken 1 time. ✗ Branch 37 not taken. ✓ Branch 38 taken 3 times. ✗ Branch 39 not taken.	28x	if (c)
451			{
452		✗	claimed[count].base = c;
453		✗	++count;
454		✗	}
455		28x	});
456		4x	desc_state_.read_ready = false;
457		4x	desc_state_.write_ready = false;
458		4x	desc_state_.read_cancel_pending = false;
459		4x	desc_state_.write_cancel_pending = false;
460		4x	desc_state_.connect_cancel_pending = false;
461		4x	desc_state_.wait_read_cancel_pending = false;
462		4x	desc_state_.wait_write_cancel_pending = false;
463		4x	desc_state_.wait_error_cancel_pending = false;
464
465	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
466		✗	desc_state_.impl_ref_ = self;
467		4x	}
468
469	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	for (int i = 0; i < count; ++i)
470			{
471		✗	claimed[i].base->impl_ptr = self;
472		✗	svc_.post(claimed[i].base);
473		✗	svc_.work_finished();
474		✗	}
475		4x	}
476
477		4x	native_handle_type released = fd_;
478
479	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	4x	if (fd_ >= 0)
480			{
481	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	if (desc_state_.registered_events != 0)
482	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	svc_.scheduler().deregister_descriptor(fd_);
483			// Do NOT close -- caller takes ownership
484		4x	fd_ = -1;
485		4x	}
486
487		4x	desc_state_.fd = -1;
488		4x	desc_state_.registered_events = 0;
489
490		4x	local_endpoint_ = Endpoint{};
491
492		4x	return released;
493		4x	}
494
495			} // namespace boost::corosio::detail
496
497			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
498