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

94.7% Lines (18/19) 100.0% List of functions (68/68) 50.0% Branches (8/16)

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

reactor_stream_ops.hpp

f(x) Functions (68)

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_STREAM_OPS_HPP
11			#define BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_OPS_HPP
12
13			#include <boost/corosio/native/detail/reactor/reactor_op.hpp>
14			#include <boost/corosio/native/detail/reactor/reactor_op_complete.hpp>
15
16			namespace boost::corosio::detail {
17
18			/* Parameterized stream op types for reactor backends.
19
20			Given a Traits type (providing write_policy, accept_policy) and
21			forward-declared Socket/Acceptor types, generates all the concrete
22			op types needed for a stream socket. The cancel() and operator()()
23			bodies reference Socket/Acceptor but are only instantiated when the
24			vtable of a derived type is emitted -- at which point those types
25			are complete.
26
27			@tparam Traits Backend traits (epoll_traits, kqueue_traits, etc.)
28			@tparam Socket The concrete stream socket type (forward-declared).
29			@tparam Acceptor The concrete stream acceptor type (forward-declared).
30			@tparam Endpoint The endpoint type (endpoint or local_endpoint).
31			*/
32
33			template<class Traits, class Socket, class Acceptor, class Endpoint>
34			struct reactor_stream_base_op : reactor_op<Socket, Acceptor>
35			{
36			void operator()() override;
37			void cancel() noexcept override;
38			};
39
40			template<class Traits, class Socket, class Acceptor, class Endpoint>
41			struct reactor_stream_connect_op final
42			: reactor_connect_op<
43			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
44			Endpoint>
45			{
46			void operator()() override;
47			};
48
49			template<class Traits, class Socket, class Acceptor, class Endpoint>
50			struct reactor_stream_read_op final
51			: reactor_read_op<
52			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>>
53			{};
54
55			template<class Traits, class Socket, class Acceptor, class Endpoint>
56			struct reactor_stream_write_op final
57			: reactor_write_op<
58			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
59			typename Traits::write_policy>
60			{};
61
62			template<class Traits, class Socket, class Acceptor, class Endpoint>
63			struct reactor_stream_accept_op final
64			: reactor_accept_op<
65			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
66			typename Traits::accept_policy>
67			{
68			void operator()() override;
69			};
70
71			template<class Traits, class Socket, class Acceptor, class Endpoint>
72			struct reactor_stream_wait_op final
73			: reactor_wait_op<
74			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>>
75			{
76			void operator()() override;
77			};
78
79			// --- Deferred implementations (instantiated when Socket/Acceptor are complete) ---
80
81			template<class Traits, class Socket, class Acceptor, class Endpoint>
82			void
83		229940x	reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>::operator()()
84			{
85		229940x	complete_io_op(*this);
86		229940x	}
87
88			template<class Traits, class Socket, class Acceptor, class Endpoint>
89			void
90		785x	reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>::cancel() noexcept
91			{
92	5/8 ✓ Branch 0 taken 653 times. ✓ Branch 1 taken 27 times. ✓ Branch 2 taken 61 times. ✓ Branch 3 taken 26 times. ✗ Branch 4 not taken. ✓ Branch 5 taken 18 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	785x	if (this->socket_impl_)
93		714x	this->socket_impl_->cancel_single_op(*this);
94	3/8 ✓ Branch 0 taken 27 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 26 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 18 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	71x	else if (this->acceptor_impl_)
95		71x	this->acceptor_impl_->cancel_single_op(*this);
96			else
97		✗	this->request_cancel();
98		785x	}
99
100			template<class Traits, class Socket, class Acceptor, class Endpoint>
101			void
102		6427x	reactor_stream_connect_op<Traits, Socket, Acceptor, Endpoint>::operator()()
103			{
104		6427x	complete_connect_op(*this);
105		6427x	}
106
107			template<class Traits, class Socket, class Acceptor, class Endpoint>
108			void
109		6458x	reactor_stream_accept_op<Traits, Socket, Acceptor, Endpoint>::operator()()
110			{
111		6458x	complete_accept_op<Socket>(*this);
112		6458x	}
113
114			template<class Traits, class Socket, class Acceptor, class Endpoint>
115			void
116		122x	reactor_stream_wait_op<Traits, Socket, Acceptor, Endpoint>::operator()()
117			{
118		122x	complete_wait_op(*this);
119		122x	}
120
121			} // namespace boost::corosio::detail
122
123			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_OPS_HPP
124