Index/include / boost / corosio / native / detail / select / select_tcp_service.hpp

include/boost/corosio/native/detail/select/select_tcp_service.hpp

73.3% Lines (63/86) 86.7% List of functions (13/15) 50.0% Branches (11/22)
[ ] prev/next file n p prev/next uncovered line
f(x) Functions (15)
Function Calls Lines Branches Blocks
boost::corosio::detail::select_tcp_service::~select_tcp_service() :52 693x 100.0% – 100.0% boost::corosio::detail::select_tcp_service::select_tcp_service(boost::capy::execution_context&) :60 462x 100.0% – 100.0% boost::corosio::detail::select_connect_op::cancel() :73 0 0.0% 0.0% 0.0% boost::corosio::detail::select_read_op::cancel() :82 38x 80.0% 50.0% 75.0% boost::corosio::detail::select_write_op::cancel() :91 0 0.0% 0.0% 0.0% boost::corosio::detail::select_op::operator()() :100 213891x 100.0% – 100.0% boost::corosio::detail::select_connect_op::operator()() :106 1789x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::select_tcp_socket(boost::corosio::detail::select_tcp_service&) :111 10778x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::~select_tcp_socket() :116 10778x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::connect(std::__1::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::endpoint, std::__1::stop_token, std::__1::error_code*) :119 1789x 100.0% 50.0% 100.0% boost::corosio::detail::select_tcp_socket::read_some(std::__1::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::buffer_param, std::__1::stop_token, std::__1::error_code*, unsigned long*) :134 465399x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::write_some(std::__1::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::buffer_param, std::__1::stop_token, std::__1::error_code*, unsigned long*) :146 466291x 100.0% 100.0% 100.0% boost::corosio::detail::select_tcp_socket::cancel() :162 44x 100.0% – 100.0% boost::corosio::detail::select_tcp_socket::close_socket() :168 16176x 100.0% – 100.0% boost::corosio::detail::select_tcp_service::open_socket(boost::corosio::tcp_socket::implementation&, int, int, int) :174 1806x 68.4% 58.3% 64.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_SELECT_SELECT_TCP_SERVICE_HPP
11 #define BOOST_COROSIO_NATIVE_DETAIL_SELECT_SELECT_TCP_SERVICE_HPP
12
13 #include <boost/corosio/detail/platform.hpp>
14
15 #if BOOST_COROSIO_HAS_SELECT
16
17 #include <boost/corosio/detail/config.hpp>
18 #include <boost/corosio/detail/tcp_service.hpp>
19
20 #include <boost/corosio/native/detail/select/select_tcp_socket.hpp>
21 #include <boost/corosio/native/detail/select/select_scheduler.hpp>
22 #include <boost/corosio/native/detail/reactor/reactor_socket_service.hpp>
23
24 #include <boost/corosio/native/detail/reactor/reactor_op_complete.hpp>
25
26 #include <coroutine>
27 #include <mutex>
28
29 #include <errno.h>
30 #include <fcntl.h>
31 #include <netinet/in.h>
32 #include <netinet/tcp.h>
33 #include <sys/select.h>
34 #include <sys/socket.h>
35 #include <unistd.h>
36
37 /*
38 Each I/O op tries the syscall speculatively; only registers with
39 the reactor on EAGAIN. Fd is registered once at open time and
40 stays registered until close. The reactor only marks ready_events_;
41 actual I/O happens in invoke_deferred_io(). cancel() captures
42 shared_from_this() into op.impl_ptr to keep the impl alive.
43 */
44
45 namespace boost::corosio::detail {
46
47 /** select TCP service implementation.
48
49 Inherits from tcp_service to enable runtime polymorphism.
50 Uses key_type = tcp_service for service lookup.
51 */
52 class BOOST_COROSIO_DECL select_tcp_service final
53 : public reactor_socket_service<
54 select_tcp_service,
55 tcp_service,
56 select_scheduler,
57 select_tcp_socket>
58 {
59 public:
60 462x explicit select_tcp_service(capy::execution_context& ctx)
61 231x : reactor_socket_service(ctx)
62 462x {
63 462x }
64
65 std::error_code open_socket(
66 tcp_socket::implementation& impl,
67 int family,
68 int type,
69 int protocol) override;
70 };
71
72 inline void
73 ✗ select_connect_op::cancel() noexcept
74 {
75 ✗ if (socket_impl_)
76 ✗ socket_impl_->cancel_single_op(*this);
77 else
78 ✗ request_cancel();
79 ✗ }
80
81 inline void
82 38x select_read_op::cancel() noexcept
83 {
84
1/2
✓ Branch 0 taken 38 times.
✗ Branch 1 not taken.
 38x if (socket_impl_)
85 38x socket_impl_->cancel_single_op(*this);
86 else
87 ✗ request_cancel();
88 38x }
89
90 inline void
91 ✗ select_write_op::cancel() noexcept
92 {
93 ✗ if (socket_impl_)
94 ✗ socket_impl_->cancel_single_op(*this);
95 else
96 ✗ request_cancel();
97 ✗ }
98
99 inline void
100 213891x select_op::operator()()
101 {
102 213891x complete_io_op(*this);
103 213891x }
104
105 inline void
106 1789x select_connect_op::operator()()
107 {
108 1789x complete_connect_op(*this);
109 1789x }
110
111 10778x inline select_tcp_socket::select_tcp_socket(select_tcp_service& svc) noexcept
112 5389x : reactor_stream_socket(svc)
113 10778x {
114 10778x }
115
116 10778x inline select_tcp_socket::~select_tcp_socket() = default;
117
118 inline std::coroutine_handle<>
119 1789x select_tcp_socket::connect(
120 std::coroutine_handle<> h,
121 capy::executor_ref ex,
122 endpoint ep,
123 std::stop_token token,
124 std::error_code* ec)
125 {
126 1789x auto result = do_connect(h, ex, ep, token, ec);
127 // Rebuild fd_sets so select() watches for writability
128
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1789 times.
 1789x if (result == std::noop_coroutine())
129 1789x svc_.scheduler().notify_reactor();
130 1789x return result;
131 }
132
133 inline std::coroutine_handle<>
134 465399x select_tcp_socket::read_some(
135 std::coroutine_handle<> h,
136 capy::executor_ref ex,
137 buffer_param param,
138 std::stop_token token,
139 std::error_code* ec,
140 std::size_t* bytes_out)
141 {
142 465399x return do_read_some(h, ex, param, token, ec, bytes_out);
143 }
144
145 inline std::coroutine_handle<>
146 466291x select_tcp_socket::write_some(
147 std::coroutine_handle<> h,
148 capy::executor_ref ex,
149 buffer_param param,
150 std::stop_token token,
151 std::error_code* ec,
152 std::size_t* bytes_out)
153 {
154 466291x auto result = do_write_some(h, ex, param, token, ec, bytes_out);
155 // Rebuild fd_sets so select() watches for writability
156
2/2
✓ Branch 0 taken 382800 times.
✓ Branch 1 taken 83491 times.
 466291x if (result == std::noop_coroutine())
157 83491x svc_.scheduler().notify_reactor();
158 466291x return result;
159 }
160
161 inline void
162 44x select_tcp_socket::cancel() noexcept
163 {
164 44x do_cancel();
165 44x }
166
167 inline void
168 16176x select_tcp_socket::close_socket() noexcept
169 {
170 16176x do_close_socket();
171 16176x }
172
173 inline std::error_code
174 1806x select_tcp_service::open_socket(
175 tcp_socket::implementation& impl, int family, int type, int protocol)
176 {
177 1806x auto* select_impl = static_cast<select_tcp_socket*>(&impl);
178 1806x select_impl->close_socket();
179
180 1806x int fd = ::socket(family, type, protocol);
181
1/2
✓ Branch 0 taken 1806 times.
✗ Branch 1 not taken.
 1806x if (fd < 0)
182 ✗ return make_err(errno);
183
184
2/2
✓ Branch 0 taken 1801 times.
✓ Branch 1 taken 5 times.
 1806x if (family == AF_INET6)
185 {
186 5x int one = 1;
187 5x ::setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, &one, sizeof(one));
188 5x }
189
190 1806x int flags = ::fcntl(fd, F_GETFL, 0);
191
1/2
✓ Branch 0 taken 1806 times.
✗ Branch 1 not taken.
 1806x if (flags == -1)
192 {
193 ✗ int errn = errno;
194 ✗ ::close(fd);
195 ✗ return make_err(errn);
196 }
197
1/2
✓ Branch 0 taken 1806 times.
✗ Branch 1 not taken.
 1806x if (::fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1)
198 {
199 ✗ int errn = errno;
200 ✗ ::close(fd);
201 ✗ return make_err(errn);
202 }
203
1/2
✓ Branch 0 taken 1806 times.
✗ Branch 1 not taken.
 1806x if (::fcntl(fd, F_SETFD, FD_CLOEXEC) == -1)
204 {
205 ✗ int errn = errno;
206 ✗ ::close(fd);
207 ✗ return make_err(errn);
208 }
209
210
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1806 times.
 1806x if (fd >= FD_SETSIZE)
211 {
212 ✗ ::close(fd);
213 ✗ return make_err(EMFILE);
214 }
215
216 #ifdef SO_NOSIGPIPE
217 {
218 1806x int one = 1;
219 1806x ::setsockopt(fd, SOL_SOCKET, SO_NOSIGPIPE, &one, sizeof(one));
220 }
221 #endif
222
223 1806x select_impl->fd_ = fd;
224
225 1806x select_impl->desc_state_.fd = fd;
226 {
227 1806x std::lock_guard lock(select_impl->desc_state_.mutex);
228 1806x select_impl->desc_state_.read_op = nullptr;
229 1806x select_impl->desc_state_.write_op = nullptr;
230 1806x select_impl->desc_state_.connect_op = nullptr;
231 1806x }
232 1806x scheduler().register_descriptor(fd, &select_impl->desc_state_);
233
234 1806x return {};
235 1806x }
236
237 } // namespace boost::corosio::detail
238
239 #endif // BOOST_COROSIO_HAS_SELECT
240
241 #endif // BOOST_COROSIO_NATIVE_DETAIL_SELECT_SELECT_TCP_SERVICE_HPP
242