/
usr
/
include
/
boost
/
asio
/
detail
/
/usr/include/boost/asio/detail
mkdir
upload
Name
Size
Mode
Actions
impl/
-
0755
rm
array.hpp
1001
0644
edit
dl
rm
array_fwd.hpp
950
0644
edit
dl
rm
assert.hpp
968
0644
edit
dl
rm
atomic_count.hpp
1955
0644
edit
dl
rm
base_from_completion_cond.hpp
1795
0644
edit
dl
rm
bind_handler.hpp
28936
0644
edit
dl
rm
blocking_executor_op.hpp
2823
0644
edit
dl
rm
buffered_stream_storage.hpp
2987
0644
edit
dl
rm
buffer_resize_guard.hpp
1593
0644
edit
dl
rm
buffer_sequence_adapter.hpp
15582
0644
edit
dl
rm
bulk_executor_op.hpp
2785
0644
edit
dl
rm
call_stack.hpp
3003
0644
edit
dl
rm
chrono.hpp
2081
0644
edit
dl
rm
chrono_time_traits.hpp
4469
0644
edit
dl
rm
completion_handler.hpp
2832
0644
edit
dl
rm
concurrency_hint.hpp
4062
0644
edit
dl
rm
conditionally_enabled_event.hpp
3124
0644
edit
dl
rm
conditionally_enabled_mutex.hpp
3126
0644
edit
dl
rm
config.hpp
76667
0644
edit
dl
rm
consuming_buffers.hpp
10631
0644
edit
dl
rm
cstddef.hpp
816
0644
edit
dl
rm
cstdint.hpp
1558
0644
edit
dl
rm
date_time_fwd.hpp
792
0644
edit
dl
rm
deadline_timer_service.hpp
9241
0644
edit
dl
rm
dependent_type.hpp
891
0644
edit
dl
rm
descriptor_ops.hpp
4244
0644
edit
dl
rm
descriptor_read_op.hpp
4798
0644
edit
dl
rm
descriptor_write_op.hpp
4801
0644
edit
dl
rm
dev_poll_reactor.hpp
8039
0644
edit
dl
rm
epoll_reactor.hpp
9467
0644
edit
dl
rm
event.hpp
1364
0644
edit
dl
rm
eventfd_select_interrupter.hpp
2524
0644
edit
dl
rm
executor_function.hpp
4857
0644
edit
dl
rm
executor_op.hpp
2605
0644
edit
dl
rm
fd_set_adapter.hpp
1064
0644
edit
dl
rm
fenced_block.hpp
3066
0644
edit
dl
rm
functional.hpp
1014
0644
edit
dl
rm
future.hpp
1241
0644
edit
dl
rm
gcc_arm_fenced_block.hpp
2238
0644
edit
dl
rm
gcc_hppa_fenced_block.hpp
1560
0644
edit
dl
rm
gcc_sync_fenced_block.hpp
1679
0644
edit
dl
rm
gcc_x86_fenced_block.hpp
2460
0644
edit
dl
rm
global.hpp
1397
0644
edit
dl
rm
handler_alloc_helpers.hpp
8236
0644
edit
dl
rm
handler_cont_helpers.hpp
1364
0644
edit
dl
rm
handler_invoke_helpers.hpp
2715
0644
edit
dl
rm
handler_tracking.hpp
9182
0644
edit
dl
rm
handler_type_requirements.hpp
20351
0644
edit
dl
rm
handler_work.hpp
12302
0644
edit
dl
rm
hash_map.hpp
8343
0644
edit
dl
rm
io_control.hpp
1883
0644
edit
dl
rm
io_object_impl.hpp
5018
0644
edit
dl
rm
is_buffer_sequence.hpp
7953
0644
edit
dl
rm
is_executor.hpp
3033
0644
edit
dl
rm
keyword_tss_ptr.hpp
1425
0644
edit
dl
rm
kqueue_reactor.hpp
8277
0644
edit
dl
rm
limits.hpp
734
0644
edit
dl
rm
local_free_on_block_exit.hpp
1470
0644
edit
dl
rm
macos_fenced_block.hpp
1380
0644
edit
dl
rm
memory.hpp
2103
0644
edit
dl
rm
mutex.hpp
1351
0644
edit
dl
rm
noncopyable.hpp
1000
0644
edit
dl
rm
non_const_lvalue.hpp
1506
0644
edit
dl
rm
null_event.hpp
2197
0644
edit
dl
rm
null_fenced_block.hpp
1044
0644
edit
dl
rm
null_global.hpp
1295
0644
edit
dl
rm
null_mutex.hpp
1255
0644
edit
dl
rm
null_reactor.hpp
1563
0644
edit
dl
rm
null_signal_blocker.hpp
1627
0644
edit
dl
rm
null_socket_service.hpp
17283
0644
edit
dl
rm
null_static_mutex.hpp
1259
0644
edit
dl
rm
null_thread.hpp
1442
0644
edit
dl
rm
null_tss_ptr.hpp
1272
0644
edit
dl
rm
object_pool.hpp
3500
0644
edit
dl
rm
old_win_sdk_compat.hpp
4478
0644
edit
dl
rm
operation.hpp
963
0644
edit
dl
rm
op_queue.hpp
3313
0644
edit
dl
rm
pipe_select_interrupter.hpp
2603
0644
edit
dl
rm
pop_options.hpp
2877
0644
edit
dl
rm
posix_event.hpp
4548
0644
edit
dl
rm
posix_fd_set_adapter.hpp
2992
0644
edit
dl
rm
posix_global.hpp
1807
0644
edit
dl
rm
posix_mutex.hpp
1685
0644
edit
dl
rm
posix_signal_blocker.hpp
1975
0644
edit
dl
rm
posix_static_mutex.hpp
1467
0644
edit
dl
rm
posix_thread.hpp
2187
0644
edit
dl
rm
posix_tss_ptr.hpp
1800
0644
edit
dl
rm
push_options.hpp
4679
0644
edit
dl
rm
reactive_descriptor_service.hpp
14507
0644
edit
dl
rm
reactive_null_buffers_op.hpp
3300
0644
edit
dl
rm
reactive_serial_port_service.hpp
8314
0644
edit
dl
rm
reactive_socket_accept_op.hpp
8322
0644
edit
dl
rm
reactive_socket_connect_op.hpp
4010
0644
edit
dl
rm
reactive_socket_recvfrom_op.hpp
5660
0644
edit
dl
rm
reactive_socket_recvmsg_op.hpp
5012
0644
edit
dl
rm
reactive_socket_recv_op.hpp
5433
0644
edit
dl
rm
reactive_socket_sendto_op.hpp
5362
0644
edit
dl
rm
reactive_socket_send_op.hpp
5530
0644
edit
dl
rm
reactive_socket_service.hpp
18653
0644
edit
dl
rm
reactive_socket_service_base.hpp
19681
0644
edit
dl
rm
reactive_wait_op.hpp
3153
0644
edit
dl
rm
reactor.hpp
1003
0644
edit
dl
rm
reactor_fwd.hpp
1155
0644
edit
dl
rm
reactor_op.hpp
1763
0644
edit
dl
rm
reactor_op_queue.hpp
4979
0644
edit
dl
rm
recycling_allocator.hpp
2467
0644
edit
dl
rm
regex_fwd.hpp
846
0644
edit
dl
rm
resolver_service.hpp
4806
0644
edit
dl
rm
resolver_service_base.hpp
4392
0644
edit
dl
rm
resolve_endpoint_op.hpp
4900
0644
edit
dl
rm
resolve_op.hpp
1090
0644
edit
dl
rm
resolve_query_op.hpp
5034
0644
edit
dl
rm
scheduler.hpp
7609
0644
edit
dl
rm
scheduler_operation.hpp
1922
0644
edit
dl
rm
scheduler_thread_info.hpp
1079
0644
edit
dl
rm
scoped_lock.hpp
1942
0644
edit
dl
rm
scoped_ptr.hpp
1448
0644
edit
dl
rm
select_interrupter.hpp
1426
0644
edit
dl
rm
select_reactor.hpp
8813
0644
edit
dl
rm
service_registry.hpp
5645
0644
edit
dl
rm
signal_blocker.hpp
1382
0644
edit
dl
rm
signal_handler.hpp
2931
0644
edit
dl
rm
signal_init.hpp
1070
0644
edit
dl
rm
signal_op.hpp
1146
0644
edit
dl
rm
signal_set_service.hpp
7018
0644
edit
dl
rm
socket_holder.hpp
2148
0644
edit
dl
rm
socket_ops.hpp
13917
0644
edit
dl
rm
socket_option.hpp
6410
0644
edit
dl
rm
socket_select_interrupter.hpp
2620
0644
edit
dl
rm
socket_types.hpp
16173
0644
edit
dl
rm
solaris_fenced_block.hpp
1338
0644
edit
dl
rm
source_location.hpp
1460
0644
edit
dl
rm
static_mutex.hpp
1745
0644
edit
dl
rm
std_event.hpp
4029
0644
edit
dl
rm
std_fenced_block.hpp
1408
0644
edit
dl
rm
std_global.hpp
1568
0644
edit
dl
rm
std_mutex.hpp
1404
0644
edit
dl
rm
std_static_mutex.hpp
1586
0644
edit
dl
rm
std_thread.hpp
1425
0644
edit
dl
rm
strand_executor_service.hpp
6110
0644
edit
dl
rm
strand_service.hpp
4896
0644
edit
dl
rm
string_view.hpp
1574
0644
edit
dl
rm
thread.hpp
1658
0644
edit
dl
rm
thread_context.hpp
1135
0644
edit
dl
rm
thread_group.hpp
1993
0644
edit
dl
rm
thread_info_base.hpp
4979
0644
edit
dl
rm
throw_error.hpp
1377
0644
edit
dl
rm
throw_exception.hpp
1512
0644
edit
dl
rm
timer_queue.hpp
9873
0644
edit
dl
rm
timer_queue_base.hpp
1754
0644
edit
dl
rm
timer_queue_ptime.hpp
3132
0644
edit
dl
rm
timer_queue_set.hpp
1805
0644
edit
dl
rm
timer_scheduler.hpp
1157
0644
edit
dl
rm
timer_scheduler_fwd.hpp
1225
0644
edit
dl
rm
tss_ptr.hpp
1883
0644
edit
dl
rm
type_traits.hpp
5070
0644
edit
dl
rm
variadic_templates.hpp
13229
0644
edit
dl
rm
wait_handler.hpp
2864
0644
edit
dl
rm
wait_op.hpp
1021
0644
edit
dl
rm
winapp_thread.hpp
2740
0644
edit
dl
rm
wince_thread.hpp
2683
0644
edit
dl
rm
winrt_async_manager.hpp
9024
0644
edit
dl
rm
winrt_async_op.hpp
1487
0644
edit
dl
rm
winrt_resolver_service.hpp
6302
0644
edit
dl
rm
winrt_resolve_op.hpp
4062
0644
edit
dl
rm
winrt_socket_connect_op.hpp
3237
0644
edit
dl
rm
winrt_socket_recv_op.hpp
4042
0644
edit
dl
rm
winrt_socket_send_op.hpp
3677
0644
edit
dl
rm
winrt_ssocket_service.hpp
7455
0644
edit
dl
rm
winrt_ssocket_service_base.hpp
12870
0644
edit
dl
rm
winrt_timer_scheduler.hpp
4839
0644
edit
dl
rm
winrt_utils.hpp
2760
0644
edit
dl
rm
winsock_init.hpp
3232
0644
edit
dl
rm
win_event.hpp
3936
0644
edit
dl
rm
win_fd_set_adapter.hpp
3911
0644
edit
dl
rm
win_fenced_block.hpp
2138
0644
edit
dl
rm
win_global.hpp
1790
0644
edit
dl
rm
win_iocp_handle_read_op.hpp
3956
0644
edit
dl
rm
win_iocp_handle_service.hpp
12900
0644
edit
dl
rm
win_iocp_handle_write_op.hpp
3758
0644
edit
dl
rm
win_iocp_io_context.hpp
11747
0644
edit
dl
rm
win_iocp_null_buffers_op.hpp
4098
0644
edit
dl
rm
win_iocp_operation.hpp
2187
0644
edit
dl
rm
win_iocp_overlapped_op.hpp
3186
0644
edit
dl
rm
win_iocp_overlapped_ptr.hpp
4418
0644
edit
dl
rm
win_iocp_serial_port_service.hpp
7981
0644
edit
dl
rm
win_iocp_socket_accept_op.hpp
10210
0644
edit
dl
rm
win_iocp_socket_connect_op.hpp
4146
0644
edit
dl
rm
win_iocp_socket_recvfrom_op.hpp
4394
0644
edit
dl
rm
win_iocp_socket_recvmsg_op.hpp
4211
0644
edit
dl
rm
win_iocp_socket_recv_op.hpp
4232
0644
edit
dl
rm
win_iocp_socket_send_op.hpp
3975
0644
edit
dl
rm
win_iocp_socket_service.hpp
20209
0644
edit
dl
rm
win_iocp_socket_service_base.hpp
23493
0644
edit
dl
rm
win_iocp_thread_info.hpp
903
0644
edit
dl
rm
win_iocp_wait_op.hpp
4016
0644
edit
dl
rm
win_mutex.hpp
1832
0644
edit
dl
rm
win_object_handle_service.hpp
6401
0644
edit
dl
rm
win_static_mutex.hpp
1937
0644
edit
dl
rm
win_thread.hpp
3233
0644
edit
dl
rm
win_tss_ptr.hpp
1744
0644
edit
dl
rm
work_dispatcher.hpp
4111
0644
edit
dl
rm
wrapped_handler.hpp
9882
0644
edit
dl
rm
Edit:
/usr/include/boost/asio/detail/buffer_sequence_adapter.hpp
(15582B)
// // detail/buffer_sequence_adapter.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_DETAIL_BUFFER_SEQUENCE_ADAPTER_HPP #define BOOST_ASIO_DETAIL_BUFFER_SEQUENCE_ADAPTER_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/buffer.hpp> #include <boost/asio/detail/array_fwd.hpp> #include <boost/asio/detail/socket_types.hpp> #include <boost/asio/detail/push_options.hpp> namespace boost { namespace asio { namespace detail { class buffer_sequence_adapter_base { #if defined(BOOST_ASIO_WINDOWS_RUNTIME) public: // The maximum number of buffers to support in a single operation. enum { max_buffers = 1 }; protected: typedef Windows::Storage::Streams::IBuffer^ native_buffer_type; BOOST_ASIO_DECL static void init_native_buffer( native_buffer_type& buf, const boost::asio::mutable_buffer& buffer); BOOST_ASIO_DECL static void init_native_buffer( native_buffer_type& buf, const boost::asio::const_buffer& buffer); #elif defined(BOOST_ASIO_WINDOWS) || defined(__CYGWIN__) public: // The maximum number of buffers to support in a single operation. enum { max_buffers = 64 < max_iov_len ? 64 : max_iov_len }; protected: typedef WSABUF native_buffer_type; static void init_native_buffer(WSABUF& buf, const boost::asio::mutable_buffer& buffer) { buf.buf = static_cast<char*>(buffer.data()); buf.len = static_cast<ULONG>(buffer.size()); } static void init_native_buffer(WSABUF& buf, const boost::asio::const_buffer& buffer) { buf.buf = const_cast<char*>(static_cast<const char*>(buffer.data())); buf.len = static_cast<ULONG>(buffer.size()); } #else // defined(BOOST_ASIO_WINDOWS) || defined(__CYGWIN__) public: // The maximum number of buffers to support in a single operation. enum { max_buffers = 64 < max_iov_len ? 64 : max_iov_len }; protected: typedef iovec native_buffer_type; static void init_iov_base(void*& base, void* addr) { base = addr; } template <typename T> static void init_iov_base(T& base, void* addr) { base = static_cast<T>(addr); } static void init_native_buffer(iovec& iov, const boost::asio::mutable_buffer& buffer) { init_iov_base(iov.iov_base, buffer.data()); iov.iov_len = buffer.size(); } static void init_native_buffer(iovec& iov, const boost::asio::const_buffer& buffer) { init_iov_base(iov.iov_base, const_cast<void*>(buffer.data())); iov.iov_len = buffer.size(); } #endif // defined(BOOST_ASIO_WINDOWS) || defined(__CYGWIN__) }; // Helper class to translate buffers into the native buffer representation. template <typename Buffer, typename Buffers> class buffer_sequence_adapter : buffer_sequence_adapter_base { public: enum { is_single_buffer = false }; explicit buffer_sequence_adapter(const Buffers& buffer_sequence) : count_(0), total_buffer_size_(0) { buffer_sequence_adapter::init( boost::asio::buffer_sequence_begin(buffer_sequence), boost::asio::buffer_sequence_end(buffer_sequence)); } native_buffer_type* buffers() { return buffers_; } std::size_t count() const { return count_; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const Buffers& buffer_sequence) { return buffer_sequence_adapter::all_empty( boost::asio::buffer_sequence_begin(buffer_sequence), boost::asio::buffer_sequence_end(buffer_sequence)); } static void validate(const Buffers& buffer_sequence) { buffer_sequence_adapter::validate( boost::asio::buffer_sequence_begin(buffer_sequence), boost::asio::buffer_sequence_end(buffer_sequence)); } static Buffer first(const Buffers& buffer_sequence) { return buffer_sequence_adapter::first( boost::asio::buffer_sequence_begin(buffer_sequence), boost::asio::buffer_sequence_end(buffer_sequence)); } enum { linearisation_storage_size = 8192 }; static Buffer linearise(const Buffers& buffer_sequence, const boost::asio::mutable_buffer& storage) { return buffer_sequence_adapter::linearise( boost::asio::buffer_sequence_begin(buffer_sequence), boost::asio::buffer_sequence_end(buffer_sequence), storage); } private: template <typename Iterator> void init(Iterator begin, Iterator end) { Iterator iter = begin; for (; iter != end && count_ < max_buffers; ++iter, ++count_) { Buffer buffer(*iter); init_native_buffer(buffers_[count_], buffer); total_buffer_size_ += buffer.size(); } } template <typename Iterator> static bool all_empty(Iterator begin, Iterator end) { Iterator iter = begin; std::size_t i = 0; for (; iter != end && i < max_buffers; ++iter, ++i) if (Buffer(*iter).size() > 0) return false; return true; } template <typename Iterator> static void validate(Iterator begin, Iterator end) { Iterator iter = begin; for (; iter != end; ++iter) { Buffer buffer(*iter); buffer.data(); } } template <typename Iterator> static Buffer first(Iterator begin, Iterator end) { Iterator iter = begin; for (; iter != end; ++iter) { Buffer buffer(*iter); if (buffer.size() != 0) return buffer; } return Buffer(); } template <typename Iterator> static Buffer linearise(Iterator begin, Iterator end, const boost::asio::mutable_buffer& storage) { boost::asio::mutable_buffer unused_storage = storage; Iterator iter = begin; while (iter != end && unused_storage.size() != 0) { Buffer buffer(*iter); ++iter; if (buffer.size() == 0) continue; if (unused_storage.size() == storage.size()) { if (iter == end) return buffer; if (buffer.size() >= unused_storage.size()) return buffer; } unused_storage += boost::asio::buffer_copy(unused_storage, buffer); } return Buffer(storage.data(), storage.size() - unused_storage.size()); } native_buffer_type buffers_[max_buffers]; std::size_t count_; std::size_t total_buffer_size_; }; template <typename Buffer> class buffer_sequence_adapter<Buffer, boost::asio::mutable_buffer> : buffer_sequence_adapter_base { public: enum { is_single_buffer = true }; explicit buffer_sequence_adapter( const boost::asio::mutable_buffer& buffer_sequence) { init_native_buffer(buffer_, Buffer(buffer_sequence)); total_buffer_size_ = buffer_sequence.size(); } native_buffer_type* buffers() { return &buffer_; } std::size_t count() const { return 1; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const boost::asio::mutable_buffer& buffer_sequence) { return buffer_sequence.size() == 0; } static void validate(const boost::asio::mutable_buffer& buffer_sequence) { buffer_sequence.data(); } static Buffer first(const boost::asio::mutable_buffer& buffer_sequence) { return Buffer(buffer_sequence); } enum { linearisation_storage_size = 1 }; static Buffer linearise(const boost::asio::mutable_buffer& buffer_sequence, const Buffer&) { return Buffer(buffer_sequence); } private: native_buffer_type buffer_; std::size_t total_buffer_size_; }; template <typename Buffer> class buffer_sequence_adapter<Buffer, boost::asio::const_buffer> : buffer_sequence_adapter_base { public: enum { is_single_buffer = true }; explicit buffer_sequence_adapter( const boost::asio::const_buffer& buffer_sequence) { init_native_buffer(buffer_, Buffer(buffer_sequence)); total_buffer_size_ = buffer_sequence.size(); } native_buffer_type* buffers() { return &buffer_; } std::size_t count() const { return 1; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const boost::asio::const_buffer& buffer_sequence) { return buffer_sequence.size() == 0; } static void validate(const boost::asio::const_buffer& buffer_sequence) { buffer_sequence.data(); } static Buffer first(const boost::asio::const_buffer& buffer_sequence) { return Buffer(buffer_sequence); } enum { linearisation_storage_size = 1 }; static Buffer linearise(const boost::asio::const_buffer& buffer_sequence, const Buffer&) { return Buffer(buffer_sequence); } private: native_buffer_type buffer_; std::size_t total_buffer_size_; }; #if !defined(BOOST_ASIO_NO_DEPRECATED) template <typename Buffer> class buffer_sequence_adapter<Buffer, boost::asio::mutable_buffers_1> : buffer_sequence_adapter_base { public: enum { is_single_buffer = true }; explicit buffer_sequence_adapter( const boost::asio::mutable_buffers_1& buffer_sequence) { init_native_buffer(buffer_, Buffer(buffer_sequence)); total_buffer_size_ = buffer_sequence.size(); } native_buffer_type* buffers() { return &buffer_; } std::size_t count() const { return 1; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const boost::asio::mutable_buffers_1& buffer_sequence) { return buffer_sequence.size() == 0; } static void validate(const boost::asio::mutable_buffers_1& buffer_sequence) { buffer_sequence.data(); } static Buffer first(const boost::asio::mutable_buffers_1& buffer_sequence) { return Buffer(buffer_sequence); } enum { linearisation_storage_size = 1 }; static Buffer linearise(const boost::asio::mutable_buffers_1& buffer_sequence, const Buffer&) { return Buffer(buffer_sequence); } private: native_buffer_type buffer_; std::size_t total_buffer_size_; }; template <typename Buffer> class buffer_sequence_adapter<Buffer, boost::asio::const_buffers_1> : buffer_sequence_adapter_base { public: enum { is_single_buffer = true }; explicit buffer_sequence_adapter( const boost::asio::const_buffers_1& buffer_sequence) { init_native_buffer(buffer_, Buffer(buffer_sequence)); total_buffer_size_ = buffer_sequence.size(); } native_buffer_type* buffers() { return &buffer_; } std::size_t count() const { return 1; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const boost::asio::const_buffers_1& buffer_sequence) { return buffer_sequence.size() == 0; } static void validate(const boost::asio::const_buffers_1& buffer_sequence) { buffer_sequence.data(); } static Buffer first(const boost::asio::const_buffers_1& buffer_sequence) { return Buffer(buffer_sequence); } enum { linearisation_storage_size = 1 }; static Buffer linearise(const boost::asio::const_buffers_1& buffer_sequence, const Buffer&) { return Buffer(buffer_sequence); } private: native_buffer_type buffer_; std::size_t total_buffer_size_; }; #endif // !defined(BOOST_ASIO_NO_DEPRECATED) template <typename Buffer, typename Elem> class buffer_sequence_adapter<Buffer, boost::array<Elem, 2> > : buffer_sequence_adapter_base { public: enum { is_single_buffer = false }; explicit buffer_sequence_adapter( const boost::array<Elem, 2>& buffer_sequence) { init_native_buffer(buffers_[0], Buffer(buffer_sequence[0])); init_native_buffer(buffers_[1], Buffer(buffer_sequence[1])); total_buffer_size_ = buffer_sequence[0].size() + buffer_sequence[1].size(); } native_buffer_type* buffers() { return buffers_; } std::size_t count() const { return 2; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const boost::array<Elem, 2>& buffer_sequence) { return buffer_sequence[0].size() == 0 && buffer_sequence[1].size() == 0; } static void validate(const boost::array<Elem, 2>& buffer_sequence) { buffer_sequence[0].data(); buffer_sequence[1].data(); } static Buffer first(const boost::array<Elem, 2>& buffer_sequence) { return Buffer(buffer_sequence[0].size() != 0 ? buffer_sequence[0] : buffer_sequence[1]); } enum { linearisation_storage_size = 8192 }; static Buffer linearise(const boost::array<Elem, 2>& buffer_sequence, const boost::asio::mutable_buffer& storage) { if (buffer_sequence[0].size() == 0) return Buffer(buffer_sequence[1]); if (buffer_sequence[1].size() == 0) return Buffer(buffer_sequence[0]); return Buffer(storage.data(), boost::asio::buffer_copy(storage, buffer_sequence)); } private: native_buffer_type buffers_[2]; std::size_t total_buffer_size_; }; #if defined(BOOST_ASIO_HAS_STD_ARRAY) template <typename Buffer, typename Elem> class buffer_sequence_adapter<Buffer, std::array<Elem, 2> > : buffer_sequence_adapter_base { public: enum { is_single_buffer = false }; explicit buffer_sequence_adapter( const std::array<Elem, 2>& buffer_sequence) { init_native_buffer(buffers_[0], Buffer(buffer_sequence[0])); init_native_buffer(buffers_[1], Buffer(buffer_sequence[1])); total_buffer_size_ = buffer_sequence[0].size() + buffer_sequence[1].size(); } native_buffer_type* buffers() { return buffers_; } std::size_t count() const { return 2; } std::size_t total_size() const { return total_buffer_size_; } bool all_empty() const { return total_buffer_size_ == 0; } static bool all_empty(const std::array<Elem, 2>& buffer_sequence) { return buffer_sequence[0].size() == 0 && buffer_sequence[1].size() == 0; } static void validate(const std::array<Elem, 2>& buffer_sequence) { buffer_sequence[0].data(); buffer_sequence[1].data(); } static Buffer first(const std::array<Elem, 2>& buffer_sequence) { return Buffer(buffer_sequence[0].size() != 0 ? buffer_sequence[0] : buffer_sequence[1]); } enum { linearisation_storage_size = 8192 }; static Buffer linearise(const std::array<Elem, 2>& buffer_sequence, const boost::asio::mutable_buffer& storage) { if (buffer_sequence[0].size() == 0) return Buffer(buffer_sequence[1]); if (buffer_sequence[1].size() == 0) return Buffer(buffer_sequence[0]); return Buffer(storage.data(), boost::asio::buffer_copy(storage, buffer_sequence)); } private: native_buffer_type buffers_[2]; std::size_t total_buffer_size_; }; #endif // defined(BOOST_ASIO_HAS_STD_ARRAY) } // namespace detail } // namespace asio } // namespace boost #include <boost/asio/detail/pop_options.hpp> #if defined(BOOST_ASIO_HEADER_ONLY) # include <boost/asio/detail/impl/buffer_sequence_adapter.ipp> #endif // defined(BOOST_ASIO_HEADER_ONLY) #endif // BOOST_ASIO_DETAIL_BUFFER_SEQUENCE_ADAPTER_HPP
Save
cmd:
run