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

94.3% Lines (165/175) 95.5% List of functions (298/312) 31.1% Branches (415/1336)

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

reactor_basic_socket.hpp

f(x) Functions (312)

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		20600x	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		20600x	~reactor_basic_socket() override = default;
85
86			/// Assign the fd, initialize descriptor state, and register with the reactor.
87		7114x	void init_and_register(int fd) noexcept
88			{
89		7114x	fd_ = fd;
90		7114x	desc_state_.fd = fd;
91			{
92	8/16 ✓ Branch 0 taken 1893 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 93 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 79 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4777 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 93 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 50 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 79 times. ✗ Branch 15 not taken.	7114x	std::lock_guard lock(desc_state_.mutex);
93		7114x	desc_state_.read_op = nullptr;
94		7114x	desc_state_.write_op = nullptr;
95		7114x	desc_state_.connect_op = nullptr;
96		7114x	}
97	8/16 ✓ Branch 0 taken 1893 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 93 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 50 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 79 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4777 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 93 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 50 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 79 times. ✗ Branch 15 not taken.	7114x	svc_.scheduler().register_descriptor(fd, &desc_state_);
98		7114x	}
99
100			/** Register an op with the reactor.
101
102			Handles cached edge events and deferred cancellation.
103			Called on the EAGAIN/EINPROGRESS path when speculative
104			I/O failed.
105			*/
106			template<class Op>
107			void register_op(
108			Op& op,
109			reactor_op_base*& desc_slot,
110			bool& ready_flag,
111			bool& cancel_flag,
112			bool is_write_direction = false) noexcept;
113
114			/** Cancel a single pending operation.
115
116			Claims the operation from its descriptor_state slot under
117			the mutex and posts it to the scheduler as cancelled.
118			Derived must implement:
119			op_to_desc_slot(Op&) -> reactor_op_base**
120			op_to_cancel_flag(Op&) -> bool*
121			*/
122			template<class Op>
123			void cancel_single_op(Op& op) noexcept;
124
125			/** Cancel all pending operations.
126
127			Invoked by the derived class's cancel() override.
128			Derived must implement:
129			for_each_op(auto fn)
130			for_each_desc_entry(auto fn)
131			*/
132			void do_cancel() noexcept;
133
134			/** Close the socket and cancel pending operations.
135
136			Invoked by the derived class's close_socket(). The
137			derived class may add backend-specific cleanup after
138			calling this method.
139			Derived must implement:
140			for_each_op(auto fn)
141			for_each_desc_entry(auto fn)
142			*/
143			void do_close_socket() noexcept;
144
145			/** Release the socket without closing the fd.
146
147			Like do_close_socket() but does not call ::close().
148			Returns the fd so the caller can take ownership.
149			*/
150			native_handle_type do_release_socket() noexcept;
151			};
152
153			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
154			template<class Op>
155			void
156		86917x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::register_op(
157			Op& op,
158			reactor_op_base*& desc_slot,
159			bool& ready_flag,
160			bool& cancel_flag,
161			bool is_write_direction) noexcept
162			{
163		86917x	svc_.work_started();
164
165	10/80 ✓ Branch 0 taken 46818 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 520 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 4750 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 11 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 32374 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 520 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1866 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 34 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 11 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 13 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.	86917x	std::lock_guard lock(desc_state_.mutex);
166		86917x	bool io_done = false;
167	13/80 ✓ Branch 0 taken 46504 times. ✓ Branch 1 taken 314 times. ✓ Branch 2 taken 518 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 4750 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 11 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 32073 times. ✓ Branch 9 taken 301 times. ✓ Branch 10 taken 520 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1866 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 34 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 11 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 13 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.	86917x	if (ready_flag)
168			{
169		617x	ready_flag = false;
170		617x	op.perform_io();
171	5/80 ✓ Branch 0 taken 299 times. ✓ Branch 1 taken 15 times. ✓ 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 280 times. ✓ Branch 9 taken 21 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	617x	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
172	5/80 ✓ Branch 0 taken 15 times. ✓ Branch 1 taken 299 times. ✗ 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 taken 21 times. ✓ Branch 9 taken 280 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken.	617x	if (!io_done)
173		581x	op.errn = 0;
174		617x	}
175
176	20/80 ✓ Branch 0 taken 46816 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 518 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 4749 times. ✓ Branch 5 taken 1 time. ✓ Branch 6 taken 9 times. ✓ Branch 7 taken 2 times. ✓ Branch 8 taken 32370 times. ✓ Branch 9 taken 4 times. ✓ Branch 10 taken 518 times. ✓ Branch 11 taken 2 times. ✓ Branch 12 taken 1865 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 30 times. ✓ Branch 15 taken 4 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 9 times. ✓ Branch 21 taken 2 times. ✓ Branch 22 taken 11 times. ✓ Branch 23 taken 2 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.	86917x	if (cancel_flag)
177			{
178		22x	cancel_flag = false;
179		22x	op.cancelled.store(true, std::memory_order_relaxed);
180		22x	}
181
182	32/160 ✓ Branch 0 taken 46803 times. ✓ Branch 1 taken 15 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 46801 times. ✓ Branch 4 taken 520 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 518 times. ✓ Branch 8 taken 4750 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1 time. ✓ Branch 11 taken 4749 times. ✓ Branch 12 taken 11 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 9 times. ✓ Branch 16 taken 32353 times. ✓ Branch 17 taken 21 times. ✓ Branch 18 taken 4 times. ✓ Branch 19 taken 32349 times. ✓ Branch 20 taken 520 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 2 times. ✓ Branch 23 taken 518 times. ✓ Branch 24 taken 1866 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 1 time. ✓ Branch 27 taken 1865 times. ✓ Branch 28 taken 34 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 4 times. ✓ Branch 31 taken 30 times. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken. ✓ Branch 40 taken 11 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 2 times. ✓ Branch 43 taken 9 times. ✓ Branch 44 taken 13 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 2 times. ✓ Branch 47 taken 11 times. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✗ Branch 68 not taken. ✗ Branch 69 not taken. ✗ Branch 70 not taken. ✗ Branch 71 not taken. ✗ Branch 72 not taken. ✗ Branch 73 not taken. ✗ Branch 74 not taken. ✗ Branch 75 not taken. ✗ Branch 76 not taken. ✗ Branch 77 not taken. ✗ Branch 78 not taken. ✗ Branch 79 not taken. ✗ Branch 80 not taken. ✗ Branch 81 not taken. ✗ Branch 82 not taken. ✗ Branch 83 not taken. ✗ Branch 84 not taken. ✗ Branch 85 not taken. ✗ Branch 86 not taken. ✗ Branch 87 not taken. ✗ Branch 88 not taken. ✗ Branch 89 not taken. ✗ Branch 90 not taken. ✗ Branch 91 not taken. ✗ Branch 92 not taken. ✗ Branch 93 not taken. ✗ Branch 94 not taken. ✗ Branch 95 not taken. ✗ Branch 96 not taken. ✗ Branch 97 not taken. ✗ Branch 98 not taken. ✗ Branch 99 not taken. ✗ Branch 100 not taken. ✗ Branch 101 not taken. ✗ Branch 102 not taken. ✗ Branch 103 not taken. ✗ Branch 104 not taken. ✗ Branch 105 not taken. ✗ Branch 106 not taken. ✗ Branch 107 not taken. ✗ Branch 108 not taken. ✗ Branch 109 not taken. ✗ Branch 110 not taken. ✗ Branch 111 not taken. ✗ Branch 112 not taken. ✗ Branch 113 not taken. ✗ Branch 114 not taken. ✗ Branch 115 not taken. ✗ Branch 116 not taken. ✗ Branch 117 not taken. ✗ Branch 118 not taken. ✗ Branch 119 not taken. ✗ Branch 120 not taken. ✗ Branch 121 not taken. ✗ Branch 122 not taken. ✗ Branch 123 not taken. ✗ Branch 124 not taken. ✗ Branch 125 not taken. ✗ Branch 126 not taken. ✗ Branch 127 not taken. ✗ Branch 128 not taken. ✗ Branch 129 not taken. ✗ Branch 130 not taken. ✗ Branch 131 not taken. ✗ Branch 132 not taken. ✗ Branch 133 not taken. ✗ Branch 134 not taken. ✗ Branch 135 not taken. ✗ Branch 136 not taken. ✗ Branch 137 not taken. ✗ Branch 138 not taken. ✗ Branch 139 not taken. ✗ Branch 140 not taken. ✗ Branch 141 not taken. ✗ Branch 142 not taken. ✗ Branch 143 not taken. ✗ Branch 144 not taken. ✗ Branch 145 not taken. ✗ Branch 146 not taken. ✗ Branch 147 not taken. ✗ Branch 148 not taken. ✗ Branch 149 not taken. ✗ Branch 150 not taken. ✗ Branch 151 not taken. ✗ Branch 152 not taken. ✗ Branch 153 not taken. ✗ Branch 154 not taken. ✗ Branch 155 not taken. ✗ Branch 156 not taken. ✗ Branch 157 not taken. ✗ Branch 158 not taken. ✗ Branch 159 not taken.	86917x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
183			{
184	10/80 ✓ Branch 0 taken 17 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 25 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 not taken. ✗ Branch 19 not taken. ✓ Branch 20 taken 2 times. ✗ 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 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.	58x	svc_.post(&op);
185		58x	svc_.work_finished();
186		58x	}
187			else
188			{
189		86859x	desc_slot = &op;
190
191			// Select must rebuild its fd_sets when a write-direction op
192			// is parked, so select() watches for writability. Compiled
193			// away to nothing for epoll and kqueue.
194			if constexpr (requires { Service::needs_write_notification; })
195			{
196			if constexpr (Service::needs_write_notification)
197			{
198	7/40 ✗ Branch 0 not taken. ✓ Branch 1 taken 32341 times. ✓ Branch 2 taken 507 times. ✓ Branch 3 taken 21 times. ✓ Branch 4 taken 1865 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 9 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 9 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 11 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.	34763x	if (is_write_direction)
199	2/40 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 507 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1865 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✗ Branch 34 not taken. ✗ Branch 35 not taken. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✗ Branch 38 not taken. ✗ Branch 39 not taken.	2372x	svc_.scheduler().notify_reactor();
200			}
201			}
202			}
203		86917x	}
204
205			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
206			template<class Op>
207			void
208		680x	reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::cancel_single_op(
209			Op& op) noexcept
210			{
211		680x	auto self = this->weak_from_this().lock();
212	5/16 ✓ Branch 0 taken 595 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 56 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 11 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 9 times. ✗ Branch 15 not taken.	680x	if (!self)
213		✗	return;
214
215		680x	op.request_cancel();
216
217		680x	auto* d = static_cast<Derived*>(this);
218		680x	reactor_op_base** desc_op_ptr = d->op_to_desc_slot(op);
219
220	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 595 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 56 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 11 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 9 times.	680x	if (desc_op_ptr)
221			{
222		680x	reactor_op_base* claimed = nullptr;
223			{
224	5/16 ✓ Branch 0 taken 595 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 56 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 11 times. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 9 times. ✗ Branch 15 not taken.	680x	std::lock_guard lock(desc_state_.mutex);
225	10/16 ✓ Branch 0 taken 10 times. ✓ Branch 1 taken 585 times. ✓ Branch 2 taken 14 times. ✓ Branch 3 taken 42 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 6 times. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 5 times. ✓ Branch 15 taken 4 times.	680x	if (*desc_op_ptr == &op)
226		640x	claimed = std::exchange(*desc_op_ptr, nullptr);
227			else
228			{
229		40x	bool* cflag = d->op_to_cancel_flag(op);
230	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 10 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 14 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 5 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✓ Branch 11 taken 6 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✓ Branch 15 taken 5 times.	40x	if (cflag)
231		40x	*cflag = true;
232			}
233		680x	}
234	10/16 ✓ Branch 0 taken 585 times. ✓ Branch 1 taken 10 times. ✓ Branch 2 taken 42 times. ✓ Branch 3 taken 14 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 6 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✓ Branch 15 taken 5 times.	680x	if (claimed)
235			{
236		640x	op.impl_ptr = self;
237	5/16 ✓ Branch 0 taken 585 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 42 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.	640x	svc_.post(&op);
238		640x	svc_.work_finished();
239		640x	}
240		680x	}
241		680x	}
242
243			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
244			void
245			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
246		167x	do_cancel() noexcept
247			{
248		167x	auto self = this->weak_from_this().lock();
249	5/16 ✓ Branch 0 taken 116 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 42 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.	167x	if (!self)
250		✗	return;
251
252		167x	auto* d = static_cast<Derived*>(this);
253
254		1197x	d->for_each_op([](auto& op) { op.request_cancel(); });
255
256			// Claim ops under a single lock acquisition
257		1336x	struct claimed_entry
258			{
259		1336x	reactor_op_base* op = nullptr;
260		1336x	reactor_op_base* base = nullptr;
261			};
262			// Max 8 ops: conn, rd, wr, wait_rd, wait_wr, wait_er, recv_rd, send_wr
263		167x	claimed_entry claimed[8];
264		167x	int count = 0;
265
266			{
267	5/16 ✓ Branch 0 taken 116 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 42 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.	167x	std::lock_guard lock(desc_state_.mutex);
268		1197x	d->for_each_desc_entry([&](auto& op, reactor_op_base*& desc_slot) {
269	42/80 ✓ Branch 0 taken 115 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 64 times. ✓ Branch 3 taken 52 times. ✓ Branch 4 taken 116 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 344 times. ✓ Branch 7 taken 4 times. ✓ Branch 8 taken 41 times. ✓ Branch 9 taken 1 time. ✓ Branch 10 taken 23 times. ✓ Branch 11 taken 19 times. ✓ Branch 12 taken 42 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 110 times. ✓ Branch 15 taken 6 times. ✓ Branch 16 taken 5 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 13 times. ✓ Branch 19 taken 2 times. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✓ Branch 28 taken 2 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 2 times. ✗ Branch 31 not taken. ✓ Branch 32 taken 2 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 1 time. ✓ Branch 35 taken 1 time. ✓ Branch 36 taken 2 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 5 times. ✓ Branch 39 taken 1 time. ✗ Branch 40 not taken. ✗ Branch 41 not taken. ✗ Branch 42 not taken. ✗ Branch 43 not taken. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✓ Branch 48 taken 5 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 3 times. ✓ Branch 51 taken 2 times. ✓ Branch 52 taken 5 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 4 times. ✓ Branch 55 taken 1 time. ✓ Branch 56 taken 5 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 13 times. ✓ Branch 59 taken 2 times. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken. ✓ Branch 68 taken 2 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 2 times. ✗ Branch 71 not taken. ✓ Branch 72 taken 2 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 1 time. ✓ Branch 75 taken 1 time. ✓ Branch 76 taken 2 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 5 times. ✓ Branch 79 taken 1 time.	1030x	if (desc_slot == &op)
270			{
271		94x	claimed[count].op = std::exchange(desc_slot, nullptr);
272		94x	claimed[count].base = &op;
273		94x	++count;
274		94x	}
275		1030x	});
276		167x	}
277
278	10/16 ✓ Branch 0 taken 116 times. ✓ Branch 1 taken 57 times. ✓ Branch 2 taken 42 times. ✓ Branch 3 taken 28 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 2 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✓ Branch 10 taken 5 times. ✓ Branch 11 taken 5 times. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 2 times.	261x	for (int i = 0; i < count; ++i)
279			{
280		94x	claimed[i].base->impl_ptr = self;
281	5/16 ✓ Branch 0 taken 57 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 28 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.	94x	svc_.post(claimed[i].base);
282		94x	svc_.work_finished();
283		94x	}
284		167x	}
285
286			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
287			void
288			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
289		62038x	do_close_socket() noexcept
290			{
291		62038x	auto self = this->weak_from_this().lock();
292	8/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 16976 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 394 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 279 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 342 times. ✗ Branch 8 not taken. ✓ Branch 9 taken 43032 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 394 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 279 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 342 times.	62038x	if (self)
293			{
294		62038x	auto* d = static_cast<Derived*>(this);
295
296		437210x	d->for_each_op([](auto& op) { op.request_cancel(); });
297
298		496304x	struct claimed_entry
299			{
300		496304x	reactor_op_base* base = nullptr;
301			};
302		62038x	claimed_entry claimed[8];
303		62038x	int count = 0;
304
305			{
306	8/16 ✓ Branch 0 taken 16976 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 394 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 279 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 342 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 43032 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 394 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 279 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 342 times. ✗ Branch 15 not taken.	62038x	std::lock_guard lock(desc_state_.mutex);
307		124076x	d->for_each_desc_entry(
308		437210x	[&](auto& /op/, reactor_op_base*& desc_slot) {
309		375172x	auto* c = std::exchange(desc_slot, nullptr);
310	50/80 ✓ Branch 0 taken 16976 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16974 times. ✓ Branch 3 taken 2 times. ✓ Branch 4 taken 16976 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 50928 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 394 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 391 times. ✓ Branch 11 taken 3 times. ✓ Branch 12 taken 394 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 394 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 394 times. ✗ Branch 17 not taken. ✓ Branch 18 taken 1181 times. ✓ Branch 19 taken 1 time. ✓ Branch 20 taken 279 times. ✗ Branch 21 not taken. ✓ Branch 22 taken 278 times. ✓ Branch 23 taken 1 time. ✓ Branch 24 taken 279 times. ✗ Branch 25 not taken. ✓ Branch 26 taken 837 times. ✗ Branch 27 not taken. ✓ Branch 28 taken 342 times. ✗ Branch 29 not taken. ✓ Branch 30 taken 341 times. ✓ Branch 31 taken 1 time. ✓ Branch 32 taken 342 times. ✗ Branch 33 not taken. ✓ Branch 34 taken 342 times. ✗ Branch 35 not taken. ✓ Branch 36 taken 342 times. ✗ Branch 37 not taken. ✓ Branch 38 taken 1026 times. ✗ Branch 39 not taken. ✓ Branch 40 taken 43032 times. ✗ Branch 41 not taken. ✓ Branch 42 taken 43028 times. ✓ Branch 43 taken 4 times. ✓ Branch 44 taken 43032 times. ✗ Branch 45 not taken. ✓ Branch 46 taken 129096 times. ✗ Branch 47 not taken. ✓ Branch 48 taken 394 times. ✗ Branch 49 not taken. ✓ Branch 50 taken 391 times. ✓ Branch 51 taken 3 times. ✓ Branch 52 taken 394 times. ✗ Branch 53 not taken. ✓ Branch 54 taken 394 times. ✗ Branch 55 not taken. ✓ Branch 56 taken 394 times. ✗ Branch 57 not taken. ✓ Branch 58 taken 1181 times. ✓ Branch 59 taken 1 time. ✓ Branch 60 taken 279 times. ✗ Branch 61 not taken. ✓ Branch 62 taken 278 times. ✓ Branch 63 taken 1 time. ✓ Branch 64 taken 279 times. ✗ Branch 65 not taken. ✓ Branch 66 taken 837 times. ✗ Branch 67 not taken. ✓ Branch 68 taken 342 times. ✗ Branch 69 not taken. ✓ Branch 70 taken 341 times. ✓ Branch 71 taken 1 time. ✓ Branch 72 taken 342 times. ✗ Branch 73 not taken. ✓ Branch 74 taken 342 times. ✗ Branch 75 not taken. ✓ Branch 76 taken 342 times. ✗ Branch 77 not taken. ✓ Branch 78 taken 1026 times. ✗ Branch 79 not taken.	375172x	if (c)
311			{
312		18x	claimed[count].base = c;
313		18x	++count;
314		18x	}
315		375172x	});
316		62038x	desc_state_.read_ready = false;
317		62038x	desc_state_.write_ready = false;
318		62038x	desc_state_.read_cancel_pending = false;
319		62038x	desc_state_.write_cancel_pending = false;
320		62038x	desc_state_.connect_cancel_pending = false;
321		62038x	desc_state_.wait_read_cancel_pending = false;
322		62038x	desc_state_.wait_write_cancel_pending = false;
323		62038x	desc_state_.wait_error_cancel_pending = false;
324
325	16/16 ✓ Branch 0 taken 16939 times. ✓ Branch 1 taken 37 times. ✓ Branch 2 taken 388 times. ✓ Branch 3 taken 6 times. ✓ Branch 4 taken 273 times. ✓ Branch 5 taken 6 times. ✓ Branch 6 taken 306 times. ✓ Branch 7 taken 36 times. ✓ Branch 8 taken 41468 times. ✓ Branch 9 taken 1564 times. ✓ Branch 10 taken 364 times. ✓ Branch 11 taken 30 times. ✓ Branch 12 taken 234 times. ✓ Branch 13 taken 45 times. ✓ Branch 14 taken 273 times. ✓ Branch 15 taken 69 times.	62038x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
326		1793x	desc_state_.impl_ref_ = self;
327		62038x	}
328
329	16/16 ✓ Branch 0 taken 16976 times. ✓ Branch 1 taken 2 times. ✓ Branch 2 taken 394 times. ✓ Branch 3 taken 4 times. ✓ Branch 4 taken 279 times. ✓ Branch 5 taken 1 time. ✓ Branch 6 taken 342 times. ✓ Branch 7 taken 1 time. ✓ Branch 8 taken 43032 times. ✓ Branch 9 taken 4 times. ✓ Branch 10 taken 394 times. ✓ Branch 11 taken 4 times. ✓ Branch 12 taken 279 times. ✓ Branch 13 taken 1 time. ✓ Branch 14 taken 342 times. ✓ Branch 15 taken 1 time.	62056x	for (int i = 0; i < count; ++i)
330			{
331		18x	claimed[i].base->impl_ptr = self;
332	8/16 ✓ Branch 0 taken 2 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 4 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken. ✓ Branch 8 taken 4 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 4 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1 time. ✗ Branch 13 not taken. ✓ Branch 14 taken 1 time. ✗ Branch 15 not taken.	18x	svc_.post(claimed[i].base);
333		18x	svc_.work_finished();
334		18x	}
335		62038x	}
336
337	16/16 ✓ Branch 0 taken 3747 times. ✓ Branch 1 taken 13229 times. ✓ Branch 2 taken 93 times. ✓ Branch 3 taken 301 times. ✓ Branch 4 taken 58 times. ✓ Branch 5 taken 221 times. ✓ Branch 6 taken 78 times. ✓ Branch 7 taken 264 times. ✓ Branch 8 taken 9515 times. ✓ Branch 9 taken 33517 times. ✓ Branch 10 taken 93 times. ✓ Branch 11 taken 301 times. ✓ Branch 12 taken 58 times. ✓ Branch 13 taken 221 times. ✓ Branch 14 taken 78 times. ✓ Branch 15 taken 264 times.	62038x	if (fd_ >= 0)
338			{
339	8/16 ✓ Branch 0 taken 3747 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 93 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 58 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 78 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 9515 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 93 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 58 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 78 times. ✗ Branch 15 not taken.	13720x	if (desc_state_.registered_events != 0)
340	8/16 ✓ Branch 0 taken 3747 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 93 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 58 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 78 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 9515 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 93 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 58 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 78 times. ✗ Branch 15 not taken.	13720x	svc_.scheduler().deregister_descriptor(fd_);
341	8/16 ✓ Branch 0 taken 3747 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 93 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 58 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 78 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 9515 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 93 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 58 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 78 times. ✗ Branch 15 not taken.	13720x	::close(fd_);
342		13720x	fd_ = -1;
343		13720x	}
344
345		62038x	desc_state_.fd = -1;
346		62038x	desc_state_.registered_events = 0;
347
348		62038x	local_endpoint_ = Endpoint{};
349		62038x	}
350
351			template<class Derived, class ImplBase, class Service, class DescState, class Endpoint>
352			native_handle_type
353			reactor_basic_socket<Derived, ImplBase, Service, DescState, Endpoint>::
354		4x	do_release_socket() noexcept
355			{
356			// Cancel pending ops (same as do_close_socket)
357		4x	auto self = this->weak_from_this().lock();
358	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	4x	if (self)
359			{
360		4x	auto* d = static_cast<Derived*>(this);
361
362		32x	d->for_each_op([](auto& op) { op.request_cancel(); });
363
364		32x	struct claimed_entry
365			{
366		32x	reactor_op_base* base = nullptr;
367			};
368		4x	claimed_entry claimed[8];
369		4x	int count = 0;
370
371			{
372	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	std::lock_guard lock(desc_state_.mutex);
373		8x	d->for_each_desc_entry(
374		32x	[&](auto& /op/, reactor_op_base*& desc_slot) {
375		28x	auto* c = std::exchange(desc_slot, nullptr);
376	16/40 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✓ Branch 4 taken 1 time. ✗ Branch 5 not taken. ✓ Branch 6 taken 3 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 2 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 4 times. ✗ Branch 15 not taken. ✓ Branch 16 taken 1 time. ✗ Branch 17 not taken. ✓ Branch 18 taken 3 times. ✗ Branch 19 not taken. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✓ Branch 28 taken 1 time. ✗ Branch 29 not taken. ✓ Branch 30 taken 1 time. ✗ Branch 31 not taken. ✓ Branch 32 taken 1 time. ✗ Branch 33 not taken. ✓ Branch 34 taken 1 time. ✗ Branch 35 not taken. ✓ Branch 36 taken 1 time. ✗ Branch 37 not taken. ✓ Branch 38 taken 3 times. ✗ Branch 39 not taken.	28x	if (c)
377			{
378		✗	claimed[count].base = c;
379		✗	++count;
380		✗	}
381		28x	});
382		4x	desc_state_.read_ready = false;
383		4x	desc_state_.write_ready = false;
384		4x	desc_state_.read_cancel_pending = false;
385		4x	desc_state_.write_cancel_pending = false;
386		4x	desc_state_.connect_cancel_pending = false;
387		4x	desc_state_.wait_read_cancel_pending = false;
388		4x	desc_state_.wait_write_cancel_pending = false;
389		4x	desc_state_.wait_error_cancel_pending = false;
390
391	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	if (desc_state_.is_enqueued_.load(std::memory_order_acquire))
392		✗	desc_state_.impl_ref_ = self;
393		4x	}
394
395	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	for (int i = 0; i < count; ++i)
396			{
397		✗	claimed[i].base->impl_ptr = self;
398		✗	svc_.post(claimed[i].base);
399		✗	svc_.work_finished();
400		✗	}
401		4x	}
402
403		4x	native_handle_type released = fd_;
404
405	3/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 2 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1 time.	4x	if (fd_ >= 0)
406			{
407	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	if (desc_state_.registered_events != 0)
408	3/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 2 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 1 time. ✗ Branch 7 not taken.	4x	svc_.scheduler().deregister_descriptor(fd_);
409			// Do NOT close -- caller takes ownership
410		4x	fd_ = -1;
411		4x	}
412
413		4x	desc_state_.fd = -1;
414		4x	desc_state_.registered_events = 0;
415
416		4x	local_endpoint_ = Endpoint{};
417
418		4x	return released;
419		4x	}
420
421			} // namespace boost::corosio::detail
422
423			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BASIC_SOCKET_HPP
424