// // impl/co_spawn.hpp // ~~~~~~~~~~~~~~~~~ // // Copyright (c) 2003-2024 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 ASIO_IMPL_CO_SPAWN_HPP #define ASIO_IMPL_CO_SPAWN_HPP #if defined(_MSC_VER) && (_MSC_VER >= 1200) # pragma once #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) #include "asio/detail/config.hpp" #include "asio/associated_cancellation_slot.hpp" #include "asio/awaitable.hpp" #include "asio/detail/memory.hpp" #include "asio/detail/recycling_allocator.hpp" #include "asio/dispatch.hpp" #include "asio/execution/outstanding_work.hpp" #include "asio/post.hpp" #include "asio/prefer.hpp" #include "asio/use_awaitable.hpp" #include "asio/detail/push_options.hpp" namespace asio { namespace detail { template class co_spawn_work_guard { public: typedef decay_t< prefer_result_t > executor_type; co_spawn_work_guard(const Executor& ex) : executor_(asio::prefer(ex, execution::outstanding_work.tracked)) { } executor_type get_executor() const noexcept { return executor_; } private: executor_type executor_; }; #if !defined(ASIO_NO_TS_EXECUTORS) template struct co_spawn_work_guard::value >> : executor_work_guard { co_spawn_work_guard(const Executor& ex) : executor_work_guard(ex) { } }; #endif // !defined(ASIO_NO_TS_EXECUTORS) template struct co_spawn_state { template co_spawn_state(H&& h, const Executor& ex, F&& f) : handler(std::forward(h)), spawn_work(ex), handler_work(asio::get_associated_executor(handler, ex)), function(std::forward(f)) { } Handler handler; co_spawn_work_guard spawn_work; co_spawn_work_guard> handler_work; Function function; }; template struct co_spawn_state::asio_associated_executor_is_unspecialised, void >::value >> { template co_spawn_state(H&& h, const Executor& ex, F&& f) : handler(std::forward(h)), handler_work(ex), function(std::forward(f)) { } Handler handler; co_spawn_work_guard handler_work; Function function; }; struct co_spawn_dispatch { template auto operator()(CompletionToken&& token) const -> decltype(asio::dispatch(std::forward(token))) { return asio::dispatch(std::forward(token)); } }; struct co_spawn_post { template auto operator()(CompletionToken&& token) const -> decltype(asio::post(std::forward(token))) { return asio::post(std::forward(token)); } }; template awaitable co_spawn_entry_point( awaitable*, co_spawn_state s) { (void) co_await co_spawn_dispatch{}; (co_await awaitable_thread_has_context_switched{}) = false; std::exception_ptr e = nullptr; bool done = false; try { T t = co_await s.function(); done = true; bool switched = (co_await awaitable_thread_has_context_switched{}); if (!switched) { co_await this_coro::throw_if_cancelled(false); (void) co_await co_spawn_post(); } (dispatch)(s.handler_work.get_executor(), [handler = std::move(s.handler), t = std::move(t)]() mutable { std::move(handler)(std::exception_ptr(), std::move(t)); }); co_return; } catch (...) { if (done) throw; e = std::current_exception(); } bool switched = (co_await awaitable_thread_has_context_switched{}); if (!switched) { co_await this_coro::throw_if_cancelled(false); (void) co_await co_spawn_post(); } (dispatch)(s.handler_work.get_executor(), [handler = std::move(s.handler), e]() mutable { std::move(handler)(e, T()); }); } template awaitable co_spawn_entry_point( awaitable*, co_spawn_state s) { (void) co_await co_spawn_dispatch{}; (co_await awaitable_thread_has_context_switched{}) = false; std::exception_ptr e = nullptr; try { co_await s.function(); } catch (...) { e = std::current_exception(); } bool switched = (co_await awaitable_thread_has_context_switched{}); if (!switched) { co_await this_coro::throw_if_cancelled(false); (void) co_await co_spawn_post(); } (dispatch)(s.handler_work.get_executor(), [handler = std::move(s.handler), e]() mutable { std::move(handler)(e); }); } template class awaitable_as_function { public: explicit awaitable_as_function(awaitable&& a) : awaitable_(std::move(a)) { } awaitable operator()() { return std::move(awaitable_); } private: awaitable awaitable_; }; template class co_spawn_cancellation_handler { public: co_spawn_cancellation_handler(const Handler&, const Executor& ex) : signal_(detail::allocate_shared( detail::recycling_allocator())), ex_(ex) { } cancellation_slot slot() { return signal_->slot(); } void operator()(cancellation_type_t type) { shared_ptr sig = signal_; asio::dispatch(ex_, [sig, type]{ sig->emit(type); }); } private: shared_ptr signal_; Executor ex_; }; template class co_spawn_cancellation_handler::asio_associated_executor_is_unspecialised, void >::value >> { public: co_spawn_cancellation_handler(const Handler&, const Executor&) { } cancellation_slot slot() { return signal_.slot(); } void operator()(cancellation_type_t type) { signal_.emit(type); } private: cancellation_signal signal_; }; template class initiate_co_spawn { public: typedef Executor executor_type; template explicit initiate_co_spawn(const OtherExecutor& ex) : ex_(ex) { } executor_type get_executor() const noexcept { return ex_; } template void operator()(Handler&& handler, F&& f) const { typedef result_of_t awaitable_type; typedef decay_t handler_type; typedef decay_t function_type; typedef co_spawn_cancellation_handler< handler_type, Executor> cancel_handler_type; auto slot = asio::get_associated_cancellation_slot(handler); cancel_handler_type* cancel_handler = slot.is_connected() ? &slot.template emplace(handler, ex_) : nullptr; cancellation_slot proxy_slot( cancel_handler ? cancel_handler->slot() : cancellation_slot()); cancellation_state cancel_state(proxy_slot); auto a = (co_spawn_entry_point)(static_cast(nullptr), co_spawn_state( std::forward(handler), ex_, std::forward(f))); awaitable_handler(std::move(a), ex_, proxy_slot, cancel_state).launch(); } private: Executor ex_; }; } // namespace detail template inline ASIO_INITFN_AUTO_RESULT_TYPE( CompletionToken, void(std::exception_ptr, T)) co_spawn(const Executor& ex, awaitable a, CompletionToken&& token, constraint_t< (is_executor::value || execution::is_executor::value) && is_convertible::value >) { return async_initiate( detail::initiate_co_spawn(AwaitableExecutor(ex)), token, detail::awaitable_as_function(std::move(a))); } template inline ASIO_INITFN_AUTO_RESULT_TYPE( CompletionToken, void(std::exception_ptr)) co_spawn(const Executor& ex, awaitable a, CompletionToken&& token, constraint_t< (is_executor::value || execution::is_executor::value) && is_convertible::value >) { return async_initiate( detail::initiate_co_spawn(AwaitableExecutor(ex)), token, detail::awaitable_as_function< void, AwaitableExecutor>(std::move(a))); } template inline ASIO_INITFN_AUTO_RESULT_TYPE( CompletionToken, void(std::exception_ptr, T)) co_spawn(ExecutionContext& ctx, awaitable a, CompletionToken&& token, constraint_t< is_convertible::value && is_convertible::value >) { return (co_spawn)(ctx.get_executor(), std::move(a), std::forward(token)); } template inline ASIO_INITFN_AUTO_RESULT_TYPE( CompletionToken, void(std::exception_ptr)) co_spawn(ExecutionContext& ctx, awaitable a, CompletionToken&& token, constraint_t< is_convertible::value && is_convertible::value >) { return (co_spawn)(ctx.get_executor(), std::move(a), std::forward(token)); } template >::type) CompletionToken> inline ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, typename detail::awaitable_signature>::type) co_spawn(const Executor& ex, F&& f, CompletionToken&& token, constraint_t< is_executor::value || execution::is_executor::value >) { return async_initiate>::type>( detail::initiate_co_spawn< typename result_of_t::executor_type>(ex), token, std::forward(f)); } template >::type) CompletionToken> inline ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, typename detail::awaitable_signature>::type) co_spawn(ExecutionContext& ctx, F&& f, CompletionToken&& token, constraint_t< is_convertible::value >) { return (co_spawn)(ctx.get_executor(), std::forward(f), std::forward(token)); } } // namespace asio #include "asio/detail/pop_options.hpp" #endif // ASIO_IMPL_CO_SPAWN_HPP