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

98.8% Lines (159/161) 98.3% List of functions (350/356) 39.8% Branches (516/1296)

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

reactor_basic_socket.hpp

f(x) Functions (356)

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/native_socket_base.hpp>
17			#include <boost/corosio/native/detail/reactor/reactor_op_base.hpp>
18			#include <boost/corosio/native/detail/make_err.hpp>
19			#include <boost/corosio/native/detail/endpoint_convert.hpp>
20
21			#include <memory>
22			#include <mutex>
23			#include <utility>
24
25			#include <errno.h>
26			#include <netinet/in.h>
27			#include <sys/socket.h>
28			#include <unistd.h>
29
30			namespace boost::corosio::detail {
31
32			/** CRTP base for reactor-backed socket implementations.
33
34			Extracts the shared data members, virtual overrides, and
35			cancel/close/register logic that is identical across TCP
36			(reactor_stream_socket) and UDP (reactor_datagram_socket).
37
38			Derived classes provide CRTP callbacks that enumerate their
39			specific op slots so cancel/close can iterate them generically.
40
41			@tparam Derived The concrete socket type (CRTP).
42			@tparam ImplBase The public vtable base (tcp_socket::implementation
43			or udp_socket::implementation).
44			@tparam Service The backend's service type.
45			@tparam DescState The backend's descriptor_state type.
46			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
47			*/
48			template<
49			class Derived,
50			class ImplBase,
51			class Service,
52			class DescState,
53			class Endpoint = endpoint>
54			class reactor_basic_socket
55			: public native_socket_base<Derived, ImplBase, Endpoint>
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<
64			class,
65			class,
66			class,
67			class,
68			class,
69			class,
70			class,
71			class,
72			class,
73			class,
74			class>
75			friend class reactor_datagram_socket;
76
77		20555x	explicit reactor_basic_socket(Service& svc) noexcept : svc_(svc) {}
78
79			protected:
80			// fd_ / local_endpoint_ and the synchronous accessors (native_handle,
81			// is_open, set_option/get_option, set_socket/set_local_endpoint, do_bind)
82			// live in native_socket_base — the readiness/completion-agnostic base
83			// shared with io_uring's sockets. The using-declarations make the
84			// inherited members visible to this template's own unqualified
85			// references below (two-phase lookup).
86			using native_socket_base<Derived, ImplBase, Endpoint>::fd_;
87			using native_socket_base<Derived, ImplBase, Endpoint>::local_endpoint_;
88
89			Service& svc_;
90
91			public:
92			/// Per-descriptor state for persistent reactor registration.
93			DescState desc_state_;
94
95		20555x	~reactor_basic_socket() override = default;
96
97			/** Assign the fd, initialize descriptor state, and register with
98			the reactor.
99
100			@param fd The descriptor to adopt.
101
102			@return The error if the reactor rejects the descriptor, in
103			which case the implementation is left closed and the caller
104			retains ownership of @a fd; otherwise a default constructed
105			error code.
106			*/
107		7161x	std::error_code init_and_register(int fd) noexcept
108			{
109		7161x	fd_ = fd;
110		7161x	desc_state_.fd = fd;
111			{
112	8/16 ✓ Branch 0 taken 1781 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 144 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 95 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 102 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4686 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 149 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 98 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 106 times. ✗ Branch 15 not taken.	7161x	std::lock_guard lock(desc_state_.mutex);
113		7161x	desc_state_.read_op = nullptr;
114		7161x	desc_state_.write_op = nullptr;
115		7161x	desc_state_.connect_op = nullptr;
116		7161x	}
117	18/32 ✓ Branch 0 taken 1781 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 1781 times. ✓ Branch 4 taken 144 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✓ Branch 7 taken 143 times. ✓ Branch 8 taken 95 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 95 times. ✓ Branch 12 taken 102 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 102 times. ✓ Branch 16 taken 4686 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 2 times. ✓ Branch 19 taken 4684 times. ✓ Branch 20 taken 149 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 149 times. ✓ Branch 24 taken 98 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 98 times. ✓ Branch 28 taken 106 times. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✓ Branch 31 taken 106 times.	7161x	if (auto ec = svc_.scheduler().register_descriptor(fd, &desc_state_))
118			{
119			// Undo the partial state so a failed adopt is
120			// indistinguishable from a closed implementation.
121		3x	fd_ = -1;
122		3x	desc_state_.fd = -1;
123		3x	desc_state_.registered_events = 0;
124		3x	return ec;
125			}
126		7158x	return {};
127		7161x	}
128
129			/** Register an op with the reactor.
130
131			Handles cached edge events. Called on the EAGAIN/EINPROGRESS
132			path when speculative I/O failed.
133			*/
134			template<class Op>
135			void register_op(
136			Op& op,
137			reactor_op_base*& desc_slot,
138			bool& ready_flag,
139			bool is_write_direction = false) noexcept;
140
141			/** Cancel a single pending operation.
142
143			Claims the operation from its descriptor_state slot under
144			the mutex and posts it to the scheduler as cancelled.
145			Derived must implement:
146			op_to_desc_slot(Op&) -> reactor_op_base**
147			*/
148			template<class Op>
149			void cancel_single_op(Op& op) noexcept;
150
151			/** Cancel all pending operations.
152
153			Invoked by the derived class's cancel() override.
154			Derived must implement:
155			for_each_op(auto fn)
156			for_each_desc_entry(auto fn)
157			*/
158			void do_cancel() noexcept;
159
160			/** Close the socket and cancel pending operations.
161
162			Invoked by the derived class's close_socket(). The
163			derived class may add backend-specific cleanup after
164			calling this method.
165			Derived must implement:
166			for_each_op(auto fn)
167			for_each_desc_entry(auto fn)
168			*/
169			void do_close_socket() noexcept;
170
171			/** Release the socket without closing the fd.
172
173			Like do_close_socket() but does not call ::close().
174			Returns the fd so the caller can take ownership.
175			*/
176			native_handle_type do_release_socket() noexcept;
177			};
178
179			template<
180			class Derived,
181			class ImplBase,
182			class Service,
183			class DescState,
184			class Endpoint>
185			template<class Op>
186			void
187			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
188		65842x	register_op(
189			Op& op,
190			reactor_op_base*& desc_slot,
191			bool& ready_flag,
192			bool is_write_direction) noexcept
193			{
194		65842x	svc_.work_started();
195
196	20/72 ✓ Branch 0 taken 32026 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 514 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 4602 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 39 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 26199 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 519 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1728 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 52 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 18 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 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 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 taken 14 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 1 time. ✗ Branch 39 not taken. ✓ Branch 40 taken 69 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 2 times. ✗ Branch 43 not taken. ✓ Branch 44 taken 1 time. ✗ Branch 45 not taken. ✓ Branch 46 taken 12 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 1 time. ✗ Branch 49 not taken. ✓ Branch 50 taken 27 times. ✗ Branch 51 not taken. ✓ Branch 52 taken 11 times. ✗ 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 taken 1 time. ✗ 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.	65842x	std::lock_guard lock(desc_state_.mutex);
197		65842x	bool io_done = false;
198	27/72 ✓ Branch 0 taken 31643 times. ✓ Branch 1 taken 383 times. ✓ Branch 2 taken 512 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 4602 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 7 times. ✓ Branch 7 taken 32 times. ✓ Branch 8 taken 25892 times. ✓ Branch 9 taken 307 times. ✓ Branch 10 taken 519 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1728 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 28 times. ✓ Branch 15 taken 24 times. ✓ Branch 16 taken 7 times. ✓ Branch 17 taken 11 times. ✗ Branch 18 not taken. ✓ Branch 19 taken 6 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 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 taken 14 times. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✓ Branch 39 taken 1 time. ✓ Branch 40 taken 67 times. ✓ Branch 41 taken 2 times. ✗ Branch 42 not taken. ✓ Branch 43 taken 2 times. ✗ Branch 44 not taken. ✓ Branch 45 taken 1 time. ✓ Branch 46 taken 12 times. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✓ Branch 49 taken 1 time. ✓ Branch 50 taken 27 times. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✓ Branch 53 taken 11 times. ✗ 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 taken 1 time. ✗ 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.	65842x	if (ready_flag)
199			{
200		783x	ready_flag = false;
201		783x	op.perform_io();
202	15/72 ✓ Branch 0 taken 344 times. ✓ Branch 1 taken 39 times. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 32 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 264 times. ✓ Branch 9 taken 43 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 24 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 11 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 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 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 taken 1 time. ✗ Branch 40 not taken. ✓ Branch 41 taken 2 times. ✓ Branch 42 taken 2 times. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✓ Branch 45 taken 1 time. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✓ Branch 49 taken 1 time. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✓ Branch 52 taken 11 times. ✗ 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.	783x	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
203	15/72 ✓ Branch 0 taken 39 times. ✓ Branch 1 taken 344 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 32 times. ✓ Branch 8 taken 43 times. ✓ Branch 9 taken 264 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 24 times. ✗ Branch 16 not taken. ✓ Branch 17 taken 11 times. ✗ Branch 18 not taken. ✓ Branch 19 taken 6 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 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 taken 1 time. ✗ Branch 39 not taken. ✓ Branch 40 taken 2 times. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✓ Branch 43 taken 2 times. ✓ Branch 44 taken 1 time. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✓ Branch 48 taken 1 time. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✓ Branch 53 taken 11 times. ✗ 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.	783x	if (!io_done)
204		696x	op.errn = 0;
205		783x	}
206
207	53/144 ✓ Branch 0 taken 31987 times. ✓ Branch 1 taken 39 times. ✓ Branch 2 taken 5 times. ✓ Branch 3 taken 31982 times. ✓ Branch 4 taken 514 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 512 times. ✓ Branch 8 taken 4602 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 4600 times. ✓ Branch 12 taken 39 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 6 times. ✓ Branch 15 taken 33 times. ✓ Branch 16 taken 26156 times. ✓ Branch 17 taken 43 times. ✓ Branch 18 taken 6 times. ✓ Branch 19 taken 26150 times. ✓ Branch 20 taken 519 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 2 times. ✓ Branch 23 taken 517 times. ✓ Branch 24 taken 1728 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 3 times. ✓ Branch 27 taken 1725 times. ✓ Branch 28 taken 52 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 6 times. ✓ Branch 31 taken 46 times. ✓ Branch 32 taken 18 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 4 times. ✓ Branch 35 taken 14 times. ✓ Branch 36 taken 6 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 2 times. ✓ Branch 39 taken 4 times. ✗ 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 taken 14 times. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✓ Branch 75 taken 14 times. ✗ Branch 76 not taken. ✓ Branch 77 taken 1 time. ✗ Branch 78 not taken. ✗ Branch 79 not taken. ✓ Branch 80 taken 67 times. ✓ Branch 81 taken 2 times. ✗ Branch 82 not taken. ✓ Branch 83 taken 67 times. ✓ Branch 84 taken 2 times. ✗ Branch 85 not taken. ✗ Branch 86 not taken. ✓ Branch 87 taken 2 times. ✗ Branch 88 not taken. ✓ Branch 89 taken 1 time. ✗ Branch 90 not taken. ✗ Branch 91 not taken. ✓ Branch 92 taken 12 times. ✗ Branch 93 not taken. ✓ Branch 94 taken 4 times. ✓ Branch 95 taken 8 times. ✗ Branch 96 not taken. ✓ Branch 97 taken 1 time. ✗ Branch 98 not taken. ✗ Branch 99 not taken. ✓ Branch 100 taken 27 times. ✗ Branch 101 not taken. ✓ Branch 102 taken 2 times. ✓ Branch 103 taken 25 times. ✓ Branch 104 taken 11 times. ✗ Branch 105 not taken. ✓ Branch 106 taken 2 times. ✓ Branch 107 taken 9 times. ✗ 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 taken 1 time. ✗ Branch 129 not taken. ✗ Branch 130 not taken. ✓ Branch 131 taken 1 time. ✗ 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.	65842x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
208			{
209	17/72 ✓ Branch 0 taken 44 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 2 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 6 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 49 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 6 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 4 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 2 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 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 taken 1 time. ✗ Branch 39 not taken. ✓ Branch 40 taken 2 times. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✓ Branch 44 taken 1 time. ✗ Branch 45 not taken. ✓ Branch 46 taken 4 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 1 time. ✗ Branch 49 not taken. ✓ Branch 50 taken 2 times. ✗ Branch 51 not taken. ✓ Branch 52 taken 2 times. ✗ 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.	133x	svc_.post(&op);
210		133x	svc_.work_finished();
211		133x	}
212			else
213			{
214		65709x	desc_slot = &op;
215
216			// Select must rebuild its fd_sets when a write-direction op
217			// is parked, so select() watches for writability. Compiled
218			// away to nothing for epoll and kqueue.
219			if constexpr (requires { Service::needs_write_notification; })
220			{
221			if constexpr (Service::needs_write_notification)
222			{
223	12/36 ✗ Branch 0 not taken. ✓ Branch 1 taken 26148 times. ✓ Branch 2 taken 513 times. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 1745 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 26 times. ✓ Branch 8 taken 1 time. ✓ Branch 9 taken 4 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 6 times. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 30 times. ✗ Branch 16 not taken. ✓ Branch 17 taken 9 times. ✗ 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.	28489x	if (is_write_direction)
224	5/36 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 513 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1745 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 1 time. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ 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.	2262x	svc_.scheduler().notify_reactor();
225			}
226			}
227			}
228		65842x	}
229
230			template<
231			class Derived,
232			class ImplBase,
233			class Service,
234			class DescState,
235			class Endpoint>
236			template<class Op>
237			void
238			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
239		772x	cancel_single_op(Op& op) noexcept
240			{
241		772x	auto self = this->weak_from_this().lock();
242	5/16 ✓ Branch 0 taken 653 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 76 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 13 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 17 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 13 times. ✗ Branch 15 not taken.	772x	if (!self)
243		✗	return;
244
245		772x	op.request_cancel();
246
247		772x	auto* d = static_cast<Derived*>(this);
248		772x	reactor_op_base** desc_op_ptr = d->op_to_desc_slot(op);
249
250	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 653 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 76 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 13 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 17 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 13 times.	772x	if (desc_op_ptr)
251			{
252		772x	reactor_op_base* claimed = nullptr;
253			{
254	5/16 ✓ Branch 0 taken 653 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 76 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 13 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 17 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 13 times. ✗ Branch 15 not taken.	772x	std::lock_guard lock(desc_state_.mutex);
255	10/16 ✓ Branch 0 taken 18 times. ✓ Branch 1 taken 635 times. ✓ Branch 2 taken 24 times. ✓ Branch 3 taken 52 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✓ Branch 7 taken 4 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 12 times. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 9 times. ✓ Branch 15 taken 4 times.	772x	if (*desc_op_ptr == &op)
256		700x	claimed = std::exchange(*desc_op_ptr, nullptr);
257			// Not in the slot: request_cancel() above already set
258			// op.cancelled, which register_op consults before parking
259			// and the completion decode consults on delivery. Latching
260			// a descriptor flag here instead would outlive this op and
261			// cancel the next wait in the same direction.
262		772x	}
263	10/16 ✓ Branch 0 taken 635 times. ✓ Branch 1 taken 18 times. ✓ Branch 2 taken 52 times. ✓ Branch 3 taken 24 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 4 times. ✓ Branch 7 taken 9 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✓ Branch 11 taken 12 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✓ Branch 15 taken 9 times.	772x	if (claimed)
264			{
265		700x	op.impl_ptr = self;
266	5/16 ✓ Branch 0 taken 635 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 52 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 4 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 4 times. ✗ Branch 15 not taken.	700x	svc_.post(&op);
267		700x	svc_.work_finished();
268		700x	}
269		772x	}
270		772x	}
271
272			template<
273			class Derived,
274			class ImplBase,
275			class Service,
276			class DescState,
277			class Endpoint>
278			void
279			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
280		250x	do_cancel() noexcept
281			{
282		250x	auto self = this->weak_from_this().lock();
283	5/16 ✓ Branch 0 taken 160 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 78 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 8 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	250x	if (!self)
284		✗	return;
285
286		250x	auto* d = static_cast<Derived*>(this);
287
288		1798x	d->for_each_op([](auto& op) { op.request_cancel(); });
289
290			// Claim ops under a single lock acquisition
291		2000x	struct claimed_entry
292			{
293		2000x	reactor_op_base* op = nullptr;
294		2000x	reactor_op_base* base = nullptr;
295			};
296			// Max 8 ops: conn, rd, wr, wait_rd, wait_wr, wait_er, recv_rd, send_wr
297		250x	claimed_entry claimed[8];
298		250x	int count = 0;
299
300			{
301	5/16 ✓ Branch 0 taken 160 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 78 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 8 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	250x	std::lock_guard lock(desc_state_.mutex);
302		1798x	d->for_each_desc_entry([&](auto& op, reactor_op_base*& desc_slot) {
303	43/80 ✓ Branch 0 taken 159 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 90 times. ✓ Branch 3 taken 70 times. ✓ Branch 4 taken 160 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 471 times. ✓ Branch 7 taken 9 times. ✓ Branch 8 taken 77 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 43 times. ✓ Branch 11 taken 35 times. ✓ Branch 12 taken 77 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 196 times. ✓ Branch 15 taken 14 times. ✓ Branch 16 taken 12 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 33 times. ✓ Branch 19 taken 3 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 8 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 6 times. ✓ Branch 51 taken 2 times. ✓ Branch 52 taken 8 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 7 times. ✓ Branch 55 taken 1 time. ✓ Branch 56 taken 8 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 21 times. ✓ Branch 59 taken 3 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.	1548x	if (desc_slot == &op)
304			{
305		144x	claimed[count].op = std::exchange(desc_slot, nullptr);
306		144x	claimed[count].base = &op;
307		144x	++count;
308		144x	}
309		1548x	});
310		250x	}
311
312	10/16 ✓ Branch 0 taken 160 times. ✓ Branch 1 taken 80 times. ✓ Branch 2 taken 78 times. ✓ Branch 3 taken 54 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 8 times. ✓ Branch 11 taken 6 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 2 times.	394x	for (int i = 0; i < count; ++i)
313			{
314		144x	claimed[i].base->impl_ptr = self;
315	5/16 ✓ Branch 0 taken 80 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 54 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 6 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	144x	svc_.post(claimed[i].base);
316		144x	svc_.work_finished();
317		144x	}
318		250x	}
319
320			template<
321			class Derived,
322			class ImplBase,
323			class Service,
324			class DescState,
325			class Endpoint>
326			void
327			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
328		61780x	do_close_socket() noexcept
329			{
330		61780x	auto self = this->weak_from_this().lock();
331	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 42781 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 16785 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 30 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 441 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 627 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 615 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 44 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 457 times.	61780x	if (self)
332			{
333		61780x	auto* d = static_cast<Derived*>(this);
334
335		436674x	d->for_each_op([](auto& op) { op.request_cancel(); });
336
337		494240x	struct claimed_entry
338			{
339		494240x	reactor_op_base* base = nullptr;
340			};
341		61780x	claimed_entry claimed[8];
342		61780x	int count = 0;
343
344			{
345	8/16 ✓ Branch 0 taken 42781 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16785 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 30 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 441 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 627 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 615 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 44 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 457 times. ✗ Branch 15 not taken.	61780x	std::lock_guard lock(desc_state_.mutex);
346		123560x	d->for_each_desc_entry(
347		436674x	[&](auto& /op/, reactor_op_base*& desc_slot) {
348		374894x	auto* c = std::exchange(desc_slot, nullptr);
349	52/80 ✓ Branch 0 taken 42780 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 42674 times. ✓ Branch 3 taken 107 times. ✓ Branch 4 taken 42781 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 128338 times. ✓ Branch 7 taken 5 times. ✓ Branch 8 taken 16784 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 16769 times. ✓ Branch 11 taken 16 times. ✓ Branch 12 taken 16784 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 49164 times. ✓ Branch 15 taken 3 times. ✓ Branch 16 taken 594 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 1780 times. ✓ Branch 19 taken 2 times. ✓ Branch 20 taken 30 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 30 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 30 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 90 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 441 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 438 times. ✓ Branch 31 taken 3 times. ✓ Branch 32 taken 441 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 441 times. ✗ Branch 35 not taken. ✓ Branch 36 taken 441 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 1323 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 627 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 627 times. ✗ Branch 43 not taken. ✓ Branch 44 taken 627 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 1881 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 615 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 608 times. ✓ Branch 51 taken 7 times. ✓ Branch 52 taken 615 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 615 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 615 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 1843 times. ✓ Branch 59 taken 2 times. ✓ Branch 60 taken 44 times. ✗ Branch 61 not taken. ✓ Branch 62 taken 44 times. ✗ Branch 63 not taken. ✓ Branch 64 taken 44 times. ✗ Branch 65 not taken. ✓ Branch 66 taken 132 times. ✗ Branch 67 not taken. ✓ Branch 68 taken 457 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 453 times. ✓ Branch 71 taken 4 times. ✓ Branch 72 taken 457 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 457 times. ✗ Branch 75 not taken. ✓ Branch 76 taken 457 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 1371 times. ✗ Branch 79 not taken.	374894x	if (c)
350			{
351		152x	claimed[count].base = c;
352		152x	++count;
353		152x	}
354		374894x	});
355		61780x	desc_state_.read_ready = false;
356		61780x	desc_state_.write_ready = false;
357
358	15/16 ✓ Branch 0 taken 41127 times. ✓ Branch 1 taken 1654 times. ✓ Branch 2 taken 16641 times. ✓ Branch 3 taken 144 times. ✓ Branch 4 taken 30 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 396 times. ✓ Branch 7 taken 45 times. ✓ Branch 8 taken 537 times. ✓ Branch 9 taken 90 times. ✓ Branch 10 taken 557 times. ✓ Branch 11 taken 58 times. ✓ Branch 12 taken 35 times. ✓ Branch 13 taken 9 times. ✓ Branch 14 taken 363 times. ✓ Branch 15 taken 94 times.	61780x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
359		2094x	desc_state_.impl_ref_ = self;
360		61780x	}
361
362	13/16 ✓ Branch 0 taken 42781 times. ✓ Branch 1 taken 113 times. ✓ Branch 2 taken 16785 times. ✓ Branch 3 taken 23 times. ✓ Branch 4 taken 30 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 441 times. ✓ Branch 7 taken 3 times. ✓ Branch 8 taken 627 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 615 times. ✓ Branch 11 taken 9 times. ✓ Branch 12 taken 44 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 457 times. ✓ Branch 15 taken 4 times.	61932x	for (int i = 0; i < count; ++i)
363			{
364		152x	claimed[i].base->impl_ptr = self;
365	5/16 ✓ Branch 0 taken 113 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 23 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 9 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✗ Branch 15 not taken.	152x	svc_.post(claimed[i].base);
366		152x	svc_.work_finished();
367		152x	}
368		61780x	}
369
370	16/16 ✓ Branch 0 taken 9316 times. ✓ Branch 1 taken 33465 times. ✓ Branch 2 taken 3703 times. ✓ Branch 3 taken 13082 times. ✓ Branch 4 taken 3 times. ✓ Branch 5 taken 27 times. ✓ Branch 6 taken 100 times. ✓ Branch 7 taken 341 times. ✓ Branch 8 taken 135 times. ✓ Branch 9 taken 492 times. ✓ Branch 10 taken 147 times. ✓ Branch 11 taken 468 times. ✓ Branch 12 taken 6 times. ✓ Branch 13 taken 38 times. ✓ Branch 14 taken 104 times. ✓ Branch 15 taken 353 times.	61780x	if (fd_ >= 0)
371			{
372	9/16 ✓ Branch 0 taken 9316 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3703 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 100 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 133 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 147 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 6 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 104 times. ✗ Branch 15 not taken.	13514x	if (desc_state_.registered_events != 0)
373	8/16 ✓ Branch 0 taken 9316 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3703 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 100 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 133 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 147 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 6 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 104 times. ✗ Branch 15 not taken.	13512x	svc_.scheduler().deregister_descriptor(fd_);
374	8/16 ✓ Branch 0 taken 9316 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3703 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 100 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 135 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 147 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 6 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 104 times. ✗ Branch 15 not taken.	13514x	::close(fd_);
375		13514x	fd_ = -1;
376		13514x	}
377
378		61780x	desc_state_.fd = -1;
379		61780x	desc_state_.registered_events = 0;
380
381		61780x	local_endpoint_ = Endpoint{};
382		61780x	}
383
384			template<
385			class Derived,
386			class ImplBase,
387			class Service,
388			class DescState,
389			class Endpoint>
390			native_handle_type
391			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
392		16x	do_release_socket() noexcept
393			{
394			// Cancel pending ops (same as do_close_socket)
395		16x	auto self = this->weak_from_this().lock();
396	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 4 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 6 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times. ✗ Branch 8 not taken. ✗ 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 taken 2 times.	16x	if (self)
397			{
398		16x	auto* d = static_cast<Derived*>(this);
399
400		128x	d->for_each_op([](auto& op) { op.request_cancel(); });
401
402		128x	struct claimed_entry
403			{
404		128x	reactor_op_base* base = nullptr;
405			};
406		16x	claimed_entry claimed[8];
407		16x	int count = 0;
408
409			{
410	5/16 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 6 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 2 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	16x	std::lock_guard lock(desc_state_.mutex);
411		32x	d->for_each_desc_entry(
412		128x	[&](auto& /op/, reactor_op_base*& desc_slot) {
413		112x	auto* c = std::exchange(desc_slot, nullptr);
414	34/80 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 3 times. ✓ Branch 4 taken 4 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 11 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 6 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 4 times. ✓ Branch 12 taken 5 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 13 times. ✓ Branch 15 taken 1 time. ✓ Branch 16 taken 2 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 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 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 2 times. ✗ Branch 35 not taken. ✓ Branch 36 taken 2 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 6 times. ✗ 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 taken 2 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 1 time. ✓ Branch 51 taken 1 time. ✓ Branch 52 taken 2 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 2 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 2 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 6 times. ✗ 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 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 2 times. ✗ Branch 75 not taken. ✓ Branch 76 taken 2 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 6 times. ✗ Branch 79 not taken.	112x	if (c)
415			{
416		11x	claimed[count].base = c;
417		11x	++count;
418		11x	}
419		112x	});
420		16x	desc_state_.read_ready = false;
421		16x	desc_state_.write_ready = false;
422
423	6/16 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 6 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 not taken. ✓ Branch 11 taken 2 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	16x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
424		4x	desc_state_.impl_ref_ = self;
425		16x	}
426
427	8/16 ✓ Branch 0 taken 4 times. ✓ Branch 1 taken 4 times. ✓ Branch 2 taken 6 times. ✓ Branch 3 taken 6 times. ✗ 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 2 times. ✓ Branch 11 taken 1 time. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	27x	for (int i = 0; i < count; ++i)
428			{
429		11x	claimed[i].base->impl_ptr = self;
430	3/16 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 6 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 1 time. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	11x	svc_.post(claimed[i].base);
431		11x	svc_.work_finished();
432		11x	}
433		16x	}
434
435		16x	native_handle_type released = fd_;
436
437	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 4 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 6 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 2 times. ✗ Branch 8 not taken. ✗ 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 taken 2 times.	16x	if (fd_ >= 0)
438			{
439	5/16 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 6 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 2 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	16x	if (desc_state_.registered_events != 0)
440	5/16 ✓ Branch 0 taken 4 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 6 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 2 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken.	16x	svc_.scheduler().deregister_descriptor(fd_);
441			// Do NOT close -- caller takes ownership
442		16x	fd_ = -1;
443		16x	}
444
445		16x	desc_state_.fd = -1;
446		16x	desc_state_.registered_events = 0;
447
448		16x	local_endpoint_ = Endpoint{};
449
450		16x	return released;
451		16x	}
452
453			} // namespace boost::corosio::detail
454
455			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
456