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

92.6% Lines (188/203) 65.4% List of functions (200/306) 24.1% Branches (315/1308)

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

reactor_basic_socket.hpp

f(x) Functions (306)

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>
61			friend class reactor_stream_socket;
62
63			template<class, class, class, class, class, class, class, class, class, class>
64			friend class reactor_datagram_socket;
65
66		44044x	explicit reactor_basic_socket(Service& svc) noexcept : svc_(svc) {}
67
68			protected:
69			Service& svc_;
70		22022x	int fd_ = -1;
71			Endpoint local_endpoint_;
72
73			public:
74			/// Per-descriptor state for persistent reactor registration.
75			DescState desc_state_;
76
77		22022x	~reactor_basic_socket() override = default;
78
79			/// Return the underlying file descriptor.
80		69927x	native_handle_type native_handle() const noexcept override
81			{
82		69927x	return fd_;
83			}
84
85			/// Return the cached local endpoint.
86		84x	Endpoint local_endpoint() const noexcept override
87			{
88		84x	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		20x	std::error_code set_option(
99			int level,
100			int optname,
101			void const* data,
102			std::size_t size) noexcept override
103			{
104	4/32 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 10 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 10 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 10 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 10 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.	20x	if (::setsockopt(
105		20x	fd_, level, optname, data, static_cast<socklen_t>(size)) != 0)
106		✗	return make_err(errno);
107		20x	return {};
108		20x	}
109
110			/// Get a socket option.
111			std::error_code
112		78x	get_option(int level, int optname, void* data, std::size_t* size)
113			const noexcept override
114			{
115		78x	socklen_t len = static_cast<socklen_t>(*size);
116	6/32 ✓ Branch 0 taken 31 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 31 times. ✓ Branch 4 taken 39 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 39 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 8 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 8 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.	78x	if (::getsockopt(fd_, level, optname, data, &len) != 0)
117		✗	return make_err(errno);
118		78x	*size = static_cast<std::size_t>(len);
119		78x	return {};
120		78x	}
121
122			/// Assign the file descriptor.
123		7235x	void set_socket(int fd) noexcept
124			{
125		7235x	fd_ = fd;
126		7235x	}
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		80x	std::error_code do_bind(Endpoint const& ep) noexcept
143			{
144		80x	sockaddr_storage storage{};
145		80x	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 28 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 26 times. ✓ Branch 8 taken 6 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✓ Branch 11 taken 5 times. ✓ Branch 12 taken 6 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 4 times. ✓ Branch 16 taken 28 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 2 times. ✓ Branch 19 taken 26 times. ✓ Branch 20 taken 6 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 1 time. ✓ Branch 23 taken 5 times.	80x	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		70x	sockaddr_storage local_storage{};
150		70x	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 26 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 26 times. ✓ Branch 8 taken 5 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 5 times. ✓ Branch 12 taken 4 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 4 times. ✓ Branch 16 taken 26 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 26 times. ✓ Branch 20 taken 5 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 5 times.	70x	if (::getsockname(
152		70x	fd_, reinterpret_cast<sockaddr*>(&local_storage), &local_len) ==
153			0)
154		70x	local_endpoint_ =
155		70x	from_sockaddr_as(local_storage, local_len, Endpoint{});
156
157		70x	return {};
158		80x	}
159
160			/// Assign the fd, initialize descriptor state, and register with the reactor.
161		7440x	void init_and_register(int fd) noexcept
162			{
163		7440x	fd_ = fd;
164		7440x	desc_state_.fd = fd;
165			{
166	8/16 ✓ Branch 0 taken 1856 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 48 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 12 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 14 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 5436 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 48 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 12 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 14 times. ✗ Branch 15 not taken.	7440x	std::lock_guard lock(desc_state_.mutex);
167		7440x	desc_state_.read_op = nullptr;
168		7440x	desc_state_.write_op = nullptr;
169		7440x	desc_state_.connect_op = nullptr;
170		7440x	}
171	8/16 ✓ Branch 0 taken 1856 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 48 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 12 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 14 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 5436 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 48 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 12 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 14 times. ✗ Branch 15 not taken.	7440x	svc_.scheduler().register_descriptor(fd, &desc_state_);
172		7440x	}
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		114898x	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		114898x	svc_.work_started();
238
239	7/64 ✓ Branch 0 taken 43111 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 14 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1834 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 64521 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5414 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ 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 taken 2 times. ✗ 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.	114898x	std::lock_guard lock(desc_state_.mutex);
240		114898x	bool io_done = false;
241	9/64 ✓ Branch 0 taken 42574 times. ✓ Branch 1 taken 537 times. ✓ Branch 2 taken 14 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1834 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 64261 times. ✓ Branch 7 taken 260 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5414 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ 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 taken 2 times. ✗ 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.	114898x	if (ready_flag)
242			{
243		797x	ready_flag = false;
244		797x	op.perform_io();
245	4/64 ✓ Branch 0 taken 529 times. ✓ Branch 1 taken 8 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 252 times. ✓ Branch 7 taken 8 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 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.	797x	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
246	4/64 ✓ Branch 0 taken 8 times. ✓ Branch 1 taken 529 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 8 times. ✓ Branch 7 taken 252 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 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.	797x	if (!io_done)
247		781x	op.errn = 0;
248		797x	}
249
250	7/64 ✓ Branch 0 taken 43111 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 14 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1834 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 64521 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5414 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ 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 taken 2 times. ✗ 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.	114898x	if (cancel_flag)
251			{
252		✗	cancel_flag = false;
253		✗	op.cancelled.store(true, std::memory_order_relaxed);
254		✗	}
255
256	16/128 ✓ Branch 0 taken 43103 times. ✓ Branch 1 taken 8 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 43103 times. ✓ Branch 4 taken 14 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 14 times. ✓ Branch 8 taken 1834 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 1834 times. ✓ Branch 12 taken 64513 times. ✓ Branch 13 taken 8 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 64513 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 5414 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 5414 times. ✗ 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 not taken. ✓ Branch 31 taken 2 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 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. ✗ 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 taken 2 times. ✗ Branch 93 not taken. ✗ Branch 94 not taken. ✓ Branch 95 taken 2 times. ✗ 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.	114898x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
257			{
258	2/64 ✓ Branch 0 taken 8 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 8 times. ✗ 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. ✗ 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.	16x	svc_.post(&op);
259		16x	svc_.work_finished();
260		16x	}
261			else
262			{
263		114882x	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	4/32 ✗ Branch 0 not taken. ✓ Branch 1 taken 43103 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 14 times. ✓ Branch 4 taken 1834 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 taken 2 times. ✗ 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.	44953x	if (is_write_direction)
273	1/32 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1834 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.	1834x	svc_.scheduler().notify_reactor();
274			}
275			}
276			}
277		114898x	}
278
279			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
280			template<class Op>
281			void
282		723x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::cancel_single_op(
283			Op& op) noexcept
284			{
285		723x	auto self = this->weak_from_this().lock();
286	3/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 686 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.	723x	if (!self)
287		✗	return;
288
289		723x	op.request_cancel();
290
291		723x	auto* d = static_cast<Derived*>(this);
292		723x	reactor_op_base** desc_op_ptr = d->op_to_desc_slot(op);
293
294	3/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 36 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 686 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 1 time. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	723x	if (desc_op_ptr)
295			{
296		723x	reactor_op_base* claimed = nullptr;
297			{
298	3/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 686 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.	723x	std::lock_guard lock(desc_state_.mutex);
299	4/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 36 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 684 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 1 time. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	723x	if (*desc_op_ptr == &op)
300		721x	claimed = std::exchange(*desc_op_ptr, nullptr);
301			else
302			{
303		2x	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 2 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 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	2x	if (cflag)
305		2x	*cflag = true;
306			}
307		723x	}
308	4/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 684 times. ✓ Branch 3 taken 2 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 taken 1 time. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	723x	if (claimed)
309			{
310		721x	op.impl_ptr = self;
311	3/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 684 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.	721x	svc_.post(&op);
312		721x	svc_.work_finished();
313		721x	}
314		723x	}
315		723x	}
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		161x	do_cancel() noexcept
321			{
322		161x	auto self = this->weak_from_this().lock();
323	3/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 122 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.	161x	if (!self)
324		✗	return;
325
326		161x	auto* d = static_cast<Derived*>(this);
327
328		656x	d->for_each_op([](auto& op) { op.request_cancel(); });
329
330			// Claim ops under a single lock acquisition
331		483x	struct claimed_entry
332			{
333		483x	reactor_op_base* op = nullptr;
334		483x	reactor_op_base* base = nullptr;
335			};
336			// Max 3 ops (conn, rd, wr)
337		161x	claimed_entry claimed[3];
338		161x	int count = 0;
339
340			{
341	3/16 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 122 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.	161x	std::lock_guard lock(desc_state_.mutex);
342		656x	d->for_each_desc_entry([&](auto& op, reactor_op_base*& desc_slot) {
343	20/64 ✓ Branch 0 taken 35 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 17 times. ✓ Branch 3 taken 19 times. ✓ Branch 4 taken 36 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 121 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 64 times. ✓ Branch 9 taken 58 times. ✓ Branch 10 taken 122 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 2 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 3 times. ✗ 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 taken 3 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 1 time. ✓ Branch 41 taken 2 times. ✓ Branch 42 taken 3 times. ✗ Branch 43 not taken. ✓ Branch 44 taken 2 times. ✓ Branch 45 taken 1 time. ✓ Branch 46 taken 3 times. ✗ 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.	495x	if (desc_slot == &op)
344			{
345		83x	claimed[count].op = std::exchange(desc_slot, nullptr);
346		83x	claimed[count].base = &op;
347		83x	++count;
348		83x	}
349		495x	});
350		161x	}
351
352	6/16 ✓ Branch 0 taken 36 times. ✓ Branch 1 taken 20 times. ✓ Branch 2 taken 122 times. ✓ Branch 3 taken 60 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 taken 3 times. ✓ Branch 11 taken 3 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	244x	for (int i = 0; i < count; ++i)
353			{
354		83x	claimed[i].base->impl_ptr = self;
355	3/16 ✓ Branch 0 taken 20 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 60 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.	83x	svc_.post(claimed[i].base);
356		83x	svc_.work_finished();
357		83x	}
358		161x	}
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		66157x	do_close_socket() noexcept
364			{
365		66157x	auto self = this->weak_from_this().lock();
366	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 16571 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 200 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 59 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 58 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 48952 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 200 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 59 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 58 times.	66157x	if (self)
367			{
368		66157x	auto* d = static_cast<Derived*>(this);
369
370		265660x	d->for_each_op([](auto& op) { op.request_cancel(); });
371
372		198471x	struct claimed_entry
373			{
374		198471x	reactor_op_base* base = nullptr;
375			};
376		66157x	claimed_entry claimed[3];
377		66157x	int count = 0;
378
379			{
380	8/16 ✓ Branch 0 taken 16571 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 200 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 59 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 58 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 48952 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 200 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 59 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 58 times. ✗ Branch 15 not taken.	66157x	std::lock_guard lock(desc_state_.mutex);
381		132314x	d->for_each_desc_entry(
382		265660x	[&](auto& /op/, reactor_op_base*& desc_slot) {
383		199503x	auto* c = std::exchange(desc_slot, nullptr);
384	36/64 ✓ Branch 0 taken 16571 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16570 times. ✓ Branch 3 taken 1 time. ✓ Branch 4 taken 16571 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 200 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 198 times. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 200 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 200 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 200 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 59 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 59 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 59 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 58 times. ✗ Branch 23 not taken. ✓ Branch 24 taken 58 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 58 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 58 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 58 times. ✗ Branch 31 not taken. ✓ Branch 32 taken 48952 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 48949 times. ✓ Branch 35 taken 3 times. ✓ Branch 36 taken 48952 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 200 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 198 times. ✓ Branch 41 taken 2 times. ✓ Branch 42 taken 200 times. ✗ Branch 43 not taken. ✓ Branch 44 taken 200 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 200 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 59 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 59 times. ✗ Branch 51 not taken. ✓ Branch 52 taken 59 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 58 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 58 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 58 times. ✗ Branch 59 not taken. ✓ Branch 60 taken 58 times. ✗ Branch 61 not taken. ✓ Branch 62 taken 58 times. ✗ Branch 63 not taken.	199503x	if (c)
385			{
386		8x	claimed[count].base = c;
387		8x	++count;
388		8x	}
389		199503x	});
390		66157x	desc_state_.read_ready = false;
391		66157x	desc_state_.write_ready = false;
392		66157x	desc_state_.read_cancel_pending = false;
393		66157x	desc_state_.write_cancel_pending = false;
394		66157x	desc_state_.connect_cancel_pending = false;
395
396	15/16 ✓ Branch 0 taken 16546 times. ✓ Branch 1 taken 25 times. ✓ Branch 2 taken 200 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 56 times. ✓ Branch 5 taken 3 times. ✓ Branch 6 taken 49 times. ✓ Branch 7 taken 9 times. ✓ Branch 8 taken 47008 times. ✓ Branch 9 taken 1944 times. ✓ Branch 10 taken 182 times. ✓ Branch 11 taken 18 times. ✓ Branch 12 taken 47 times. ✓ Branch 13 taken 12 times. ✓ Branch 14 taken 40 times. ✓ Branch 15 taken 18 times.	66157x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
397		2029x	desc_state_.impl_ref_ = self;
398		66157x	}
399
400	12/16 ✓ Branch 0 taken 16571 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 200 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 59 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 58 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 48952 times. ✓ Branch 9 taken 3 times. ✓ Branch 10 taken 200 times. ✓ Branch 11 taken 2 times. ✓ Branch 12 taken 59 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 58 times. ✗ Branch 15 not taken.	66165x	for (int i = 0; i < count; ++i)
401			{
402		8x	claimed[i].base->impl_ptr = self;
403	4/16 ✓ 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 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 3 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	8x	svc_.post(claimed[i].base);
404		8x	svc_.work_finished();
405		8x	}
406		66157x	}
407
408	16/16 ✓ Branch 0 taken 3681 times. ✓ Branch 1 taken 12890 times. ✓ Branch 2 taken 48 times. ✓ Branch 3 taken 152 times. ✓ Branch 4 taken 13 times. ✓ Branch 5 taken 46 times. ✓ Branch 6 taken 14 times. ✓ Branch 7 taken 44 times. ✓ Branch 8 taken 10842 times. ✓ Branch 9 taken 38110 times. ✓ Branch 10 taken 48 times. ✓ Branch 11 taken 152 times. ✓ Branch 12 taken 13 times. ✓ Branch 13 taken 46 times. ✓ Branch 14 taken 14 times. ✓ Branch 15 taken 44 times.	66157x	if (fd_ >= 0)
409			{
410	8/16 ✓ Branch 0 taken 3681 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 48 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 13 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 14 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 10842 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 48 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 13 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 14 times. ✗ Branch 15 not taken.	14673x	if (desc_state_.registered_events != 0)
411	8/16 ✓ Branch 0 taken 3681 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 48 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 13 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 14 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 10842 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 48 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 13 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 14 times. ✗ Branch 15 not taken.	14673x	svc_.scheduler().deregister_descriptor(fd_);
412	8/16 ✓ Branch 0 taken 3681 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 48 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 13 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 14 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 10842 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 48 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 13 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 14 times. ✗ Branch 15 not taken.	14673x	::close(fd_);
413		14673x	fd_ = -1;
414		14673x	}
415
416		66157x	desc_state_.fd = -1;
417		66157x	desc_state_.registered_events = 0;
418
419		66157x	local_endpoint_ = Endpoint{};
420		66157x	}
421
422			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
423			native_handle_type
424			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
425		2x	do_release_socket() noexcept
426			{
427			// Cancel pending ops (same as do_close_socket)
428		2x	auto self = this->weak_from_this().lock();
429	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (self)
430			{
431		2x	auto* d = static_cast<Derived*>(this);
432
433		8x	d->for_each_op([](auto& op) { op.request_cancel(); });
434
435		6x	struct claimed_entry
436			{
437		6x	reactor_op_base* base = nullptr;
438			};
439		2x	claimed_entry claimed[3];
440		2x	int count = 0;
441
442			{
443	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	std::lock_guard lock(desc_state_.mutex);
444		4x	d->for_each_desc_entry(
445		8x	[&](auto& /op/, reactor_op_base*& desc_slot) {
446		6x	auto* c = std::exchange(desc_slot, nullptr);
447	6/32 ✓ 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 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 taken 1 time. ✗ Branch 17 not taken. ✓ Branch 18 taken 1 time. ✗ Branch 19 not taken. ✓ Branch 20 taken 1 time. ✗ 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.	6x	if (c)
448			{
449		✗	claimed[count].base = c;
450		✗	++count;
451		✗	}
452		6x	});
453		2x	desc_state_.read_ready = false;
454		2x	desc_state_.write_ready = false;
455		2x	desc_state_.read_cancel_pending = false;
456		2x	desc_state_.write_cancel_pending = false;
457		2x	desc_state_.connect_cancel_pending = false;
458
459	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
460		✗	desc_state_.impl_ref_ = self;
461		2x	}
462
463	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	for (int i = 0; i < count; ++i)
464			{
465		✗	claimed[i].base->impl_ptr = self;
466		✗	svc_.post(claimed[i].base);
467		✗	svc_.work_finished();
468		✗	}
469		2x	}
470
471		2x	native_handle_type released = fd_;
472
473	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 1 time. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (fd_ >= 0)
474			{
475	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (desc_state_.registered_events != 0)
476	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	svc_.scheduler().deregister_descriptor(fd_);
477			// Do NOT close -- caller takes ownership
478		2x	fd_ = -1;
479		2x	}
480
481		2x	desc_state_.fd = -1;
482		2x	desc_state_.registered_events = 0;
483
484		2x	local_endpoint_ = Endpoint{};
485
486		2x	return released;
487		2x	}
488
489			} // namespace boost::corosio::detail
490
491			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
492