/usr/include/boost/asio/impl
Edit: /usr/include/boost/asio/impl/dispatch.hpp (7567B)
//
// impl/dispatch.hpp
// ~~~~~~~~~~~~~~~~~
//
// Copyright (c) 2003-2020 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_DISPATCH_HPP
#define BOOST_ASIO_IMPL_DISPATCH_HPP
#if defined(_MSC_VER) && (_MSC_VER >= 1200)
# pragma once
#endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
#include
#include
#include
#include
#include
#include
#include
#include
namespace boost {
namespace asio {
namespace detail {
class initiate_dispatch
{
public:
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
execution::is_executor<
typename associated_executor<
typename decay::type
>::type
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typename associated_executor::type ex(
(get_associated_executor)(handler));
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
execution::execute(
boost::asio::prefer(ex,
execution::blocking.possibly,
execution::allocator(alloc)),
BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler));
}
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
!execution::is_executor<
typename associated_executor<
typename decay::type
>::type
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typename associated_executor::type ex(
(get_associated_executor)(handler));
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
ex.dispatch(BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler), alloc);
}
};
template
class initiate_dispatch_with_executor
{
public:
typedef Executor executor_type;
explicit initiate_dispatch_with_executor(const Executor& ex)
: ex_(ex)
{
}
executor_type get_executor() const BOOST_ASIO_NOEXCEPT
{
return ex_;
}
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
execution::is_executor<
typename conditional::type
>::value
&&
!detail::is_work_dispatcher_required<
typename decay::type,
Executor
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
execution::execute(
boost::asio::prefer(ex_,
execution::blocking.possibly,
execution::allocator(alloc)),
BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler));
}
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
execution::is_executor<
typename conditional::type
>::value
&&
detail::is_work_dispatcher_required<
typename decay::type,
Executor
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typedef typename associated_executor<
handler_t, Executor>::type handler_ex_t;
handler_ex_t handler_ex((get_associated_executor)(handler, ex_));
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
execution::execute(
boost::asio::prefer(ex_,
execution::blocking.possibly,
execution::allocator(alloc)),
detail::work_dispatcher(
BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler), handler_ex));
}
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
!execution::is_executor<
typename conditional::type
>::value
&&
!detail::is_work_dispatcher_required<
typename decay::type,
Executor
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
ex_.dispatch(BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler), alloc);
}
template
void operator()(BOOST_ASIO_MOVE_ARG(CompletionHandler) handler,
typename enable_if<
!execution::is_executor<
typename conditional::type
>::value
&&
detail::is_work_dispatcher_required<
typename decay::type,
Executor
>::value
>::type* = 0) const
{
typedef typename decay::type handler_t;
typedef typename associated_executor<
handler_t, Executor>::type handler_ex_t;
handler_ex_t handler_ex((get_associated_executor)(handler, ex_));
typename associated_allocator::type alloc(
(get_associated_allocator)(handler));
ex_.dispatch(detail::work_dispatcher(
BOOST_ASIO_MOVE_CAST(CompletionHandler)(handler),
handler_ex), alloc);
}
private:
Executor ex_;
};
} // namespace detail
template
BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) dispatch(
BOOST_ASIO_MOVE_ARG(CompletionToken) token)
{
return async_initiate(
detail::initiate_dispatch(), token);
}
template
BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) dispatch(
const Executor& ex, BOOST_ASIO_MOVE_ARG(CompletionToken) token,
typename enable_if<
execution::is_executor::value || is_executor::value
>::type*)
{
return async_initiate(
detail::initiate_dispatch_with_executor(ex), token);
}
template
inline BOOST_ASIO_INITFN_AUTO_RESULT_TYPE(CompletionToken, void()) dispatch(
ExecutionContext& ctx, BOOST_ASIO_MOVE_ARG(CompletionToken) token,
typename enable_if::value>::type*)
{
return async_initiate(
detail::initiate_dispatch_with_executor<
typename ExecutionContext::executor_type>(
ctx.get_executor()), token);
}
} // namespace asio
} // namespace boost
#include
#endif // BOOST_ASIO_IMPL_DISPATCH_HPP