Index/include / boost / corosio / native / detail / reactor / reactor_op_complete.hpp

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

91.7% Lines (99/108) 100.0% List of functions (16/16) 55.2% Branches (128/232)
[ ] prev/next file n p prev/next uncovered line
f(x) Functions (16)
Function Calls Lines Branches Blocks
void boost::corosio::detail::complete_io_op<boost::corosio::detail::kqueue_datagram_op>(boost::corosio::detail::kqueue_datagram_op&) :39 10x 100.0% – 66.0% void boost::corosio::detail::complete_io_op<boost::corosio::detail::kqueue_op>(boost::corosio::detail::kqueue_op&) :39 222116x 100.0% 79.2% 86.0% void boost::corosio::detail::complete_io_op<boost::corosio::detail::kqueue_recv_op>(boost::corosio::detail::kqueue_recv_op&) :39 2x 93.8% 36.1% 73.0% void boost::corosio::detail::complete_io_op<boost::corosio::detail::select_datagram_op>(boost::corosio::detail::select_datagram_op&) :39 10x 100.0% – 66.0% void boost::corosio::detail::complete_io_op<boost::corosio::detail::select_op>(boost::corosio::detail::select_op&) :39 213891x 0.0% 0.0% 80.0% void boost::corosio::detail::complete_io_op<boost::corosio::detail::select_recv_op>(boost::corosio::detail::select_recv_op&) :39 2x 100.0% – 73.0% void boost::corosio::detail::complete_connect_op<boost::corosio::detail::kqueue_connect_op>(boost::corosio::detail::kqueue_connect_op&) :72 5618x 96.0% 66.7% 83.0% void boost::corosio::detail::complete_connect_op<boost::corosio::detail::kqueue_udp_connect_op>(boost::corosio::detail::kqueue_udp_connect_op&) :72 5x 92.0% 25.0% 77.0% void boost::corosio::detail::complete_connect_op<boost::corosio::detail::select_connect_op>(boost::corosio::detail::select_connect_op&) :72 1789x 0.0% 0.0% 83.0% void boost::corosio::detail::complete_connect_op<boost::corosio::detail::select_udp_connect_op>(boost::corosio::detail::select_udp_connect_op&) :72 5x 100.0% – 77.0% bool boost::corosio::detail::setup_accepted_socket<boost::corosio::detail::kqueue_tcp_socket, boost::corosio::detail::kqueue_tcp_acceptor>(boost::corosio::detail::kqueue_tcp_acceptor*, int&, sockaddr_storage const&, boost::corosio::io_object::implementation**, std::__1::error_code*) :122 5616x 90.5% 50.0% 83.0% bool boost::corosio::detail::setup_accepted_socket<boost::corosio::detail::select_tcp_socket, boost::corosio::detail::select_tcp_acceptor>(boost::corosio::detail::select_tcp_acceptor*, int&, sockaddr_storage const&, boost::corosio::io_object::implementation**, std::__1::error_code*) :122 1786x 100.0% – 83.0% void boost::corosio::detail::complete_accept_op<boost::corosio::detail::kqueue_tcp_socket, boost::corosio::detail::kqueue_accept_op>(boost::corosio::detail::kqueue_accept_op&) :168 5625x 82.8% 61.5% 80.0% void boost::corosio::detail::complete_accept_op<boost::corosio::detail::select_tcp_socket, boost::corosio::detail::select_accept_op>(boost::corosio::detail::select_accept_op&) :168 1789x 100.0% – 80.0% void boost::corosio::detail::complete_datagram_op<boost::corosio::detail::kqueue_recv_from_op>(boost::corosio::detail::kqueue_recv_from_op&, boost::corosio::endpoint*) :221 11x 94.1% 71.4% 80.0% void boost::corosio::detail::complete_datagram_op<boost::corosio::detail::select_recv_from_op>(boost::corosio::detail::select_recv_from_op&, boost::corosio::endpoint*) :221 16x 100.0% – 80.0%
Line Branch TLA 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_OP_COMPLETE_HPP
11 #define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_COMPLETE_HPP
12
13 #include <boost/corosio/detail/dispatch_coro.hpp>
14 #include <boost/corosio/native/detail/endpoint_convert.hpp>
15 #include <boost/corosio/native/detail/make_err.hpp>
16 #include <boost/corosio/io/io_object.hpp>
17
18 #include <coroutine>
19 #include <mutex>
20 #include <utility>
21
22 #include <netinet/in.h>
23 #include <sys/socket.h>
24 #include <unistd.h>
25
26 namespace boost::corosio::detail {
27
28 /** Complete a base read/write operation.
29
30 Translates the recorded errno and cancellation state into
31 an error_code, stores the byte count, then resumes the
32 caller via symmetric transfer.
33
34 @tparam Op The concrete operation type.
35 @param op The operation to complete.
36 */
37 template<typename Op>
38 void
39 436031x complete_io_op(Op& op)
40 {
41 436031x op.stop_cb.reset();
42 436031x op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
43
44
9/12
✓ Branch 0 taken 71 times.
✓ Branch 1 taken 213820 times.
✓ Branch 2 taken 827 times.
✓ Branch 3 taken 221299 times.
✓ Branch 4 taken 1 time.
✓ Branch 5 taken 1 time.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✓ Branch 9 taken 10 times.
✓ Branch 10 taken 1 time.
✓ Branch 11 taken 1 time.
 436031x if (op.cancelled.load(std::memory_order_acquire))
45 900x *op.ec_out = capy::error::canceled;
46
7/12
✗ Branch 0 not taken.
✓ Branch 1 taken 213820 times.
✓ Branch 2 taken 7 times.
✓ Branch 3 taken 221292 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 1 time.
✗ Branch 6 not taken.
✗ Branch 7 not taken.
✓ Branch 8 taken 2 times.
✓ Branch 9 taken 8 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 1 time.
 435131x else if (op.errn != 0)
47 9x *op.ec_out = make_err(op.errn);
48
13/24
✓ Branch 0 taken 130332 times.
✓ Branch 1 taken 83488 times.
✓ Branch 2 taken 130330 times.
✓ Branch 3 taken 2 times.
✓ Branch 4 taken 126448 times.
✓ Branch 5 taken 94844 times.
✓ Branch 6 taken 126445 times.
✓ Branch 7 taken 3 times.
✓ Branch 8 taken 1 time.
✗ 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.
✗ Branch 16 not taken.
✓ Branch 17 taken 8 times.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
✓ Branch 20 taken 1 time.
✗ Branch 21 not taken.
✓ Branch 22 taken 1 time.
✗ Branch 23 not taken.
 435122x else if (op.is_read_operation() && op.bytes_transferred == 0)
49 5x *op.ec_out = capy::error::eof;
50 else
51 435117x *op.ec_out = {};
52
53 436031x *op.bytes_out = op.bytes_transferred;
54
55 436031x capy::executor_ref saved_ex(op.ex);
56 436031x std::coroutine_handle<> saved_h(op.h);
57 436031x auto prevent = std::move(op.impl_ptr);
58
10/24
✓ Branch 0 taken 213891 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 213891 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 222126 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 222126 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 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✓ Branch 16 taken 10 times.
✗ Branch 17 not taken.
✓ Branch 18 taken 10 times.
✗ Branch 19 not taken.
✓ Branch 20 taken 2 times.
✗ Branch 21 not taken.
✓ Branch 22 taken 2 times.
✗ Branch 23 not taken.
 436031x dispatch_coro(saved_ex, saved_h).resume();
59 436031x }
60
61 /** Complete a connect operation with endpoint caching.
62
63 On success, queries the local endpoint via getsockname and
64 caches both endpoints in the socket impl. Then resumes the
65 caller via symmetric transfer.
66
67 @tparam Op The concrete connect operation type.
68 @param op The operation to complete.
69 */
70 template<typename Op>
71 void
72 7417x complete_connect_op(Op& op)
73 {
74 7417x op.stop_cb.reset();
75 7417x op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
76
77 7417x bool success =
78
5/8
✓ Branch 0 taken 3 times.
✓ Branch 1 taken 1786 times.
✓ Branch 2 taken 2 times.
✓ Branch 3 taken 5621 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5 times.
 7417x (op.errn == 0 && !op.cancelled.load(std::memory_order_acquire));
79
80
8/16
✓ Branch 0 taken 1786 times.
✓ Branch 1 taken 3 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1786 times.
✓ Branch 4 taken 5621 times.
✓ Branch 5 taken 2 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 5621 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 5 times.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
✓ Branch 15 taken 5 times.
 7417x if (success && op.socket_impl_)
81 {
82 7412x endpoint local_ep;
83 7412x sockaddr_storage local_storage{};
84 7412x socklen_t local_len = sizeof(local_storage);
85
6/16
✗ Branch 0 not taken.
✓ Branch 1 taken 1786 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 1786 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 5621 times.
✗ Branch 6 not taken.
✓ Branch 7 taken 5621 times.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✓ Branch 13 taken 5 times.
✗ Branch 14 not taken.
✓ Branch 15 taken 5 times.
 14824x if (::getsockname(
86 7412x op.fd, reinterpret_cast<sockaddr*>(&local_storage),
87 7412x &local_len) == 0)
88 7412x local_ep = from_sockaddr(local_storage);
89 7412x op.socket_impl_->set_endpoints(local_ep, op.target_endpoint);
90 7412x }
91
92
3/8
✗ Branch 0 not taken.
✓ Branch 1 taken 1789 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5623 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5 times.
 7417x if (op.cancelled.load(std::memory_order_acquire))
93 ✗ *op.ec_out = capy::error::canceled;
94
5/8
✓ Branch 0 taken 3 times.
✓ Branch 1 taken 1786 times.
✓ Branch 2 taken 2 times.
✓ Branch 3 taken 5621 times.
✗ Branch 4 not taken.
✗ Branch 5 not taken.
✗ Branch 6 not taken.
✓ Branch 7 taken 5 times.
 7417x else if (op.errn != 0)
95 5x *op.ec_out = make_err(op.errn);
96 else
97 7412x *op.ec_out = {};
98
99 7417x capy::executor_ref saved_ex(op.ex);
100 7417x std::coroutine_handle<> saved_h(op.h);
101 7417x auto prevent = std::move(op.impl_ptr);
102
6/16
✓ Branch 0 taken 1789 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 1789 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 5623 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 5623 times.
✗ Branch 7 not taken.
✗ Branch 8 not taken.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 5 times.
✗ Branch 13 not taken.
✓ Branch 14 taken 5 times.
✗ Branch 15 not taken.
 7417x dispatch_coro(saved_ex, saved_h).resume();
103 7417x }
104
105 /** Construct and register a peer socket from an accepted fd.
106
107 Creates a new socket impl via the acceptor's associated
108 socket service, registers it with the scheduler, and caches
109 the local and remote endpoints.
110
111 @tparam SocketImpl The concrete socket implementation type.
112 @tparam AcceptorImpl The concrete acceptor implementation type.
113 @param acceptor_impl The acceptor that accepted the connection.
114 @param accepted_fd The accepted file descriptor (set to -1 on success).
115 @param peer_storage The peer address from accept().
116 @param impl_out Output pointer for the new socket impl.
117 @param ec_out Output pointer for any error.
118 @return True on success, false on failure.
119 */
120 template<typename SocketImpl, typename AcceptorImpl>
121 bool
122 7402x setup_accepted_socket(
123 AcceptorImpl* acceptor_impl,
124 int& accepted_fd,
125 sockaddr_storage const& peer_storage,
126 io_object::implementation** impl_out,
127 std::error_code* ec_out)
128 {
129 7402x auto* socket_svc = acceptor_impl->service().tcp_service();
130
2/4
✓ Branch 0 taken 1786 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 5616 times.
✗ Branch 3 not taken.
 7402x if (!socket_svc)
131 {
132 ✗ *ec_out = make_err(ENOENT);
133 ✗ return false;
134 }
135
136 7402x auto& impl = static_cast<SocketImpl&>(*socket_svc->construct());
137 7402x impl.set_socket(accepted_fd);
138
139 7402x impl.desc_state_.fd = accepted_fd;
140 {
141 7402x std::lock_guard lock(impl.desc_state_.mutex);
142 7402x impl.desc_state_.read_op = nullptr;
143 7402x impl.desc_state_.write_op = nullptr;
144 7402x impl.desc_state_.connect_op = nullptr;
145 7402x }
146 7402x socket_svc->scheduler().register_descriptor(accepted_fd, &impl.desc_state_);
147
148 14804x impl.set_endpoints(
149 7402x acceptor_impl->local_endpoint(), from_sockaddr(peer_storage));
150
151
2/4
✗ Branch 0 not taken.
✓ Branch 1 taken 1786 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5616 times.
 7402x if (impl_out)
152 7402x *impl_out = &impl;
153 7402x accepted_fd = -1;
154 7402x return true;
155 7402x }
156
157 /** Complete an accept operation.
158
159 Sets up the peer socket on success, or closes the accepted
160 fd on failure. Then resumes the caller via symmetric transfer.
161
162 @tparam SocketImpl The concrete socket implementation type.
163 @tparam Op The concrete accept operation type.
164 @param op The operation to complete.
165 */
166 template<typename SocketImpl, typename Op>
167 void
168 7414x complete_accept_op(Op& op)
169 {
170 7414x op.stop_cb.reset();
171 7414x op.acceptor_impl_->desc_state_.scheduler_->reset_inline_budget();
172
173 7414x bool success =
174
2/4
✗ Branch 0 not taken.
✓ Branch 1 taken 1789 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5625 times.
 7414x (op.errn == 0 && !op.cancelled.load(std::memory_order_acquire));
175
176
4/4
✓ Branch 0 taken 3 times.
✓ Branch 1 taken 1786 times.
✓ Branch 2 taken 9 times.
✓ Branch 3 taken 5616 times.
 7414x if (op.cancelled.load(std::memory_order_acquire))
177 12x *op.ec_out = capy::error::canceled;
178
2/4
✗ Branch 0 not taken.
✓ Branch 1 taken 1786 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 5616 times.
 7402x else if (op.errn != 0)
179 ✗ *op.ec_out = make_err(op.errn);
180 else
181 7402x *op.ec_out = {};
182
183
8/12
✓ Branch 0 taken 1786 times.
✓ Branch 1 taken 3 times.
✓ Branch 2 taken 1786 times.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
✓ Branch 5 taken 1786 times.
✓ Branch 6 taken 5616 times.
✓ Branch 7 taken 9 times.
✓ Branch 8 taken 5616 times.
✗ Branch 9 not taken.
✗ Branch 10 not taken.
✓ Branch 11 taken 5616 times.
 7414x if (success && op.accepted_fd >= 0 && op.acceptor_impl_)
184 {
185
2/4
✓ Branch 0 taken 1786 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 5616 times.
✗ Branch 3 not taken.
 7402x if (!setup_accepted_socket<SocketImpl>(
186 7402x op.acceptor_impl_, op.accepted_fd, op.peer_storage, op.impl_out,
187 7402x op.ec_out))
188 ✗ success = false;
189 7402x }
190
191
6/8
✓ Branch 0 taken 1786 times.
✓ Branch 1 taken 3 times.
✓ Branch 2 taken 1786 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 5616 times.
✓ Branch 5 taken 9 times.
✓ Branch 6 taken 5616 times.
✗ Branch 7 not taken.
 7414x if (!success || !op.acceptor_impl_)
192 {
193
2/4
✓ Branch 0 taken 3 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 9 times.
✗ Branch 3 not taken.
 12x if (op.accepted_fd >= 0)
194 {
195 ✗ ::close(op.accepted_fd);
196 ✗ op.accepted_fd = -1;
197 ✗ }
198
2/4
✗ Branch 0 not taken.
✓ Branch 1 taken 3 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 9 times.
 12x if (op.impl_out)
199 12x *op.impl_out = nullptr;
200 12x }
201
202 7414x capy::executor_ref saved_ex(op.ex);
203 7414x std::coroutine_handle<> saved_h(op.h);
204 7414x auto prevent = std::move(op.impl_ptr);
205
4/8
✓ Branch 0 taken 1789 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 1789 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 5625 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 5625 times.
✗ Branch 7 not taken.
 7414x dispatch_coro(saved_ex, saved_h).resume();
206 7414x }
207
208 /** Complete a datagram operation (send_to or recv_from).
209
210 For recv_from operations, writes the source endpoint from the
211 recorded sockaddr_storage into the caller's endpoint pointer.
212 Then resumes the caller via symmetric transfer.
213
214 @tparam Op The concrete datagram operation type.
215 @param op The operation to complete.
216 @param source_out Optional pointer to store source endpoint
217 (non-null for recv_from, null for send_to).
218 */
219 template<typename Op>
220 void
221 27x complete_datagram_op(Op& op, endpoint* source_out)
222 {
223 27x op.stop_cb.reset();
224 27x op.socket_impl_->desc_state_.scheduler_->reset_inline_budget();
225
226
4/4
✓ Branch 0 taken 5 times.
✓ Branch 1 taken 11 times.
✓ Branch 2 taken 5 times.
✓ Branch 3 taken 6 times.
 27x if (op.cancelled.load(std::memory_order_acquire))
227 10x *op.ec_out = capy::error::canceled;
228
2/4
✗ Branch 0 not taken.
✓ Branch 1 taken 11 times.
✗ Branch 2 not taken.
✓ Branch 3 taken 6 times.
 17x else if (op.errn != 0)
229 ✗ *op.ec_out = make_err(op.errn);
230 else
231 17x *op.ec_out = {};
232
233 27x *op.bytes_out = op.bytes_transferred;
234
235
10/12
✓ Branch 0 taken 15 times.
✓ Branch 1 taken 1 time.
✓ Branch 2 taken 10 times.
✓ Branch 3 taken 5 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 10 times.
✓ Branch 6 taken 10 times.
✓ Branch 7 taken 1 time.
✓ Branch 8 taken 5 times.
✓ Branch 9 taken 5 times.
✗ Branch 10 not taken.
✓ Branch 11 taken 5 times.
 27x if (source_out && !op.cancelled.load(std::memory_order_acquire) &&
236 15x op.errn == 0)
237 15x *source_out = from_sockaddr(op.source_storage);
238
239 27x capy::executor_ref saved_ex(op.ex);
240 27x std::coroutine_handle<> saved_h(op.h);
241 27x auto prevent = std::move(op.impl_ptr);
242
4/8
✓ Branch 0 taken 16 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 16 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 11 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 11 times.
✗ Branch 7 not taken.
 27x dispatch_coro(saved_ex, saved_h).resume();
243 27x }
244
245 } // namespace boost::corosio::detail
246
247 #endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_OP_COMPLETE_HPP
248