Index/include / boost / corosio / native / detail / epoll / epoll_local_stream_service.hpp

include/boost/corosio/native/detail/epoll/epoll_local_stream_service.hpp

72.2% Lines (52/72) 75.0% List of functions (12/16)
[ ] prev/next file n p prev/next uncovered line
epoll_local_stream_service.hpp
f(x) Functions (16)
Function Calls Lines Blocks
boost::corosio::detail::epoll_local_stream_service::epoll_local_stream_service(boost::capy::execution_context&) :43 356x 100.0% 100.0% boost::corosio::detail::epoll_local_connect_op::cancel() :62 0 0.0% 0.0% boost::corosio::detail::epoll_local_read_op::cancel() :71 0 0.0% 0.0% boost::corosio::detail::epoll_local_write_op::cancel() :80 0 0.0% 0.0% boost::corosio::detail::epoll_local_stream_op::operator()() :89 3x 100.0% 100.0% boost::corosio::detail::epoll_local_connect_op::operator()() :95 2x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::epoll_local_stream_socket(boost::corosio::detail::epoll_local_stream_service&) :102 17x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::~epoll_local_stream_socket() :108 17x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::connect(std::__n4861::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::local_endpoint, std::stop_token, std::error_code*) :111 2x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::read_some(std::__n4861::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::buffer_param, std::stop_token, std::error_code*, unsigned long*) :122 1x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::write_some(std::__n4861::coroutine_handle<void>, boost::capy::executor_ref, boost::corosio::buffer_param, std::stop_token, std::error_code*, unsigned long*) :134 2x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::cancel() :146 0 0.0% 0.0% boost::corosio::detail::epoll_local_stream_socket::close_socket() :152 59x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_socket::release_socket() :158 1x 100.0% 100.0% boost::corosio::detail::epoll_local_stream_service::open_socket(boost::corosio::local_stream_socket::implementation&, int, int, int) :166 4x 93.3% 92.0% boost::corosio::detail::epoll_local_stream_service::assign_socket(boost::corosio::local_stream_socket::implementation&, int) :194 8x 92.9% 92.0%
Line TLA Hits Source Code
1 //
2 // Copyright (c) 2026 Michael Vandeberg
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_EPOLL_EPOLL_LOCAL_STREAM_SERVICE_HPP
11 #define BOOST_COROSIO_NATIVE_DETAIL_EPOLL_EPOLL_LOCAL_STREAM_SERVICE_HPP
12
13 #include <boost/corosio/detail/platform.hpp>
14
15 #if BOOST_COROSIO_HAS_EPOLL
16
17 #include <boost/corosio/detail/config.hpp>
18 #include <boost/corosio/detail/local_stream_service.hpp>
19
20 #include <boost/corosio/native/detail/epoll/epoll_local_stream_socket.hpp>
21 #include <boost/corosio/native/detail/epoll/epoll_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
28 #include <errno.h>
29 #include <sys/socket.h>
30 #include <sys/un.h>
31 #include <unistd.h>
32
33 namespace boost::corosio::detail {
34
35 class BOOST_COROSIO_DECL epoll_local_stream_service final
36 : public reactor_socket_service<
37 epoll_local_stream_service,
38 local_stream_service,
39 epoll_scheduler,
40 epoll_local_stream_socket>
41 {
42 public:
43 356x explicit epoll_local_stream_service(capy::execution_context& ctx)
44 356x : reactor_socket_service(ctx)
45 {
46 356x }
47
48 std::error_code open_socket(
49 local_stream_socket::implementation& impl,
50 int family,
51 int type,
52 int protocol) override;
53
54 std::error_code assign_socket(
55 local_stream_socket::implementation& impl,
56 native_handle_type fd) override;
57 };
58
59 // Op implementations
60
61 inline void
62 ✗ epoll_local_connect_op::cancel() noexcept
63 {
64 ✗ if (socket_impl_)
65 ✗ socket_impl_->cancel_single_op(*this);
66 else
67 ✗ request_cancel();
68 ✗ }
69
70 inline void
71 ✗ epoll_local_read_op::cancel() noexcept
72 {
73 ✗ if (socket_impl_)
74 ✗ socket_impl_->cancel_single_op(*this);
75 else
76 ✗ request_cancel();
77 ✗ }
78
79 inline void
80 ✗ epoll_local_write_op::cancel() noexcept
81 {
82 ✗ if (socket_impl_)
83 ✗ socket_impl_->cancel_single_op(*this);
84 else
85 ✗ request_cancel();
86 ✗ }
87
88 inline void
89 3x epoll_local_stream_op::operator()()
90 {
91 3x complete_io_op(*this);
92 3x }
93
94 inline void
95 2x epoll_local_connect_op::operator()()
96 {
97 2x complete_connect_op(*this);
98 2x }
99
100 // Socket implementations
101
102 17x inline epoll_local_stream_socket::epoll_local_stream_socket(
103 17x epoll_local_stream_service& svc) noexcept
104 17x : reactor_stream_socket(svc)
105 {
106 17x }
107
108 17x inline epoll_local_stream_socket::~epoll_local_stream_socket() = default;
109
110 inline std::coroutine_handle<>
111 2x epoll_local_stream_socket::connect(
112 std::coroutine_handle<> h,
113 capy::executor_ref ex,
114 corosio::local_endpoint ep,
115 std::stop_token token,
116 std::error_code* ec)
117 {
118 2x return do_connect(h, ex, ep, token, ec);
119 }
120
121 inline std::coroutine_handle<>
122 1x epoll_local_stream_socket::read_some(
123 std::coroutine_handle<> h,
124 capy::executor_ref ex,
125 buffer_param param,
126 std::stop_token token,
127 std::error_code* ec,
128 std::size_t* bytes_out)
129 {
130 1x return do_read_some(h, ex, param, token, ec, bytes_out);
131 }
132
133 inline std::coroutine_handle<>
134 2x epoll_local_stream_socket::write_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 2x return do_write_some(h, ex, param, token, ec, bytes_out);
143 }
144
145 inline void
146 ✗ epoll_local_stream_socket::cancel() noexcept
147 {
148 ✗ do_cancel();
149 ✗ }
150
151 inline void
152 59x epoll_local_stream_socket::close_socket() noexcept
153 {
154 59x do_close_socket();
155 59x }
156
157 inline native_handle_type
158 1x epoll_local_stream_socket::release_socket() noexcept
159 {
160 1x return this->do_release_socket();
161 }
162
163 // Service implementations
164
165 inline std::error_code
166 4x epoll_local_stream_service::open_socket(
167 local_stream_socket::implementation& impl,
168 int family,
169 int type,
170 int protocol)
171 {
172 4x auto* epoll_impl = static_cast<epoll_local_stream_socket*>(&impl);
173 4x epoll_impl->close_socket();
174
175 4x int fd = ::socket(family, type | SOCK_NONBLOCK | SOCK_CLOEXEC, protocol);
176 4x if (fd < 0)
177 ✗ return make_err(errno);
178
179 4x epoll_impl->fd_ = fd;
180
181 4x epoll_impl->desc_state_.fd = fd;
182 {
183 4x std::lock_guard lock(epoll_impl->desc_state_.mutex);
184 4x epoll_impl->desc_state_.read_op = nullptr;
185 4x epoll_impl->desc_state_.write_op = nullptr;
186 4x epoll_impl->desc_state_.connect_op = nullptr;
187 4x }
188 4x scheduler().register_descriptor(fd, &epoll_impl->desc_state_);
189
190 4x return {};
191 }
192
193 inline std::error_code
194 8x epoll_local_stream_service::assign_socket(
195 local_stream_socket::implementation& impl,
196 native_handle_type fd)
197 {
198 8x if (fd < 0)
199 ✗ return make_err(EBADF);
200
201 8x auto* epoll_impl = static_cast<epoll_local_stream_socket*>(&impl);
202 8x epoll_impl->close_socket();
203
204 8x epoll_impl->fd_ = fd;
205
206 8x epoll_impl->desc_state_.fd = fd;
207 {
208 8x std::lock_guard lock(epoll_impl->desc_state_.mutex);
209 8x epoll_impl->desc_state_.read_op = nullptr;
210 8x epoll_impl->desc_state_.write_op = nullptr;
211 8x epoll_impl->desc_state_.connect_op = nullptr;
212 8x }
213 8x scheduler().register_descriptor(fd, &epoll_impl->desc_state_);
214
215 8x return {};
216 }
217
218 } // namespace boost::corosio::detail
219
220 #endif // BOOST_COROSIO_HAS_EPOLL
221
222 #endif // BOOST_COROSIO_NATIVE_DETAIL_EPOLL_EPOLL_LOCAL_STREAM_SERVICE_HPP
223