include/boost/corosio/detail/op_base.hpp

100.0% Lines (25/25) 100.0% List of functions (148/148) 47.1% Branches (48/102)

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

op_base.hpp

f(x) Functions (148)

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		3267222x	bytes_op_base() = default;
40
41			public:
42			std::stop_token token_;
43			mutable std::error_code ec_;
44		1633611x	mutable std::size_t bytes_ = 0;
45
46		1633611x	bool await_ready() const noexcept
47			{
48		1633611x	return token_.stop_requested();
49			}
50
51		1633603x	capy::io_result<std::size_t> await_resume() const noexcept
52			{
53	16/20 ✓ Branch 0 taken 501 times. ✓ Branch 1 taken 769957 times. ✓ Branch 2 taken 135 times. ✓ Branch 3 taken 862831 times. ✓ Branch 4 taken 6 times. ✓ Branch 5 taken 38 times. ✓ Branch 6 taken 2 times. ✓ Branch 7 taken 47 times. ✓ Branch 8 taken 4 times. ✓ Branch 9 taken 22 times. ✓ Branch 10 taken 2 times. ✓ Branch 11 taken 24 times. ✓ Branch 12 taken 4 times. ✓ Branch 13 taken 12 times. ✓ Branch 14 taken 2 times. ✓ Branch 15 taken 16 times. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	1633603x	if (token_.stop_requested())
54	8/20 ✓ Branch 0 taken 501 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 135 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 6 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 2 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 4 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 2 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 4 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 2 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	656x	return {make_error_code(std::errc::operation_canceled), 0};
55	8/20 ✓ Branch 0 taken 769957 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 862831 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 38 times. ✗ Branch 5 not taken. ✓ Branch 6 taken 47 times. ✗ Branch 7 not taken. ✓ Branch 8 taken 22 times. ✗ Branch 9 not taken. ✓ Branch 10 taken 24 times. ✗ Branch 11 not taken. ✓ Branch 12 taken 12 times. ✗ Branch 13 not taken. ✓ Branch 14 taken 16 times. ✗ Branch 15 not taken. ✗ Branch 16 not taken. ✗ Branch 17 not taken. ✗ Branch 18 not taken. ✗ Branch 19 not taken.	1632947x	return {ec_, bytes_};
56		1633603x	}
57
58		1633611x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
59			-> std::coroutine_handle<>
60			{
61		1633611x	token_ = env->stop_token;
62		1633611x	return static_cast<Derived const*>(this)->dispatch(
63		1633611x	h, env->executor);
64			}
65			};
66
67			/* CRTP base for awaitables that return io_result<>.
68
69			Derived classes must provide:
70
71			std::coroutine_handle<> dispatch(
72			std::coroutine_handle<> h,
73			capy::executor_ref ex) const;
74
75			which forwards to the backend implementation method, passing
76			token_ and &ec_ as the cancellation/output parameters.
77			*/
78			template<class Derived>
79			class void_op_base
80			{
81			friend Derived;
82		6700x	void_op_base() = default;
83
84			public:
85			std::stop_token token_;
86			mutable std::error_code ec_;
87
88		6700x	bool await_ready() const noexcept
89			{
90		6700x	return token_.stop_requested();
91			}
92
93		6700x	capy::io_result<> await_resume() const noexcept
94			{
95	8/14 ✓ Branch 0 taken 6 times. ✓ Branch 1 taken 6634 times. ✓ Branch 2 taken 12 times. ✓ Branch 3 taken 22 times. ✓ Branch 4 taken 8 times. ✓ Branch 5 taken 10 times. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✓ Branch 9 taken 6 times. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken.	6700x	if (token_.stop_requested())
96	4/14 ✓ Branch 0 taken 6 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 12 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 8 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 2 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken.	28x	return {make_error_code(std::errc::operation_canceled)};
97	4/14 ✓ Branch 0 taken 6634 times. ✗ Branch 1 not taken. ✓ Branch 2 taken 22 times. ✗ Branch 3 not taken. ✓ Branch 4 taken 10 times. ✗ Branch 5 not taken. ✗ Branch 6 not taken. ✗ Branch 7 not taken. ✓ Branch 8 taken 6 times. ✗ Branch 9 not taken. ✗ Branch 10 not taken. ✗ Branch 11 not taken. ✗ Branch 12 not taken. ✗ Branch 13 not taken.	6672x	return {ec_};
98		6700x	}
99
100		6700x	auto await_suspend(std::coroutine_handle<> h, capy::io_env const* env)
101			-> std::coroutine_handle<>
102			{
103		6700x	token_ = env->stop_token;
104		6700x	return static_cast<Derived const*>(this)->dispatch(
105		6700x	h, env->executor);
106			}
107			};
108
109			} // namespace boost::corosio::detail
110
111			#endif // BOOST_COROSIO_DETAIL_OP_BASE_HPP
112