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

94.9% Lines (168/177) 96.1% List of functions (346/360) 31.0% Branches (447/1440)

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

reactor_basic_socket.hpp

f(x) Functions (360)

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<class, class, class, class, class, class, class, class, class, class, class>
64			friend class reactor_datagram_socket;
65
66		23829x	explicit reactor_basic_socket(Service& svc) noexcept : svc_(svc) {}
67
68			protected:
69			// fd_ / local_endpoint_ and the synchronous accessors (native_handle,
70			// is_open, set_option/get_option, set_socket/set_local_endpoint, do_bind)
71			// live in native_socket_base — the readiness/completion-agnostic base
72			// shared with io_uring's sockets. The using-declarations make the
73			// inherited members visible to this template's own unqualified
74			// references below (two-phase lookup).
75			using native_socket_base<Derived, ImplBase, Endpoint>::fd_;
76			using native_socket_base<Derived, ImplBase, Endpoint>::local_endpoint_;
77
78			Service& svc_;
79
80			public:
81			/// Per-descriptor state for persistent reactor registration.
82			DescState desc_state_;
83
84		23829x	~reactor_basic_socket() override = default;
85
86			/** Assign the fd, initialize descriptor state, and register with
87			the reactor.
88
89			@param fd The descriptor to adopt.
90
91			@return The error if the reactor rejects the descriptor, in
92			which case the implementation is left closed and the caller
93			retains ownership of @a fd; otherwise a default constructed
94			error code.
95			*/
96		8166x	std::error_code init_and_register(int fd) noexcept
97			{
98		8166x	fd_ = fd;
99		8166x	desc_state_.fd = fd;
100			{
101	8/16 ✓ Branch 0 taken 1720 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 113 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 73 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 82 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 5892 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 124 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 76 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 86 times. ✗ Branch 15 not taken.	8166x	std::lock_guard lock(desc_state_.mutex);
102		8166x	desc_state_.read_op = nullptr;
103		8166x	desc_state_.write_op = nullptr;
104		8166x	desc_state_.connect_op = nullptr;
105		8166x	}
106	16/32 ✓ Branch 0 taken 1720 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 1720 times. ✓ Branch 4 taken 113 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 113 times. ✓ Branch 8 taken 73 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 73 times. ✓ Branch 12 taken 82 times. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 82 times. ✓ Branch 16 taken 5892 times. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✓ Branch 19 taken 5892 times. ✓ Branch 20 taken 124 times. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✓ Branch 23 taken 124 times. ✓ Branch 24 taken 76 times. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✓ Branch 27 taken 76 times. ✓ Branch 28 taken 86 times. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✓ Branch 31 taken 86 times.	8166x	if (auto ec = svc_.scheduler().register_descriptor(fd, &desc_state_))
107			{
108			// Undo the partial state so a failed adopt is
109			// indistinguishable from a closed implementation.
110		✗	fd_ = -1;
111		✗	desc_state_.fd = -1;
112		✗	desc_state_.registered_events = 0;
113		✗	return ec;
114			}
115		8166x	return {};
116		8166x	}
117
118			/** Register an op with the reactor.
119
120			Handles cached edge events and deferred cancellation.
121			Called on the EAGAIN/EINPROGRESS path when speculative
122			I/O failed.
123			*/
124			template<class Op>
125			void register_op(
126			Op& op,
127			reactor_op_base*& desc_slot,
128			bool& ready_flag,
129			bool& cancel_flag,
130			bool is_write_direction = false) noexcept;
131
132			/** Cancel a single pending operation.
133
134			Claims the operation from its descriptor_state slot under
135			the mutex and posts it to the scheduler as cancelled.
136			Derived must implement:
137			op_to_desc_slot(Op&) -> reactor_op_base**
138			op_to_cancel_flag(Op&) -> bool*
139			*/
140			template<class Op>
141			void cancel_single_op(Op& op) noexcept;
142
143			/** Cancel all pending operations.
144
145			Invoked by the derived class's cancel() override.
146			Derived must implement:
147			for_each_op(auto fn)
148			for_each_desc_entry(auto fn)
149			*/
150			void do_cancel() noexcept;
151
152			/** Close the socket and cancel pending operations.
153
154			Invoked by the derived class's close_socket(). The
155			derived class may add backend-specific cleanup after
156			calling this method.
157			Derived must implement:
158			for_each_op(auto fn)
159			for_each_desc_entry(auto fn)
160			*/
161			void do_close_socket() noexcept;
162
163			/** Release the socket without closing the fd.
164
165			Like do_close_socket() but does not call ::close().
166			Returns the fd so the caller can take ownership.
167			*/
168			native_handle_type do_release_socket() noexcept;
169			};
170
171			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
172			template<class Op>
173			void
174		96793x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::register_op(
175			Op& op,
176			reactor_op_base*& desc_slot,
177			bool& ready_flag,
178			bool& cancel_flag,
179			bool is_write_direction) noexcept
180			{
181		96793x	svc_.work_started();
182
183	13/80 ✓ Branch 0 taken 50070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 527 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 5857 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 23 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 38032 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 522 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1688 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 43 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 6 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 14 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 taken 4 times. ✗ 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 taken 1 time. ✗ 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.	96793x	std::lock_guard lock(desc_state_.mutex);
184		96793x	bool io_done = false;
185	19/80 ✓ Branch 0 taken 49535 times. ✓ Branch 1 taken 535 times. ✓ Branch 2 taken 525 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 5857 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 5 times. ✓ Branch 7 taken 18 times. ✓ Branch 8 taken 37598 times. ✓ Branch 9 taken 434 times. ✓ Branch 10 taken 508 times. ✓ Branch 11 taken 14 times. ✓ Branch 12 taken 1688 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 28 times. ✓ Branch 15 taken 15 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 6 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. ✗ 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 taken 4 times. ✗ 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 taken 1 time. ✗ 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.	96793x	if (ready_flag)
186			{
187		1032x	ready_flag = false;
188		1032x	op.perform_io();
189	9/80 ✓ Branch 0 taken 477 times. ✓ Branch 1 taken 58 times. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 18 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 408 times. ✓ Branch 9 taken 26 times. ✓ Branch 10 taken 14 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 15 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 taken 14 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.	1032x	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
190	9/80 ✓ Branch 0 taken 58 times. ✓ Branch 1 taken 477 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 18 times. ✓ Branch 8 taken 26 times. ✓ Branch 9 taken 408 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 14 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 15 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 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. ✗ 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.	1032x	if (!io_done)
191		948x	op.errn = 0;
192		1032x	}
193
194	13/80 ✓ Branch 0 taken 50070 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 527 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 5857 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 23 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 38032 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 522 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1688 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 43 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 6 times. ✗ Branch 19 not taken. ✓ Branch 20 taken 6 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 14 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 taken 4 times. ✗ 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 taken 1 time. ✗ 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.	96793x	if (cancel_flag)
195			{
196		✗	cancel_flag = false;
197		✗	op.cancelled.store(true, std::memory_order_relaxed);
198		✗	}
199
200	40/160 ✓ Branch 0 taken 50012 times. ✓ Branch 1 taken 58 times. ✓ Branch 2 taken 3 times. ✓ Branch 3 taken 50009 times. ✓ Branch 4 taken 527 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 525 times. ✓ Branch 8 taken 5857 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 5855 times. ✓ Branch 12 taken 23 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 3 times. ✓ Branch 15 taken 20 times. ✓ Branch 16 taken 38006 times. ✓ Branch 17 taken 26 times. ✓ Branch 18 taken 3 times. ✓ Branch 19 taken 38003 times. ✓ Branch 20 taken 522 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 2 times. ✓ Branch 23 taken 520 times. ✓ Branch 24 taken 1688 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 1 time. ✓ Branch 27 taken 1687 times. ✓ Branch 28 taken 43 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 4 times. ✓ Branch 31 taken 39 times. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✓ Branch 36 taken 6 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 1 time. ✓ Branch 39 taken 5 times. ✓ Branch 40 taken 6 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 1 time. ✓ Branch 43 taken 5 times. ✓ Branch 44 taken 14 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 2 times. ✓ Branch 47 taken 12 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 taken 4 times. ✗ Branch 101 not taken. ✓ Branch 102 taken 2 times. ✓ Branch 103 taken 2 times. ✗ 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 taken 1 time. ✗ Branch 141 not taken. ✗ Branch 142 not taken. ✓ Branch 143 taken 1 time. ✗ 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.	96793x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
201			{
202	12/80 ✓ Branch 0 taken 61 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 3 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 29 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✓ Branch 18 taken 1 time. ✗ Branch 19 not taken. ✓ Branch 20 taken 1 time. ✗ Branch 21 not taken. ✓ Branch 22 taken 2 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 taken 2 times. ✗ 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.	110x	svc_.post(&op);
203		110x	svc_.work_finished();
204		110x	}
205			else
206			{
207		96683x	desc_slot = &op;
208
209			// Select must rebuild its fd_sets when a write-direction op
210			// is parked, so select() watches for writability. Compiled
211			// away to nothing for epoll and kqueue.
212			if constexpr (requires { Service::needs_write_notification; })
213			{
214			if constexpr (Service::needs_write_notification)
215			{
216	8/40 ✗ Branch 0 not taken. ✓ Branch 1 taken 37998 times. ✓ Branch 2 taken 508 times. ✓ Branch 3 taken 26 times. ✓ Branch 4 taken 1687 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 times. ✓ Branch 7 taken 15 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 5 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 12 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.	40254x	if (is_write_direction)
217	3/40 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 508 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1687 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 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.	2198x	svc_.scheduler().notify_reactor();
218			}
219			}
220			}
221		96793x	}
222
223			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
224			template<class Op>
225			void
226		1042x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::cancel_single_op(
227			Op& op) noexcept
228			{
229		1042x	auto self = this->weak_from_this().lock();
230	5/16 ✓ Branch 0 taken 953 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 58 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 13 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 9 times. ✗ Branch 15 not taken.	1042x	if (!self)
231		✗	return;
232
233		1042x	op.request_cancel();
234
235		1042x	auto* d = static_cast<Derived*>(this);
236		1042x	reactor_op_base** desc_op_ptr = d->op_to_desc_slot(op);
237
238	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 953 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 58 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 9 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 13 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 9 times.	1042x	if (desc_op_ptr)
239			{
240		1042x	reactor_op_base* claimed = nullptr;
241			{
242	5/16 ✓ Branch 0 taken 953 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 58 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 13 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 9 times. ✗ Branch 15 not taken.	1042x	std::lock_guard lock(desc_state_.mutex);
243	10/16 ✓ Branch 0 taken 13 times. ✓ Branch 1 taken 940 times. ✓ Branch 2 taken 15 times. ✓ Branch 3 taken 43 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 5 times. ✓ Branch 7 taken 4 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 8 times. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 5 times. ✓ Branch 15 taken 4 times.	1042x	if (*desc_op_ptr == &op)
244		996x	claimed = std::exchange(*desc_op_ptr, nullptr);
245			// Not in the slot: request_cancel() above already set
246			// op.cancelled, which register_op consults before parking
247			// and the completion decode consults on delivery. Latching
248			// a descriptor flag here instead would outlive this op and
249			// cancel the next wait in the same direction.
250		1042x	}
251	10/16 ✓ Branch 0 taken 940 times. ✓ Branch 1 taken 13 times. ✓ Branch 2 taken 43 times. ✓ Branch 3 taken 15 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 4 times. ✓ Branch 7 taken 5 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✓ Branch 11 taken 8 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✓ Branch 15 taken 5 times.	1042x	if (claimed)
252			{
253		996x	op.impl_ptr = self;
254	5/16 ✓ Branch 0 taken 940 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 43 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.	996x	svc_.post(&op);
255		996x	svc_.work_finished();
256		996x	}
257		1042x	}
258		1042x	}
259
260			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
261			void
262			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
263		215x	do_cancel() noexcept
264			{
265		215x	auto self = this->weak_from_this().lock();
266	5/16 ✓ Branch 0 taken 152 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 2 times. ✗ 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 taken 2 times. ✗ Branch 15 not taken.	215x	if (!self)
267		✗	return;
268
269		215x	auto* d = static_cast<Derived*>(this);
270
271		1539x	d->for_each_op([](auto& op) { op.request_cancel(); });
272
273			// Claim ops under a single lock acquisition
274		1720x	struct claimed_entry
275			{
276		1720x	reactor_op_base* op = nullptr;
277		1720x	reactor_op_base* base = nullptr;
278			};
279			// Max 8 ops: conn, rd, wr, wait_rd, wait_wr, wait_er, recv_rd, send_wr
280		215x	claimed_entry claimed[8];
281		215x	int count = 0;
282
283			{
284	5/16 ✓ Branch 0 taken 152 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 2 times. ✗ 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 taken 2 times. ✗ Branch 15 not taken.	215x	std::lock_guard lock(desc_state_.mutex);
285		1539x	d->for_each_desc_entry([&](auto& op, reactor_op_base*& desc_slot) {
286	42/80 ✓ Branch 0 taken 151 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 89 times. ✓ Branch 3 taken 63 times. ✓ Branch 4 taken 152 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 448 times. ✓ Branch 7 taken 8 times. ✓ Branch 8 taken 51 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 30 times. ✓ Branch 11 taken 22 times. ✓ Branch 12 taken 52 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 136 times. ✓ Branch 15 taken 8 times. ✓ Branch 16 taken 6 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 15 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 7 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 5 times. ✓ Branch 51 taken 2 times. ✓ Branch 52 taken 7 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 6 times. ✓ Branch 55 taken 1 time. ✓ Branch 56 taken 7 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 18 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.	1324x	if (desc_slot == &op)
287			{
288		116x	claimed[count].op = std::exchange(desc_slot, nullptr);
289		116x	claimed[count].base = &op;
290		116x	++count;
291		116x	}
292		1324x	});
293		215x	}
294
295	10/16 ✓ Branch 0 taken 152 times. ✓ Branch 1 taken 72 times. ✓ Branch 2 taken 52 times. ✓ Branch 3 taken 34 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 7 times. ✓ Branch 11 taken 6 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 2 times.	331x	for (int i = 0; i < count; ++i)
296			{
297		116x	claimed[i].base->impl_ptr = self;
298	5/16 ✓ Branch 0 taken 72 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 34 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.	116x	svc_.post(claimed[i].base);
299		116x	svc_.work_finished();
300		116x	}
301		215x	}
302
303			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
304			void
305			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
306		71520x	do_close_socket() noexcept
307			{
308		71520x	auto self = this->weak_from_this().lock();
309	7/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 53962 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 16294 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 358 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 2 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 516 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 14 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 374 times.	71520x	if (self)
310			{
311		71520x	auto* d = static_cast<Derived*>(this);
312
313		504080x	d->for_each_op([](auto& op) { op.request_cancel(); });
314
315		572160x	struct claimed_entry
316			{
317		572160x	reactor_op_base* base = nullptr;
318			};
319		71520x	claimed_entry claimed[8];
320		71520x	int count = 0;
321
322			{
323	7/16 ✓ Branch 0 taken 53962 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16294 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 358 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 516 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 14 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 374 times. ✗ Branch 15 not taken.	71520x	std::lock_guard lock(desc_state_.mutex);
324		143040x	d->for_each_desc_entry(
325		504080x	[&](auto& /op/, reactor_op_base*& desc_slot) {
326		432560x	auto* c = std::exchange(desc_slot, nullptr);
327	43/80 ✓ Branch 0 taken 53962 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 53861 times. ✓ Branch 3 taken 101 times. ✓ Branch 4 taken 53962 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 161886 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 16294 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 16283 times. ✓ Branch 11 taken 11 times. ✓ Branch 12 taken 16294 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 47938 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 472 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 1415 times. ✓ Branch 19 taken 1 time. ✗ 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 358 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 356 times. ✓ Branch 31 taken 2 times. ✓ Branch 32 taken 358 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 358 times. ✗ Branch 35 not taken. ✓ Branch 36 taken 358 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 1074 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 2 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 2 times. ✗ Branch 43 not taken. ✓ Branch 44 taken 2 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 6 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 516 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 512 times. ✓ Branch 51 taken 4 times. ✓ Branch 52 taken 516 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 516 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 516 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 1547 times. ✓ Branch 59 taken 1 time. ✓ Branch 60 taken 14 times. ✗ Branch 61 not taken. ✓ Branch 62 taken 14 times. ✗ Branch 63 not taken. ✓ Branch 64 taken 14 times. ✗ Branch 65 not taken. ✓ Branch 66 taken 42 times. ✗ Branch 67 not taken. ✓ Branch 68 taken 374 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 372 times. ✓ Branch 71 taken 2 times. ✓ Branch 72 taken 374 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 374 times. ✗ Branch 75 not taken. ✓ Branch 76 taken 374 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 1122 times. ✗ Branch 79 not taken.	432560x	if (c)
328			{
329		122x	claimed[count].base = c;
330		122x	++count;
331		122x	}
332		432560x	});
333		71520x	desc_state_.read_ready = false;
334		71520x	desc_state_.write_ready = false;
335		71520x	desc_state_.read_cancel_pending = false;
336		71520x	desc_state_.write_cancel_pending = false;
337		71520x	desc_state_.connect_cancel_pending = false;
338		71520x	desc_state_.wait_read_cancel_pending = false;
339		71520x	desc_state_.wait_write_cancel_pending = false;
340		71520x	desc_state_.wait_error_cancel_pending = false;
341
342	13/16 ✓ Branch 0 taken 51155 times. ✓ Branch 1 taken 2807 times. ✓ Branch 2 taken 16209 times. ✓ Branch 3 taken 85 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 319 times. ✓ Branch 7 taken 39 times. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 467 times. ✓ Branch 11 taken 49 times. ✓ Branch 12 taken 5 times. ✓ Branch 13 taken 9 times. ✓ Branch 14 taken 298 times. ✓ Branch 15 taken 76 times.	71520x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
343		3065x	desc_state_.impl_ref_ = self;
344		71520x	}
345
346	12/16 ✓ Branch 0 taken 53962 times. ✓ Branch 1 taken 101 times. ✓ Branch 2 taken 16294 times. ✓ Branch 3 taken 12 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 358 times. ✓ Branch 7 taken 2 times. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 516 times. ✓ Branch 11 taken 5 times. ✓ Branch 12 taken 14 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 374 times. ✓ Branch 15 taken 2 times.	71642x	for (int i = 0; i < count; ++i)
347			{
348		122x	claimed[i].base->impl_ptr = self;
349	5/16 ✓ Branch 0 taken 101 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 12 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.	122x	svc_.post(claimed[i].base);
350		122x	svc_.work_finished();
351		122x	}
352		71520x	}
353
354	13/16 ✓ Branch 0 taken 11817 times. ✓ Branch 1 taken 42145 times. ✓ Branch 2 taken 3595 times. ✓ Branch 3 taken 12699 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 81 times. ✓ Branch 7 taken 277 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 2 times. ✓ Branch 10 taken 123 times. ✓ Branch 11 taken 393 times. ✓ Branch 12 taken 3 times. ✓ Branch 13 taken 11 times. ✓ Branch 14 taken 85 times. ✓ Branch 15 taken 289 times.	71520x	if (fd_ >= 0)
355			{
356	6/16 ✓ Branch 0 taken 11817 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3595 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 81 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 123 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 85 times. ✗ Branch 15 not taken.	15704x	if (desc_state_.registered_events != 0)
357	6/16 ✓ Branch 0 taken 11817 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3595 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 81 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 123 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 85 times. ✗ Branch 15 not taken.	15704x	svc_.scheduler().deregister_descriptor(fd_);
358	6/16 ✓ Branch 0 taken 11817 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 3595 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 81 times. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 123 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 3 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 85 times. ✗ Branch 15 not taken.	15704x	::close(fd_);
359		15704x	fd_ = -1;
360		15704x	}
361
362		71520x	desc_state_.fd = -1;
363		71520x	desc_state_.registered_events = 0;
364
365		71520x	local_endpoint_ = Endpoint{};
366		71520x	}
367
368			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
369			native_handle_type
370			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
371		10x	do_release_socket() noexcept
372			{
373			// Cancel pending ops (same as do_close_socket)
374		10x	auto self = this->weak_from_this().lock();
375	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time. ✗ 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 taken 1 time.	10x	if (self)
376			{
377		10x	auto* d = static_cast<Derived*>(this);
378
379		78x	d->for_each_op([](auto& op) { op.request_cancel(); });
380
381		80x	struct claimed_entry
382			{
383		80x	reactor_op_base* base = nullptr;
384			};
385		10x	claimed_entry claimed[8];
386		10x	int count = 0;
387
388			{
389	5/16 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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 taken 1 time. ✗ Branch 15 not taken.	10x	std::lock_guard lock(desc_state_.mutex);
390		20x	d->for_each_desc_entry(
391		78x	[&](auto& /op/, reactor_op_base*& desc_slot) {
392		68x	auto* c = std::exchange(desc_slot, nullptr);
393	30/80 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 3 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 9 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✓ Branch 11 taken 3 times. ✓ Branch 12 taken 4 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 10 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. ✗ 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 1 time. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✓ Branch 51 taken 1 time. ✓ Branch 52 taken 1 time. ✗ Branch 53 not taken. ✓ Branch 54 taken 1 time. ✗ Branch 55 not taken. ✓ Branch 56 taken 1 time. ✗ Branch 57 not taken. ✓ Branch 58 taken 3 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 1 time. ✗ Branch 69 not taken. ✓ Branch 70 taken 1 time. ✗ Branch 71 not taken. ✓ Branch 72 taken 1 time. ✗ Branch 73 not taken. ✓ Branch 74 taken 1 time. ✗ Branch 75 not taken. ✓ Branch 76 taken 1 time. ✗ Branch 77 not taken. ✓ Branch 78 taken 3 times. ✗ Branch 79 not taken.	68x	if (c)
394			{
395		6x	claimed[count].base = c;
396		6x	++count;
397		6x	}
398		68x	});
399		10x	desc_state_.read_ready = false;
400		10x	desc_state_.write_ready = false;
401		10x	desc_state_.read_cancel_pending = false;
402		10x	desc_state_.write_cancel_pending = false;
403		10x	desc_state_.connect_cancel_pending = false;
404		10x	desc_state_.wait_read_cancel_pending = false;
405		10x	desc_state_.wait_write_cancel_pending = false;
406		10x	desc_state_.wait_error_cancel_pending = false;
407
408	6/16 ✓ Branch 0 taken 1 time. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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 taken 1 time. ✗ Branch 15 not taken.	10x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
409		3x	desc_state_.impl_ref_ = self;
410		10x	}
411
412	8/16 ✓ Branch 0 taken 3 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 4 times. ✓ Branch 3 taken 3 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✓ Branch 11 taken 1 time. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken.	16x	for (int i = 0; i < count; ++i)
413			{
414		6x	claimed[i].base->impl_ptr = self;
415	3/16 ✓ Branch 0 taken 2 times. ✗ 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 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.	6x	svc_.post(claimed[i].base);
416		6x	svc_.work_finished();
417		6x	}
418		10x	}
419
420		10x	native_handle_type released = fd_;
421
422	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 4 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time. ✗ 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 taken 1 time.	10x	if (fd_ >= 0)
423			{
424	5/16 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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 taken 1 time. ✗ Branch 15 not taken.	10x	if (desc_state_.registered_events != 0)
425	5/16 ✓ Branch 0 taken 3 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ 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 taken 1 time. ✗ Branch 15 not taken.	10x	svc_.scheduler().deregister_descriptor(fd_);
426			// Do NOT close -- caller takes ownership
427		10x	fd_ = -1;
428		10x	}
429
430		10x	desc_state_.fd = -1;
431		10x	desc_state_.registered_events = 0;
432
433		10x	local_endpoint_ = Endpoint{};
434
435		10x	return released;
436		10x	}
437
438			} // namespace boost::corosio::detail
439
440			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
441