| /third_party/boost/libs/asio/include/boost/asio/detail/ |
| D | null_socket_service.hpp | 278 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
282 boost::asio::post(io_ex, detail::bind_handler( in async_send()
289 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
293 boost::asio::post(io_ex, detail::bind_handler( in async_send()
319 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
323 boost::asio::post(io_ex, detail::bind_handler( in async_receive()
330 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
334 boost::asio::post(io_ex, detail::bind_handler( in async_receive()
364 socket_base::message_flags&, Handler& handler, const IoExecutor& io_ex) in async_receive_with_flags() argument
368 boost::asio::post(io_ex, detail::bind_handler( in async_receive_with_flags()
[all …]
|
| D | win_iocp_handle_service.hpp | 149 Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
156 p.p = new (p.v) op(buffers, handler, io_ex); in async_write_some()
172 Handler& handler, const IoExecutor& io_ex) in async_write_some_at() argument
179 p.p = new (p.v) op(buffers, handler, io_ex); in async_write_some_at()
216 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
223 p.p = new (p.v) op(buffers, handler, io_ex); in async_read_some()
241 Handler& handler, const IoExecutor& io_ex) in async_read_some_at() argument
248 p.p = new (p.v) op(buffers, handler, io_ex); in async_read_some_at()
268 const IoExecutor& io_ex);
271 const null_buffers& buffers, Handler& handler, const IoExecutor& io_ex);
[all …]
|
| D | win_iocp_socket_service.hpp | 332 const IoExecutor& io_ex) in async_send_to() argument
339 p.p = new (p.v) op(impl.cancel_token_, buffers, handler, io_ex); in async_send_to()
357 const IoExecutor& io_ex) in async_send_to() argument
363 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_send_to()
416 const IoExecutor& io_ex) in async_receive_from() argument
424 buffers, handler, io_ex); in async_receive_from()
441 Handler& handler, const IoExecutor& io_ex) in async_receive_from() argument
447 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_receive_from()
493 endpoint_type* peer_endpoint, Handler& handler, const IoExecutor& io_ex) in async_accept() argument
503 peer_endpoint, enable_connection_aborted, handler, io_ex); in async_accept()
[all …]
|
| D | reactive_socket_service.hpp | 259 Handler& handler, const IoExecutor& io_ex) in async_send_to() argument
270 buffers, destination, flags, handler, io_ex); in async_send_to()
283 Handler& handler, const IoExecutor& io_ex) in async_send_to() argument
292 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_send_to()
357 const IoExecutor& io_ex) in async_receive_from() argument
369 buffers, sender_endpoint, flags, handler, io_ex); in async_receive_from()
385 Handler& handler, const IoExecutor& io_ex) in async_receive_from() argument
394 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_receive_from()
443 endpoint_type* peer_endpoint, Handler& handler, const IoExecutor& io_ex) in async_accept() argument
453 peer, impl.protocol_, peer_endpoint, handler, io_ex); in async_accept()
[all …]
|
| D | win_iocp_socket_service_base.hpp | 215 socket_base::wait_type w, Handler& handler, const IoExecutor& io_ex) in async_wait() argument
224 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_wait()
277 Handler& handler, const IoExecutor& io_ex) in async_send() argument
284 p.p = new (p.v) op(impl.cancel_token_, buffers, handler, io_ex); in async_send()
301 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
307 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_send()
345 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
353 buffers, handler, io_ex); in async_receive()
371 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
377 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_receive()
[all …]
|
| D | reactive_socket_service_base.hpp | 198 socket_base::wait_type w, Handler& handler, const IoExecutor& io_ex) in async_wait() argument
207 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_wait()
273 Handler& handler, const IoExecutor& io_ex) in async_send() argument
284 impl.state_, buffers, flags, handler, io_ex); in async_send()
299 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
308 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_send()
356 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
367 impl.state_, buffers, flags, handler, io_ex); in async_receive()
387 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
396 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_receive()
[all …]
|
| D | reactive_descriptor_service.hpp | 196 Handler& handler, const IoExecutor& io_ex) in async_wait() argument
205 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_wait()
271 const IoExecutor& io_ex) in async_write_some() argument
280 p.p = new (p.v) op(success_ec_, impl.descriptor_, buffers, handler, io_ex); in async_write_some()
294 const null_buffers&, Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
303 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_write_some()
351 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
360 p.p = new (p.v) op(success_ec_, impl.descriptor_, buffers, handler, io_ex); in async_read_some()
374 const null_buffers&, Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
383 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_read_some()
|
| D | winrt_ssocket_service_base.hpp | 196 Handler& handler, const IoExecutor& io_ex) in async_send() argument
205 p.p = new (p.v) op(buffers, handler, io_ex); in async_send()
220 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
224 boost::asio::post(io_ex, in async_send()
253 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
262 p.p = new (p.v) op(buffers, handler, io_ex); in async_receive()
277 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
281 boost::asio::post(io_ex, in async_receive()
|
| D | resolver_service.hpp | 91 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
97 p.p = new (p.v) op(impl, qry, scheduler_, handler, io_ex); in async_resolve()
123 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
129 p.p = new (p.v) op(impl, endpoint, scheduler_, handler, io_ex); in async_resolve()
|
| D | winrt_resolver_service.hpp | 144 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
153 p.p = new (p.v) op(query, handler, io_ex); in async_resolve()
187 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
191 boost::asio::post(io_ex, detail::bind_handler(handler, ec, results)); in async_resolve()
|
| D | win_iocp_serial_port_service.hpp | 157 Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
159 handle_service_.async_write_some(impl, buffers, handler, io_ex); in async_write_some()
176 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
178 handle_service_.async_read_some(impl, buffers, handler, io_ex); in async_read_some()
|
| /third_party/boost/boost/asio/detail/ |
| D | null_socket_service.hpp | 278 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
282 boost::asio::post(io_ex, detail::bind_handler( in async_send()
289 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
293 boost::asio::post(io_ex, detail::bind_handler( in async_send()
319 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
323 boost::asio::post(io_ex, detail::bind_handler( in async_receive()
330 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
334 boost::asio::post(io_ex, detail::bind_handler( in async_receive()
364 socket_base::message_flags&, Handler& handler, const IoExecutor& io_ex) in async_receive_with_flags() argument
368 boost::asio::post(io_ex, detail::bind_handler( in async_receive_with_flags()
[all …]
|
| D | win_iocp_handle_service.hpp | 149 Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
156 p.p = new (p.v) op(buffers, handler, io_ex); in async_write_some()
172 Handler& handler, const IoExecutor& io_ex) in async_write_some_at() argument
179 p.p = new (p.v) op(buffers, handler, io_ex); in async_write_some_at()
216 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
223 p.p = new (p.v) op(buffers, handler, io_ex); in async_read_some()
241 Handler& handler, const IoExecutor& io_ex) in async_read_some_at() argument
248 p.p = new (p.v) op(buffers, handler, io_ex); in async_read_some_at()
268 const IoExecutor& io_ex);
271 const null_buffers& buffers, Handler& handler, const IoExecutor& io_ex);
[all …]
|
| D | win_iocp_socket_service.hpp | 332 const IoExecutor& io_ex) in async_send_to() argument
339 p.p = new (p.v) op(impl.cancel_token_, buffers, handler, io_ex); in async_send_to()
357 const IoExecutor& io_ex) in async_send_to() argument
363 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_send_to()
416 const IoExecutor& io_ex) in async_receive_from() argument
424 buffers, handler, io_ex); in async_receive_from()
441 Handler& handler, const IoExecutor& io_ex) in async_receive_from() argument
447 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_receive_from()
493 endpoint_type* peer_endpoint, Handler& handler, const IoExecutor& io_ex) in async_accept() argument
503 peer_endpoint, enable_connection_aborted, handler, io_ex); in async_accept()
[all …]
|
| D | reactive_socket_service.hpp | 259 Handler& handler, const IoExecutor& io_ex) in async_send_to() argument
270 buffers, destination, flags, handler, io_ex); in async_send_to()
283 Handler& handler, const IoExecutor& io_ex) in async_send_to() argument
292 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_send_to()
357 const IoExecutor& io_ex) in async_receive_from() argument
369 buffers, sender_endpoint, flags, handler, io_ex); in async_receive_from()
385 Handler& handler, const IoExecutor& io_ex) in async_receive_from() argument
394 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_receive_from()
443 endpoint_type* peer_endpoint, Handler& handler, const IoExecutor& io_ex) in async_accept() argument
453 peer, impl.protocol_, peer_endpoint, handler, io_ex); in async_accept()
[all …]
|
| D | win_iocp_socket_service_base.hpp | 215 socket_base::wait_type w, Handler& handler, const IoExecutor& io_ex) in async_wait() argument
224 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_wait()
277 Handler& handler, const IoExecutor& io_ex) in async_send() argument
284 p.p = new (p.v) op(impl.cancel_token_, buffers, handler, io_ex); in async_send()
301 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
307 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_send()
345 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
353 buffers, handler, io_ex); in async_receive()
371 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
377 p.p = new (p.v) op(impl.cancel_token_, handler, io_ex); in async_receive()
[all …]
|
| D | reactive_socket_service_base.hpp | 198 socket_base::wait_type w, Handler& handler, const IoExecutor& io_ex) in async_wait() argument
207 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_wait()
273 Handler& handler, const IoExecutor& io_ex) in async_send() argument
284 impl.state_, buffers, flags, handler, io_ex); in async_send()
299 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
308 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_send()
356 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
367 impl.state_, buffers, flags, handler, io_ex); in async_receive()
387 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
396 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_receive()
[all …]
|
| D | reactive_descriptor_service.hpp | 196 Handler& handler, const IoExecutor& io_ex) in async_wait() argument
205 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_wait()
271 const IoExecutor& io_ex) in async_write_some() argument
280 p.p = new (p.v) op(success_ec_, impl.descriptor_, buffers, handler, io_ex); in async_write_some()
294 const null_buffers&, Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
303 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_write_some()
351 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
360 p.p = new (p.v) op(success_ec_, impl.descriptor_, buffers, handler, io_ex); in async_read_some()
374 const null_buffers&, Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
383 p.p = new (p.v) op(success_ec_, handler, io_ex); in async_read_some()
|
| D | winrt_ssocket_service_base.hpp | 196 Handler& handler, const IoExecutor& io_ex) in async_send() argument
205 p.p = new (p.v) op(buffers, handler, io_ex); in async_send()
220 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_send() argument
224 boost::asio::post(io_ex, in async_send()
253 Handler& handler, const IoExecutor& io_ex) in async_receive() argument
262 p.p = new (p.v) op(buffers, handler, io_ex); in async_receive()
277 socket_base::message_flags, Handler& handler, const IoExecutor& io_ex) in async_receive() argument
281 boost::asio::post(io_ex, in async_receive()
|
| D | resolver_service.hpp | 91 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
97 p.p = new (p.v) op(impl, qry, scheduler_, handler, io_ex); in async_resolve()
123 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
129 p.p = new (p.v) op(impl, endpoint, scheduler_, handler, io_ex); in async_resolve()
|
| D | winrt_resolver_service.hpp | 144 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
153 p.p = new (p.v) op(query, handler, io_ex); in async_resolve()
187 Handler& handler, const IoExecutor& io_ex) in async_resolve() argument
191 boost::asio::post(io_ex, detail::bind_handler(handler, ec, results)); in async_resolve()
|
| D | reactive_serial_port_service.hpp | 161 Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
163 descriptor_service_.async_write_some(impl, buffers, handler, io_ex); in async_write_some()
180 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
182 descriptor_service_.async_read_some(impl, buffers, handler, io_ex); in async_read_some()
|
| D | win_iocp_serial_port_service.hpp | 157 Handler& handler, const IoExecutor& io_ex) in async_write_some() argument
159 handle_service_.async_write_some(impl, buffers, handler, io_ex); in async_write_some()
176 Handler& handler, const IoExecutor& io_ex) in async_read_some() argument
178 handle_service_.async_read_some(impl, buffers, handler, io_ex); in async_read_some()
|
| /third_party/boost/libs/asio/example/cpp14/executors/ |
| D | async_2.cpp | 15 void async_getline(IoExecutor io_ex, std::istream& is, Handler handler) in async_getline() argument
19 get_associated_executor(handler, io_ex), in async_getline()
24 boost::asio::require(io_ex, execution::blocking.never), in async_getline()
42 void async_getlines(IoExecutor io_ex, std::istream& is, std::string init, Handler handler) in async_getlines() argument
45 auto io_work_ex = boost::asio::prefer(io_ex, in async_getlines()
50 get_associated_executor(handler, io_ex), in async_getlines()
|
| D | async_1.cpp | 15 void async_getline(IoExecutor io_ex, std::istream& is, Handler handler) in async_getline() argument
19 get_associated_executor(handler, io_ex), in async_getline()
24 boost::asio::require(io_ex, execution::blocking.never), in async_getline()
|