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

68.4% Lines (52/76) 100.0% List of functions (4/4) 15.6% Branches (20/128)

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

reactor_backend.hpp

f(x) Functions (4)

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_BACKEND_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BACKEND_HPP
12
13			/* Reactor backend: acceptor accept() implementation.
14
15			Contains the accept() method body for reactor_acceptor_impl,
16			which needs all socket/service types to be complete. Included
17			by per-backend type files (epoll_types.hpp, etc.) after all
18			named types are defined.
19			*/
20
21			#include <boost/corosio/native/detail/reactor/reactor_service_finals.hpp>
22			#include <boost/corosio/native/detail/reactor/reactor_op_complete.hpp>
23			#include <boost/corosio/native/detail/endpoint_convert.hpp>
24			#include <boost/corosio/detail/dispatch_coro.hpp>
25
26			#include <mutex>
27
28			namespace boost::corosio::detail {
29
30			// ============================================================
31			// Acceptor accept() implementation
32			// ============================================================
33
34			template<class Derived, class Traits, class Service,
35			class SocketFinal, class AccImplBase, class Endpoint>
36			std::coroutine_handle<>
37		5744x	reactor_acceptor_impl<Derived, Traits, Service, SocketFinal, AccImplBase, Endpoint>::accept(
38			std::coroutine_handle<> h,
39			capy::executor_ref ex,
40			std::stop_token token,
41			std::error_code* ec,
42			io_object::implementation** impl_out)
43			{
44		5744x	auto& op = this->acc_;
45		5744x	op.reset();
46		5744x	op.h = h;
47		5744x	op.ex = ex;
48		5744x	op.ec_out = ec;
49		5744x	op.impl_out = impl_out;
50		5744x	op.fd = this->fd_;
51		5744x	op.start(token, static_cast<Derived*>(this));
52
53		5744x	sockaddr_storage peer_storage{};
54		5744x	socklen_t peer_addrlen = 0;
55
56		5744x	int accepted = Traits::accept_policy::do_accept(
57		5744x	this->fd_, peer_storage, peer_addrlen);
58
59	4/8 ✓ Branch 0 taken 3866 times. ✓ Branch 1 taken 1 time. ✓ Branch 2 taken 1876 times. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5744x	if (accepted >= 0)
60			{
61			{
62		2x	std::lock_guard lock(this->desc_state_.mutex);
63		2x	this->desc_state_.read_ready = false;
64		2x	}
65
66	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (this->svc_.scheduler().try_consume_inline_budget())
67			{
68		2x	auto* socket_svc = this->svc_.stream_service();
69	2/8 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (socket_svc)
70			{
71		2x	auto& impl =
72		2x	static_cast<SocketFinal&>(*socket_svc->construct());
73		2x	impl.set_socket(accepted);
74
75		2x	impl.desc_state_.fd = accepted;
76			{
77		2x	std::lock_guard lock(impl.desc_state_.mutex);
78		2x	impl.desc_state_.read_op = nullptr;
79		2x	impl.desc_state_.write_op = nullptr;
80		2x	impl.desc_state_.connect_op = nullptr;
81		2x	}
82		4x	socket_svc->scheduler().register_descriptor(
83		2x	accepted, &impl.desc_state_);
84
85		4x	impl.set_endpoints(
86		2x	this->local_endpoint_,
87		2x	from_sockaddr_as(
88		2x	peer_storage, peer_addrlen, Endpoint{}));
89
90		2x	*ec = {};
91	2/8 ✗ Branch 0 not taken. ✓ Branch 1 taken 1 time. ✗ Branch 2 not taken. ✓ Branch 3 taken 1 time. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	2x	if (impl_out)
92		2x	*impl_out = &impl;
93		2x	}
94			else
95			{
96		✗	::close(accepted);
97		✗	*ec = make_err(ENOENT);
98		✗	if (impl_out)
99		✗	*impl_out = nullptr;
100			}
101		2x	op.cont_op.cont.h = h;
102		2x	return dispatch_coro(ex, op.cont_op.cont);
103			}
104
105		✗	op.accepted_fd = accepted;
106		✗	op.peer_storage = peer_storage;
107		✗	op.peer_addrlen = peer_addrlen;
108		✗	op.complete(0, 0);
109		✗	op.impl_ptr = this->shared_from_this();
110		✗	this->svc_.post(&op);
111		✗	return std::noop_coroutine();
112			}
113
114	2/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 3866 times. ✗ Branch 2 not taken. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✓ Branch 5 taken 1876 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5742x	if (errno == EAGAIN \|\| errno == EWOULDBLOCK)
115			{
116	2/8 ✓ Branch 0 taken 3866 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1876 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5742x	op.impl_ptr = this->shared_from_this();
117		5742x	this->svc_.work_started();
118
119		5742x	std::lock_guard lock(this->desc_state_.mutex);
120		5742x	bool io_done = false;
121	2/8 ✓ Branch 0 taken 3866 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 1876 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	5742x	if (this->desc_state_.read_ready)
122			{
123		✗	this->desc_state_.read_ready = false;
124		✗	op.perform_io();
125		✗	io_done = (op.errn != EAGAIN && op.errn != EWOULDBLOCK);
126		✗	if (!io_done)
127		✗	op.errn = 0;
128		✗	}
129
130	4/16 ✓ Branch 0 taken 3866 times. ✗ Branch 1 not taken. ✗ Branch 2 not taken. ✓ Branch 3 taken 3866 times. ✓ Branch 4 taken 1876 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✓ Branch 7 taken 1876 times. ✗ Branch 8 not taken. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken. ✗ Branch 14 not taken. ✗ Branch 15 not taken.	5742x	if (io_done \|\| op.cancelled.load(std::memory_order_acquire))
131			{
132		✗	this->svc_.post(&op);
133		✗	this->svc_.work_finished();
134		✗	}
135			else
136			{
137		5742x	this->desc_state_.read_op = &op;
138			}
139		5742x	return std::noop_coroutine();
140		5742x	}
141
142		✗	op.complete(errno, 0);
143		✗	op.impl_ptr = this->shared_from_this();
144		✗	this->svc_.post(&op);
145		✗	return std::noop_coroutine();
146		5744x	}
147
148			} // namespace boost::corosio::detail
149
150			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_BACKEND_HPP
151