| /third_party/boost/libs/asio/test/ |
| D | thread_pool.cpp | 29 using namespace boost::asio;
49 boost::asio::post(*pool, bindns::bind(decrement_to_zero, pool, count)); in decrement_to_zero()
62 boost::asio::dispatch(*pool, in nested_decrement_to_zero()
75 boost::asio::post(pool, bindns::bind(increment, &count1)); in thread_pool_test()
78 boost::asio::post(pool, bindns::bind(decrement_to_zero, &pool, &count2)); in thread_pool_test()
81 boost::asio::post(pool, bindns::bind(nested_decrement_to_zero, &pool, &count3)); in thread_pool_test()
90 class test_service : public boost::asio::execution_context::service
94 static boost::asio::execution_context::id id;
99 test_service(boost::asio::execution_context& ctx) in test_service()
100 : boost::asio::execution_context::service(ctx) in test_service()
[all …]
|
| D | system_executor.cpp | 34 using namespace boost::asio;
42 void increment(boost::asio::detail::atomic_count* count) in increment()
50 &boost::asio::query(system_executor(), in system_executor_query_test()
51 boost::asio::execution::context) in system_executor_query_test()
55 boost::asio::query(system_executor(), in system_executor_query_test()
56 boost::asio::execution::blocking) in system_executor_query_test()
57 == boost::asio::execution::blocking.possibly); in system_executor_query_test()
60 boost::asio::query(system_executor(), in system_executor_query_test()
61 boost::asio::execution::blocking.possibly) in system_executor_query_test()
62 == boost::asio::execution::blocking.possibly); in system_executor_query_test()
[all …]
|
| D | io_context.cpp | 38 using namespace boost::asio;
51 namespace chronons = boost::asio::chrono;
66 boost::asio::post(*ioc, bindns::bind(decrement_to_zero, ioc, count)); in decrement_to_zero()
79 boost::asio::dispatch(*ioc, in nested_decrement_to_zero()
93 boost::asio::post(*ioc, bindns::bind(sleep_increment, ioc, count)); in sleep_increment()
103 boost::asio::post(*ioc, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
121 boost::asio::post(ioc, bindns::bind(increment, &count)); in io_context_test()
135 boost::asio::post(ioc, bindns::bind(increment, &count)); in io_context_test()
136 boost::asio::post(ioc, bindns::bind(increment, &count)); in io_context_test()
137 boost::asio::post(ioc, bindns::bind(increment, &count)); in io_context_test()
[all …]
|
| D | error.cpp | 46 test_error_code(boost::asio::error::access_denied); in error_test()
47 test_error_code(boost::asio::error::address_family_not_supported); in error_test()
48 test_error_code(boost::asio::error::address_in_use); in error_test()
49 test_error_code(boost::asio::error::already_connected); in error_test()
50 test_error_code(boost::asio::error::already_started); in error_test()
51 test_error_code(boost::asio::error::connection_aborted); in error_test()
52 test_error_code(boost::asio::error::connection_refused); in error_test()
53 test_error_code(boost::asio::error::connection_reset); in error_test()
54 test_error_code(boost::asio::error::bad_descriptor); in error_test()
55 test_error_code(boost::asio::error::eof); in error_test()
[all …]
|
| D | connect.cpp | 44 boost::asio::ip::tcp::endpoint( in connection_sink()
45 boost::asio::ip::address_v4::loopback(), 0)), in connection_sink()
58 boost::asio::ip::tcp::endpoint target_endpoint() in target_endpoint()
76 boost::asio::io_context io_context_;
77 boost::asio::ip::tcp::acceptor acceptor_;
78 boost::asio::ip::tcp::endpoint target_endpoint_;
79 boost::asio::ip::tcp::socket socket_;
80 boost::asio::detail::thread thread_;
84 const boost::asio::ip::tcp::endpoint& /*endpoint*/) in true_cond_1()
99 std::vector<boost::asio::ip::tcp::endpoint>::const_iterator legacy_true_cond_1( in legacy_true_cond_1()
[all …]
|
| D | write_at.cpp | 45 typedef boost::asio::io_context::executor_type executor_type;
47 test_random_access_device(boost::asio::io_context& io_context) in test_random_access_device()
72 bool check_buffers(boost::asio::uint64_t offset, in check_buffers()
82 size_t buffer_length = boost::asio::buffer_size(*iter); in check_buffers()
95 bool check_buffers(boost::asio::uint64_t offset, in check_buffers()
98 return check_buffers(offset, boost::asio::buffer_sequence_begin(buffers), in check_buffers()
99 boost::asio::buffer_sequence_end(buffers), length); in check_buffers()
103 size_t write_some_at(boost::asio::uint64_t offset, in write_some_at()
106 return boost::asio::buffer_copy( in write_some_at()
107 boost::asio::buffer(data_, length_) + offset, in write_some_at()
[all …]
|
| D | write.cpp | 46 typedef boost::asio::io_context::executor_type executor_type;
48 test_stream(boost::asio::io_context& io_context) in test_stream()
87 size_t buffer_length = boost::asio::buffer_size(*iter); in check_buffers()
101 return check_buffers(boost::asio::buffer_sequence_begin(buffers), in check_buffers()
102 boost::asio::buffer_sequence_end(buffers), length); in check_buffers()
108 size_t n = boost::asio::buffer_copy( in write_some()
109 boost::asio::buffer(data_, length_) + position_, in write_some()
127 boost::asio::post(get_executor(), in async_write_some()
128 boost::asio::detail::bind_handler( in async_write_some()
134 boost::asio::io_context& io_context_;
[all …]
|
| D | strand.cpp | 39 using namespace boost::asio;
52 namespace chronons = boost::asio::chrono;
168 boost::asio::detail::thread thread1(bindns::bind(io_context_run, &ioc)); in strand_test()
169 boost::asio::detail::thread thread2(bindns::bind(io_context_run, &ioc)); in strand_test()
264 &boost::asio::query(s1, boost::asio::execution::context) in strand_query_test()
268 boost::asio::query(s1, boost::asio::execution::blocking) in strand_query_test()
269 == boost::asio::execution::blocking.possibly); in strand_query_test()
272 boost::asio::query(s1, boost::asio::execution::blocking.possibly) in strand_query_test()
273 == boost::asio::execution::blocking.possibly); in strand_query_test()
276 boost::asio::query(s1, boost::asio::execution::outstanding_work) in strand_query_test()
[all …]
|
| D | read_at.cpp | 45 typedef boost::asio::io_context::executor_type executor_type;
47 test_random_access_device(boost::asio::io_context& io_context) in test_random_access_device()
79 bool check_buffers(boost::asio::uint64_t offset, in check_buffers()
89 size_t buffer_length = boost::asio::buffer_size(*iter); in check_buffers()
102 bool check_buffers(boost::asio::uint64_t offset, in check_buffers()
105 return check_buffers(offset, boost::asio::buffer_sequence_begin(buffers), in check_buffers()
106 boost::asio::buffer_sequence_end(buffers), length); in check_buffers()
110 size_t read_some_at(boost::asio::uint64_t offset, in read_some_at()
113 return boost::asio::buffer_copy(buffers, in read_some_at()
114 boost::asio::buffer(data_, length_) + offset, in read_some_at()
[all …]
|
| D | read.cpp | 46 typedef boost::asio::io_context::executor_type executor_type;
48 test_stream(boost::asio::io_context& io_context) in test_stream()
86 size_t buffer_length = boost::asio::buffer_size(*iter); in check_buffers()
100 return check_buffers(boost::asio::buffer_sequence_begin(buffers), in check_buffers()
101 boost::asio::buffer_sequence_end(buffers), length); in check_buffers()
107 size_t n = boost::asio::buffer_copy(buffers, in read_some()
108 boost::asio::buffer(data_, length_) + position_, in read_some()
127 boost::asio::post(get_executor(), in async_read_some()
128 boost::asio::detail::bind_handler( in async_read_some()
134 boost::asio::io_context& io_context_;
[all …]
|
| D | is_read_buffered.cpp | 30 typedef boost::asio::io_context io_context_type;
36 test_stream(boost::asio::io_context& io_context) in test_stream()
68 boost::asio::post(io_context_, in async_write()
69 boost::asio::detail::bind_handler(handler, error, 0)); in async_write()
89 boost::asio::post(io_context_, in async_read()
90 boost::asio::detail::bind_handler(handler, error, 0)); in async_read()
99 BOOST_ASIO_CHECK(!boost::asio::is_read_buffered< in is_read_buffered_test()
100 boost::asio::ip::tcp::socket>::value); in is_read_buffered_test()
102 BOOST_ASIO_CHECK(!!boost::asio::is_read_buffered< in is_read_buffered_test()
103 boost::asio::buffered_read_stream< in is_read_buffered_test()
[all …]
|
| D | is_write_buffered.cpp | 30 typedef boost::asio::io_context io_context_type;
36 test_stream(boost::asio::io_context& io_context) in test_stream()
68 boost::asio::post(io_context_, in async_write()
69 boost::asio::detail::bind_handler(handler, error, 0)); in async_write()
89 boost::asio::post(io_context_, in async_read()
90 boost::asio::detail::bind_handler(handler, error, 0)); in async_read()
99 BOOST_ASIO_CHECK(!boost::asio::is_write_buffered< in is_write_buffered_test()
100 boost::asio::ip::tcp::socket>::value); in is_write_buffered_test()
102 BOOST_ASIO_CHECK(!boost::asio::is_write_buffered< in is_write_buffered_test()
103 boost::asio::buffered_read_stream< in is_write_buffered_test()
[all …]
|
| /third_party/boost/boost/asio/detail/ |
| D | handler_type_requirements.hpp | 57 namespace asio { namespace
138 sizeof(boost::asio::detail::zero_arg_copyable_handler_test( \
139 boost::asio::detail::clvref< \
143 typedef boost::asio::detail::handler_type_requirements< \
145 boost::asio::detail::argbyv( \
146 boost::asio::detail::clvref< \
149 boost::asio::detail::lvref< \
161 sizeof(boost::asio::detail::two_arg_handler_test( \
162 boost::asio::detail::rvref< \
168 typedef boost::asio::detail::handler_type_requirements< \
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | handler_type_requirements.hpp | 57 namespace asio { namespace
138 sizeof(boost::asio::detail::zero_arg_copyable_handler_test( \
139 boost::asio::detail::clvref< \
143 typedef boost::asio::detail::handler_type_requirements< \
145 boost::asio::detail::argbyv( \
146 boost::asio::detail::clvref< \
149 boost::asio::detail::lvref< \
161 sizeof(boost::asio::detail::two_arg_handler_test( \
162 boost::asio::detail::rvref< \
168 typedef boost::asio::detail::handler_type_requirements< \
[all …]
|
| /third_party/boost/libs/asio/test/archetypes/ |
| D | async_ops.hpp | 37 typedef typename boost::asio::async_completion<CompletionToken, in BOOST_ASIO_INITFN_RESULT_TYPE()
40 boost::asio::async_completion<CompletionToken, in BOOST_ASIO_INITFN_RESULT_TYPE()
43 typename boost::asio::associated_allocator<handler_type>::type a in BOOST_ASIO_INITFN_RESULT_TYPE()
44 = boost::asio::get_associated_allocator(completion.completion_handler); in BOOST_ASIO_INITFN_RESULT_TYPE()
46 typename boost::asio::associated_executor<handler_type>::type ex in BOOST_ASIO_INITFN_RESULT_TYPE()
47 = boost::asio::get_associated_executor(completion.completion_handler); in BOOST_ASIO_INITFN_RESULT_TYPE()
58 typedef typename boost::asio::async_completion<CompletionToken, in BOOST_ASIO_INITFN_RESULT_TYPE()
61 boost::asio::async_completion<CompletionToken, in BOOST_ASIO_INITFN_RESULT_TYPE()
64 typename boost::asio::associated_allocator<handler_type>::type a in BOOST_ASIO_INITFN_RESULT_TYPE()
65 = boost::asio::get_associated_allocator(completion.completion_handler); in BOOST_ASIO_INITFN_RESULT_TYPE()
[all …]
|
| D | deprecated_async_ops.hpp | 37 typename boost::asio::async_result<
38 typename boost::asio::handler_type<CompletionToken,
40 deprecated_async_op_0(boost::asio::io_context& ctx, in deprecated_async_op_0()
43 typedef typename boost::asio::handler_type<CompletionToken, in deprecated_async_op_0()
48 boost::asio::async_result<handler_type> result(handler); in deprecated_async_op_0()
56 typename boost::asio::async_result<
57 typename boost::asio::handler_type<CompletionToken,
59 deprecated_async_op_ec_0(boost::asio::io_context& ctx, in deprecated_async_op_ec_0()
62 typedef typename boost::asio::handler_type<CompletionToken, in deprecated_async_op_ec_0()
67 boost::asio::async_result<handler_type> result(handler); in deprecated_async_op_ec_0()
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/chat/ |
| D | posix_chat_client.cpp | 21 using boost::asio::ip::tcp;
22 namespace posix = boost::asio::posix;
27 posix_chat_client(boost::asio::io_context& io_context, in posix_chat_client()
34 boost::asio::async_connect(socket_, endpoints, in posix_chat_client()
36 boost::asio::placeholders::error)); in posix_chat_client()
46 boost::asio::async_read(socket_, in handle_connect()
47 boost::asio::buffer(read_msg_.data(), chat_message::header_length), in handle_connect()
49 boost::asio::placeholders::error)); in handle_connect()
52 boost::asio::async_read_until(input_, input_buffer_, '\n', in handle_connect()
54 boost::asio::placeholders::error, in handle_connect()
[all …]
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/chat/ |
| D | posix_chat_client.cpp | 21 using boost::asio::ip::tcp;
22 namespace posix = boost::asio::posix;
27 posix_chat_client(boost::asio::io_context& io_context, in posix_chat_client()
34 boost::asio::async_connect(socket_, endpoints, in posix_chat_client()
36 boost::asio::placeholders::error)); in posix_chat_client()
46 boost::asio::async_read(socket_, in handle_connect()
47 boost::asio::buffer(read_msg_.data(), chat_message::header_length), in handle_connect()
49 boost::asio::placeholders::error)); in handle_connect()
52 boost::asio::async_read_until(input_, input_buffer_, '\n', in handle_connect()
54 boost::asio::placeholders::error, in handle_connect()
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/ssl/detail/ |
| D | stream_core.hpp | 31 namespace asio { namespace
47 output_buffer_(boost::asio::buffer(output_buffer_space_)), in stream_core()
49 input_buffer_(boost::asio::buffer(input_buffer_space_)) in stream_core()
60 BOOST_ASIO_MOVE_CAST(boost::asio::deadline_timer)( in stream_core()
63 BOOST_ASIO_MOVE_CAST(boost::asio::deadline_timer)( in stream_core()
67 BOOST_ASIO_MOVE_CAST(boost::asio::steady_timer)( in stream_core()
70 BOOST_ASIO_MOVE_CAST(boost::asio::steady_timer)( in stream_core()
83 other.output_buffer_ = boost::asio::mutable_buffer(0, 0); in stream_core()
84 other.input_buffer_ = boost::asio::mutable_buffer(0, 0); in stream_core()
85 other.input_ = boost::asio::const_buffer(0, 0); in stream_core()
[all …]
|
| /third_party/boost/boost/asio/ssl/detail/ |
| D | stream_core.hpp | 31 namespace asio { namespace
47 output_buffer_(boost::asio::buffer(output_buffer_space_)), in stream_core()
49 input_buffer_(boost::asio::buffer(input_buffer_space_)) in stream_core()
60 BOOST_ASIO_MOVE_CAST(boost::asio::deadline_timer)( in stream_core()
63 BOOST_ASIO_MOVE_CAST(boost::asio::deadline_timer)( in stream_core()
67 BOOST_ASIO_MOVE_CAST(boost::asio::steady_timer)( in stream_core()
70 BOOST_ASIO_MOVE_CAST(boost::asio::steady_timer)( in stream_core()
83 other.output_buffer_ = boost::asio::mutable_buffer(0, 0); in stream_core()
84 other.input_buffer_ = boost::asio::mutable_buffer(0, 0); in stream_core()
85 other.input_ = boost::asio::const_buffer(0, 0); in stream_core()
[all …]
|
| /third_party/boost/boost/asio/ |
| D | system_executor.hpp | 25 namespace asio { namespace
182 friend struct boost::asio::execution::detail::blocking_t<0>;
183 friend struct boost::asio::execution::detail::mapping_t<0>;
184 friend struct boost::asio::execution::detail::outstanding_work_t<0>;
185 friend struct boost::asio::execution::detail::relationship_t<0>;
456 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>
470 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>,
485 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>,
486 boost::asio::execution::blocking_t::possibly_t
491 typedef boost::asio::basic_system_executor<
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/ |
| D | system_executor.hpp | 25 namespace asio { namespace
182 friend struct boost::asio::execution::detail::blocking_t<0>;
183 friend struct boost::asio::execution::detail::mapping_t<0>;
184 friend struct boost::asio::execution::detail::outstanding_work_t<0>;
185 friend struct boost::asio::execution::detail::relationship_t<0>;
456 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>
470 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>,
485 boost::asio::basic_system_executor<Blocking, Relationship, Allocator>,
486 boost::asio::execution::blocking_t::possibly_t
491 typedef boost::asio::basic_system_executor<
[all …]
|
| /third_party/boost/libs/asio/test/execution/ |
| D | receiver.cpp | 55 namespace asio { namespace
117 namespace asio { namespace
190 namespace asio { namespace
263 namespace asio { namespace
307 !boost::asio::execution::is_receiver< in is_receiver_test()
313 !boost::asio::execution::is_receiver< in is_receiver_test()
319 boost::asio::execution::is_receiver< in is_receiver_test()
325 boost::asio::execution::is_receiver< in is_receiver_test()
331 boost::asio::execution::is_receiver< in is_receiver_test()
337 boost::asio::execution::is_receiver< in is_receiver_test()
[all …]
|
| /third_party/boost/libs/asio/example/cpp03/ssl/ |
| D | server.cpp | 17 typedef boost::asio::ssl::stream<boost::asio::ip::tcp::socket> ssl_socket;
22 session(boost::asio::io_context& io_context, in session()
23 boost::asio::ssl::context& context) in session()
35 socket_.async_handshake(boost::asio::ssl::stream_base::server, in start()
37 boost::asio::placeholders::error)); in start()
44 socket_.async_read_some(boost::asio::buffer(data_, max_length), in handle_handshake()
46 boost::asio::placeholders::error, in handle_handshake()
47 boost::asio::placeholders::bytes_transferred)); in handle_handshake()
60 boost::asio::async_write(socket_, in handle_read()
61 boost::asio::buffer(data_, bytes_transferred), in handle_read()
[all …]
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/ssl/ |
| D | server.cpp | 17 typedef boost::asio::ssl::stream<boost::asio::ip::tcp::socket> ssl_socket;
22 session(boost::asio::io_context& io_context, in session()
23 boost::asio::ssl::context& context) in session()
35 socket_.async_handshake(boost::asio::ssl::stream_base::server, in start()
37 boost::asio::placeholders::error)); in start()
44 socket_.async_read_some(boost::asio::buffer(data_, max_length), in handle_handshake()
46 boost::asio::placeholders::error, in handle_handshake()
47 boost::asio::placeholders::bytes_transferred)); in handle_handshake()
60 boost::asio::async_write(socket_, in handle_read()
61 boost::asio::buffer(data_, bytes_transferred), in handle_read()
[all …]
|