Index/src / corosio / src / io_context.cpp

src/corosio/src/io_context.cpp

52.3% Lines (23/44) 50.0% List of functions (5/10) 40.0% Branches (2/5)
[ ] prev/next file n p prev/next uncovered line
io_context.cpp
f(x) Functions (10)
Function Calls Lines Branches Blocks
boost::corosio::iocp_t::construct(boost::capy::execution_context&, unsigned int) :99 442x 100.0% 100.0% 100.0% boost::corosio::(anonymous namespace)::pre_create_services(boost::capy::execution_context&, boost::corosio::io_context_options const&) :123 0 0.0% – 0.0% boost::corosio::(anonymous namespace)::apply_scheduler_options(boost::corosio::detail::scheduler&, boost::corosio::io_context_options const&) :145 0 0.0% 0.0% 0.0% boost::corosio::(anonymous namespace)::construct_default(boost::capy::execution_context&, unsigned int) :173 195x 100.0% – 100.0% boost::corosio::io_context::io_context() :188 194x 100.0% – 100.0% boost::corosio::io_context::io_context(unsigned int) :190 195x 100.0% 100.0% 80.0% boost::corosio::io_context::io_context(boost::corosio::io_context_options const&, unsigned int) :196 0 0.0% 0.0% 0.0% boost::corosio::io_context::apply_options_pre_(boost::corosio::io_context_options const&) :208 0 0.0% – 0.0% boost::corosio::io_context::apply_options_post_(boost::corosio::io_context_options const&) :214 0 0.0% – 0.0% boost::corosio::io_context::~io_context() :219 442x 100.0% – 100.0%
Line Branch TLA Hits Source Code
1 //
2 // Copyright (c) 2026 Steve Gerbino
3 // Copyright (c) 2026 Michael Vandeberg
4 //
5 // Distributed under the Boost Software License, Version 1.0. (See accompanying
6 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
7 //
8 // Official repository: https://github.com/cppalliance/corosio
9 //
10
11 #include <boost/corosio/io_context.hpp>
12 #include <boost/corosio/backend.hpp>
13 #include <boost/corosio/detail/thread_pool.hpp>
14
15 #include <stdexcept>
16 #include <thread>
17
18 #if BOOST_COROSIO_HAS_EPOLL
19 #include <boost/corosio/native/detail/epoll/epoll_types.hpp>
20 #endif
21
22 #if BOOST_COROSIO_HAS_SELECT
23 #include <boost/corosio/native/detail/select/select_types.hpp>
24 #endif
25
26 #if BOOST_COROSIO_HAS_KQUEUE
27 #include <boost/corosio/native/detail/kqueue/kqueue_types.hpp>
28 #endif
29
30 #if BOOST_COROSIO_HAS_IOCP
31 #include <boost/corosio/native/detail/iocp/win_scheduler.hpp>
32 #include <boost/corosio/native/detail/iocp/win_tcp_acceptor_service.hpp>
33 #include <boost/corosio/native/detail/iocp/win_udp_service.hpp>
34 #include <boost/corosio/native/detail/iocp/win_local_stream_acceptor_service.hpp>
35 #include <boost/corosio/native/detail/iocp/win_local_dgram_service.hpp>
36 #include <boost/corosio/native/detail/iocp/win_signals.hpp>
37 #include <boost/corosio/native/detail/iocp/win_file_service.hpp>
38 #include <boost/corosio/native/detail/iocp/win_random_access_file_service.hpp>
39 #endif
40
41 namespace boost::corosio {
42
43 #if BOOST_COROSIO_HAS_EPOLL
44 detail::scheduler&
45 epoll_t::construct(capy::execution_context& ctx, unsigned concurrency_hint)
46 {
47 auto& sched = ctx.make_service<detail::epoll_scheduler>(
48 static_cast<int>(concurrency_hint));
49
50 ctx.make_service<detail::epoll_tcp_service>();
51 ctx.make_service<detail::epoll_tcp_acceptor_service>();
52 ctx.make_service<detail::epoll_udp_service>();
53 ctx.make_service<detail::epoll_local_stream_service>();
54 ctx.make_service<detail::epoll_local_stream_acceptor_service>();
55 ctx.make_service<detail::epoll_local_datagram_service>();
56
57 return sched;
58 }
59 #endif
60
61 #if BOOST_COROSIO_HAS_SELECT
62 detail::scheduler&
63 select_t::construct(capy::execution_context& ctx, unsigned concurrency_hint)
64 {
65 auto& sched = ctx.make_service<detail::select_scheduler>(
66 static_cast<int>(concurrency_hint));
67
68 ctx.make_service<detail::select_tcp_service>();
69 ctx.make_service<detail::select_tcp_acceptor_service>();
70 ctx.make_service<detail::select_udp_service>();
71 ctx.make_service<detail::select_local_stream_service>();
72 ctx.make_service<detail::select_local_stream_acceptor_service>();
73 ctx.make_service<detail::select_local_datagram_service>();
74
75 return sched;
76 }
77 #endif
78
79 #if BOOST_COROSIO_HAS_KQUEUE
80 detail::scheduler&
81 kqueue_t::construct(capy::execution_context& ctx, unsigned concurrency_hint)
82 {
83 auto& sched = ctx.make_service<detail::kqueue_scheduler>(
84 static_cast<int>(concurrency_hint));
85
86 ctx.make_service<detail::kqueue_tcp_service>();
87 ctx.make_service<detail::kqueue_tcp_acceptor_service>();
88 ctx.make_service<detail::kqueue_udp_service>();
89 ctx.make_service<detail::kqueue_local_stream_service>();
90 ctx.make_service<detail::kqueue_local_stream_acceptor_service>();
91 ctx.make_service<detail::kqueue_local_datagram_service>();
92
93 return sched;
94 }
95 #endif
96
97 #if BOOST_COROSIO_HAS_IOCP
98 detail::scheduler&
99 442x iocp_t::construct(capy::execution_context& ctx, unsigned concurrency_hint)
100 {
101 884x auto& sched = ctx.make_service<detail::win_scheduler>(
102
1/1
✓ Branch 2 → 3 taken 442 times.
 442x static_cast<int>(concurrency_hint));
103
104 442x auto& tcp_svc = ctx.make_service<detail::win_tcp_service>();
105 442x ctx.make_service<detail::win_tcp_acceptor_service>(tcp_svc);
106 442x ctx.make_service<detail::win_udp_service>();
107 auto& local_svc =
108 442x ctx.make_service<detail::win_local_stream_service>(tcp_svc);
109 442x ctx.make_service<detail::win_local_stream_acceptor_service>(local_svc);
110 442x ctx.make_service<detail::win_local_dgram_service>();
111 442x ctx.make_service<detail::win_signals>();
112 442x ctx.make_service<detail::win_file_service>();
113 442x ctx.make_service<detail::win_random_access_file_service>();
114
115 442x return sched;
116 }
117 #endif
118
119 namespace {
120
121 // Pre-create services that must exist before construct() runs.
122 void
123 ✗ pre_create_services(
124 capy::execution_context& ctx,
125 io_context_options const& opts)
126 {
127 #if BOOST_COROSIO_POSIX
128 if (opts.thread_pool_size < 1)
129 throw std::invalid_argument(
130 "thread_pool_size must be at least 1");
131 // Pre-create the shared thread pool with the configured size.
132 // This must happen before construct() because the scheduler
133 // constructor creates file and resolver services that call
134 // get_or_create_pool(), which would create a 1-thread pool.
135 if (opts.thread_pool_size != 1)
136 ctx.make_service<detail::thread_pool>(opts.thread_pool_size);
137 #endif
138
139 (void)ctx;
140 (void)opts;
141 ✗ }
142
143 // Apply runtime tuning to the scheduler after construction.
144 void
145 ✗ apply_scheduler_options(
146 detail::scheduler& sched,
147 io_context_options const& opts)
148 {
149 #if BOOST_COROSIO_HAS_EPOLL || BOOST_COROSIO_HAS_KQUEUE || BOOST_COROSIO_HAS_SELECT
150 auto& reactor =
151 static_cast<detail::reactor_scheduler&>(sched);
152 reactor.configure_reactor(
153 opts.max_events_per_poll,
154 opts.inline_budget_initial,
155 opts.inline_budget_max,
156 opts.unassisted_budget);
157 if (opts.single_threaded)
158 reactor.configure_single_threaded(true);
159 #endif
160
161 #if BOOST_COROSIO_HAS_IOCP
162 ✗ auto& iocp_sched = static_cast<detail::win_scheduler&>(sched);
163 ✗ iocp_sched.configure_iocp(opts.gqcs_timeout_ms);
164 ✗ if (opts.single_threaded)
165 ✗ iocp_sched.configure_single_threaded(true);
166 #endif
167
168 (void)sched;
169 (void)opts;
170 ✗ }
171
172 detail::scheduler&
173 195x construct_default(capy::execution_context& ctx, unsigned concurrency_hint)
174 {
175 #if BOOST_COROSIO_HAS_IOCP
176 195x return iocp_t::construct(ctx, concurrency_hint);
177 #elif BOOST_COROSIO_HAS_EPOLL
178 return epoll_t::construct(ctx, concurrency_hint);
179 #elif BOOST_COROSIO_HAS_KQUEUE
180 return kqueue_t::construct(ctx, concurrency_hint);
181 #elif BOOST_COROSIO_HAS_SELECT
182 return select_t::construct(ctx, concurrency_hint);
183 #endif
184 }
185
186 } // anonymous namespace
187
188 194x io_context::io_context() : io_context(std::thread::hardware_concurrency()) {}
189
190 195x io_context::io_context(unsigned concurrency_hint)
191 : capy::execution_context(this)
192
1/1
✓ Branch 3 → 4 taken 195 times.
 195x , sched_(&construct_default(*this, concurrency_hint))
193 {
194 195x }
195
196 ✗ io_context::io_context(
197 io_context_options const& opts,
198 ✗ unsigned concurrency_hint)
199 : capy::execution_context(this)
200 ✗ , sched_(nullptr)
201 {
202 ✗ pre_create_services(*this, opts);
203 ✗ sched_ = &construct_default(*this, concurrency_hint);
204 ✗ apply_scheduler_options(*sched_, opts);
205 ✗ }
206
207 void
208 ✗ io_context::apply_options_pre_(io_context_options const& opts)
209 {
210 ✗ pre_create_services(*this, opts);
211 ✗ }
212
213 void
214 ✗ io_context::apply_options_post_(io_context_options const& opts)
215 {
216 ✗ apply_scheduler_options(*sched_, opts);
217 ✗ }
218
219 442x io_context::~io_context()
220 {
221 442x shutdown();
222 442x destroy();
223 442x }
224
225 } // namespace boost::corosio
226