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

97.8% Lines (45/47) 93.5% List of functions (86/92) 52.1% Branches (50/96)

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

reactor_socket_service.hpp

f(x) Functions (92)

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_SOCKET_SERVICE_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
12
13			#include <boost/corosio/io/io_object.hpp>
14			#include <boost/corosio/detail/scheduler_op.hpp>
15			#include <boost/corosio/native/detail/reactor/reactor_service_state.hpp>
16			#include <boost/capy/ex/execution_context.hpp>
17
18			#include <memory>
19			#include <mutex>
20
21			namespace boost::corosio::detail {
22
23			/** CRTP base for reactor-backed socket/datagram service implementations.
24
25			Provides the shared construct/destroy/shutdown/close/post/work
26			logic that is identical across all reactor backends and socket
27			types. Derived classes add only protocol-specific open/bind.
28
29			@tparam Derived The concrete service type (CRTP).
30			@tparam ServiceBase The abstract service base (tcp_service
31			or udp_service).
32			@tparam Scheduler The backend's scheduler type.
33			@tparam Impl The backend's socket/datagram impl type.
34			*/
35			template<class Derived, class ServiceBase, class Scheduler, class Impl>
36			class reactor_socket_service : public ServiceBase
37			{
38			friend Derived;
39			using state_type = reactor_service_state<Scheduler, Impl>;
40
41			protected:
42			// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
43		9164x	explicit reactor_socket_service(capy::execution_context& ctx)
44		9164x	: state_(
45	8/16 ✓ Branch 0 taken 829 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 829 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 829 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 829 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 1462 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1462 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1462 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 1462 times. ✗ Branch 15 not taken.	9164x	std::make_unique<state_type>(
46	8/16 ✓ Branch 0 taken 829 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 829 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 829 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 829 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 1462 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 1462 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 1462 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 1462 times. ✗ Branch 15 not taken.	9164x	ctx.template use_service<Scheduler>()))
47		9164x	{
48		9164x	}
49
50			public:
51		9164x	~reactor_socket_service() override = default;
52
53		9164x	void shutdown() override
54			{
55		9164x	std::lock_guard lock(state_->mutex_);
56
57	10/16 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 829 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 829 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 829 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 829 times. ✓ Branch 8 taken 3 times. ✓ Branch 9 taken 1462 times. ✗ Branch 10 not taken. ✓ Branch 11 taken 1462 times. ✗ Branch 12 not taken. ✓ Branch 13 taken 1462 times. ✗ Branch 14 not taken. ✓ Branch 15 taken 1462 times.	9169x	while (auto* impl = state_->impl_list_.pop_front())
58			{
59		5x	static_cast<Derived*>(this)->pre_shutdown(impl);
60		5x	impl->close_socket();
61			}
62
63			// Don't clear impl_ptrs_ here. The scheduler shuts down after us
64			// and drains completed_ops_, calling destroy() on each queued op.
65			// Letting ~state_ release the ptrs (during service destruction,
66			// after scheduler shutdown) keeps every impl alive until all ops
67			// have been drained.
68		9164x	}
69
70		20555x	io_object::implementation* construct() override
71			{
72		20555x	auto impl = std::make_shared<Impl>(static_cast<Derived&>(*this));
73		20555x	auto* raw = impl.get();
74
75			{
76	8/16 ✓ Branch 0 taken 14366 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 5549 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 12 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 120 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 208 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 160 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 16 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 124 times. ✗ Branch 15 not taken.	20555x	std::lock_guard lock(state_->mutex_);
77	8/16 ✓ Branch 0 taken 14366 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 5549 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 12 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 120 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 208 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 160 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 16 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 124 times. ✗ Branch 15 not taken.	20555x	state_->impl_ptrs_.emplace(raw, std::move(impl));
78		20555x	state_->impl_list_.push_back(raw);
79		20555x	}
80
81		20555x	return raw;
82		20555x	}
83
84		20550x	void destroy(io_object::implementation* impl) override
85			{
86		20550x	auto* typed = static_cast<Impl*>(impl);
87		20550x	static_cast<Derived*>(this)->pre_destroy(typed);
88		20550x	typed->close_socket();
89		20550x	std::lock_guard lock(state_->mutex_);
90		20550x	state_->impl_list_.remove(typed);
91	8/16 ✓ Branch 0 taken 14363 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 5547 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 12 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 120 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 208 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 160 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 16 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 124 times. ✗ Branch 15 not taken.	20550x	state_->impl_ptrs_.erase(typed);
92		20550x	}
93
94		34052x	void close(io_object::handle& h) override
95			{
96		34052x	static_cast<Impl*>(h.get())->close_socket();
97		34052x	}
98
99		940591x	Scheduler& scheduler() const noexcept
100			{
101		940591x	return state_->sched_;
102			}
103
104		172117x	void post(scheduler_op* op)
105			{
106		172117x	state_->sched_.post(op);
107		172117x	}
108
109		65842x	void work_started() noexcept
110			{
111		65842x	state_->sched_.work_started();
112		65842x	}
113
114		1140x	void work_finished() noexcept
115			{
116		1140x	state_->sched_.work_finished();
117		1140x	}
118
119			protected:
120			// Override in derived to add pre-close logic. No backend currently needs
121			// it; the hooks exist so a trait can run fd-level teardown before close.
122		✗	void pre_shutdown(Impl*) noexcept {
123		−	} // LCOV_EXCL_LINE optional CRTP hook; no backend overrides it today
124		869x	void pre_destroy(Impl*) noexcept {}
125
126			std::unique_ptr<state_type> state_;
127
128			private:
129			reactor_socket_service(reactor_socket_service const&) = delete;
130			reactor_socket_service& operator=(reactor_socket_service const&) = delete;
131			};
132
133			} // namespace boost::corosio::detail
134
135			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
136