| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142 |
- //
- // experimental/cancellation_condition.hpp
- // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
- //
- // Copyright (c) 2003-2025 Christopher M. Kohlhoff (chris at kohlhoff dot com)
- //
- // Distributed under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- //
- #ifndef BOOST_ASIO_EXPERIMENTAL_CANCELLATION_CONDITION_HPP
- #define BOOST_ASIO_EXPERIMENTAL_CANCELLATION_CONDITION_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
- #include <boost/asio/detail/config.hpp>
- #include <boost/asio/cancellation_type.hpp>
- #include <boost/asio/disposition.hpp>
- #include <boost/asio/detail/type_traits.hpp>
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- namespace experimental {
- /// Wait for all operations to complete.
- class wait_for_all
- {
- public:
- template <typename... Args>
- constexpr cancellation_type_t operator()(Args&&...) const noexcept
- {
- return cancellation_type::none;
- }
- };
- /// Wait until an operation completes, then cancel the others.
- class wait_for_one
- {
- public:
- constexpr explicit wait_for_one(
- cancellation_type_t cancel_type = cancellation_type::all)
- : cancel_type_(cancel_type)
- {
- }
- template <typename... Args>
- constexpr cancellation_type_t operator()(Args&&...) const noexcept
- {
- return cancel_type_;
- }
- private:
- cancellation_type_t cancel_type_;
- };
- /// Wait until an operation completes without an error, then cancel the others.
- /**
- * If no operation completes without an error, waits for completion of all
- * operations.
- */
- class wait_for_one_success
- {
- public:
- constexpr explicit wait_for_one_success(
- cancellation_type_t cancel_type = cancellation_type::all)
- : cancel_type_(cancel_type)
- {
- }
- constexpr cancellation_type_t
- operator()() const noexcept
- {
- return cancel_type_;
- }
- template <typename E, typename... Args>
- constexpr constraint_t<!is_disposition<E>::value, cancellation_type_t>
- operator()(const E&, Args&&...) const noexcept
- {
- return cancel_type_;
- }
- template <typename E, typename... Args>
- constexpr constraint_t<is_disposition<E>::value, cancellation_type_t>
- operator()(const E& e, Args&&...) const noexcept
- {
- return e != no_error ? cancellation_type::none : cancel_type_;
- }
- private:
- cancellation_type_t cancel_type_;
- };
- /// Wait until an operation completes with an error, then cancel the others.
- /**
- * If no operation completes with an error, waits for completion of all
- * operations.
- */
- class wait_for_one_error
- {
- public:
- constexpr explicit wait_for_one_error(
- cancellation_type_t cancel_type = cancellation_type::all)
- : cancel_type_(cancel_type)
- {
- }
- constexpr cancellation_type_t operator()() const noexcept
- {
- return cancellation_type::none;
- }
- template <typename E, typename... Args>
- constexpr constraint_t<!is_disposition<E>::value, cancellation_type_t>
- operator()(const E&, Args&&...) const noexcept
- {
- return cancellation_type::none;
- }
- template <typename E, typename... Args>
- constexpr constraint_t<is_disposition<E>::value, cancellation_type_t>
- operator()(const E& e, Args&&...) const noexcept
- {
- return e != no_error ? cancel_type_ : cancellation_type::none;
- }
- private:
- cancellation_type_t cancel_type_;
- };
- } // namespace experimental
- } // namespace asio
- } // namespace boost
- #include <boost/asio/detail/pop_options.hpp>
- #endif // BOOST_ASIO_EXPERIMENTAL_CANCELLATION_CONDITION_HPP
|