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

100.0% Lines (45/45) 100.0% List of functions (44/44) 54.2% Branches (26/48)

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

reactor_acceptor_service.hpp

f(x) Functions (44)

Function Calls Lines Branches Blocks

Line	Branch	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_REACTOR_REACTOR_ACCEPTOR_SERVICE_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_ACCEPTOR_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 acceptor service implementations.
24
25			Provides the shared construct/destroy/shutdown/close/post/work
26			logic that is identical across all reactor backends and acceptor
27			types (TCP and local stream). Derived classes add only
28			protocol-specific open/bind/listen/stream_service.
29
30			@tparam Derived The concrete service type (CRTP).
31			@tparam ServiceBase The abstract service base
32			(tcp_acceptor_service or
33			local_stream_acceptor_service).
34			@tparam Scheduler The backend's scheduler type.
35			@tparam Impl The backend's acceptor impl type.
36			@tparam StreamService The concrete stream service type returned
37			by stream_service().
38			*/
39			template<
40			class Derived,
41			class ServiceBase,
42			class Scheduler,
43			class Impl,
44			class StreamService>
45			class reactor_acceptor_service : public ServiceBase
46			{
47			friend Derived;
48			using state_type = reactor_service_state<Scheduler, Impl>;
49
50			protected:
51			// NOLINTNEXTLINE(bugprone-crtp-constructor-accessibility)
52		4582x	explicit reactor_acceptor_service(capy::execution_context& ctx)
53		4582x	: ctx_(ctx)
54		4582x	, state_(
55	4/8 ✓ Branch 0 taken 829 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 829 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1462 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1462 times. ✗ Branch 7 not taken.	4582x	std::make_unique<state_type>(
56	4/8 ✓ Branch 0 taken 829 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 829 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1462 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 1462 times. ✗ Branch 7 not taken.	4582x	ctx.template use_service<Scheduler>()))
57		4582x	{
58		4582x	}
59
60			public:
61		4582x	~reactor_acceptor_service() override = default;
62
63		4582x	void shutdown() override
64			{
65		4582x	std::lock_guard lock(state_->mutex_);
66
67	6/8 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 829 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 829 times. ✓ Branch 4 taken 3 times. ✓ Branch 5 taken 1462 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 1462 times.	4587x	while (auto* impl = state_->impl_list_.pop_front())
68		5x	impl->close_socket();
69		4582x	}
70
71		1745x	io_object::implementation* construct() override
72			{
73		1745x	auto impl = std::make_shared<Impl>(static_cast<Derived&>(*this));
74		1745x	auto* raw = impl.get();
75
76	4/8 ✓ Branch 0 taken 255 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 51 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1386 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 53 times. ✗ Branch 7 not taken.	1745x	std::lock_guard lock(state_->mutex_);
77	4/8 ✓ Branch 0 taken 255 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 51 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1386 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 53 times. ✗ Branch 7 not taken.	1745x	state_->impl_ptrs_.emplace(raw, std::move(impl));
78		1745x	state_->impl_list_.push_back(raw);
79
80		1745x	return raw;
81		1745x	}
82
83		1740x	void destroy(io_object::implementation* impl) override
84			{
85		1740x	auto* typed = static_cast<Impl*>(impl);
86		1740x	typed->close_socket();
87		1740x	std::lock_guard lock(state_->mutex_);
88		1740x	state_->impl_list_.remove(typed);
89	4/8 ✓ Branch 0 taken 253 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 51 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 1383 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 53 times. ✗ Branch 7 not taken.	1740x	state_->impl_ptrs_.erase(typed);
90		1740x	}
91
92		3407x	void close(io_object::handle& h) override
93			{
94		3407x	static_cast<Impl*>(h.get())->close_socket();
95		3407x	}
96
97		3289x	Scheduler& scheduler() const noexcept
98			{
99		3289x	return state_->sched_;
100			}
101
102		167x	void post(scheduler_op* op)
103			{
104		167x	state_->sched_.post(op);
105		167x	}
106
107		6458x	void work_started() noexcept
108			{
109		6458x	state_->sched_.work_started();
110		6458x	}
111
112		110x	void work_finished() noexcept
113			{
114		110x	state_->sched_.work_finished();
115		110x	}
116
117		6372x	StreamService* stream_service() const noexcept
118			{
119		6372x	return stream_svc_;
120			}
121
122			protected:
123			capy::execution_context& ctx_;
124			std::unique_ptr<state_type> state_;
125		4582x	StreamService* stream_svc_ = nullptr;
126
127			private:
128			reactor_acceptor_service(reactor_acceptor_service const&) = delete;
129			reactor_acceptor_service&
130			operator=(reactor_acceptor_service const&) = delete;
131			};
132
133			} // namespace boost::corosio::detail
134
135			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_ACCEPTOR_SERVICE_HPP
136