123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115 |
- //
- // impl/defer.hpp
- // ~~~~~~~~~~~~~~
- //
- // Copyright (c) 2003-2019 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_IMPL_DEFER_HPP
- #define BOOST_ASIO_IMPL_DEFER_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/associated_allocator.hpp>
- #include <boost/asio/associated_executor.hpp>
- #include <boost/asio/detail/work_dispatcher.hpp>
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- namespace detail {
- class initiate_defer
- {
- public:
- template <typename CompletionHandler>
- void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler) const
- {
- typedef typename decay<CompletionHandler>::type DecayedHandler;
- typename associated_executor<DecayedHandler>::type ex(
- (get_associated_executor)(handler));
- typename associated_allocator<DecayedHandler>::type alloc(
- (get_associated_allocator)(handler));
- ex.defer(BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler), alloc);
- }
- };
- template <typename Executor>
- class initiate_defer_with_executor
- {
- public:
- typedef Executor executor_type;
- explicit initiate_defer_with_executor(const Executor& ex)
- : ex_(ex)
- {
- }
- executor_type get_executor() const BOOST_ASIO_NOEXCEPT
- {
- return ex_;
- }
- template <typename CompletionHandler>
- void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler) const
- {
- typedef typename decay<CompletionHandler>::type DecayedHandler;
- typename associated_allocator<DecayedHandler>::type alloc(
- (get_associated_allocator)(handler));
- ex_.defer(detail::work_dispatcher<DecayedHandler>(
- BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler)), alloc);
- }
- private:
- Executor ex_;
- };
- } // namespace detail
- template <BOOST_ASIO_COMPLETION_TOKEN_FOR(void()) CompletionToken>
- BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) defer(
- BOOST_ASIO_MOVE_ARG(CompletionToken) token)
- {
- return async_initiate<CompletionToken, void()>(
- detail::initiate_defer(), token);
- }
- template <typename Executor,
- BOOST_ASIO_COMPLETION_TOKEN_FOR(void()) CompletionToken>
- BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) defer(
- const Executor& ex, BOOST_ASIO_MOVE_ARG(CompletionToken) token,
- typename enable_if<is_executor<Executor>::value>::type*)
- {
- return async_initiate<CompletionToken, void()>(
- detail::initiate_defer_with_executor<Executor>(ex), token);
- }
- template <typename ExecutionContext,
- BOOST_ASIO_COMPLETION_TOKEN_FOR(void()) CompletionToken>
- inline BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) defer(
- ExecutionContext& ctx, BOOST_ASIO_MOVE_ARG(CompletionToken) token,
- typename enable_if<is_convertible<
- ExecutionContext&, execution_context&>::value>::type*)
- {
- return (defer)(ctx.get_executor(),
- BOOST_ASIO_MOVE_CAST(CompletionToken)(token));
- }
- } // namespace asio
- } // namespace boost
- #include <boost/asio/detail/pop_options.hpp>
- #endif // BOOST_ASIO_IMPL_DEFER_HPP
|