/
usr
/
include
/
boost
/
asio
/
impl
/
/usr/include/boost/asio/impl
mkdir
upload
Name
Size
Mode
Actions
awaitable.hpp
11748
0644
edit
dl
rm
buffered_read_stream.hpp
16925
0644
edit
dl
rm
buffered_write_stream.hpp
16429
0644
edit
dl
rm
compose.hpp
20461
0644
edit
dl
rm
connect.hpp
32234
0644
edit
dl
rm
co_spawn.hpp
8834
0644
edit
dl
rm
defer.hpp
7803
0644
edit
dl
rm
detached.hpp
3374
0644
edit
dl
rm
dispatch.hpp
7567
0644
edit
dl
rm
error.ipp
3070
0644
edit
dl
rm
execution_context.hpp
3247
0644
edit
dl
rm
execution_context.ipp
1801
0644
edit
dl
rm
executor.hpp
6835
0644
edit
dl
rm
executor.ipp
1002
0644
edit
dl
rm
handler_alloc_hook.ipp
1984
0644
edit
dl
rm
io_context.hpp
13728
0644
edit
dl
rm
io_context.ipp
4108
0644
edit
dl
rm
multiple_exceptions.ipp
1280
0644
edit
dl
rm
post.hpp
7762
0644
edit
dl
rm
read.hpp
45178
0644
edit
dl
rm
read_at.hpp
28331
0644
edit
dl
rm
read_until.hpp
115335
0644
edit
dl
rm
redirect_error.hpp
12015
0644
edit
dl
rm
serial_port_base.hpp
1375
0644
edit
dl
rm
serial_port_base.ipp
13327
0644
edit
dl
rm
spawn.hpp
15854
0644
edit
dl
rm
src.hpp
3833
0644
edit
dl
rm
system_context.hpp
875
0644
edit
dl
rm
system_context.ipp
2109
0644
edit
dl
rm
system_executor.hpp
6391
0644
edit
dl
rm
thread_pool.hpp
10853
0644
edit
dl
rm
thread_pool.ipp
3132
0644
edit
dl
rm
use_awaitable.hpp
7244
0644
edit
dl
rm
use_future.hpp
27610
0644
edit
dl
rm
write.hpp
41076
0644
edit
dl
rm
write_at.hpp
24732
0644
edit
dl
rm
Edit:
/usr/include/boost/asio/impl/executor.hpp
(6835B)
// // impl/executor.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_EXECUTOR_HPP #define BOOST_ASIO_IMPL_EXECUTOR_HPP #if defined(_MSC_VER) && (_MSC_VER >= 1200) # pragma once #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) #include <boost/asio/detail/config.hpp> #if !defined(BOOST_ASIO_NO_TS_EXECUTORS) #include <boost/asio/detail/atomic_count.hpp> #include <boost/asio/detail/global.hpp> #include <boost/asio/detail/memory.hpp> #include <boost/asio/detail/recycling_allocator.hpp> #include <boost/asio/executor.hpp> #include <boost/asio/system_executor.hpp> #include <boost/asio/detail/push_options.hpp> namespace boost { namespace asio { #if !defined(GENERATING_DOCUMENTATION) // Default polymorphic executor implementation. template <typename Executor, typename Allocator> class executor::impl : public executor::impl_base { public: typedef BOOST_ASIO_REBIND_ALLOC(Allocator, impl) allocator_type; static impl_base* create(const Executor& e, Allocator a = Allocator()) { raw_mem mem(a); impl* p = new (mem.ptr_) impl(e, a); mem.ptr_ = 0; return p; } impl(const Executor& e, const Allocator& a) BOOST_ASIO_NOEXCEPT : impl_base(false), ref_count_(1), executor_(e), allocator_(a) { } impl_base* clone() const BOOST_ASIO_NOEXCEPT { detail::ref_count_up(ref_count_); return const_cast<impl_base*>(static_cast<const impl_base*>(this)); } void destroy() BOOST_ASIO_NOEXCEPT { if (detail::ref_count_down(ref_count_)) { allocator_type alloc(allocator_); impl* p = this; p->~impl(); alloc.deallocate(p, 1); } } void on_work_started() BOOST_ASIO_NOEXCEPT { executor_.on_work_started(); } void on_work_finished() BOOST_ASIO_NOEXCEPT { executor_.on_work_finished(); } execution_context& context() BOOST_ASIO_NOEXCEPT { return executor_.context(); } void dispatch(BOOST_ASIO_MOVE_ARG(function) f) { executor_.dispatch(BOOST_ASIO_MOVE_CAST(function)(f), allocator_); } void post(BOOST_ASIO_MOVE_ARG(function) f) { executor_.post(BOOST_ASIO_MOVE_CAST(function)(f), allocator_); } void defer(BOOST_ASIO_MOVE_ARG(function) f) { executor_.defer(BOOST_ASIO_MOVE_CAST(function)(f), allocator_); } type_id_result_type target_type() const BOOST_ASIO_NOEXCEPT { return type_id<Executor>(); } void* target() BOOST_ASIO_NOEXCEPT { return &executor_; } const void* target() const BOOST_ASIO_NOEXCEPT { return &executor_; } bool equals(const impl_base* e) const BOOST_ASIO_NOEXCEPT { if (this == e) return true; if (target_type() != e->target_type()) return false; return executor_ == *static_cast<const Executor*>(e->target()); } private: mutable detail::atomic_count ref_count_; Executor executor_; Allocator allocator_; struct raw_mem { allocator_type allocator_; impl* ptr_; explicit raw_mem(const Allocator& a) : allocator_(a), ptr_(allocator_.allocate(1)) { } ~raw_mem() { if (ptr_) allocator_.deallocate(ptr_, 1); } private: // Disallow copying and assignment. raw_mem(const raw_mem&); raw_mem operator=(const raw_mem&); }; }; // Polymorphic executor specialisation for system_executor. template <typename Allocator> class executor::impl<system_executor, Allocator> : public executor::impl_base { public: static impl_base* create(const system_executor&, const Allocator& = Allocator()) { return &detail::global<impl<system_executor, std::allocator<void> > >(); } impl() : impl_base(true) { } impl_base* clone() const BOOST_ASIO_NOEXCEPT { return const_cast<impl_base*>(static_cast<const impl_base*>(this)); } void destroy() BOOST_ASIO_NOEXCEPT { } void on_work_started() BOOST_ASIO_NOEXCEPT { executor_.on_work_started(); } void on_work_finished() BOOST_ASIO_NOEXCEPT { executor_.on_work_finished(); } execution_context& context() BOOST_ASIO_NOEXCEPT { return executor_.context(); } void dispatch(BOOST_ASIO_MOVE_ARG(function) f) { executor_.dispatch(BOOST_ASIO_MOVE_CAST(function)(f), std::allocator<void>()); } void post(BOOST_ASIO_MOVE_ARG(function) f) { executor_.post(BOOST_ASIO_MOVE_CAST(function)(f), std::allocator<void>()); } void defer(BOOST_ASIO_MOVE_ARG(function) f) { executor_.defer(BOOST_ASIO_MOVE_CAST(function)(f), std::allocator<void>()); } type_id_result_type target_type() const BOOST_ASIO_NOEXCEPT { return type_id<system_executor>(); } void* target() BOOST_ASIO_NOEXCEPT { return &executor_; } const void* target() const BOOST_ASIO_NOEXCEPT { return &executor_; } bool equals(const impl_base* e) const BOOST_ASIO_NOEXCEPT { return this == e; } private: system_executor executor_; }; template <typename Executor> executor::executor(Executor e) : impl_(impl<Executor, std::allocator<void> >::create(e)) { } template <typename Executor, typename Allocator> executor::executor(allocator_arg_t, const Allocator& a, Executor e) : impl_(impl<Executor, Allocator>::create(e, a)) { } template <typename Function, typename Allocator> void executor::dispatch(BOOST_ASIO_MOVE_ARG(Function) f, const Allocator& a) const { impl_base* i = get_impl(); if (i->fast_dispatch_) system_executor().dispatch(BOOST_ASIO_MOVE_CAST(Function)(f), a); else i->dispatch(function(BOOST_ASIO_MOVE_CAST(Function)(f), a)); } template <typename Function, typename Allocator> void executor::post(BOOST_ASIO_MOVE_ARG(Function) f, const Allocator& a) const { get_impl()->post(function(BOOST_ASIO_MOVE_CAST(Function)(f), a)); } template <typename Function, typename Allocator> void executor::defer(BOOST_ASIO_MOVE_ARG(Function) f, const Allocator& a) const { get_impl()->defer(function(BOOST_ASIO_MOVE_CAST(Function)(f), a)); } template <typename Executor> Executor* executor::target() BOOST_ASIO_NOEXCEPT { return impl_ && impl_->target_type() == type_id<Executor>() ? static_cast<Executor*>(impl_->target()) : 0; } template <typename Executor> const Executor* executor::target() const BOOST_ASIO_NOEXCEPT { return impl_ && impl_->target_type() == type_id<Executor>() ? static_cast<Executor*>(impl_->target()) : 0; } #endif // !defined(GENERATING_DOCUMENTATION) } // namespace asio } // namespace boost #include <boost/asio/detail/pop_options.hpp> #endif // !defined(BOOST_ASIO_NO_TS_EXECUTORS) #endif // BOOST_ASIO_IMPL_EXECUTOR_HPP
Save
cmd:
run