include/boost/corosio/detail/op_base.hpp

100.0% Lines (38/38) 99.7% List of functions (651/653) 55.2% Branches (74/134)

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

op_base.hpp

f(x) Functions (653)

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_DETAIL_OP_BASE_HPP
11			#define BOOST_COROSIO_DETAIL_OP_BASE_HPP
12
13			#include <boost/capy/error.hpp>
14			#include <boost/capy/io_result.hpp>
15			#include <boost/capy/ex/executor_ref.hpp>
16			#include <boost/capy/ex/io_env.hpp>
17
18			#include <coroutine>
19			#include <cstddef>
20			#include <stop_token>
21			#include <system_error>
22
23			namespace boost::corosio::detail {
24
25			/* CRTP base for awaitables that return io_result<std::size_t>.
26
27			Derived classes must provide:
28
29			std::coroutine_handle<> dispatch(
30			std::coroutine_handle<> h,
31			capy::executor_ref ex) const;
32
33			which forwards to the backend implementation method, passing
34			token_, &ec_, and &bytes_ as the cancellation/output parameters.
35			*/
36			template<class Derived>
37			class bytes_op_base
38			{
39			friend Derived;
40		3995580x	bytes_op_base() = default;
41
42			public:
43			std::stop_token token_;
44			mutable std::error_code ec_;
45		1997790x	mutable std::size_t bytes_ = 0;
46
47		1997790x	bool await_ready() const noexcept
48			{
49			// A pre-set ec_ means the initiator failed before dispatch
50			// (e.g. a closed object); complete immediately with that error.
51		1997790x	return static_cast<bool>(ec_);
52			}
53
54		1997750x	[[nodiscard]] capy::io_result<std::size_t> await_resume() const noexcept
55			{
56		1997750x	return {ec_, bytes_};
57			}
58
59		1997754x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
60			-> std::coroutine_handle<>
61			{
62		1997754x	token_ = env->stop_token;
63			// A pre-stopped token short-circuits before dispatch so no I/O
64			// is performed. A stop landing after dispatch is decoded by the
65			// backend, and a completed transfer is reported verbatim: the
66			// stream contracts forbid discarding the byte count.
67	34/68 ✓ Branch 0 taken 24 times. ✓ Branch 1 taken 1852230 times. ✓ Branch 2 taken 11 times. ✓ Branch 3 taken 144683 times. ✓ Branch 4 taken 10 times. ✓ Branch 5 taken 461 times. ✓ Branch 6 taken 5 times. ✓ Branch 7 taken 116 times. ✓ Branch 8 taken 5 times. ✓ Branch 9 taken 68 times. ✓ Branch 10 taken 4 times. ✓ Branch 11 taken 44 times. ✓ Branch 12 taken 4 times. ✓ Branch 13 taken 31 times. ✓ Branch 14 taken 4 times. ✓ Branch 15 taken 22 times. ✓ Branch 16 taken 1 time. ✓ Branch 17 taken 1 time. ✓ Branch 18 taken 1 time. ✓ Branch 19 taken 1 time. ✗ Branch 20 not taken. ✗ Branch 21 not taken. ✗ Branch 22 not taken. ✗ Branch 23 not taken. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✓ Branch 34 taken 2 times. ✓ Branch 35 taken 7 times. ✗ Branch 36 not taken. ✗ Branch 37 not taken. ✓ Branch 38 taken 1 time. ✓ Branch 39 taken 2 times. ✓ Branch 40 taken 1 time. ✓ Branch 41 taken 1 time. ✓ Branch 42 taken 1 time. ✓ Branch 43 taken 2 times. ✓ Branch 44 taken 1 time. ✓ Branch 45 taken 4 times. ✓ Branch 46 taken 1 time. ✓ Branch 47 taken 2 times. ✓ Branch 48 taken 1 time. ✓ Branch 49 taken 2 times. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken. ✗ Branch 60 not taken. ✗ Branch 61 not taken. ✗ Branch 62 not taken. ✗ Branch 63 not taken. ✗ Branch 64 not taken. ✗ Branch 65 not taken. ✗ Branch 66 not taken. ✗ Branch 67 not taken.	1997754x	if (token_.stop_requested())
68			{
69		77x	ec_ = capy::error::canceled;
70		77x	return h;
71			}
72		1997677x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
73		1997754x	}
74			};
75
76			/* CRTP base for awaitables that return io_result<Value> for a
77			moved-out result object (e.g. the resolver's result lists).
78
79			Derived classes must provide:
80
81			std::coroutine_handle<> dispatch(
82			std::coroutine_handle<> h,
83			capy::executor_ref ex) const;
84
85			which forwards to the backend implementation method, passing
86			token_, &ec_, and &value_ as the cancellation/output parameters.
87			*/
88			template<class Derived, class Value>
89			class value_op_base
90			{
91			friend Derived;
92		2392x	value_op_base() = default;
93
94			public:
95			std::stop_token token_;
96			mutable std::error_code ec_;
97		1196x	mutable Value value_{};
98
99		1196x	bool await_ready() const noexcept
100			{
101			// A pre-set ec_ means the initiator failed before dispatch;
102			// complete immediately with that error.
103		1196x	return static_cast<bool>(ec_);
104			}
105
106		1182x	[[nodiscard]] capy::io_result<Value> await_resume() const noexcept
107			{
108		1182x	return {ec_, std::move(value_)};
109			}
110
111		1196x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
112			-> std::coroutine_handle<>
113			{
114		1196x	token_ = env->stop_token;
115			// A pre-stopped token short-circuits before dispatch; a stop
116			// landing after dispatch leaves the completed result intact.
117	6/6 ✓ Branch 0 taken 40 times. ✓ Branch 1 taken 1129 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 8 times. ✓ Branch 4 taken 1 time. ✓ Branch 5 taken 16 times.	1196x	if (token_.stop_requested())
118			{
119		43x	ec_ = capy::error::canceled;
120		43x	return h;
121			}
122		1153x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
123		1196x	}
124			};
125
126			/* CRTP base for awaitables that return io_result<>.
127
128			Derived classes must provide:
129
130			std::coroutine_handle<> dispatch(
131			std::coroutine_handle<> h,
132			capy::executor_ref ex) const;
133
134			which forwards to the backend implementation method, passing
135			token_ and &ec_ as the cancellation/output parameters.
136			*/
137			template<class Derived>
138			class void_op_base
139			{
140			friend Derived;
141		16747x	void_op_base() = default;
142
143			public:
144			std::stop_token token_;
145			mutable std::error_code ec_;
146
147		16747x	bool await_ready() const noexcept
148			{
149			// A pre-set ec_ means the initiator failed before dispatch
150			// (e.g. auto-open); complete immediately with that error.
151		16747x	return static_cast<bool>(ec_);
152			}
153
154		8477x	[[nodiscard]] capy::io_result<> await_resume() const noexcept
155			{
156		8477x	return {ec_};
157			}
158
159		16725x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
160			-> std::coroutine_handle<>
161			{
162		16725x	token_ = env->stop_token;
163			// A pre-stopped token short-circuits before dispatch; a stop
164			// landing after dispatch leaves the completed result intact.
165	34/60 ✓ Branch 0 taken 10 times. ✓ Branch 1 taken 8250 times. ✓ Branch 2 taken 9 times. ✓ Branch 3 taken 8163 times. ✓ Branch 4 taken 10 times. ✓ Branch 5 taken 104 times. ✓ Branch 6 taken 7 times. ✓ Branch 7 taken 88 times. ✓ Branch 8 taken 3 times. ✓ Branch 9 taken 34 times. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 6 times. ✓ Branch 12 taken 2 times. ✓ Branch 13 taken 3 times. ✓ Branch 14 taken 1 time. ✓ Branch 15 taken 2 times. ✓ Branch 16 taken 1 time. ✓ Branch 17 taken 5 times. ✓ Branch 18 taken 1 time. ✓ Branch 19 taken 1 time. ✓ Branch 20 taken 1 time. ✓ Branch 21 taken 2 times. ✓ Branch 22 taken 1 time. ✓ Branch 23 taken 2 times. ✗ Branch 24 not taken. ✗ Branch 25 not taken. ✗ Branch 26 not taken. ✗ Branch 27 not taken. ✗ Branch 28 not taken. ✗ Branch 29 not taken. ✗ Branch 30 not taken. ✗ Branch 31 not taken. ✗ Branch 32 not taken. ✗ Branch 33 not taken. ✓ Branch 34 taken 1 time. ✓ Branch 35 taken 4 times. ✓ Branch 36 taken 1 time. ✓ Branch 37 taken 1 time. ✓ Branch 38 taken 1 time. ✓ Branch 39 taken 2 times. ✓ Branch 40 taken 1 time. ✓ Branch 41 taken 4 times. ✓ Branch 42 taken 1 time. ✓ Branch 43 taken 1 time. ✗ Branch 44 not taken. ✗ Branch 45 not taken. ✗ Branch 46 not taken. ✗ Branch 47 not taken. ✗ Branch 48 not taken. ✗ Branch 49 not taken. ✗ Branch 50 not taken. ✗ Branch 51 not taken. ✗ Branch 52 not taken. ✗ Branch 53 not taken. ✗ Branch 54 not taken. ✗ Branch 55 not taken. ✗ Branch 56 not taken. ✗ Branch 57 not taken. ✗ Branch 58 not taken. ✗ Branch 59 not taken.	16725x	if (token_.stop_requested())
166			{
167		53x	ec_ = capy::error::canceled;
168		53x	return h;
169			}
170		16672x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
171		16725x	}
172			};
173
174			} // namespace boost::corosio::detail
175
176			#endif // BOOST_COROSIO_DETAIL_OP_BASE_HPP
177