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

93.8% Lines (15/16) 96.4% List of functions (54/56) 25.0% Branches (4/16)

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

reactor_stream_ops.hpp

f(x) Functions (56)

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
35			: reactor_op<Socket, Acceptor>
36			{
37			void operator()() override;
38			void cancel() noexcept override;
39			};
40
41			template<class Traits, class Socket, class Acceptor, class Endpoint>
42			struct reactor_stream_connect_op final
43			: reactor_connect_op<
44			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
45			Endpoint>
46			{
47			void operator()() override;
48			};
49
50			template<class Traits, class Socket, class Acceptor, class Endpoint>
51			struct reactor_stream_read_op final
52			: reactor_read_op<
53			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>>
54			{
55			};
56
57			template<class Traits, class Socket, class Acceptor, class Endpoint>
58			struct reactor_stream_write_op final
59			: reactor_write_op<
60			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
61			typename Traits::write_policy>
62			{
63			};
64
65			template<class Traits, class Socket, class Acceptor, class Endpoint>
66			struct reactor_stream_accept_op final
67			: reactor_accept_op<
68			reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>,
69			typename Traits::accept_policy>
70			{
71			void operator()() override;
72			};
73
74			// --- Deferred implementations (instantiated when Socket/Acceptor are complete) ---
75
76			template<class Traits, class Socket, class Acceptor, class Endpoint>
77			void
78		394380x	reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>::operator()()
79			{
80		394380x	complete_io_op(*this);
81		394380x	}
82
83			template<class Traits, class Socket, class Acceptor, class Endpoint>
84			void
85		727x	reactor_stream_base_op<Traits, Socket, Acceptor, Endpoint>::cancel() noexcept
86			{
87	3/8 ✓ Branch 0 taken 36 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 685 times. ✓ Branch 3 taken 6 times. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	727x	if (this->socket_impl_)
88		721x	this->socket_impl_->cancel_single_op(*this);
89	1/8 ✗ Branch 0 not taken. ✗ Branch 1 not taken. ✓ Branch 2 taken 6 times. ✗ Branch 3 not taken. ✗ Branch 4 not taken. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken.	6x	else if (this->acceptor_impl_)
90		6x	this->acceptor_impl_->cancel_single_op(*this);
91			else
92		✗	this->request_cancel();
93		727x	}
94
95			template<class Traits, class Socket, class Acceptor, class Endpoint>
96			void
97		7252x	reactor_stream_connect_op<Traits, Socket, Acceptor, Endpoint>::operator()()
98			{
99		7252x	complete_connect_op(*this);
100		7252x	}
101
102			template<class Traits, class Socket, class Acceptor, class Endpoint>
103			void
104		7247x	reactor_stream_accept_op<Traits, Socket, Acceptor, Endpoint>::operator()()
105			{
106		7247x	complete_accept_op<Socket>(*this);
107		7247x	}
108
109			} // namespace boost::corosio::detail
110
111			#endif // BOOST_COROSIO_NATIVE_DETAIL_REACTOR_REACTOR_STREAM_OPS_HPP
112