include/boost/corosio/detail/op_base.hpp

100.0% Lines (35/35) 99.0% List of functions (202/204) 63.1% Branches (53/84)

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

op_base.hpp

f(x) Functions (204)

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/io_result.hpp>
14			#include <boost/capy/ex/executor_ref.hpp>
15			#include <boost/capy/ex/io_env.hpp>
16
17			#include <coroutine>
18			#include <cstddef>
19			#include <stop_token>
20			#include <system_error>
21
22			namespace boost::corosio::detail {
23
24			/* CRTP base for awaitables that return io_result<std::size_t>.
25
26			Derived classes must provide:
27
28			std::coroutine_handle<> dispatch(
29			std::coroutine_handle<> h,
30			capy::executor_ref ex) const;
31
32			which forwards to the backend implementation method, passing
33			token_, &ec_, and &bytes_ as the cancellation/output parameters.
34			*/
35			template<class Derived>
36			class bytes_op_base
37			{
38			friend Derived;
39		1941190x	bytes_op_base() = default;
40
41			public:
42			std::stop_token token_;
43			mutable std::error_code ec_;
44		970595x	mutable std::size_t bytes_ = 0;
45
46		970595x	bool await_ready() const noexcept
47			{
48			// A pre-set ec_ means the initiator failed before dispatch
49			// (e.g. a closed object); complete immediately with that error.
50	16/20 ✓ Branch 0 taken 2 times. ✓ Branch 1 taken 467362 times. ✓ Branch 2 taken 2 times. ✓ Branch 3 taken 502741 times. ✓ Branch 4 taken 2 times. ✓ Branch 5 taken 104 times. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 118 times. ✓ Branch 8 taken 2 times. ✓ Branch 9 taken 46 times. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 37 times. ✓ Branch 12 taken 2 times. ✓ Branch 13 taken 29 times. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 21 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	970595x	return static_cast<bool>(ec_) \|\| token_.stop_requested();
51			}
52
53		970562x	[[nodiscard]] capy::io_result<std::size_t> await_resume() const noexcept
54			{
55	16/20 ✓ Branch 0 taken 687 times. ✓ Branch 1 taken 466692 times. ✓ Branch 2 taken 9 times. ✓ Branch 3 taken 502821 times. ✓ Branch 4 taken 7 times. ✓ Branch 5 taken 93 times. ✓ Branch 6 taken 3 times. ✓ Branch 7 taken 114 times. ✓ Branch 8 taken 4 times. ✓ Branch 9 taken 42 times. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 37 times. ✓ Branch 12 taken 4 times. ✓ Branch 13 taken 24 times. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 21 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	970562x	if (token_.stop_requested())
56		718x	return {make_error_code(std::errc::operation_canceled), 0};
57		969844x	return {ec_, bytes_};
58		970562x	}
59
60		970579x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
61			-> std::coroutine_handle<>
62			{
63		970579x	token_ = env->stop_token;
64		970579x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
65			}
66			};
67
68			/* CRTP base for awaitables that return io_result<Value> for a
69			moved-out result object (e.g. the resolver's result lists).
70
71			Derived classes must provide:
72
73			std::coroutine_handle<> dispatch(
74			std::coroutine_handle<> h,
75			capy::executor_ref ex) const;
76
77			which forwards to the backend implementation method, passing
78			token_, &ec_, and &value_ as the cancellation/output parameters.
79			*/
80			template<class Derived, class Value>
81			class value_op_base
82			{
83			friend Derived;
84		88x	value_op_base() = default;
85
86			public:
87			std::stop_token token_;
88			mutable std::error_code ec_;
89		44x	mutable Value value_{};
90
91		44x	bool await_ready() const noexcept
92			{
93			// A pre-set ec_ means the initiator failed before dispatch;
94			// complete immediately with that error.
95	2/4 ✗ Branch 0 not taken. ✓ Branch 1 taken 25 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 15 times.	44x	return static_cast<bool>(ec_) \|\| token_.stop_requested();
96			}
97
98		42x	[[nodiscard]] capy::io_result<Value> await_resume() const noexcept
99			{
100	4/4 ✓ Branch 0 taken 23 times. ✓ Branch 1 taken 3 times. ✓ Branch 2 taken 13 times. ✓ Branch 3 taken 3 times.	42x	if (token_.stop_requested())
101	2/4 ✓ Branch 0 taken 1 time. ✗ Branch 1 not taken. ✓ Branch 2 taken 1 time. ✗ Branch 3 not taken.	2x	return {make_error_code(std::errc::operation_canceled), {}};
102		40x	return {ec_, std::move(value_)};
103		42x	}
104
105		44x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
106			-> std::coroutine_handle<>
107			{
108		44x	token_ = env->stop_token;
109		44x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
110			}
111			};
112
113			/* CRTP base for awaitables that return io_result<>.
114
115			Derived classes must provide:
116
117			std::coroutine_handle<> dispatch(
118			std::coroutine_handle<> h,
119			capy::executor_ref ex) const;
120
121			which forwards to the backend implementation method, passing
122			token_ and &ec_ as the cancellation/output parameters.
123			*/
124			template<class Derived>
125			class void_op_base
126			{
127			friend Derived;
128		6602x	void_op_base() = default;
129
130			public:
131			std::stop_token token_;
132			mutable std::error_code ec_;
133
134		6602x	bool await_ready() const noexcept
135			{
136			// A pre-set ec_ means the initiator failed before dispatch
137			// (e.g. auto-open); complete immediately with that error.
138	5/16 ✗ Branch 0 not taken. ✓ Branch 1 taken 6334 times. ✗ Branch 2 not taken. ✓ Branch 3 taken 85 times. ✓ Branch 4 taken 4 times. ✓ Branch 5 taken 53 times. ✗ Branch 6 not taken. ✓ Branch 7 taken 28 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.	6602x	return static_cast<bool>(ec_) \|\| token_.stop_requested();
139			}
140
141		6588x	[[nodiscard]] capy::io_result<> await_resume() const noexcept
142			{
143	8/16 ✓ Branch 0 taken 7 times. ✓ Branch 1 taken 6421 times. ✓ Branch 2 taken 11 times. ✓ Branch 3 taken 68 times. ✓ Branch 4 taken 8 times. ✓ Branch 5 taken 45 times. ✓ Branch 6 taken 6 times. ✓ Branch 7 taken 22 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.	6588x	if (token_.stop_requested())
144		32x	return {make_error_code(std::errc::operation_canceled)};
145		6556x	return {ec_};
146		6588x	}
147
148		6598x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
149			-> std::coroutine_handle<>
150			{
151		6598x	token_ = env->stop_token;
152		6598x	return static_cast<Derived const*>(this)->dispatch(h, env->executor);
153			}
154			};
155
156			} // namespace boost::corosio::detail
157
158			#endif // BOOST_COROSIO_DETAIL_OP_BASE_HPP
159