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

93.5% Lines (43/46) 93.5% List of functions (43/46) 45.8% Branches (22/48)

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

reactor_socket_service.hpp

f(x) Functions (46)

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		1358x	explicit reactor_socket_service(capy::execution_context& ctx)
42		1358x	: state_(
43	4/8 ✓ Branch 0 taken 242 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 242 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 437 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 437 times. ✗ Branch 7 not taken.	1358x	std::make_unique<state_type>(
44	4/8 ✓ Branch 0 taken 242 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 242 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 437 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 437 times. ✗ Branch 7 not taken.	1358x	ctx.template use_service<Scheduler>()))
45		1358x	{
46		1358x	}
47
48			public:
49		1358x	~reactor_socket_service() override = default;
50
51		1358x	void shutdown() override
52			{
53		1358x	std::lock_guard lock(state_->mutex_);
54
55	4/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 242 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 242 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 437 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 437 times.	1358x	while (auto* impl = state_->impl_list_.pop_front())
56			{
57		✗	static_cast<Derived*>(this)->pre_shutdown(impl);
58		✗	impl->close_socket();
59			}
60
61			// Don't clear impl_ptrs_ here. The scheduler shuts down after us
62			// and drains completed_ops_, calling destroy() on each queued op.
63			// Letting ~state_ release the ptrs (during service destruction,
64			// after scheduler shutdown) keeps every impl alive until all ops
65			// have been drained.
66		1358x	}
67
68		21386x	io_object::implementation* construct() override
69			{
70		21386x	auto impl = std::make_shared<Impl>(static_cast<Derived&>(*this));
71		21386x	auto* raw = impl.get();
72
73			{
74	3/8 ✓ Branch 0 taken 5247 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16087 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 52 times. ✗ Branch 7 not taken.	21386x	std::lock_guard lock(state_->mutex_);
75	3/8 ✓ Branch 0 taken 5247 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 16087 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✓ Branch 6 taken 52 times. ✗ Branch 7 not taken.	21386x	state_->impl_ptrs_.emplace(raw, std::move(impl));
76		21386x	state_->impl_list_.push_back(raw);
77		21386x	}
78
79		21386x	return raw;
80		21386x	}
81
82		21386x	void destroy(io_object::implementation* impl) override
83			{
84		21386x	auto* typed = static_cast<Impl*>(impl);
85		21386x	static_cast<Derived*>(this)->pre_destroy(typed);
86		21386x	typed->close_socket();
87		21386x	std::lock_guard lock(state_->mutex_);
88		21386x	state_->impl_list_.remove(typed);
89	4/8 ✓ Branch 0 taken 5247 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 52 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 16035 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 52 times. ✗ Branch 7 not taken.	21386x	state_->impl_ptrs_.erase(typed);
90		21386x	}
91
92		35618x	void close(io_object::handle& h) override
93			{
94		35618x	static_cast<Impl*>(h.get())->close_socket();
95		35618x	}
96
97		1759263x	Scheduler& scheduler() const noexcept
98			{
99		1759263x	return state_->sched_;
100			}
101
102		307171x	void post(scheduler_op* op)
103			{
104		307171x	state_->sched_.post(op);
105		307171x	}
106
107		118475x	void work_started() noexcept
108			{
109		118475x	state_->sched_.work_started();
110		118475x	}
111
112		792x	void work_finished() noexcept
113			{
114		792x	state_->sched_.work_finished();
115		792x	}
116
117			protected:
118			// Override in derived to add pre-close logic (e.g. kqueue linger reset)
119		✗	void pre_shutdown(Impl*) noexcept {}
120		5351x	void pre_destroy(Impl*) noexcept {}
121
122			std::unique_ptr<state_type> state_;
123
124			private:
125			reactor_socket_service(reactor_socket_service const&) = delete;
126			reactor_socket_service& operator=(reactor_socket_service const&) = delete;
127			};
128
129			} // namespace boost::corosio::detail
130
131			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_SOCKET_SERVICE_HPP
132