| /third_party/boost/libs/asio/test/ |
| D | io_context.cpp | 59 void decrement_to_zero(io_context* ioc, int* count) in decrement_to_zero() argument
66 boost::asio::post(*ioc, bindns::bind(decrement_to_zero, ioc, count)); in decrement_to_zero()
73 void nested_decrement_to_zero(io_context* ioc, int* count) in nested_decrement_to_zero() argument
79 boost::asio::dispatch(*ioc, in nested_decrement_to_zero()
80 bindns::bind(nested_decrement_to_zero, ioc, count)); in nested_decrement_to_zero()
87 void sleep_increment(io_context* ioc, int* count) in sleep_increment() argument
89 timer t(*ioc, chronons::seconds(2)); in sleep_increment()
93 boost::asio::post(*ioc, bindns::bind(sleep_increment, ioc, count)); in sleep_increment()
96 void start_sleep_increments(io_context* ioc, int* count) in start_sleep_increments() argument
99 timer t(*ioc, chronons::seconds(2)); in start_sleep_increments()
[all …]
|
| D | strand.cpp | 86 void sleep_increment(io_context* ioc, int* count) in sleep_increment() argument
88 timer t(*ioc, chronons::seconds(2)); in sleep_increment()
114 void start_sleep_increments(io_context* ioc, in start_sleep_increments() argument
118 timer t(*ioc, chronons::seconds(2)); in start_sleep_increments()
122 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
123 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
124 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
132 void io_context_run(io_context* ioc) in io_context_run() argument
134 ioc->run(); in io_context_run()
139 io_context ioc; in strand_test() local
[all …]
|
| D | io_context_strand.cpp | 85 void sleep_increment(io_context* ioc, int* count) in sleep_increment() argument
87 timer t(*ioc, chronons::seconds(2)); in sleep_increment()
113 void start_sleep_increments(io_context* ioc, io_context::strand* s, int* count) in start_sleep_increments() argument
116 timer t(*ioc, chronons::seconds(2)); in start_sleep_increments()
120 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
121 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
122 post(*s, bindns::bind(sleep_increment, ioc, count)); in start_sleep_increments()
130 void io_context_run(io_context* ioc) in io_context_run() argument
132 ioc->run(); in io_context_run()
137 io_context ioc; in strand_test() local
[all …]
|
| D | compose.cpp | 35 explicit impl_0_completion_args(boost::asio::io_context& ioc) in impl_0_completion_args() argument
36 : ioc_(ioc), in impl_0_completion_args()
65 async_0_completion_args(boost::asio::io_context& ioc, in BOOST_ASIO_INITFN_RESULT_TYPE()
69 impl_0_completion_args(ioc), token); in BOOST_ASIO_INITFN_RESULT_TYPE()
95 boost::asio::io_context ioc; in compose_0_completion_args_test() local
98 async_0_completion_args(ioc, bindns::bind(&compose_0_args_handler, &count)); in compose_0_completion_args_test()
101 BOOST_ASIO_CHECK(!ioc.stopped()); in compose_0_completion_args_test()
104 ioc.run(); in compose_0_completion_args_test()
107 BOOST_ASIO_CHECK(ioc.stopped()); in compose_0_completion_args_test()
110 ioc.restart(); in compose_0_completion_args_test()
[all …]
|
| D | write_at.cpp | 145 boost::asio::io_context ioc; in test_3_arg_const_buffer_write_at() local
146 test_random_access_device s(ioc); in test_3_arg_const_buffer_write_at()
187 boost::asio::io_context ioc; in test_3_arg_mutable_buffer_write_at() local
188 test_random_access_device s(ioc); in test_3_arg_mutable_buffer_write_at()
229 boost::asio::io_context ioc; in test_3_arg_vector_buffers_write_at() local
230 test_random_access_device s(ioc); in test_3_arg_vector_buffers_write_at()
272 boost::asio::io_context ioc; in test_4_arg_nothrow_const_buffer_write_at() local
273 test_random_access_device s(ioc); in test_4_arg_nothrow_const_buffer_write_at()
321 boost::asio::io_context ioc; in test_4_arg_nothrow_mutable_buffer_write_at() local
322 test_random_access_device s(ioc); in test_4_arg_nothrow_mutable_buffer_write_at()
[all …]
|
| D | write.cpp | 149 boost::asio::io_context ioc; in test_2_arg_zero_buffers_write() local
150 test_stream s(ioc); in test_2_arg_zero_buffers_write()
159 boost::asio::io_context ioc; in test_2_arg_const_buffer_write() local
160 test_stream s(ioc); in test_2_arg_const_buffer_write()
184 boost::asio::io_context ioc; in test_2_arg_mutable_buffer_write() local
185 test_stream s(ioc); in test_2_arg_mutable_buffer_write()
209 boost::asio::io_context ioc; in test_2_arg_vector_buffers_write() local
210 test_stream s(ioc); in test_2_arg_vector_buffers_write()
236 boost::asio::io_context ioc; in test_2_arg_dynamic_string_write() local
237 test_stream s(ioc); in test_2_arg_dynamic_string_write()
[all …]
|
| D | read_until.cpp | 109 boost::asio::io_context ioc; in test_dynamic_string_read_until_char() local
110 test_stream s(ioc); in test_dynamic_string_read_until_char()
199 boost::asio::io_context ioc; in test_streambuf_read_until_char() local
200 test_stream s(ioc); in test_streambuf_read_until_char()
286 boost::asio::io_context ioc; in test_dynamic_string_read_until_string() local
287 test_stream s(ioc); in test_dynamic_string_read_until_string()
376 boost::asio::io_context ioc; in test_streambuf_read_until_string() local
377 test_stream s(ioc); in test_streambuf_read_until_string()
492 boost::asio::io_context ioc; in test_dynamic_string_read_until_match_condition() local
493 test_stream s(ioc); in test_dynamic_string_read_until_match_condition()
[all …]
|
| D | deadline_timer.cpp | 83 boost::asio::io_context ioc; in deadline_timer_test() local
88 boost::asio::deadline_timer t1(ioc, seconds(1)); in deadline_timer_test()
98 boost::asio::deadline_timer t2(ioc, seconds(1) + microseconds(500000)); in deadline_timer_test()
126 boost::asio::deadline_timer t3(ioc, seconds(5)); in deadline_timer_test()
132 ioc.run(); in deadline_timer_test()
144 boost::asio::deadline_timer t4(ioc, seconds(1)); in deadline_timer_test()
150 ioc.restart(); in deadline_timer_test()
151 ioc.run(); in deadline_timer_test()
163 boost::asio::deadline_timer t5(ioc, seconds(10)); in deadline_timer_test()
166 boost::asio::deadline_timer t6(ioc, seconds(1)); in deadline_timer_test()
[all …]
|
| D | read_at.cpp | 150 boost::asio::io_context ioc; in test_3_arg_mutable_buffer_read_at() local
151 test_random_access_device s(ioc); in test_3_arg_mutable_buffer_read_at()
199 boost::asio::io_context ioc; in test_3_arg_vector_buffers_read_at() local
200 test_random_access_device s(ioc); in test_3_arg_vector_buffers_read_at()
249 boost::asio::io_context ioc; in test_3_arg_streambuf_read_at() local
250 test_random_access_device s(ioc); in test_3_arg_streambuf_read_at()
302 boost::asio::io_context ioc; in test_4_arg_nothrow_mutable_buffer_read_at() local
303 test_random_access_device s(ioc); in test_4_arg_nothrow_mutable_buffer_read_at()
358 boost::asio::io_context ioc; in test_4_arg_nothrow_vector_buffers_read_at() local
359 test_random_access_device s(ioc); in test_4_arg_nothrow_vector_buffers_read_at()
[all …]
|
| D | read.cpp | 147 boost::asio::io_context ioc; in test_2_arg_zero_buffers_read() local
148 test_stream s(ioc); in test_2_arg_zero_buffers_read()
157 boost::asio::io_context ioc; in test_2_arg_mutable_buffer_read() local
158 test_stream s(ioc); in test_2_arg_mutable_buffer_read()
186 boost::asio::io_context ioc; in test_2_arg_vector_buffers_read() local
187 test_stream s(ioc); in test_2_arg_vector_buffers_read()
217 boost::asio::io_context ioc; in test_2_arg_dynamic_string_read() local
218 test_stream s(ioc); in test_2_arg_dynamic_string_read()
251 boost::asio::io_context ioc; in test_2_arg_streambuf_read() local
252 test_stream s(ioc); in test_2_arg_streambuf_read()
[all …]
|
| D | system_timer.cpp | 96 boost::asio::io_context ioc; in system_timer_test() local
97 const boost::asio::io_context::executor_type ioc_ex = ioc.get_executor(); in system_timer_test()
102 boost::asio::system_timer t1(ioc, seconds(1)); in system_timer_test()
140 boost::asio::system_timer t3(ioc, seconds(5)); in system_timer_test()
146 ioc.run(); in system_timer_test()
158 boost::asio::system_timer t4(ioc, seconds(1)); in system_timer_test()
164 ioc.restart(); in system_timer_test()
165 ioc.run(); in system_timer_test()
177 boost::asio::system_timer t5(ioc, seconds(10)); in system_timer_test()
179 boost::asio::system_timer t6(ioc, seconds(1)); in system_timer_test()
[all …]
|
| /third_party/boost/libs/beast/test/beast/websocket/ |
| D | read3.cpp | 34 net::io_context ioc; in testSuspend() local
35 stream<test::stream> ws{ioc, fc}; in testSuspend()
48 ioc.run_one(); in testSuspend()
58 ioc.run(); in testSuspend()
66 net::io_context ioc; in testSuspend() local
67 stream<test::stream> ws{ioc, fc}; in testSuspend()
89 ioc.run(); in testSuspend()
97 net::io_context ioc; in testSuspend() local
98 stream<test::stream> ws{ioc, fc}; in testSuspend()
127 ioc.run(); in testSuspend()
[all …]
|
| D | timer.cpp | 31 net::io_context ioc; in testIdlePing() local
36 stream<tcp::socket> ws1(ioc); in testIdlePing()
37 stream<tcp::socket> ws2(ioc); in testIdlePing()
41 test::run(ioc); in testIdlePing()
60 test::run_for(ioc, std::chrono::milliseconds(500)); in testIdlePing()
64 test::run(ioc); in testIdlePing()
69 stream<tcp::socket> ws1(ioc); in testIdlePing()
70 stream<tcp::socket> ws2(ioc); in testIdlePing()
74 test::run(ioc); in testIdlePing()
83 test::run(ioc); in testIdlePing()
[all …]
|
| D | read1.cpp | 29 net::io_context ioc; in testTimeout() local
34 stream<tcp::socket> ws1(ioc); in testTimeout()
35 stream<tcp::socket> ws2(ioc); in testTimeout()
39 test::run(ioc); in testTimeout()
45 test::run(ioc); in testTimeout()
49 stream<test::stream> ws1(ioc); in testTimeout()
50 stream<test::stream> ws2(ioc); in testTimeout()
54 test::run(ioc); in testTimeout()
60 test::run(ioc); in testTimeout()
66 stream<tcp::socket> ws1(ioc); in testTimeout()
[all …]
|
| D | ping.cpp | 111 net::io_context ioc; in testSuspend() local
112 stream<test::stream> ws{ioc, fc}; in testSuspend()
136 ioc.run(); in testSuspend()
144 net::io_context ioc; in testSuspend() local
145 stream<test::stream> ws{ioc, fc}; in testSuspend()
168 ioc.run(); in testSuspend()
176 net::io_context ioc; in testSuspend() local
177 stream<test::stream> ws{ioc, fc}; in testSuspend()
195 ioc.run_one(); in testSuspend()
196 if(! BEAST_EXPECT(! ioc.stopped())) in testSuspend()
[all …]
|
| D | close.cpp | 181 net::io_context ioc; in testTimeout() local
186 stream<tcp::socket> ws1(ioc); in testTimeout()
187 stream<tcp::socket> ws2(ioc); in testTimeout()
191 test::run(ioc); in testTimeout()
195 test::run(ioc); in testTimeout()
199 stream<test::stream> ws1(ioc); in testTimeout()
200 stream<test::stream> ws2(ioc); in testTimeout()
204 test::run(ioc); in testTimeout()
208 test::run(ioc); in testTimeout()
214 stream<tcp::socket> ws1(ioc); in testTimeout()
[all …]
|
| D | handshake.cpp | 502 net::io_context ioc; in testMoveOnly() local
503 stream<test::stream> ws{ioc}; in testMoveOnly()
521 net::io_context ioc; in testAsync() local
526 stream<tcp::socket> ws1(ioc); in testAsync()
527 stream<tcp::socket> ws2(ioc); in testAsync()
532 test::run_for(ioc, std::chrono::seconds(1)); in testAsync()
536 stream<test::stream> ws1(ioc); in testAsync()
537 stream<test::stream> ws2(ioc); in testAsync()
542 test::run_for(ioc, std::chrono::seconds(1)); in testAsync()
548 stream<tcp::socket> ws1(ioc); in testAsync()
[all …]
|
| D | accept.cpp | 67 net::io_context ioc; in fail_loop() local
74 ws(ioc, fc); in fail_loop()
104 net::io_context ioc; in testMatrix() local
306 net::io_context ioc; in testOversized() local
317 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc, in testOversized()
343 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc, in testOversized()
372 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc}; in testOversized()
398 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc}; in testOversized()
426 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc, in testOversized()
452 stream<test::basic_stream<net::io_context::executor_type>> ws{ioc, in testOversized()
[all …]
|
| D | write.cpp | 287 net::io_context ioc; in testPausationAbandoning() local
288 auto ws = std::make_shared<stream<test::stream>>(ioc); in testPausationAbandoning()
308 net::io_context ioc; in testWriteSuspend() local
309 stream<test::stream> ws{ioc, fc}; in testWriteSuspend()
333 ioc.run(); in testWriteSuspend()
341 net::io_context ioc; in testWriteSuspend() local
342 stream<test::stream> ws{ioc, fc}; in testWriteSuspend()
365 ioc.run(); in testWriteSuspend()
373 net::io_context ioc; in testWriteSuspend() local
374 stream<test::stream> ws{ioc, fc}; in testWriteSuspend()
[all …]
|
| /third_party/boost/libs/beast/test/beast/core/ |
| D | basic_stream.cpp | 145 net::io_context ioc; member
150 : a(ioc) in test_acceptor()
330 net::io_context ioc; in testSpecialMembers() local
335 auto ex = ioc.get_executor(); in testSpecialMembers()
336 basic_stream<tcp, executor> s1(ioc); in testSpecialMembers()
338 basic_stream<tcp, executor> s3(ioc, tcp::v4()); in testSpecialMembers()
341 net::basic_stream_socket<tcp, executor>(ioc); in testSpecialMembers()
363 auto ex = net::make_strand(ioc); in testSpecialMembers()
384 tcp_stream s(ioc); in testSpecialMembers()
399 simple_rate_policy> s(ioc); in testSpecialMembers()
[all …]
|
| D | _detail_bind_continuation.cpp | 61 net::io_context ioc;
66 test_executor<> ex(ioc.get_executor());
70 ioc.run();
71 ioc.restart();
76 test_executor<> ex(ioc.get_executor());
80 ioc.run();
81 ioc.restart();
86 test_executor<> ex(ioc.get_executor());
90 ioc.run();
91 ioc.restart();
[all …]
|
| D | _detail_get_io_context.cpp | 29 net::io_context ioc; in testFunction() local
32 BEAST_EXPECT(get_io_context(ioc) == &ioc); in testFunction()
33 BEAST_EXPECT(get_io_context(ioc.get_executor()) == &ioc); in testFunction()
34 BEAST_EXPECT(get_io_context(net::make_strand(ioc)) == &ioc); in testFunction()
35 BEAST_EXPECT(get_io_context(net::any_io_executor(ioc.get_executor())) == &ioc); in testFunction()
|
| D | detect_ssl.cpp | 70 net::io_context ioc; in testRead() local
77 test::stream s1(ioc); in testRead()
89 test::stream s1(ioc); in testRead()
103 test::stream s1(ioc); in testRead()
114 test::stream s1(ioc); in testRead()
127 net::io_context ioc; in testAsyncRead() local
133 test::stream s1(ioc); in testAsyncRead()
136 test::run(ioc); in testAsyncRead()
143 test::stream s1(ioc); in testAsyncRead()
148 test::run(ioc); in testAsyncRead()
[all …]
|
| /third_party/boost/libs/beast/test/beast/_experimental/ |
| D | stream.cpp | 37 net::io_context ioc; in testTestStream() local
40 test::stream ts(ioc); in testTestStream()
43 test::stream ts(ioc); in testTestStream()
47 test::stream t1(ioc); in testTestStream()
51 test::stream t1(ioc); in testTestStream()
58 net::io_context ioc; in testTestStream() local
59 test::stream ts(ioc); in testTestStream()
68 net::io_context ioc; in testTestStream() local
70 test::stream ts(ioc); in testTestStream()
75 test::run(ioc); in testTestStream()
[all …]
|
| /third_party/boost/libs/asio/test/windows/ |
| D | overlapped_ptr.cpp | 53 io_context ioc; in test() local
54 boost::asio::any_io_executor ex1(ioc.get_executor()); in test()
56 boost::asio::executor ex2(ioc.get_executor()); in test()
63 win::overlapped_ptr ptr2(ioc, &overlapped_handler_1); in test()
64 win::overlapped_ptr ptr3(ioc, overlapped_handler_2()); in test()
66 win::overlapped_ptr ptr4(ioc.get_executor(), &overlapped_handler_1); in test()
67 win::overlapped_ptr ptr5(ioc.get_executor(), overlapped_handler_2()); in test()
79 ptr2.reset(ioc, &overlapped_handler_1); in test()
80 ptr3.reset(ioc, overlapped_handler_2()); in test()
82 ptr2.reset(ioc.get_executor(), &overlapped_handler_1); in test()
[all …]
|