From aea4e8ad9a9b659c4c29ff6827cf5f6a94b06056 Mon Sep 17 00:00:00 2001 From: Tristan Stenner Date: Sat, 11 Nov 2023 10:14:49 +0100 Subject: [PATCH] Update Asio for MacOS --- thirdparty/asio/asio.hpp | 32 +- .../asio/asio/any_completion_executor.hpp | 342 ++++ .../asio/asio/any_completion_handler.hpp | 762 ++++++++ thirdparty/asio/asio/any_io_executor.hpp | 135 +- thirdparty/asio/asio/append.hpp | 78 + thirdparty/asio/asio/as_tuple.hpp | 139 ++ thirdparty/asio/asio/associated_allocator.hpp | 112 +- .../asio/associated_cancellation_slot.hpp | 79 +- thirdparty/asio/asio/associated_executor.hpp | 57 +- .../asio/associated_immediate_executor.hpp | 297 +++ thirdparty/asio/asio/associator.hpp | 2 +- thirdparty/asio/asio/async_result.hpp | 408 +++- thirdparty/asio/asio/awaitable.hpp | 11 +- .../asio/asio/basic_datagram_socket.hpp | 331 ++-- thirdparty/asio/asio/basic_deadline_timer.hpp | 48 +- thirdparty/asio/asio/basic_file.hpp | 829 +++++++++ thirdparty/asio/asio/basic_io_object.hpp | 2 +- .../asio/asio/basic_random_access_file.hpp | 701 +++++++ thirdparty/asio/asio/basic_raw_socket.hpp | 335 ++-- thirdparty/asio/asio/basic_readable_pipe.hpp | 635 +++++++ .../asio/asio/basic_seq_packet_socket.hpp | 135 +- thirdparty/asio/asio/basic_serial_port.hpp | 159 +- thirdparty/asio/asio/basic_signal_set.hpp | 109 +- thirdparty/asio/asio/basic_socket.hpp | 90 +- .../asio/asio/basic_socket_acceptor.hpp | 469 +++-- .../asio/asio/basic_socket_iostream.hpp | 2 +- .../asio/asio/basic_socket_streambuf.hpp | 2 +- thirdparty/asio/asio/basic_stream_file.hpp | 754 ++++++++ thirdparty/asio/asio/basic_stream_socket.hpp | 241 ++- thirdparty/asio/asio/basic_streambuf.hpp | 2 +- thirdparty/asio/asio/basic_streambuf_fwd.hpp | 2 +- thirdparty/asio/asio/basic_waitable_timer.hpp | 48 +- thirdparty/asio/asio/basic_writable_pipe.hpp | 631 +++++++ thirdparty/asio/asio/bind_allocator.hpp | 733 ++++++++ .../asio/asio/bind_cancellation_slot.hpp | 39 +- thirdparty/asio/asio/bind_executor.hpp | 75 +- .../asio/asio/bind_immediate_executor.hpp | 736 ++++++++ thirdparty/asio/asio/buffer.hpp | 497 ++++- thirdparty/asio/asio/buffer_registration.hpp | 328 ++++ thirdparty/asio/asio/buffered_read_stream.hpp | 53 +- .../asio/asio/buffered_read_stream_fwd.hpp | 2 +- thirdparty/asio/asio/buffered_stream.hpp | 49 +- thirdparty/asio/asio/buffered_stream_fwd.hpp | 2 +- .../asio/asio/buffered_write_stream.hpp | 53 +- .../asio/asio/buffered_write_stream_fwd.hpp | 2 +- thirdparty/asio/asio/buffers_iterator.hpp | 2 +- thirdparty/asio/asio/cancellation_signal.hpp | 74 +- thirdparty/asio/asio/cancellation_state.hpp | 2 +- thirdparty/asio/asio/cancellation_type.hpp | 2 +- thirdparty/asio/asio/co_spawn.hpp | 42 +- thirdparty/asio/asio/completion_condition.hpp | 2 +- thirdparty/asio/asio/compose.hpp | 421 ++++- thirdparty/asio/asio/connect.hpp | 193 +- thirdparty/asio/asio/connect_pipe.hpp | 83 + thirdparty/asio/asio/consign.hpp | 88 + thirdparty/asio/asio/coroutine.hpp | 2 +- thirdparty/asio/asio/deadline_timer.hpp | 2 +- thirdparty/asio/asio/defer.hpp | 182 +- thirdparty/asio/asio/deferred.hpp | 802 ++++++++ thirdparty/asio/asio/detached.hpp | 11 +- thirdparty/asio/asio/detail/array.hpp | 2 +- thirdparty/asio/asio/detail/array_fwd.hpp | 2 +- thirdparty/asio/asio/detail/assert.hpp | 2 +- thirdparty/asio/asio/detail/atomic_count.hpp | 5 +- .../detail/base_from_cancellation_state.hpp | 2 +- .../asio/detail/base_from_completion_cond.hpp | 2 +- thirdparty/asio/asio/detail/bind_handler.hpp | 124 +- .../asio/asio/detail/blocking_executor_op.hpp | 3 +- .../asio/asio/detail/buffer_resize_guard.hpp | 2 +- .../asio/detail/buffer_sequence_adapter.hpp | 193 +- .../asio/detail/buffered_stream_storage.hpp | 2 +- .../asio/asio/detail/bulk_executor_op.hpp | 3 +- thirdparty/asio/asio/detail/call_stack.hpp | 2 +- thirdparty/asio/asio/detail/chrono.hpp | 2 +- .../asio/asio/detail/chrono_time_traits.hpp | 2 +- .../asio/asio/detail/completion_handler.hpp | 2 +- thirdparty/asio/asio/detail/composed_work.hpp | 328 ++++ .../asio/asio/detail/concurrency_hint.hpp | 2 +- .../detail/conditionally_enabled_event.hpp | 2 +- .../detail/conditionally_enabled_mutex.hpp | 2 +- thirdparty/asio/asio/detail/config.hpp | 391 +++- .../asio/asio/detail/consuming_buffers.hpp | 39 +- thirdparty/asio/asio/detail/cstddef.hpp | 2 +- thirdparty/asio/asio/detail/cstdint.hpp | 4 +- thirdparty/asio/asio/detail/date_time_fwd.hpp | 2 +- .../asio/detail/deadline_timer_service.hpp | 2 +- .../asio/asio/detail/dependent_type.hpp | 2 +- .../asio/asio/detail/descriptor_ops.hpp | 44 +- .../asio/asio/detail/descriptor_read_op.hpp | 42 +- .../asio/asio/detail/descriptor_write_op.hpp | 41 +- .../asio/asio/detail/dev_poll_reactor.hpp | 34 +- thirdparty/asio/asio/detail/epoll_reactor.hpp | 27 +- thirdparty/asio/asio/detail/event.hpp | 2 +- .../detail/eventfd_select_interrupter.hpp | 2 +- thirdparty/asio/asio/detail/exception.hpp | 40 + .../asio/asio/detail/executor_function.hpp | 2 +- thirdparty/asio/asio/detail/executor_op.hpp | 3 +- .../asio/asio/detail/fd_set_adapter.hpp | 2 +- thirdparty/asio/asio/detail/fenced_block.hpp | 2 +- thirdparty/asio/asio/detail/functional.hpp | 2 +- thirdparty/asio/asio/detail/future.hpp | 2 +- .../asio/asio/detail/gcc_arm_fenced_block.hpp | 2 +- .../asio/detail/gcc_hppa_fenced_block.hpp | 2 +- .../asio/detail/gcc_sync_fenced_block.hpp | 2 +- .../asio/asio/detail/gcc_x86_fenced_block.hpp | 4 +- thirdparty/asio/asio/detail/global.hpp | 2 +- .../asio/detail/handler_alloc_helpers.hpp | 10 +- .../asio/asio/detail/handler_cont_helpers.hpp | 2 +- .../asio/detail/handler_invoke_helpers.hpp | 2 +- .../asio/asio/detail/handler_tracking.hpp | 2 +- .../asio/detail/handler_type_requirements.hpp | 2 +- thirdparty/asio/asio/detail/handler_work.hpp | 64 +- thirdparty/asio/asio/detail/hash_map.hpp | 2 +- .../detail/impl/buffer_sequence_adapter.ipp | 2 +- .../asio/asio/detail/impl/descriptor_ops.ipp | 372 +++- .../asio/detail/impl/dev_poll_reactor.hpp | 16 +- .../asio/detail/impl/dev_poll_reactor.ipp | 17 +- .../asio/asio/detail/impl/epoll_reactor.hpp | 4 +- .../asio/asio/detail/impl/epoll_reactor.ipp | 25 +- .../impl/eventfd_select_interrupter.ipp | 2 +- .../asio/detail/impl/handler_tracking.ipp | 6 +- .../impl/io_uring_descriptor_service.ipp | 205 ++ .../detail/impl/io_uring_file_service.ipp | 140 ++ .../asio/detail/impl/io_uring_service.hpp | 112 ++ .../asio/detail/impl/io_uring_service.ipp | 909 +++++++++ .../impl/io_uring_socket_service_base.ipp | 249 +++ .../asio/asio/detail/impl/kqueue_reactor.hpp | 4 +- .../asio/asio/detail/impl/kqueue_reactor.ipp | 21 +- .../asio/asio/detail/impl/null_event.ipp | 2 +- .../detail/impl/pipe_select_interrupter.ipp | 2 +- .../asio/asio/detail/impl/posix_event.ipp | 2 +- .../asio/asio/detail/impl/posix_mutex.ipp | 2 +- ...vice.ipp => posix_serial_port_service.ipp} | 57 +- .../asio/asio/detail/impl/posix_thread.ipp | 2 +- .../asio/asio/detail/impl/posix_tss_ptr.ipp | 2 +- .../impl/reactive_descriptor_service.ipp | 25 +- .../impl/reactive_socket_service_base.ipp | 48 +- .../detail/impl/resolver_service_base.ipp | 2 +- .../asio/asio/detail/impl/scheduler.ipp | 24 +- .../asio/asio/detail/impl/select_reactor.hpp | 4 +- .../asio/asio/detail/impl/select_reactor.ipp | 53 +- .../asio/detail/impl/service_registry.hpp | 2 +- .../asio/detail/impl/service_registry.ipp | 2 +- .../asio/detail/impl/signal_set_service.ipp | 168 +- .../asio/asio/detail/impl/socket_ops.ipp | 259 +-- .../detail/impl/socket_select_interrupter.ipp | 8 +- .../detail/impl/strand_executor_service.hpp | 17 +- .../detail/impl/strand_executor_service.ipp | 2 +- .../asio/asio/detail/impl/strand_service.hpp | 2 +- .../asio/asio/detail/impl/strand_service.ipp | 2 +- .../asio/asio/detail/impl/thread_context.ipp | 2 +- .../asio/asio/detail/impl/throw_error.ipp | 22 +- .../asio/detail/impl/timer_queue_ptime.ipp | 2 +- .../asio/asio/detail/impl/timer_queue_set.ipp | 2 +- .../asio/asio/detail/impl/win_event.ipp | 2 +- .../detail/impl/win_iocp_file_service.ipp | 265 +++ .../detail/impl/win_iocp_handle_service.ipp | 96 +- .../asio/detail/impl/win_iocp_io_context.hpp | 2 +- .../asio/detail/impl/win_iocp_io_context.ipp | 11 +- .../impl/win_iocp_serial_port_service.ipp | 10 +- .../impl/win_iocp_socket_service_base.ipp | 22 +- .../asio/asio/detail/impl/win_mutex.ipp | 2 +- .../detail/impl/win_object_handle_service.ipp | 6 +- .../asio/detail/impl/win_static_mutex.ipp | 2 +- .../asio/asio/detail/impl/win_thread.ipp | 2 +- .../asio/asio/detail/impl/win_tss_ptr.ipp | 2 +- .../impl/winrt_ssocket_service_base.ipp | 8 +- .../detail/impl/winrt_timer_scheduler.hpp | 2 +- .../detail/impl/winrt_timer_scheduler.ipp | 2 +- .../asio/asio/detail/impl/winsock_init.ipp | 2 +- .../defer.hpp => detail/initiate_defer.hpp} | 76 +- .../initiate_dispatch.hpp} | 76 +- .../post.hpp => detail/initiate_post.hpp} | 76 +- thirdparty/asio/asio/detail/io_control.hpp | 2 +- .../asio/asio/detail/io_object_impl.hpp | 13 +- .../detail/io_uring_descriptor_read_at_op.hpp | 195 ++ .../detail/io_uring_descriptor_read_op.hpp | 190 ++ .../detail/io_uring_descriptor_service.hpp | 687 +++++++ .../io_uring_descriptor_write_at_op.hpp | 189 ++ .../detail/io_uring_descriptor_write_op.hpp | 185 ++ .../asio/detail/io_uring_file_service.hpp | 261 +++ .../asio/detail/io_uring_null_buffers_op.hpp | 115 ++ .../asio/asio/detail/io_uring_operation.hpp | 84 + .../asio/asio/detail/io_uring_service.hpp | 319 ++++ .../asio/detail/io_uring_socket_accept_op.hpp | 285 +++ .../detail/io_uring_socket_connect_op.hpp | 141 ++ .../asio/detail/io_uring_socket_recv_op.hpp | 205 ++ .../detail/io_uring_socket_recvfrom_op.hpp | 206 ++ .../detail/io_uring_socket_recvmsg_op.hpp | 192 ++ .../asio/detail/io_uring_socket_send_op.hpp | 191 ++ .../asio/detail/io_uring_socket_sendto_op.hpp | 194 ++ .../asio/detail/io_uring_socket_service.hpp | 631 +++++++ .../detail/io_uring_socket_service_base.hpp | 663 +++++++ .../asio/asio/detail/io_uring_wait_op.hpp | 113 ++ .../asio/asio/detail/is_buffer_sequence.hpp | 28 +- thirdparty/asio/asio/detail/is_executor.hpp | 2 +- .../asio/asio/detail/keyword_tss_ptr.hpp | 2 +- .../asio/asio/detail/kqueue_reactor.hpp | 27 +- .../asio/detail/local_free_on_block_exit.hpp | 2 +- .../asio/asio/detail/macos_fenced_block.hpp | 2 +- thirdparty/asio/asio/detail/memory.hpp | 36 +- thirdparty/asio/asio/detail/mutex.hpp | 2 +- .../asio/asio/detail/non_const_lvalue.hpp | 2 +- thirdparty/asio/asio/detail/noncopyable.hpp | 2 +- thirdparty/asio/asio/detail/null_event.hpp | 2 +- .../asio/asio/detail/null_fenced_block.hpp | 2 +- thirdparty/asio/asio/detail/null_global.hpp | 2 +- thirdparty/asio/asio/detail/null_mutex.hpp | 6 +- thirdparty/asio/asio/detail/null_reactor.hpp | 23 +- .../asio/asio/detail/null_signal_blocker.hpp | 2 +- .../asio/asio/detail/null_socket_service.hpp | 2 +- .../asio/asio/detail/null_static_mutex.hpp | 2 +- thirdparty/asio/asio/detail/null_thread.hpp | 2 +- thirdparty/asio/asio/detail/null_tss_ptr.hpp | 2 +- thirdparty/asio/asio/detail/object_pool.hpp | 2 +- .../asio/asio/detail/old_win_sdk_compat.hpp | 2 +- thirdparty/asio/asio/detail/op_queue.hpp | 2 +- thirdparty/asio/asio/detail/operation.hpp | 2 +- .../asio/detail/pipe_select_interrupter.hpp | 2 +- thirdparty/asio/asio/detail/pop_options.hpp | 10 +- thirdparty/asio/asio/detail/posix_event.hpp | 2 +- .../asio/asio/detail/posix_fd_set_adapter.hpp | 2 +- thirdparty/asio/asio/detail/posix_global.hpp | 2 +- thirdparty/asio/asio/detail/posix_mutex.hpp | 2 +- ...vice.hpp => posix_serial_port_service.hpp} | 48 +- .../asio/asio/detail/posix_signal_blocker.hpp | 2 +- .../asio/asio/detail/posix_static_mutex.hpp | 2 +- thirdparty/asio/asio/detail/posix_thread.hpp | 2 +- thirdparty/asio/asio/detail/posix_tss_ptr.hpp | 2 +- thirdparty/asio/asio/detail/push_options.hpp | 14 +- .../detail/reactive_descriptor_service.hpp | 109 +- .../asio/detail/reactive_null_buffers_op.hpp | 36 +- .../asio/detail/reactive_socket_accept_op.hpp | 88 +- .../detail/reactive_socket_connect_op.hpp | 42 +- .../asio/detail/reactive_socket_recv_op.hpp | 41 +- .../detail/reactive_socket_recvfrom_op.hpp | 42 +- .../detail/reactive_socket_recvmsg_op.hpp | 42 +- .../asio/detail/reactive_socket_send_op.hpp | 42 +- .../asio/detail/reactive_socket_sendto_op.hpp | 41 +- .../asio/detail/reactive_socket_service.hpp | 70 +- .../detail/reactive_socket_service_base.hpp | 158 +- .../asio/asio/detail/reactive_wait_op.hpp | 36 +- thirdparty/asio/asio/detail/reactor.hpp | 32 +- thirdparty/asio/asio/detail/reactor_fwd.hpp | 40 - thirdparty/asio/asio/detail/reactor_op.hpp | 2 +- .../asio/asio/detail/reactor_op_queue.hpp | 2 +- .../asio/asio/detail/recycling_allocator.hpp | 2 +- thirdparty/asio/asio/detail/regex_fwd.hpp | 2 +- .../asio/asio/detail/resolve_endpoint_op.hpp | 3 +- thirdparty/asio/asio/detail/resolve_op.hpp | 2 +- .../asio/asio/detail/resolve_query_op.hpp | 3 +- .../asio/asio/detail/resolver_service.hpp | 4 +- .../asio/detail/resolver_service_base.hpp | 2 +- thirdparty/asio/asio/detail/scheduler.hpp | 20 +- .../asio/asio/detail/scheduler_operation.hpp | 2 +- .../asio/asio/detail/scheduler_task.hpp | 49 + .../asio/detail/scheduler_thread_info.hpp | 2 +- thirdparty/asio/asio/detail/scoped_lock.hpp | 2 +- thirdparty/asio/asio/detail/scoped_ptr.hpp | 2 +- .../asio/asio/detail/select_interrupter.hpp | 2 +- .../asio/asio/detail/select_reactor.hpp | 49 +- .../asio/asio/detail/service_registry.hpp | 2 +- .../asio/asio/detail/signal_blocker.hpp | 2 +- .../asio/asio/detail/signal_handler.hpp | 2 +- thirdparty/asio/asio/detail/signal_init.hpp | 2 +- thirdparty/asio/asio/detail/signal_op.hpp | 6 +- .../asio/asio/detail/signal_set_service.hpp | 71 +- thirdparty/asio/asio/detail/socket_holder.hpp | 2 +- thirdparty/asio/asio/detail/socket_ops.hpp | 82 +- thirdparty/asio/asio/detail/socket_option.hpp | 2 +- .../asio/detail/socket_select_interrupter.hpp | 2 +- thirdparty/asio/asio/detail/socket_types.hpp | 12 +- .../asio/asio/detail/solaris_fenced_block.hpp | 2 +- .../asio/asio/detail/source_location.hpp | 2 +- thirdparty/asio/asio/detail/static_mutex.hpp | 2 +- thirdparty/asio/asio/detail/std_event.hpp | 2 +- .../asio/asio/detail/std_fenced_block.hpp | 2 +- thirdparty/asio/asio/detail/std_global.hpp | 2 +- thirdparty/asio/asio/detail/std_mutex.hpp | 2 +- .../asio/asio/detail/std_static_mutex.hpp | 2 +- thirdparty/asio/asio/detail/std_thread.hpp | 2 +- .../asio/detail/strand_executor_service.hpp | 2 +- .../asio/asio/detail/strand_service.hpp | 2 +- thirdparty/asio/asio/detail/string_view.hpp | 2 +- thirdparty/asio/asio/detail/thread.hpp | 2 +- .../asio/asio/detail/thread_context.hpp | 2 +- thirdparty/asio/asio/detail/thread_group.hpp | 2 +- .../asio/asio/detail/thread_info_base.hpp | 6 +- thirdparty/asio/asio/detail/throw_error.hpp | 27 +- .../asio/asio/detail/throw_exception.hpp | 10 +- thirdparty/asio/asio/detail/timer_queue.hpp | 2 +- .../asio/asio/detail/timer_queue_base.hpp | 2 +- .../asio/asio/detail/timer_queue_ptime.hpp | 2 +- .../asio/asio/detail/timer_queue_set.hpp | 2 +- .../asio/asio/detail/timer_scheduler.hpp | 4 +- .../asio/asio/detail/timer_scheduler_fwd.hpp | 4 +- thirdparty/asio/asio/detail/tss_ptr.hpp | 2 +- thirdparty/asio/asio/detail/type_traits.hpp | 10 +- thirdparty/asio/asio/detail/utility.hpp | 83 + .../asio/asio/detail/variadic_templates.hpp | 2 +- thirdparty/asio/asio/detail/wait_handler.hpp | 2 +- thirdparty/asio/asio/detail/wait_op.hpp | 2 +- thirdparty/asio/asio/detail/win_event.hpp | 2 +- .../asio/asio/detail/win_fd_set_adapter.hpp | 2 +- .../asio/asio/detail/win_fenced_block.hpp | 2 +- thirdparty/asio/asio/detail/win_global.hpp | 2 +- .../asio/detail/win_iocp_file_service.hpp | 287 +++ .../asio/detail/win_iocp_handle_read_op.hpp | 5 +- .../asio/detail/win_iocp_handle_service.hpp | 30 +- .../asio/detail/win_iocp_handle_write_op.hpp | 9 +- .../asio/asio/detail/win_iocp_io_context.hpp | 4 +- .../asio/detail/win_iocp_null_buffers_op.hpp | 5 +- .../asio/asio/detail/win_iocp_operation.hpp | 2 +- .../asio/detail/win_iocp_overlapped_op.hpp | 9 +- .../asio/detail/win_iocp_overlapped_ptr.hpp | 2 +- .../detail/win_iocp_serial_port_service.hpp | 3 +- .../asio/detail/win_iocp_socket_accept_op.hpp | 10 +- .../detail/win_iocp_socket_connect_op.hpp | 6 +- .../asio/detail/win_iocp_socket_recv_op.hpp | 5 +- .../detail/win_iocp_socket_recvfrom_op.hpp | 5 +- .../detail/win_iocp_socket_recvmsg_op.hpp | 5 +- .../asio/detail/win_iocp_socket_send_op.hpp | 5 +- .../asio/detail/win_iocp_socket_service.hpp | 40 +- .../detail/win_iocp_socket_service_base.hpp | 14 +- .../asio/asio/detail/win_iocp_thread_info.hpp | 2 +- .../asio/asio/detail/win_iocp_wait_op.hpp | 5 +- thirdparty/asio/asio/detail/win_mutex.hpp | 2 +- .../asio/detail/win_object_handle_service.hpp | 2 +- .../asio/asio/detail/win_static_mutex.hpp | 2 +- thirdparty/asio/asio/detail/win_thread.hpp | 2 +- thirdparty/asio/asio/detail/win_tss_ptr.hpp | 2 +- thirdparty/asio/asio/detail/winapp_thread.hpp | 2 +- thirdparty/asio/asio/detail/wince_thread.hpp | 2 +- .../asio/asio/detail/winrt_async_manager.hpp | 2 +- .../asio/asio/detail/winrt_async_op.hpp | 2 +- .../asio/asio/detail/winrt_resolve_op.hpp | 3 +- .../asio/detail/winrt_resolver_service.hpp | 2 +- .../asio/detail/winrt_socket_connect_op.hpp | 3 +- .../asio/asio/detail/winrt_socket_recv_op.hpp | 3 +- .../asio/asio/detail/winrt_socket_send_op.hpp | 3 +- .../asio/detail/winrt_ssocket_service.hpp | 2 +- .../detail/winrt_ssocket_service_base.hpp | 2 +- .../asio/detail/winrt_timer_scheduler.hpp | 2 +- thirdparty/asio/asio/detail/winrt_utils.hpp | 2 +- thirdparty/asio/asio/detail/winsock_init.hpp | 2 +- .../asio/asio/detail/work_dispatcher.hpp | 14 +- .../asio/asio/detail/wrapped_handler.hpp | 2 +- thirdparty/asio/asio/dispatch.hpp | 165 +- thirdparty/asio/asio/error.hpp | 37 +- thirdparty/asio/asio/error_code.hpp | 2 +- thirdparty/asio/asio/execution.hpp | 2 +- thirdparty/asio/asio/execution/allocator.hpp | 27 +- .../asio/asio/execution/any_executor.hpp | 611 ++++-- .../asio/asio/execution/bad_executor.hpp | 2 +- thirdparty/asio/asio/execution/blocking.hpp | 67 +- .../asio/execution/blocking_adaptation.hpp | 59 +- .../asio/asio/execution/bulk_execute.hpp | 7 +- .../asio/asio/execution/bulk_guarantee.hpp | 47 +- thirdparty/asio/asio/execution/connect.hpp | 7 +- thirdparty/asio/asio/execution/context.hpp | 17 +- thirdparty/asio/asio/execution/context_as.hpp | 17 +- .../asio/execution/detail/as_invocable.hpp | 2 +- .../asio/execution/detail/as_operation.hpp | 6 +- .../asio/execution/detail/as_receiver.hpp | 2 +- .../asio/execution/detail/bulk_sender.hpp | 2 +- .../asio/execution/detail/submit_receiver.hpp | 2 +- .../asio/execution/detail/void_receiver.hpp | 2 +- thirdparty/asio/asio/execution/execute.hpp | 13 +- thirdparty/asio/asio/execution/executor.hpp | 14 +- .../asio/asio/execution/impl/bad_executor.ipp | 2 +- .../impl/receiver_invocation_error.ipp | 2 +- .../asio/execution/invocable_archetype.hpp | 2 +- thirdparty/asio/asio/execution/mapping.hpp | 62 +- thirdparty/asio/asio/execution/occupancy.hpp | 17 +- .../asio/asio/execution/operation_state.hpp | 7 +- .../asio/asio/execution/outstanding_work.hpp | 47 +- .../asio/asio/execution/prefer_only.hpp | 2 +- thirdparty/asio/asio/execution/receiver.hpp | 7 +- .../execution/receiver_invocation_error.hpp | 2 +- .../asio/asio/execution/relationship.hpp | 47 +- thirdparty/asio/asio/execution/schedule.hpp | 7 +- thirdparty/asio/asio/execution/scheduler.hpp | 7 +- thirdparty/asio/asio/execution/sender.hpp | 7 +- thirdparty/asio/asio/execution/set_done.hpp | 7 +- thirdparty/asio/asio/execution/set_error.hpp | 7 +- thirdparty/asio/asio/execution/set_value.hpp | 7 +- thirdparty/asio/asio/execution/start.hpp | 7 +- thirdparty/asio/asio/execution/submit.hpp | 7 +- thirdparty/asio/asio/execution_context.hpp | 2 +- thirdparty/asio/asio/executor.hpp | 2 +- thirdparty/asio/asio/executor_work_guard.hpp | 145 +- thirdparty/asio/asio/experimental/append.hpp | 47 +- .../asio/asio/experimental/as_single.hpp | 11 +- .../asio/asio/experimental/as_tuple.hpp | 107 +- .../asio/experimental/awaitable_operators.hpp | 28 +- .../asio/asio/experimental/basic_channel.hpp | 491 +++++ .../experimental/basic_concurrent_channel.hpp | 491 +++++ .../experimental/cancellation_condition.hpp | 2 +- thirdparty/asio/asio/experimental/channel.hpp | 70 + .../asio/asio/experimental/channel_error.hpp | 84 + .../asio/asio/experimental/channel_traits.hpp | 301 +++ .../asio/asio/experimental/co_composed.hpp | 144 ++ .../asio/asio/experimental/co_spawn.hpp | 187 ++ .../asio/experimental/concurrent_channel.hpp | 70 + thirdparty/asio/asio/experimental/coro.hpp | 1014 ++-------- .../experimental/{detail => }/coro_traits.hpp | 85 +- .../asio/asio/experimental/deferred.hpp | 581 +----- .../experimental/detail/channel_handler.hpp | 80 + .../experimental/detail/channel_message.hpp | 129 ++ .../experimental/detail/channel_operation.hpp | 284 +++ .../experimental/detail/channel_payload.hpp | 139 ++ .../detail/channel_receive_op.hpp | 120 ++ .../detail/channel_send_functions.hpp | 144 ++ .../experimental/detail/channel_send_op.hpp | 148 ++ .../experimental/detail/channel_service.hpp | 677 +++++++ .../detail/completion_handler_erasure.hpp | 158 -- .../detail/coro_completion_handler.hpp | 169 ++ .../detail/coro_promise_allocator.hpp | 161 +- .../experimental/detail/has_signature.hpp | 54 + .../detail/impl/channel_service.hpp | 612 ++++++ .../experimental/detail/partial_promise.hpp | 118 +- .../asio/asio/experimental/impl/as_single.hpp | 18 +- .../asio/experimental/impl/channel_error.ipp | 61 + .../asio/experimental/impl/co_composed.hpp | 1175 ++++++++++++ .../asio/asio/experimental/impl/coro.hpp | 1222 ++++++++++++ .../asio/asio/experimental/impl/deferred.hpp | 104 -- .../asio/experimental/impl/parallel_group.hpp | 414 ++++- .../asio/asio/experimental/impl/promise.hpp | 218 ++- .../asio/asio/experimental/impl/use_coro.hpp | 214 +++ .../asio/experimental/impl/use_promise.hpp | 66 + .../asio/asio/experimental/parallel_group.hpp | 320 +++- thirdparty/asio/asio/experimental/prepend.hpp | 47 +- thirdparty/asio/asio/experimental/promise.hpp | 554 +----- .../asio/asio/experimental/use_coro.hpp | 369 ++-- .../asio/asio/experimental/use_promise.hpp | 111 ++ thirdparty/asio/asio/file_base.hpp | 166 ++ .../asio/asio/generic/basic_endpoint.hpp | 2 +- .../asio/asio/generic/datagram_protocol.hpp | 2 +- .../asio/asio/generic/detail/endpoint.hpp | 2 +- .../asio/generic/detail/impl/endpoint.ipp | 2 +- thirdparty/asio/asio/generic/raw_protocol.hpp | 2 +- .../asio/asio/generic/seq_packet_protocol.hpp | 2 +- .../asio/asio/generic/stream_protocol.hpp | 2 +- thirdparty/asio/asio/handler_alloc_hook.hpp | 2 +- .../asio/asio/handler_continuation_hook.hpp | 2 +- thirdparty/asio/asio/handler_invoke_hook.hpp | 2 +- .../asio/asio/high_resolution_timer.hpp | 2 +- .../asio/impl/any_completion_executor.ipp | 130 ++ thirdparty/asio/asio/impl/any_io_executor.ipp | 141 ++ .../asio/{experimental => }/impl/append.hpp | 50 +- .../asio/{experimental => }/impl/as_tuple.hpp | 124 +- thirdparty/asio/asio/impl/awaitable.hpp | 445 ++++- .../asio/asio/impl/buffered_read_stream.hpp | 47 +- .../asio/asio/impl/buffered_write_stream.hpp | 47 +- .../asio/asio/impl/cancellation_signal.ipp | 96 + thirdparty/asio/asio/impl/co_spawn.hpp | 151 +- thirdparty/asio/asio/impl/compose.hpp | 687 ------- thirdparty/asio/asio/impl/connect.hpp | 135 +- thirdparty/asio/asio/impl/connect_pipe.hpp | 73 + thirdparty/asio/asio/impl/connect_pipe.ipp | 149 ++ thirdparty/asio/asio/impl/consign.hpp | 202 ++ thirdparty/asio/asio/impl/deferred.hpp | 156 ++ thirdparty/asio/asio/impl/detached.hpp | 2 +- thirdparty/asio/asio/impl/error.ipp | 2 +- thirdparty/asio/asio/impl/error_code.ipp | 2 +- .../asio/asio/impl/execution_context.hpp | 2 +- .../asio/asio/impl/execution_context.ipp | 2 +- thirdparty/asio/asio/impl/executor.hpp | 2 +- thirdparty/asio/asio/impl/executor.ipp | 2 +- .../asio/asio/impl/handler_alloc_hook.ipp | 4 +- thirdparty/asio/asio/impl/io_context.hpp | 100 +- thirdparty/asio/asio/impl/io_context.ipp | 3 +- .../asio/asio/impl/multiple_exceptions.ipp | 2 +- .../asio/{experimental => }/impl/prepend.hpp | 46 +- thirdparty/asio/asio/impl/read.hpp | 197 +- thirdparty/asio/asio/impl/read_at.hpp | 115 +- thirdparty/asio/asio/impl/read_until.hpp | 306 ++- thirdparty/asio/asio/impl/redirect_error.hpp | 93 +- .../asio/asio/impl/serial_port_base.hpp | 2 +- .../asio/asio/impl/serial_port_base.ipp | 2 +- thirdparty/asio/asio/impl/spawn.hpp | 1653 ++++++++++++++--- thirdparty/asio/asio/impl/src.hpp | 14 +- thirdparty/asio/asio/impl/system_context.hpp | 2 +- thirdparty/asio/asio/impl/system_context.ipp | 2 +- thirdparty/asio/asio/impl/system_executor.hpp | 2 +- thirdparty/asio/asio/impl/thread_pool.hpp | 2 +- thirdparty/asio/asio/impl/thread_pool.ipp | 9 +- thirdparty/asio/asio/impl/use_awaitable.hpp | 26 +- thirdparty/asio/asio/impl/use_future.hpp | 31 +- thirdparty/asio/asio/impl/write.hpp | 213 ++- thirdparty/asio/asio/impl/write_at.hpp | 117 +- thirdparty/asio/asio/io_context.hpp | 238 ++- thirdparty/asio/asio/io_context_strand.hpp | 18 +- thirdparty/asio/asio/io_service.hpp | 2 +- thirdparty/asio/asio/io_service_strand.hpp | 2 +- thirdparty/asio/asio/ip/address.hpp | 2 +- thirdparty/asio/asio/ip/address_v4.hpp | 81 +- .../asio/asio/ip/address_v4_iterator.hpp | 2 +- thirdparty/asio/asio/ip/address_v4_range.hpp | 2 +- thirdparty/asio/asio/ip/address_v6.hpp | 36 +- .../asio/asio/ip/address_v6_iterator.hpp | 2 +- thirdparty/asio/asio/ip/address_v6_range.hpp | 2 +- thirdparty/asio/asio/ip/bad_address_cast.hpp | 2 +- thirdparty/asio/asio/ip/basic_endpoint.hpp | 2 +- thirdparty/asio/asio/ip/basic_resolver.hpp | 194 +- .../asio/asio/ip/basic_resolver_entry.hpp | 2 +- .../asio/asio/ip/basic_resolver_iterator.hpp | 2 +- .../asio/asio/ip/basic_resolver_query.hpp | 2 +- .../asio/asio/ip/basic_resolver_results.hpp | 2 +- thirdparty/asio/asio/ip/detail/endpoint.hpp | 2 +- .../asio/asio/ip/detail/impl/endpoint.ipp | 2 +- .../asio/asio/ip/detail/socket_option.hpp | 2 +- thirdparty/asio/asio/ip/host_name.hpp | 2 +- thirdparty/asio/asio/ip/icmp.hpp | 2 +- thirdparty/asio/asio/ip/impl/address.hpp | 2 +- thirdparty/asio/asio/ip/impl/address.ipp | 2 +- thirdparty/asio/asio/ip/impl/address_v4.hpp | 2 +- thirdparty/asio/asio/ip/impl/address_v4.ipp | 2 +- thirdparty/asio/asio/ip/impl/address_v6.hpp | 2 +- thirdparty/asio/asio/ip/impl/address_v6.ipp | 2 +- .../asio/asio/ip/impl/basic_endpoint.hpp | 2 +- thirdparty/asio/asio/ip/impl/host_name.ipp | 2 +- thirdparty/asio/asio/ip/impl/network_v4.hpp | 2 +- thirdparty/asio/asio/ip/impl/network_v4.ipp | 6 +- thirdparty/asio/asio/ip/impl/network_v6.hpp | 2 +- thirdparty/asio/asio/ip/impl/network_v6.ipp | 6 +- thirdparty/asio/asio/ip/multicast.hpp | 2 +- thirdparty/asio/asio/ip/network_v4.hpp | 4 +- thirdparty/asio/asio/ip/network_v6.hpp | 2 +- thirdparty/asio/asio/ip/resolver_base.hpp | 2 +- .../asio/asio/ip/resolver_query_base.hpp | 2 +- thirdparty/asio/asio/ip/tcp.hpp | 2 +- thirdparty/asio/asio/ip/udp.hpp | 2 +- thirdparty/asio/asio/ip/unicast.hpp | 2 +- thirdparty/asio/asio/ip/v6_only.hpp | 4 +- .../asio/asio/is_applicable_property.hpp | 2 +- .../asio/asio/is_contiguous_iterator.hpp | 45 + thirdparty/asio/asio/is_executor.hpp | 2 +- thirdparty/asio/asio/is_read_buffered.hpp | 2 +- thirdparty/asio/asio/is_write_buffered.hpp | 2 +- thirdparty/asio/asio/local/basic_endpoint.hpp | 2 +- thirdparty/asio/asio/local/connect_pair.hpp | 2 +- .../asio/asio/local/datagram_protocol.hpp | 2 +- .../asio/asio/local/detail/endpoint.hpp | 2 +- .../asio/asio/local/detail/impl/endpoint.ipp | 2 +- .../asio/asio/local/seq_packet_protocol.hpp | 84 + .../asio/asio/local/stream_protocol.hpp | 2 +- thirdparty/asio/asio/multiple_exceptions.hpp | 2 +- thirdparty/asio/asio/packaged_task.hpp | 2 +- thirdparty/asio/asio/placeholders.hpp | 2 +- .../asio/asio/posix/basic_descriptor.hpp | 109 +- .../asio/posix/basic_stream_descriptor.hpp | 126 +- thirdparty/asio/asio/posix/descriptor.hpp | 2 +- .../asio/asio/posix/descriptor_base.hpp | 2 +- .../asio/asio/posix/stream_descriptor.hpp | 2 +- thirdparty/asio/asio/post.hpp | 182 +- thirdparty/asio/asio/prefer.hpp | 2 +- thirdparty/asio/asio/prepend.hpp | 78 + thirdparty/asio/asio/query.hpp | 2 +- thirdparty/asio/asio/random_access_file.hpp | 35 + thirdparty/asio/asio/read.hpp | 398 ++-- thirdparty/asio/asio/read_at.hpp | 163 +- thirdparty/asio/asio/read_until.hpp | 467 +++-- thirdparty/asio/asio/readable_pipe.hpp | 35 + thirdparty/asio/asio/recycling_allocator.hpp | 138 ++ thirdparty/asio/asio/redirect_error.hpp | 6 +- thirdparty/asio/asio/registered_buffer.hpp | 356 ++++ thirdparty/asio/asio/require.hpp | 2 +- thirdparty/asio/asio/require_concept.hpp | 2 +- thirdparty/asio/asio/serial_port.hpp | 2 +- thirdparty/asio/asio/serial_port_base.hpp | 2 +- thirdparty/asio/asio/signal_set.hpp | 2 +- thirdparty/asio/asio/signal_set_base.hpp | 182 ++ thirdparty/asio/asio/socket_base.hpp | 2 +- thirdparty/asio/asio/spawn.hpp | 736 +++++++- thirdparty/asio/asio/ssl.hpp | 2 +- thirdparty/asio/asio/ssl/context.hpp | 5 +- thirdparty/asio/asio/ssl/context_base.hpp | 48 +- .../asio/ssl/detail/buffered_handshake_op.hpp | 2 +- thirdparty/asio/asio/ssl/detail/engine.hpp | 5 +- .../asio/asio/ssl/detail/handshake_op.hpp | 2 +- .../asio/asio/ssl/detail/impl/engine.ipp | 20 +- .../asio/ssl/detail/impl/openssl_init.ipp | 10 +- thirdparty/asio/asio/ssl/detail/io.hpp | 18 +- .../asio/asio/ssl/detail/openssl_init.hpp | 2 +- .../asio/asio/ssl/detail/openssl_types.hpp | 2 +- .../asio/ssl/detail/password_callback.hpp | 2 +- thirdparty/asio/asio/ssl/detail/read_op.hpp | 2 +- .../asio/asio/ssl/detail/shutdown_op.hpp | 2 +- .../asio/asio/ssl/detail/stream_core.hpp | 17 +- .../asio/asio/ssl/detail/verify_callback.hpp | 2 +- thirdparty/asio/asio/ssl/detail/write_op.hpp | 2 +- thirdparty/asio/asio/ssl/error.hpp | 2 +- .../asio/asio/ssl/host_name_verification.hpp | 2 +- thirdparty/asio/asio/ssl/impl/context.hpp | 2 +- thirdparty/asio/asio/ssl/impl/context.ipp | 204 +- thirdparty/asio/asio/ssl/impl/error.ipp | 28 +- .../asio/ssl/impl/host_name_verification.ipp | 2 +- .../asio/ssl/impl/rfc2818_verification.ipp | 2 +- thirdparty/asio/asio/ssl/impl/src.hpp | 2 +- .../asio/asio/ssl/rfc2818_verification.hpp | 2 +- thirdparty/asio/asio/ssl/stream.hpp | 207 ++- thirdparty/asio/asio/ssl/stream_base.hpp | 2 +- thirdparty/asio/asio/ssl/verify_context.hpp | 2 +- thirdparty/asio/asio/ssl/verify_mode.hpp | 2 +- thirdparty/asio/asio/static_thread_pool.hpp | 2 +- thirdparty/asio/asio/steady_timer.hpp | 2 +- thirdparty/asio/asio/strand.hpp | 31 +- thirdparty/asio/asio/stream_file.hpp | 35 + thirdparty/asio/asio/streambuf.hpp | 2 +- thirdparty/asio/asio/system_context.hpp | 2 +- thirdparty/asio/asio/system_error.hpp | 2 +- thirdparty/asio/asio/system_executor.hpp | 15 +- thirdparty/asio/asio/system_timer.hpp | 2 +- thirdparty/asio/asio/this_coro.hpp | 24 +- thirdparty/asio/asio/thread.hpp | 2 +- thirdparty/asio/asio/thread_pool.hpp | 52 +- thirdparty/asio/asio/time_traits.hpp | 2 +- .../asio/asio/traits/bulk_execute_free.hpp | 2 +- .../asio/asio/traits/bulk_execute_member.hpp | 2 +- thirdparty/asio/asio/traits/connect_free.hpp | 2 +- .../asio/asio/traits/connect_member.hpp | 2 +- .../asio/asio/traits/equality_comparable.hpp | 2 +- thirdparty/asio/asio/traits/execute_free.hpp | 2 +- .../asio/asio/traits/execute_member.hpp | 2 +- thirdparty/asio/asio/traits/prefer_free.hpp | 2 +- thirdparty/asio/asio/traits/prefer_member.hpp | 2 +- thirdparty/asio/asio/traits/query_free.hpp | 2 +- thirdparty/asio/asio/traits/query_member.hpp | 2 +- .../traits/query_static_constexpr_member.hpp | 2 +- .../asio/asio/traits/require_concept_free.hpp | 2 +- .../asio/traits/require_concept_member.hpp | 2 +- thirdparty/asio/asio/traits/require_free.hpp | 2 +- .../asio/asio/traits/require_member.hpp | 2 +- thirdparty/asio/asio/traits/schedule_free.hpp | 2 +- .../asio/asio/traits/schedule_member.hpp | 2 +- thirdparty/asio/asio/traits/set_done_free.hpp | 2 +- .../asio/asio/traits/set_done_member.hpp | 2 +- .../asio/asio/traits/set_error_free.hpp | 2 +- .../asio/asio/traits/set_error_member.hpp | 2 +- .../asio/asio/traits/set_value_free.hpp | 2 +- .../asio/asio/traits/set_value_member.hpp | 2 +- thirdparty/asio/asio/traits/start_free.hpp | 2 +- thirdparty/asio/asio/traits/start_member.hpp | 2 +- thirdparty/asio/asio/traits/static_query.hpp | 2 +- .../asio/asio/traits/static_require.hpp | 2 +- .../asio/traits/static_require_concept.hpp | 2 +- thirdparty/asio/asio/traits/submit_free.hpp | 2 +- thirdparty/asio/asio/traits/submit_member.hpp | 2 +- thirdparty/asio/asio/ts/buffer.hpp | 2 +- thirdparty/asio/asio/ts/executor.hpp | 2 +- thirdparty/asio/asio/ts/internet.hpp | 2 +- thirdparty/asio/asio/ts/io_context.hpp | 2 +- thirdparty/asio/asio/ts/net.hpp | 2 +- thirdparty/asio/asio/ts/netfwd.hpp | 2 +- thirdparty/asio/asio/ts/socket.hpp | 2 +- thirdparty/asio/asio/ts/timer.hpp | 2 +- thirdparty/asio/asio/unyield.hpp | 2 +- thirdparty/asio/asio/use_awaitable.hpp | 7 +- thirdparty/asio/asio/use_future.hpp | 17 +- thirdparty/asio/asio/uses_executor.hpp | 2 +- thirdparty/asio/asio/version.hpp | 4 +- thirdparty/asio/asio/wait_traits.hpp | 2 +- .../asio/asio/windows/basic_object_handle.hpp | 86 +- .../asio/windows/basic_overlapped_handle.hpp | 103 +- .../windows/basic_random_access_handle.hpp | 131 +- .../asio/asio/windows/basic_stream_handle.hpp | 127 +- .../asio/asio/windows/object_handle.hpp | 2 +- .../asio/asio/windows/overlapped_handle.hpp | 2 +- .../asio/asio/windows/overlapped_ptr.hpp | 2 +- .../asio/windows/random_access_handle.hpp | 2 +- .../asio/asio/windows/stream_handle.hpp | 2 +- thirdparty/asio/asio/writable_pipe.hpp | 35 + thirdparty/asio/asio/write.hpp | 392 ++-- thirdparty/asio/asio/write_at.hpp | 165 +- thirdparty/asio/asio/yield.hpp | 2 +- 676 files changed, 41128 insertions(+), 8100 deletions(-) create mode 100644 thirdparty/asio/asio/any_completion_executor.hpp create mode 100644 thirdparty/asio/asio/any_completion_handler.hpp create mode 100644 thirdparty/asio/asio/append.hpp create mode 100644 thirdparty/asio/asio/as_tuple.hpp create mode 100644 thirdparty/asio/asio/associated_immediate_executor.hpp create mode 100644 thirdparty/asio/asio/basic_file.hpp create mode 100644 thirdparty/asio/asio/basic_random_access_file.hpp create mode 100644 thirdparty/asio/asio/basic_readable_pipe.hpp create mode 100644 thirdparty/asio/asio/basic_stream_file.hpp create mode 100644 thirdparty/asio/asio/basic_writable_pipe.hpp create mode 100644 thirdparty/asio/asio/bind_allocator.hpp create mode 100644 thirdparty/asio/asio/bind_immediate_executor.hpp create mode 100644 thirdparty/asio/asio/buffer_registration.hpp create mode 100644 thirdparty/asio/asio/connect_pipe.hpp create mode 100644 thirdparty/asio/asio/consign.hpp create mode 100644 thirdparty/asio/asio/deferred.hpp create mode 100644 thirdparty/asio/asio/detail/composed_work.hpp create mode 100644 thirdparty/asio/asio/detail/exception.hpp create mode 100644 thirdparty/asio/asio/detail/impl/io_uring_descriptor_service.ipp create mode 100644 thirdparty/asio/asio/detail/impl/io_uring_file_service.ipp create mode 100644 thirdparty/asio/asio/detail/impl/io_uring_service.hpp create mode 100644 thirdparty/asio/asio/detail/impl/io_uring_service.ipp create mode 100644 thirdparty/asio/asio/detail/impl/io_uring_socket_service_base.ipp rename thirdparty/asio/asio/detail/impl/{reactive_serial_port_service.ipp => posix_serial_port_service.ipp} (68%) create mode 100644 thirdparty/asio/asio/detail/impl/win_iocp_file_service.ipp rename thirdparty/asio/asio/{impl/defer.hpp => detail/initiate_defer.hpp} (82%) rename thirdparty/asio/asio/{impl/dispatch.hpp => detail/initiate_dispatch.hpp} (76%) rename thirdparty/asio/asio/{impl/post.hpp => detail/initiate_post.hpp} (82%) create mode 100644 thirdparty/asio/asio/detail/io_uring_descriptor_read_at_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_descriptor_read_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_descriptor_service.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_descriptor_write_at_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_descriptor_write_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_file_service.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_null_buffers_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_operation.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_service.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_accept_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_connect_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_recv_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_recvfrom_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_recvmsg_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_send_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_sendto_op.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_service.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_socket_service_base.hpp create mode 100644 thirdparty/asio/asio/detail/io_uring_wait_op.hpp rename thirdparty/asio/asio/detail/{reactive_serial_port_service.hpp => posix_serial_port_service.hpp} (81%) delete mode 100644 thirdparty/asio/asio/detail/reactor_fwd.hpp create mode 100644 thirdparty/asio/asio/detail/scheduler_task.hpp create mode 100644 thirdparty/asio/asio/detail/utility.hpp create mode 100644 thirdparty/asio/asio/detail/win_iocp_file_service.hpp create mode 100644 thirdparty/asio/asio/experimental/basic_channel.hpp create mode 100644 thirdparty/asio/asio/experimental/basic_concurrent_channel.hpp create mode 100644 thirdparty/asio/asio/experimental/channel.hpp create mode 100644 thirdparty/asio/asio/experimental/channel_error.hpp create mode 100644 thirdparty/asio/asio/experimental/channel_traits.hpp create mode 100644 thirdparty/asio/asio/experimental/co_composed.hpp create mode 100644 thirdparty/asio/asio/experimental/co_spawn.hpp create mode 100644 thirdparty/asio/asio/experimental/concurrent_channel.hpp rename thirdparty/asio/asio/experimental/{detail => }/coro_traits.hpp (60%) create mode 100644 thirdparty/asio/asio/experimental/detail/channel_handler.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_message.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_operation.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_payload.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_receive_op.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_send_functions.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_send_op.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/channel_service.hpp delete mode 100644 thirdparty/asio/asio/experimental/detail/completion_handler_erasure.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/coro_completion_handler.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/has_signature.hpp create mode 100644 thirdparty/asio/asio/experimental/detail/impl/channel_service.hpp create mode 100644 thirdparty/asio/asio/experimental/impl/channel_error.ipp create mode 100644 thirdparty/asio/asio/experimental/impl/co_composed.hpp create mode 100644 thirdparty/asio/asio/experimental/impl/coro.hpp delete mode 100644 thirdparty/asio/asio/experimental/impl/deferred.hpp create mode 100644 thirdparty/asio/asio/experimental/impl/use_coro.hpp create mode 100644 thirdparty/asio/asio/experimental/impl/use_promise.hpp create mode 100644 thirdparty/asio/asio/experimental/use_promise.hpp create mode 100644 thirdparty/asio/asio/file_base.hpp create mode 100644 thirdparty/asio/asio/impl/any_completion_executor.ipp create mode 100644 thirdparty/asio/asio/impl/any_io_executor.ipp rename thirdparty/asio/asio/{experimental => }/impl/append.hpp (81%) rename thirdparty/asio/asio/{experimental => }/impl/as_tuple.hpp (60%) create mode 100644 thirdparty/asio/asio/impl/cancellation_signal.ipp delete mode 100644 thirdparty/asio/asio/impl/compose.hpp create mode 100644 thirdparty/asio/asio/impl/connect_pipe.hpp create mode 100644 thirdparty/asio/asio/impl/connect_pipe.ipp create mode 100644 thirdparty/asio/asio/impl/consign.hpp create mode 100644 thirdparty/asio/asio/impl/deferred.hpp rename thirdparty/asio/asio/{experimental => }/impl/prepend.hpp (82%) create mode 100644 thirdparty/asio/asio/is_contiguous_iterator.hpp create mode 100644 thirdparty/asio/asio/local/seq_packet_protocol.hpp create mode 100644 thirdparty/asio/asio/prepend.hpp create mode 100644 thirdparty/asio/asio/random_access_file.hpp create mode 100644 thirdparty/asio/asio/readable_pipe.hpp create mode 100644 thirdparty/asio/asio/recycling_allocator.hpp create mode 100644 thirdparty/asio/asio/registered_buffer.hpp create mode 100644 thirdparty/asio/asio/signal_set_base.hpp create mode 100644 thirdparty/asio/asio/stream_file.hpp create mode 100644 thirdparty/asio/asio/writable_pipe.hpp diff --git a/thirdparty/asio/asio.hpp b/thirdparty/asio/asio.hpp index 94db21e8..a973ab17 100644 --- a/thirdparty/asio/asio.hpp +++ b/thirdparty/asio/asio.hpp @@ -2,7 +2,7 @@ // asio.hpp // ~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -15,16 +15,25 @@ # pragma once #endif // defined(_MSC_VER) && (_MSC_VER >= 1200) +#include "asio/any_completion_executor.hpp" +#include "asio/any_completion_handler.hpp" +#include "asio/any_io_executor.hpp" +#include "asio/append.hpp" +#include "asio/as_tuple.hpp" #include "asio/associated_allocator.hpp" -#include "asio/associated_executor.hpp" #include "asio/associated_cancellation_slot.hpp" +#include "asio/associated_executor.hpp" +#include "asio/associated_immediate_executor.hpp" #include "asio/associator.hpp" #include "asio/async_result.hpp" #include "asio/awaitable.hpp" #include "asio/basic_datagram_socket.hpp" #include "asio/basic_deadline_timer.hpp" +#include "asio/basic_file.hpp" #include "asio/basic_io_object.hpp" +#include "asio/basic_random_access_file.hpp" #include "asio/basic_raw_socket.hpp" +#include "asio/basic_readable_pipe.hpp" #include "asio/basic_seq_packet_socket.hpp" #include "asio/basic_serial_port.hpp" #include "asio/basic_signal_set.hpp" @@ -32,12 +41,17 @@ #include "asio/basic_socket_acceptor.hpp" #include "asio/basic_socket_iostream.hpp" #include "asio/basic_socket_streambuf.hpp" +#include "asio/basic_stream_file.hpp" #include "asio/basic_stream_socket.hpp" #include "asio/basic_streambuf.hpp" #include "asio/basic_waitable_timer.hpp" +#include "asio/basic_writable_pipe.hpp" +#include "asio/bind_allocator.hpp" #include "asio/bind_cancellation_slot.hpp" #include "asio/bind_executor.hpp" +#include "asio/bind_immediate_executor.hpp" #include "asio/buffer.hpp" +#include "asio/buffer_registration.hpp" #include "asio/buffered_read_stream_fwd.hpp" #include "asio/buffered_read_stream.hpp" #include "asio/buffered_stream_fwd.hpp" @@ -52,9 +66,12 @@ #include "asio/completion_condition.hpp" #include "asio/compose.hpp" #include "asio/connect.hpp" +#include "asio/connect_pipe.hpp" +#include "asio/consign.hpp" #include "asio/coroutine.hpp" #include "asio/deadline_timer.hpp" #include "asio/defer.hpp" +#include "asio/deferred.hpp" #include "asio/detached.hpp" #include "asio/dispatch.hpp" #include "asio/error.hpp" @@ -90,6 +107,7 @@ #include "asio/execution_context.hpp" #include "asio/executor.hpp" #include "asio/executor_work_guard.hpp" +#include "asio/file_base.hpp" #include "asio/generic/basic_endpoint.hpp" #include "asio/generic/datagram_protocol.hpp" #include "asio/generic/raw_protocol.hpp" @@ -128,12 +146,14 @@ #include "asio/ip/unicast.hpp" #include "asio/ip/v6_only.hpp" #include "asio/is_applicable_property.hpp" +#include "asio/is_contiguous_iterator.hpp" #include "asio/is_executor.hpp" #include "asio/is_read_buffered.hpp" #include "asio/is_write_buffered.hpp" #include "asio/local/basic_endpoint.hpp" #include "asio/local/connect_pair.hpp" #include "asio/local/datagram_protocol.hpp" +#include "asio/local/seq_packet_protocol.hpp" #include "asio/local/stream_protocol.hpp" #include "asio/multiple_exceptions.hpp" #include "asio/packaged_task.hpp" @@ -145,20 +165,27 @@ #include "asio/posix/stream_descriptor.hpp" #include "asio/post.hpp" #include "asio/prefer.hpp" +#include "asio/prepend.hpp" #include "asio/query.hpp" +#include "asio/random_access_file.hpp" #include "asio/read.hpp" #include "asio/read_at.hpp" #include "asio/read_until.hpp" +#include "asio/readable_pipe.hpp" +#include "asio/recycling_allocator.hpp" #include "asio/redirect_error.hpp" +#include "asio/registered_buffer.hpp" #include "asio/require.hpp" #include "asio/require_concept.hpp" #include "asio/serial_port.hpp" #include "asio/serial_port_base.hpp" #include "asio/signal_set.hpp" +#include "asio/signal_set_base.hpp" #include "asio/socket_base.hpp" #include "asio/static_thread_pool.hpp" #include "asio/steady_timer.hpp" #include "asio/strand.hpp" +#include "asio/stream_file.hpp" #include "asio/streambuf.hpp" #include "asio/system_context.hpp" #include "asio/system_error.hpp" @@ -182,6 +209,7 @@ #include "asio/windows/overlapped_ptr.hpp" #include "asio/windows/random_access_handle.hpp" #include "asio/windows/stream_handle.hpp" +#include "asio/writable_pipe.hpp" #include "asio/write.hpp" #include "asio/write_at.hpp" diff --git a/thirdparty/asio/asio/any_completion_executor.hpp b/thirdparty/asio/asio/any_completion_executor.hpp new file mode 100644 index 00000000..420927cc --- /dev/null +++ b/thirdparty/asio/asio/any_completion_executor.hpp @@ -0,0 +1,342 @@ +// +// any_completion_executor.hpp +// ~~~~~~~~~~~~~~~~~~~~~~~~~~~ +// +// Copyright (c) 2003-2023 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 ASIO_ANY_COMPLETION_EXECUTOR_HPP +#define ASIO_ANY_COMPLETION_EXECUTOR_HPP + +#if defined(_MSC_VER) && (_MSC_VER >= 1200) +# pragma once +#endif // defined(_MSC_VER) && (_MSC_VER >= 1200) + +#include "asio/detail/config.hpp" +#if defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) +# include "asio/executor.hpp" +#else // defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) +# include "asio/execution.hpp" +#endif // defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + +#include "asio/detail/push_options.hpp" + +namespace asio { + +#if defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + +typedef executor any_completion_executor; + +#else // defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + +/// Polymorphic executor type for use with I/O objects. +/** + * The @c any_completion_executor type is a polymorphic executor that supports + * the set of properties required for the execution of completion handlers. It + * is defined as the execution::any_executor class template parameterised as + * follows: + * @code execution::any_executor< + * execution::prefer_only, + * execution::prefer_only + * execution::prefer_only, + * execution::prefer_only + * > @endcode + */ +class any_completion_executor : +#if defined(GENERATING_DOCUMENTATION) + public execution::any_executor<...> +#else // defined(GENERATING_DOCUMENTATION) + public execution::any_executor< + execution::prefer_only, + execution::prefer_only, + execution::prefer_only, + execution::prefer_only + > +#endif // defined(GENERATING_DOCUMENTATION) +{ +public: +#if !defined(GENERATING_DOCUMENTATION) + typedef execution::any_executor< + execution::prefer_only, + execution::prefer_only, + execution::prefer_only, + execution::prefer_only + > base_type; + + typedef void supportable_properties_type( + execution::prefer_only, + execution::prefer_only, + execution::prefer_only, + execution::prefer_only + ); +#endif // !defined(GENERATING_DOCUMENTATION) + + /// Default constructor. + ASIO_DECL any_completion_executor() ASIO_NOEXCEPT; + + /// Construct in an empty state. Equivalent effects to default constructor. + ASIO_DECL any_completion_executor(nullptr_t) ASIO_NOEXCEPT; + + /// Copy constructor. + ASIO_DECL any_completion_executor( + const any_completion_executor& e) ASIO_NOEXCEPT; + +#if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + /// Move constructor. + ASIO_DECL any_completion_executor( + any_completion_executor&& e) ASIO_NOEXCEPT; +#endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + + /// Construct to point to the same target as another any_executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_completion_executor( + execution::any_executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(OtherAnyExecutor e, + typename constraint< + conditional< + !is_same::value + && is_base_of::value, + typename execution::detail::supportable_properties< + 0, supportable_properties_type>::template + is_valid_target, + false_type + >::type::value + >::type = 0) + : base_type(ASIO_MOVE_CAST(OtherAnyExecutor)(e)) + { + } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Construct to point to the same target as another any_executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(std::nothrow_t, + execution::any_executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(std::nothrow_t, OtherAnyExecutor e, + typename constraint< + conditional< + !is_same::value + && is_base_of::value, + typename execution::detail::supportable_properties< + 0, supportable_properties_type>::template + is_valid_target, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : base_type(std::nothrow, ASIO_MOVE_CAST(OtherAnyExecutor)(e)) + { + } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Construct to point to the same target as another any_executor. + ASIO_DECL any_completion_executor(std::nothrow_t, + const any_completion_executor& e) ASIO_NOEXCEPT; + +#if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + /// Construct to point to the same target as another any_executor. + ASIO_DECL any_completion_executor(std::nothrow_t, + any_completion_executor&& e) ASIO_NOEXCEPT; +#endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + + /// Construct a polymorphic wrapper for the specified executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(Executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(Executor e, + typename constraint< + conditional< + !is_same::value + && !is_base_of::value, + execution::detail::is_valid_target_executor< + Executor, supportable_properties_type>, + false_type + >::type::value + >::type = 0) + : base_type(ASIO_MOVE_CAST(Executor)(e)) + { + } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Construct a polymorphic wrapper for the specified executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(std::nothrow_t, Executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_completion_executor(std::nothrow_t, Executor e, + typename constraint< + conditional< + !is_same::value + && !is_base_of::value, + execution::detail::is_valid_target_executor< + Executor, supportable_properties_type>, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : base_type(std::nothrow, ASIO_MOVE_CAST(Executor)(e)) + { + } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Assignment operator. + ASIO_DECL any_completion_executor& operator=( + const any_completion_executor& e) ASIO_NOEXCEPT; + +#if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + /// Move assignment operator. + ASIO_DECL any_completion_executor& operator=( + any_completion_executor&& e) ASIO_NOEXCEPT; +#endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + + /// Assignment operator that sets the polymorphic wrapper to the empty state. + ASIO_DECL any_completion_executor& operator=(nullptr_t); + + /// Destructor. + ASIO_DECL ~any_completion_executor(); + + /// Swap targets with another polymorphic wrapper. + ASIO_DECL void swap(any_completion_executor& other) ASIO_NOEXCEPT; + + /// Obtain a polymorphic wrapper with the specified property. + /** + * Do not call this function directly. It is intended for use with the + * asio::require and asio::prefer customisation points. + * + * For example: + * @code any_completion_executor ex = ...; + * auto ex2 = asio::require(ex, execution::relationship.fork); @endcode + */ + template + any_completion_executor require(const Property& p, + typename constraint< + traits::require_member::is_valid + >::type = 0) const + { + return static_cast(*this).require(p); + } + + /// Obtain a polymorphic wrapper with the specified property. + /** + * Do not call this function directly. It is intended for use with the + * asio::prefer customisation point. + * + * For example: + * @code any_completion_executor ex = ...; + * auto ex2 = asio::prefer(ex, execution::relationship.fork); @endcode + */ + template + any_completion_executor prefer(const Property& p, + typename constraint< + traits::prefer_member::is_valid + >::type = 0) const + { + return static_cast(*this).prefer(p); + } +}; + +#if !defined(GENERATING_DOCUMENTATION) + +template <> +ASIO_DECL any_completion_executor any_completion_executor::prefer( + const execution::outstanding_work_t::tracked_t&, int) const; + +template <> +ASIO_DECL any_completion_executor any_completion_executor::prefer( + const execution::outstanding_work_t::untracked_t&, int) const; + +template <> +ASIO_DECL any_completion_executor any_completion_executor::prefer( + const execution::relationship_t::fork_t&, int) const; + +template <> +ASIO_DECL any_completion_executor any_completion_executor::prefer( + const execution::relationship_t::continuation_t&, int) const; + +namespace traits { + +#if !defined(ASIO_HAS_DEDUCED_EQUALITY_COMPARABLE_TRAIT) + +template <> +struct equality_comparable +{ + static const bool is_valid = true; + static const bool is_noexcept = true; +}; + +#endif // !defined(ASIO_HAS_DEDUCED_EQUALITY_COMPARABLE_TRAIT) + +#if !defined(ASIO_HAS_DEDUCED_EXECUTE_MEMBER_TRAIT) + +template +struct execute_member +{ + static const bool is_valid = true; + static const bool is_noexcept = false; + typedef void result_type; +}; + +#endif // !defined(ASIO_HAS_DEDUCED_EXECUTE_MEMBER_TRAIT) + +#if !defined(ASIO_HAS_DEDUCED_QUERY_MEMBER_TRAIT) + +template +struct query_member : + query_member +{ +}; + +#endif // !defined(ASIO_HAS_DEDUCED_QUERY_MEMBER_TRAIT) + +#if !defined(ASIO_HAS_DEDUCED_REQUIRE_MEMBER_TRAIT) + +template +struct require_member : + require_member +{ + typedef any_completion_executor result_type; +}; + +#endif // !defined(ASIO_HAS_DEDUCED_REQUIRE_MEMBER_TRAIT) + +#if !defined(ASIO_HAS_DEDUCED_PREFER_MEMBER_TRAIT) + +template +struct prefer_member : + prefer_member +{ + typedef any_completion_executor result_type; +}; + +#endif // !defined(ASIO_HAS_DEDUCED_PREFER_MEMBER_TRAIT) + +} // namespace traits + +#endif // !defined(GENERATING_DOCUMENTATION) + +#endif // defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + +} // namespace asio + +#include "asio/detail/pop_options.hpp" + +#if defined(ASIO_HEADER_ONLY) \ + && !defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) +# include "asio/impl/any_completion_executor.ipp" +#endif // defined(ASIO_HEADER_ONLY) + // && !defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + +#endif // ASIO_ANY_COMPLETION_EXECUTOR_HPP diff --git a/thirdparty/asio/asio/any_completion_handler.hpp b/thirdparty/asio/asio/any_completion_handler.hpp new file mode 100644 index 00000000..cd114537 --- /dev/null +++ b/thirdparty/asio/asio/any_completion_handler.hpp @@ -0,0 +1,762 @@ +// +// any_completion_handler.hpp +// ~~~~~~~~~~~~~~~~~~~~~~~~~~ +// +// Copyright (c) 2003-2023 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 ASIO_ANY_COMPLETION_HANDLER_HPP +#define ASIO_ANY_COMPLETION_HANDLER_HPP + +#include "asio/detail/config.hpp" + +#if (defined(ASIO_HAS_STD_TUPLE) \ + && defined(ASIO_HAS_MOVE) \ + && defined(ASIO_HAS_VARIADIC_TEMPLATES)) \ + || defined(GENERATING_DOCUMENTATION) + +#include +#include +#include +#include +#include "asio/any_completion_executor.hpp" +#include "asio/associated_allocator.hpp" +#include "asio/associated_cancellation_slot.hpp" +#include "asio/associated_executor.hpp" +#include "asio/cancellation_state.hpp" +#include "asio/recycling_allocator.hpp" + +#include "asio/detail/push_options.hpp" + +namespace asio { +namespace detail { + +class any_completion_handler_impl_base +{ +public: + template + explicit any_completion_handler_impl_base(S&& slot) + : cancel_state_(ASIO_MOVE_CAST(S)(slot), enable_total_cancellation()) + { + } + + cancellation_slot get_cancellation_slot() const ASIO_NOEXCEPT + { + return cancel_state_.slot(); + } + +private: + cancellation_state cancel_state_; +}; + +template +class any_completion_handler_impl : + public any_completion_handler_impl_base +{ +public: + template + any_completion_handler_impl(S&& slot, H&& h) + : any_completion_handler_impl_base(ASIO_MOVE_CAST(S)(slot)), + handler_(ASIO_MOVE_CAST(H)(h)) + { + } + + struct uninit_deleter + { + typename std::allocator_traits< + associated_allocator_t>>::template + rebind_alloc alloc; + + void operator()(any_completion_handler_impl* ptr) + { + std::allocator_traits::deallocate(alloc, ptr, 1); + } + }; + + struct deleter + { + typename std::allocator_traits< + associated_allocator_t>>::template + rebind_alloc alloc; + + void operator()(any_completion_handler_impl* ptr) + { + std::allocator_traits::destroy(alloc, ptr); + std::allocator_traits::deallocate(alloc, ptr, 1); + } + }; + + template + static any_completion_handler_impl* create(S&& slot, H&& h) + { + uninit_deleter d{ + (get_associated_allocator)(h, + asio::recycling_allocator())}; + + std::unique_ptr uninit_ptr( + std::allocator_traits::allocate(d.alloc, 1), d); + + any_completion_handler_impl* ptr = + new (uninit_ptr.get()) any_completion_handler_impl( + ASIO_MOVE_CAST(S)(slot), ASIO_MOVE_CAST(H)(h)); + + uninit_ptr.release(); + return ptr; + } + + void destroy() + { + deleter d{ + (get_associated_allocator)(handler_, + asio::recycling_allocator())}; + + d(this); + } + + any_completion_executor executor( + const any_completion_executor& candidate) const ASIO_NOEXCEPT + { + return any_completion_executor(std::nothrow, + (get_associated_executor)(handler_, candidate)); + } + + void* allocate(std::size_t size, std::size_t align) const + { + typename std::allocator_traits< + associated_allocator_t>>::template + rebind_alloc alloc( + (get_associated_allocator)(handler_, + asio::recycling_allocator())); + + std::size_t space = size + align - 1; + unsigned char* base = + std::allocator_traits::allocate( + alloc, space + sizeof(std::ptrdiff_t)); + + void* p = base; + if (detail::align(align, size, p, space)) + { + std::ptrdiff_t off = static_cast(p) - base; + std::memcpy(static_cast(p) + size, &off, sizeof(off)); + return p; + } + + std::bad_alloc ex; + asio::detail::throw_exception(ex); + return nullptr; + } + + void deallocate(void* p, std::size_t size, std::size_t align) const + { + if (p) + { + typename std::allocator_traits< + associated_allocator_t>>::template + rebind_alloc alloc( + (get_associated_allocator)(handler_, + asio::recycling_allocator())); + + std::ptrdiff_t off; + std::memcpy(&off, static_cast(p) + size, sizeof(off)); + unsigned char* base = static_cast(p) - off; + + std::allocator_traits::deallocate( + alloc, base, size + align -1 + sizeof(std::ptrdiff_t)); + } + } + + template + void call(Args&&... args) + { + deleter d{ + (get_associated_allocator)(handler_, + asio::recycling_allocator())}; + + std::unique_ptr ptr(this, d); + Handler handler(ASIO_MOVE_CAST(Handler)(handler_)); + ptr.reset(); + + ASIO_MOVE_CAST(Handler)(handler)( + ASIO_MOVE_CAST(Args)(args)...); + } + +private: + Handler handler_; +}; + +template +class any_completion_handler_call_fn; + +template +class any_completion_handler_call_fn +{ +public: + using type = void(*)(any_completion_handler_impl_base*, Args...); + + constexpr any_completion_handler_call_fn(type fn) + : call_fn_(fn) + { + } + + void call(any_completion_handler_impl_base* impl, Args... args) const + { + call_fn_(impl, ASIO_MOVE_CAST(Args)(args)...); + } + + template + static void impl(any_completion_handler_impl_base* impl, Args... args) + { + static_cast*>(impl)->call( + ASIO_MOVE_CAST(Args)(args)...); + } + +private: + type call_fn_; +}; + +template +class any_completion_handler_call_fns; + +template +class any_completion_handler_call_fns : + public any_completion_handler_call_fn +{ +public: + using any_completion_handler_call_fn< + Signature>::any_completion_handler_call_fn; + using any_completion_handler_call_fn::call; +}; + +template +class any_completion_handler_call_fns : + public any_completion_handler_call_fn, + public any_completion_handler_call_fns +{ +public: + template + constexpr any_completion_handler_call_fns(CallFn fn, CallFns... fns) + : any_completion_handler_call_fn(fn), + any_completion_handler_call_fns(fns...) + { + } + + using any_completion_handler_call_fn::call; + using any_completion_handler_call_fns::call; +}; + +class any_completion_handler_destroy_fn +{ +public: + using type = void(*)(any_completion_handler_impl_base*); + + constexpr any_completion_handler_destroy_fn(type fn) + : destroy_fn_(fn) + { + } + + void destroy(any_completion_handler_impl_base* impl) const + { + destroy_fn_(impl); + } + + template + static void impl(any_completion_handler_impl_base* impl) + { + static_cast*>(impl)->destroy(); + } + +private: + type destroy_fn_; +}; + +class any_completion_handler_executor_fn +{ +public: + using type = any_completion_executor(*)( + any_completion_handler_impl_base*, const any_completion_executor&); + + constexpr any_completion_handler_executor_fn(type fn) + : executor_fn_(fn) + { + } + + any_completion_executor executor(any_completion_handler_impl_base* impl, + const any_completion_executor& candidate) const + { + return executor_fn_(impl, candidate); + } + + template + static any_completion_executor impl(any_completion_handler_impl_base* impl, + const any_completion_executor& candidate) + { + return static_cast*>(impl)->executor( + candidate); + } + +private: + type executor_fn_; +}; + +class any_completion_handler_allocate_fn +{ +public: + using type = void*(*)(any_completion_handler_impl_base*, + std::size_t, std::size_t); + + constexpr any_completion_handler_allocate_fn(type fn) + : allocate_fn_(fn) + { + } + + void* allocate(any_completion_handler_impl_base* impl, + std::size_t size, std::size_t align) const + { + return allocate_fn_(impl, size, align); + } + + template + static void* impl(any_completion_handler_impl_base* impl, + std::size_t size, std::size_t align) + { + return static_cast*>(impl)->allocate( + size, align); + } + +private: + type allocate_fn_; +}; + +class any_completion_handler_deallocate_fn +{ +public: + using type = void(*)(any_completion_handler_impl_base*, + void*, std::size_t, std::size_t); + + constexpr any_completion_handler_deallocate_fn(type fn) + : deallocate_fn_(fn) + { + } + + void deallocate(any_completion_handler_impl_base* impl, + void* p, std::size_t size, std::size_t align) const + { + deallocate_fn_(impl, p, size, align); + } + + template + static void impl(any_completion_handler_impl_base* impl, + void* p, std::size_t size, std::size_t align) + { + static_cast*>(impl)->deallocate( + p, size, align); + } + +private: + type deallocate_fn_; +}; + +template +class any_completion_handler_fn_table + : private any_completion_handler_destroy_fn, + private any_completion_handler_executor_fn, + private any_completion_handler_allocate_fn, + private any_completion_handler_deallocate_fn, + private any_completion_handler_call_fns +{ +public: + template + constexpr any_completion_handler_fn_table( + any_completion_handler_destroy_fn::type destroy_fn, + any_completion_handler_executor_fn::type executor_fn, + any_completion_handler_allocate_fn::type allocate_fn, + any_completion_handler_deallocate_fn::type deallocate_fn, + CallFns... call_fns) + : any_completion_handler_destroy_fn(destroy_fn), + any_completion_handler_executor_fn(executor_fn), + any_completion_handler_allocate_fn(allocate_fn), + any_completion_handler_deallocate_fn(deallocate_fn), + any_completion_handler_call_fns(call_fns...) + { + } + + using any_completion_handler_destroy_fn::destroy; + using any_completion_handler_executor_fn::executor; + using any_completion_handler_allocate_fn::allocate; + using any_completion_handler_deallocate_fn::deallocate; + using any_completion_handler_call_fns::call; +}; + +template +struct any_completion_handler_fn_table_instance +{ + static constexpr any_completion_handler_fn_table + value = any_completion_handler_fn_table( + &any_completion_handler_destroy_fn::impl, + &any_completion_handler_executor_fn::impl, + &any_completion_handler_allocate_fn::impl, + &any_completion_handler_deallocate_fn::impl, + &any_completion_handler_call_fn::template impl...); +}; + +template +constexpr any_completion_handler_fn_table +any_completion_handler_fn_table_instance::value; + +} // namespace detail + +template +class any_completion_handler; + +/// An allocator type that forwards memory allocation operations through an +/// instance of @c any_completion_handler. +template +class any_completion_handler_allocator +{ +private: + template + friend class any_completion_handler; + + template + friend class any_completion_handler_allocator; + + const detail::any_completion_handler_fn_table* fn_table_; + detail::any_completion_handler_impl_base* impl_; + + constexpr any_completion_handler_allocator(int, + const any_completion_handler& h) ASIO_NOEXCEPT + : fn_table_(h.fn_table_), + impl_(h.impl_) + { + } + +public: + /// The type of objects that may be allocated by the allocator. + typedef T value_type; + + /// Rebinds an allocator to another value type. + template + struct rebind + { + /// Specifies the type of the rebound allocator. + typedef any_completion_handler_allocator other; + }; + + /// Construct from another @c any_completion_handler_allocator. + template + constexpr any_completion_handler_allocator( + const any_completion_handler_allocator& a) + ASIO_NOEXCEPT + : fn_table_(a.fn_table_), + impl_(a.impl_) + { + } + + /// Equality operator. + constexpr bool operator==( + const any_completion_handler_allocator& other) const ASIO_NOEXCEPT + { + return fn_table_ == other.fn_table_ && impl_ == other.impl_; + } + + /// Inequality operator. + constexpr bool operator!=( + const any_completion_handler_allocator& other) const ASIO_NOEXCEPT + { + return fn_table_ != other.fn_table_ || impl_ != other.impl_; + } + + /// Allocate space for @c n objects of the allocator's value type. + T* allocate(std::size_t n) const + { + return static_cast( + fn_table_->allocate( + impl_, sizeof(T) * n, alignof(T))); + } + + /// Deallocate space for @c n objects of the allocator's value type. + void deallocate(T* p, std::size_t n) const + { + fn_table_->deallocate(impl_, p, sizeof(T) * n, alignof(T)); + } +}; + +/// A protoco-allocator type that may be rebound to obtain an allocator that +/// forwards memory allocation operations through an instance of +/// @c any_completion_handler. +template +class any_completion_handler_allocator +{ +private: + template + friend class any_completion_handler; + + template + friend class any_completion_handler_allocator; + + const detail::any_completion_handler_fn_table* fn_table_; + detail::any_completion_handler_impl_base* impl_; + + constexpr any_completion_handler_allocator(int, + const any_completion_handler& h) ASIO_NOEXCEPT + : fn_table_(h.fn_table_), + impl_(h.impl_) + { + } + +public: + /// @c void as no objects can be allocated through a proto-allocator. + typedef void value_type; + + /// Rebinds an allocator to another value type. + template + struct rebind + { + /// Specifies the type of the rebound allocator. + typedef any_completion_handler_allocator other; + }; + + /// Construct from another @c any_completion_handler_allocator. + template + constexpr any_completion_handler_allocator( + const any_completion_handler_allocator& a) + ASIO_NOEXCEPT + : fn_table_(a.fn_table_), + impl_(a.impl_) + { + } + + /// Equality operator. + constexpr bool operator==( + const any_completion_handler_allocator& other) const ASIO_NOEXCEPT + { + return fn_table_ == other.fn_table_ && impl_ == other.impl_; + } + + /// Inequality operator. + constexpr bool operator!=( + const any_completion_handler_allocator& other) const ASIO_NOEXCEPT + { + return fn_table_ != other.fn_table_ || impl_ != other.impl_; + } +}; + +/// Polymorphic wrapper for completion handlers. +/** + * The @c any_completion_handler class template is a polymorphic wrapper for + * completion handlers that propagates the associated executor, associated + * allocator, and associated cancellation slot through a type-erasing interface. + * + * When using @c any_completion_handler, specify one or more completion + * signatures as template parameters. These will dictate the arguments that may + * be passed to the handler through the polymorphic interface. + * + * Typical uses for @c any_completion_handler include: + * + * @li Separate compilation of asynchronous operation implementations. + * + * @li Enabling interoperability between asynchronous operations and virtual + * functions. + */ +template +class any_completion_handler +{ +#if !defined(GENERATING_DOCUMENTATION) +private: + template + friend class any_completion_handler_allocator; + + template + friend struct associated_executor; + + const detail::any_completion_handler_fn_table* fn_table_; + detail::any_completion_handler_impl_base* impl_; +#endif // !defined(GENERATING_DOCUMENTATION) + +public: + /// The associated allocator type. + using allocator_type = any_completion_handler_allocator; + + /// The associated cancellation slot type. + using cancellation_slot_type = cancellation_slot; + + /// Construct an @c any_completion_handler in an empty state, without a target + /// object. + constexpr any_completion_handler() + : fn_table_(nullptr), + impl_(nullptr) + { + } + + /// Construct an @c any_completion_handler in an empty state, without a target + /// object. + constexpr any_completion_handler(nullptr_t) + : fn_table_(nullptr), + impl_(nullptr) + { + } + + /// Construct an @c any_completion_handler to contain the specified target. + template ::type> + any_completion_handler(H&& h, + typename constraint< + !is_same::type, any_completion_handler>::value + >::type = 0) + : fn_table_( + &detail::any_completion_handler_fn_table_instance< + Handler, Signatures...>::value), + impl_(detail::any_completion_handler_impl::create( + (get_associated_cancellation_slot)(h), ASIO_MOVE_CAST(H)(h))) + { + } + + /// Move-construct an @c any_completion_handler from another. + /** + * After the operation, the moved-from object @c other has no target. + */ + any_completion_handler(any_completion_handler&& other) ASIO_NOEXCEPT + : fn_table_(other.fn_table_), + impl_(other.impl_) + { + other.fn_table_ = nullptr; + other.impl_ = nullptr; + } + + /// Move-assign an @c any_completion_handler from another. + /** + * After the operation, the moved-from object @c other has no target. + */ + any_completion_handler& operator=( + any_completion_handler&& other) ASIO_NOEXCEPT + { + any_completion_handler( + ASIO_MOVE_CAST(any_completion_handler)(other)).swap(*this); + return *this; + } + + /// Assignment operator that sets the polymorphic wrapper to the empty state. + any_completion_handler& operator=(nullptr_t) ASIO_NOEXCEPT + { + any_completion_handler().swap(*this); + return *this; + } + + /// Destructor. + ~any_completion_handler() + { + if (impl_) + fn_table_->destroy(impl_); + } + + /// Test if the polymorphic wrapper is empty. + constexpr explicit operator bool() const ASIO_NOEXCEPT + { + return impl_ != nullptr; + } + + /// Test if the polymorphic wrapper is non-empty. + constexpr bool operator!() const ASIO_NOEXCEPT + { + return impl_ == nullptr; + } + + /// Swap the content of an @c any_completion_handler with another. + void swap(any_completion_handler& other) ASIO_NOEXCEPT + { + std::swap(fn_table_, other.fn_table_); + std::swap(impl_, other.impl_); + } + + /// Get the associated allocator. + allocator_type get_allocator() const ASIO_NOEXCEPT + { + return allocator_type(0, *this); + } + + /// Get the associated cancellation slot. + cancellation_slot_type get_cancellation_slot() const ASIO_NOEXCEPT + { + return impl_->get_cancellation_slot(); + } + + /// Function call operator. + /** + * Invokes target completion handler with the supplied arguments. + * + * This function may only be called once, as the target handler is moved from. + * The polymorphic wrapper is left in an empty state. + * + * Throws @c std::bad_function_call if the polymorphic wrapper is empty. + */ + template + auto operator()(Args&&... args) + -> decltype(fn_table_->call(impl_, ASIO_MOVE_CAST(Args)(args)...)) + { + if (detail::any_completion_handler_impl_base* impl = impl_) + { + impl_ = nullptr; + return fn_table_->call(impl, ASIO_MOVE_CAST(Args)(args)...); + } + std::bad_function_call ex; + asio::detail::throw_exception(ex); + } + + /// Equality operator. + friend constexpr bool operator==( + const any_completion_handler& a, nullptr_t) ASIO_NOEXCEPT + { + return a.impl_ == nullptr; + } + + /// Equality operator. + friend constexpr bool operator==( + nullptr_t, const any_completion_handler& b) ASIO_NOEXCEPT + { + return nullptr == b.impl_; + } + + /// Inequality operator. + friend constexpr bool operator!=( + const any_completion_handler& a, nullptr_t) ASIO_NOEXCEPT + { + return a.impl_ != nullptr; + } + + /// Inequality operator. + friend constexpr bool operator!=( + nullptr_t, const any_completion_handler& b) ASIO_NOEXCEPT + { + return nullptr != b.impl_; + } +}; + +template +struct associated_executor, Candidate> +{ + using type = any_completion_executor; + + static type get(const any_completion_handler& handler, + const Candidate& candidate = Candidate()) ASIO_NOEXCEPT + { + return handler.fn_table_->executor(handler.impl_, + any_completion_executor(std::nothrow, candidate)); + } +}; + +} // namespace asio + +#include "asio/detail/pop_options.hpp" + +#endif // (defined(ASIO_HAS_STD_TUPLE) + // && defined(ASIO_HAS_MOVE) + // && defined(ASIO_HAS_VARIADIC_TEMPLATES)) + // || defined(GENERATING_DOCUMENTATION) + +#endif // ASIO_ANY_COMPLETION_HANDLER_HPP diff --git a/thirdparty/asio/asio/any_io_executor.hpp b/thirdparty/asio/asio/any_io_executor.hpp index 5f2c13f0..7a77c90d 100644 --- a/thirdparty/asio/asio/any_io_executor.hpp +++ b/thirdparty/asio/asio/any_io_executor.hpp @@ -2,7 +2,7 @@ // any_io_executor.hpp // ~~~~~~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -87,29 +87,17 @@ class any_io_executor : #endif // !defined(GENERATING_DOCUMENTATION) /// Default constructor. - any_io_executor() ASIO_NOEXCEPT - : base_type() - { - } + ASIO_DECL any_io_executor() ASIO_NOEXCEPT; /// Construct in an empty state. Equivalent effects to default constructor. - any_io_executor(nullptr_t) ASIO_NOEXCEPT - : base_type(nullptr_t()) - { - } + ASIO_DECL any_io_executor(nullptr_t) ASIO_NOEXCEPT; /// Copy constructor. - any_io_executor(const any_io_executor& e) ASIO_NOEXCEPT - : base_type(static_cast(e)) - { - } + ASIO_DECL any_io_executor(const any_io_executor& e) ASIO_NOEXCEPT; #if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) /// Move constructor. - any_io_executor(any_io_executor&& e) ASIO_NOEXCEPT - : base_type(static_cast(e)) - { - } + ASIO_DECL any_io_executor(any_io_executor&& e) ASIO_NOEXCEPT; #endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) /// Construct to point to the same target as another any_executor. @@ -135,6 +123,40 @@ class any_io_executor : } #endif // defined(GENERATING_DOCUMENTATION) + /// Construct to point to the same target as another any_executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_io_executor(std::nothrow_t, + execution::any_executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_io_executor(std::nothrow_t, OtherAnyExecutor e, + typename constraint< + conditional< + !is_same::value + && is_base_of::value, + typename execution::detail::supportable_properties< + 0, supportable_properties_type>::template + is_valid_target, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : base_type(std::nothrow, ASIO_MOVE_CAST(OtherAnyExecutor)(e)) + { + } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Construct to point to the same target as another any_executor. + ASIO_DECL any_io_executor(std::nothrow_t, + const any_io_executor& e) ASIO_NOEXCEPT; + +#if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + /// Construct to point to the same target as another any_executor. + ASIO_DECL any_io_executor(std::nothrow_t, + any_io_executor&& e) ASIO_NOEXCEPT; +#endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) + /// Construct a polymorphic wrapper for the specified executor. #if defined(GENERATING_DOCUMENTATION) template @@ -157,39 +179,46 @@ class any_io_executor : } #endif // defined(GENERATING_DOCUMENTATION) - /// Assignment operator. - any_io_executor& operator=(const any_io_executor& e) ASIO_NOEXCEPT + /// Construct a polymorphic wrapper for the specified executor. +#if defined(GENERATING_DOCUMENTATION) + template + any_io_executor(std::nothrow_t, Executor e); +#else // defined(GENERATING_DOCUMENTATION) + template + any_io_executor(std::nothrow_t, Executor e, + typename constraint< + conditional< + !is_same::value + && !is_base_of::value, + execution::detail::is_valid_target_executor< + Executor, supportable_properties_type>, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : base_type(std::nothrow, ASIO_MOVE_CAST(Executor)(e)) { - base_type::operator=(static_cast(e)); - return *this; } +#endif // defined(GENERATING_DOCUMENTATION) + + /// Assignment operator. + ASIO_DECL any_io_executor& operator=( + const any_io_executor& e) ASIO_NOEXCEPT; #if defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) /// Move assignment operator. - any_io_executor& operator=(any_io_executor&& e) ASIO_NOEXCEPT - { - base_type::operator=(static_cast(e)); - return *this; - } + ASIO_DECL any_io_executor& operator=( + any_io_executor&& e) ASIO_NOEXCEPT; #endif // defined(ASIO_HAS_MOVE) || defined(GENERATING_DOCUMENTATION) /// Assignment operator that sets the polymorphic wrapper to the empty state. - any_io_executor& operator=(nullptr_t) - { - base_type::operator=(nullptr_t()); - return *this; - } + ASIO_DECL any_io_executor& operator=(nullptr_t); /// Destructor. - ~any_io_executor() - { - } + ASIO_DECL ~any_io_executor(); /// Swap targets with another polymorphic wrapper. - void swap(any_io_executor& other) ASIO_NOEXCEPT - { - static_cast(*this).swap(static_cast(other)); - } + ASIO_DECL void swap(any_io_executor& other) ASIO_NOEXCEPT; /// Obtain a polymorphic wrapper with the specified property. /** @@ -230,6 +259,30 @@ class any_io_executor : #if !defined(GENERATING_DOCUMENTATION) +template <> +ASIO_DECL any_io_executor any_io_executor::require( + const execution::blocking_t::never_t&, int) const; + +template <> +ASIO_DECL any_io_executor any_io_executor::prefer( + const execution::blocking_t::possibly_t&, int) const; + +template <> +ASIO_DECL any_io_executor any_io_executor::prefer( + const execution::outstanding_work_t::tracked_t&, int) const; + +template <> +ASIO_DECL any_io_executor any_io_executor::prefer( + const execution::outstanding_work_t::untracked_t&, int) const; + +template <> +ASIO_DECL any_io_executor any_io_executor::prefer( + const execution::relationship_t::fork_t&, int) const; + +template <> +ASIO_DECL any_io_executor any_io_executor::prefer( + const execution::relationship_t::continuation_t&, int) const; + namespace traits { #if !defined(ASIO_HAS_DEDUCED_EQUALITY_COMPARABLE_TRAIT) @@ -297,4 +350,10 @@ struct prefer_member : #include "asio/detail/pop_options.hpp" +#if defined(ASIO_HEADER_ONLY) \ + && !defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) +# include "asio/impl/any_io_executor.ipp" +#endif // defined(ASIO_HEADER_ONLY) + // && !defined(ASIO_USE_TS_EXECUTOR_AS_DEFAULT) + #endif // ASIO_ANY_IO_EXECUTOR_HPP diff --git a/thirdparty/asio/asio/append.hpp b/thirdparty/asio/asio/append.hpp new file mode 100644 index 00000000..9ac4a950 --- /dev/null +++ b/thirdparty/asio/asio/append.hpp @@ -0,0 +1,78 @@ +// +// append.hpp +// ~~~~~~~~~~ +// +// Copyright (c) 2003-2023 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 ASIO_APPEND_HPP +#define ASIO_APPEND_HPP + +#if defined(_MSC_VER) && (_MSC_VER >= 1200) +# pragma once +#endif // defined(_MSC_VER) && (_MSC_VER >= 1200) + +#include "asio/detail/config.hpp" + +#if (defined(ASIO_HAS_STD_TUPLE) \ + && defined(ASIO_HAS_VARIADIC_TEMPLATES)) \ + || defined(GENERATING_DOCUMENTATION) + +#include +#include "asio/detail/type_traits.hpp" + +#include "asio/detail/push_options.hpp" + +namespace asio { + +/// Completion token type used to specify that the completion handler +/// arguments should be passed additional values after the results of the +/// operation. +template +class append_t +{ +public: + /// Constructor. + template + ASIO_CONSTEXPR explicit append_t( + ASIO_MOVE_ARG(T) completion_token, + ASIO_MOVE_ARG(V)... values) + : token_(ASIO_MOVE_CAST(T)(completion_token)), + values_(ASIO_MOVE_CAST(V)(values)...) + { + } + +//private: + CompletionToken token_; + std::tuple values_; +}; + +/// Completion token type used to specify that the completion handler +/// arguments should be passed additional values after the results of the +/// operation. +template +ASIO_NODISCARD inline ASIO_CONSTEXPR append_t< + typename decay::type, typename decay::type...> +append(ASIO_MOVE_ARG(CompletionToken) completion_token, + ASIO_MOVE_ARG(Values)... values) +{ + return append_t< + typename decay::type, typename decay::type...>( + ASIO_MOVE_CAST(CompletionToken)(completion_token), + ASIO_MOVE_CAST(Values)(values)...); +} + +} // namespace asio + +#include "asio/detail/pop_options.hpp" + +#include "asio/impl/append.hpp" + +#endif // (defined(ASIO_HAS_STD_TUPLE) + // && defined(ASIO_HAS_VARIADIC_TEMPLATES)) + // || defined(GENERATING_DOCUMENTATION) + +#endif // ASIO_APPEND_HPP diff --git a/thirdparty/asio/asio/as_tuple.hpp b/thirdparty/asio/asio/as_tuple.hpp new file mode 100644 index 00000000..96ac47c8 --- /dev/null +++ b/thirdparty/asio/asio/as_tuple.hpp @@ -0,0 +1,139 @@ +// +// as_tuple.hpp +// ~~~~~~~~~~~~ +// +// Copyright (c) 2003-2023 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 ASIO_AS_TUPLE_HPP +#define ASIO_AS_TUPLE_HPP + +#if defined(_MSC_VER) && (_MSC_VER >= 1200) +# pragma once +#endif // defined(_MSC_VER) && (_MSC_VER >= 1200) + +#include "asio/detail/config.hpp" + +#if (defined(ASIO_HAS_STD_TUPLE) \ + && defined(ASIO_HAS_VARIADIC_TEMPLATES)) \ + || defined(GENERATING_DOCUMENTATION) + +#include "asio/detail/type_traits.hpp" + +#include "asio/detail/push_options.hpp" + +namespace asio { + +/// A @ref completion_token adapter used to specify that the completion handler +/// arguments should be combined into a single tuple argument. +/** + * The as_tuple_t class is used to indicate that any arguments to the + * completion handler should be combined and passed as a single tuple argument. + * The arguments are first moved into a @c std::tuple and that tuple is then + * passed to the completion handler. + */ +template +class as_tuple_t +{ +public: + /// Tag type used to prevent the "default" constructor from being used for + /// conversions. + struct default_constructor_tag {}; + + /// Default constructor. + /** + * This constructor is only valid if the underlying completion token is + * default constructible and move constructible. The underlying completion + * token is itself defaulted as an argument to allow it to capture a source + * location. + */ + ASIO_CONSTEXPR as_tuple_t( + default_constructor_tag = default_constructor_tag(), + CompletionToken token = CompletionToken()) + : token_(ASIO_MOVE_CAST(CompletionToken)(token)) + { + } + + /// Constructor. + template + ASIO_CONSTEXPR explicit as_tuple_t( + ASIO_MOVE_ARG(T) completion_token) + : token_(ASIO_MOVE_CAST(T)(completion_token)) + { + } + + /// Adapts an executor to add the @c as_tuple_t completion token as the + /// default. + template + struct executor_with_default : InnerExecutor + { + /// Specify @c as_tuple_t as the default completion token type. + typedef as_tuple_t default_completion_token_type; + + /// Construct the adapted executor from the inner executor type. + template + executor_with_default(const InnerExecutor1& ex, + typename constraint< + conditional< + !is_same::value, + is_convertible, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : InnerExecutor(ex) + { + } + }; + + /// Type alias to adapt an I/O object to use @c as_tuple_t as its + /// default completion token type. +#if defined(ASIO_HAS_ALIAS_TEMPLATES) \ + || defined(GENERATING_DOCUMENTATION) + template + using as_default_on_t = typename T::template rebind_executor< + executor_with_default >::other; +#endif // defined(ASIO_HAS_ALIAS_TEMPLATES) + // || defined(GENERATING_DOCUMENTATION) + + /// Function helper to adapt an I/O object to use @c as_tuple_t as its + /// default completion token type. + template + static typename decay::type::template rebind_executor< + executor_with_default::type::executor_type> + >::other + as_default_on(ASIO_MOVE_ARG(T) object) + { + return typename decay::type::template rebind_executor< + executor_with_default::type::executor_type> + >::other(ASIO_MOVE_CAST(T)(object)); + } + +//private: + CompletionToken token_; +}; + +/// Adapt a @ref completion_token to specify that the completion handler +/// arguments should be combined into a single tuple argument. +template +ASIO_NODISCARD inline +ASIO_CONSTEXPR as_tuple_t::type> +as_tuple(ASIO_MOVE_ARG(CompletionToken) completion_token) +{ + return as_tuple_t::type>( + ASIO_MOVE_CAST(CompletionToken)(completion_token)); +} + +} // namespace asio + +#include "asio/detail/pop_options.hpp" + +#include "asio/impl/as_tuple.hpp" + +#endif // (defined(ASIO_HAS_STD_TUPLE) + // && defined(ASIO_HAS_VARIADIC_TEMPLATES)) + // || defined(GENERATING_DOCUMENTATION) + +#endif // ASIO_AS_TUPLE_HPP diff --git a/thirdparty/asio/asio/associated_allocator.hpp b/thirdparty/asio/asio/associated_allocator.hpp index 3f945834..8e864673 100644 --- a/thirdparty/asio/asio/associated_allocator.hpp +++ b/thirdparty/asio/asio/associated_allocator.hpp @@ -2,7 +2,7 @@ // associated_allocator.hpp // ~~~~~~~~~~~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -37,42 +37,58 @@ struct has_allocator_type : false_type template struct has_allocator_type::type> + typename void_type::type> : true_type { }; -template +template struct associated_allocator_impl { - typedef E type; + typedef void asio_associated_allocator_is_unspecialised; + + typedef A type; + + static type get(const T&) ASIO_NOEXCEPT + { + return type(); + } - static type get(const T&, const E& e) ASIO_NOEXCEPT + static const type& get(const T&, const A& a) ASIO_NOEXCEPT { - return e; + return a; } }; -template -struct associated_allocator_impl +struct associated_allocator_impl::type> { typedef typename T::allocator_type type; - static type get(const T& t, const E&) ASIO_NOEXCEPT + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + const T& t) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX((t.get_allocator())) + { + return t.get_allocator(); + } + + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + const T& t, const A&) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX((t.get_allocator())) { return t.get_allocator(); } }; -template -struct associated_allocator_impl +struct associated_allocator_impl::value >::type, typename void_type< - typename associator::type - >::type> : associator + typename associator::type + >::type> : associator { }; @@ -92,29 +108,32 @@ struct associated_allocator_impl > struct associated_allocator +#if !defined(GENERATING_DOCUMENTATION) + : detail::associated_allocator_impl +#endif // !defined(GENERATING_DOCUMENTATION) { +#if defined(GENERATING_DOCUMENTATION) /// If @c T has a nested type @c allocator_type, T::allocator_type. /// Otherwise @c Allocator. -#if defined(GENERATING_DOCUMENTATION) typedef see_below type; -#else // defined(GENERATING_DOCUMENTATION) - typedef typename detail::associated_allocator_impl::type type; -#endif // defined(GENERATING_DOCUMENTATION) + + /// If @c T has a nested type @c allocator_type, returns + /// t.get_allocator(). Otherwise returns @c type(). + static decltype(auto) get(const T& t) ASIO_NOEXCEPT; /// If @c T has a nested type @c allocator_type, returns /// t.get_allocator(). Otherwise returns @c a. - static type get(const T& t, - const Allocator& a = Allocator()) ASIO_NOEXCEPT - { - return detail::associated_allocator_impl::get(t, a); - } + static decltype(auto) get(const T& t, const Allocator& a) ASIO_NOEXCEPT; +#endif // defined(GENERATING_DOCUMENTATION) }; /// Helper function to obtain an object's associated allocator. @@ -122,7 +141,7 @@ struct associated_allocator * @returns associated_allocator::get(t) */ template -inline typename associated_allocator::type +ASIO_NODISCARD inline typename associated_allocator::type get_associated_allocator(const T& t) ASIO_NOEXCEPT { return associated_allocator::get(t); @@ -133,8 +152,11 @@ get_associated_allocator(const T& t) ASIO_NOEXCEPT * @returns associated_allocator::get(t, a) */ template -inline typename associated_allocator::type +ASIO_NODISCARD inline ASIO_AUTO_RETURN_TYPE_PREFIX2( + typename associated_allocator::type) get_associated_allocator(const T& t, const Allocator& a) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_allocator::get(t, a))) { return associated_allocator::get(t, a); } @@ -147,12 +169,37 @@ using associated_allocator_t #endif // defined(ASIO_HAS_ALIAS_TEMPLATES) +namespace detail { + +template +struct associated_allocator_forwarding_base +{ +}; + +template +struct associated_allocator_forwarding_base::asio_associated_allocator_is_unspecialised, + void + >::value + >::type> +{ + typedef void asio_associated_allocator_is_unspecialised; +}; + +} // namespace detail + #if defined(ASIO_HAS_STD_REFERENCE_WRAPPER) \ || defined(GENERATING_DOCUMENTATION) /// Specialisation of associated_allocator for @c std::reference_wrapper. template struct associated_allocator, Allocator> +#if !defined(GENERATING_DOCUMENTATION) + : detail::associated_allocator_forwarding_base +#endif // !defined(GENERATING_DOCUMENTATION) { /// Forwards @c type to the associator specialisation for the unwrapped type /// @c T. @@ -160,8 +207,17 @@ struct associated_allocator, Allocator> /// Forwards the request to get the allocator to the associator specialisation /// for the unwrapped type @c T. - static type get(reference_wrapper t, - const Allocator& a = Allocator()) ASIO_NOEXCEPT + static type get(reference_wrapper t) ASIO_NOEXCEPT + { + return associated_allocator::get(t.get()); + } + + /// Forwards the request to get the allocator to the associator specialisation + /// for the unwrapped type @c T. + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + reference_wrapper t, const Allocator& a) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_allocator::get(t.get(), a))) { return associated_allocator::get(t.get(), a); } diff --git a/thirdparty/asio/asio/associated_cancellation_slot.hpp b/thirdparty/asio/asio/associated_cancellation_slot.hpp index 6a809e71..65d82b64 100644 --- a/thirdparty/asio/asio/associated_cancellation_slot.hpp +++ b/thirdparty/asio/asio/associated_cancellation_slot.hpp @@ -2,7 +2,7 @@ // associated_cancellation_slot.hpp // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -18,6 +18,7 @@ #include "asio/detail/config.hpp" #include "asio/associator.hpp" #include "asio/cancellation_signal.hpp" +#include "asio/detail/functional.hpp" #include "asio/detail/type_traits.hpp" #include "asio/detail/push_options.hpp" @@ -48,7 +49,12 @@ struct associated_cancellation_slot_impl typedef S type; - static type get(const T&, const S& s = S()) ASIO_NOEXCEPT + static type get(const T&) ASIO_NOEXCEPT + { + return type(); + } + + static const type& get(const T&, const S& s) ASIO_NOEXCEPT { return s; } @@ -60,7 +66,16 @@ struct associated_cancellation_slot_impl struct associated_cancellation_slot @@ -110,10 +127,14 @@ struct associated_cancellation_slot /// @c CancellationSlot. typedef see_below type; + /// If @c T has a nested type @c cancellation_slot_type, returns + /// t.get_cancellation_slot(). Otherwise returns @c type(). + static decltype(auto) get(const T& t) ASIO_NOEXCEPT; + /// If @c T has a nested type @c cancellation_slot_type, returns /// t.get_cancellation_slot(). Otherwise returns @c s. - static type get(const T& t, - const CancellationSlot& s = CancellationSlot()) ASIO_NOEXCEPT; + static decltype(auto) get(const T& t, + const CancellationSlot& s) ASIO_NOEXCEPT; #endif // defined(GENERATING_DOCUMENTATION) }; @@ -122,7 +143,7 @@ struct associated_cancellation_slot * @returns associated_cancellation_slot::get(t) */ template -inline typename associated_cancellation_slot::type +ASIO_NODISCARD inline typename associated_cancellation_slot::type get_associated_cancellation_slot(const T& t) ASIO_NOEXCEPT { return associated_cancellation_slot::get(t); @@ -134,9 +155,12 @@ get_associated_cancellation_slot(const T& t) ASIO_NOEXCEPT * CancellationSlot>::get(t, st) */ template -inline typename associated_cancellation_slot::type +ASIO_NODISCARD inline ASIO_AUTO_RETURN_TYPE_PREFIX2( + typename associated_cancellation_slot::type) get_associated_cancellation_slot(const T& t, const CancellationSlot& st) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_cancellation_slot::get(t, st))) { return associated_cancellation_slot::get(t, st); } @@ -170,6 +194,43 @@ struct associated_cancellation_slot_forwarding_base +struct associated_cancellation_slot, CancellationSlot> +#if !defined(GENERATING_DOCUMENTATION) + : detail::associated_cancellation_slot_forwarding_base +#endif // !defined(GENERATING_DOCUMENTATION) +{ + /// Forwards @c type to the associator specialisation for the unwrapped type + /// @c T. + typedef typename associated_cancellation_slot::type type; + + /// Forwards the request to get the cancellation slot to the associator + /// specialisation for the unwrapped type @c T. + static type get(reference_wrapper t) ASIO_NOEXCEPT + { + return associated_cancellation_slot::get(t.get()); + } + + /// Forwards the request to get the cancellation slot to the associator + /// specialisation for the unwrapped type @c T. + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get(reference_wrapper t, + const CancellationSlot& s) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_cancellation_slot::get(t.get(), s))) + { + return associated_cancellation_slot::get(t.get(), s); + } +}; + +#endif // defined(ASIO_HAS_STD_REFERENCE_WRAPPER) + // || defined(GENERATING_DOCUMENTATION) + } // namespace asio #include "asio/detail/pop_options.hpp" diff --git a/thirdparty/asio/asio/associated_executor.hpp b/thirdparty/asio/asio/associated_executor.hpp index 1e62e37a..92279891 100644 --- a/thirdparty/asio/asio/associated_executor.hpp +++ b/thirdparty/asio/asio/associated_executor.hpp @@ -2,7 +2,7 @@ // associated_executor.hpp // ~~~~~~~~~~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -51,7 +51,12 @@ struct associated_executor_impl typedef E type; - static type get(const T&, const E& e = E()) ASIO_NOEXCEPT + static type get(const T&) ASIO_NOEXCEPT + { + return type(); + } + + static const type& get(const T&, const E& e) ASIO_NOEXCEPT { return e; } @@ -63,7 +68,16 @@ struct associated_executor_impl struct associated_executor @@ -112,10 +128,13 @@ struct associated_executor /// Otherwise @c Executor. typedef see_below type; + /// If @c T has a nested type @c executor_type, returns + /// t.get_executor(). Otherwise returns @c type(). + static decltype(auto) get(const T& t) ASIO_NOEXCEPT; + /// If @c T has a nested type @c executor_type, returns /// t.get_executor(). Otherwise returns @c ex. - static type get(const T& t, - const Executor& ex = Executor()) ASIO_NOEXCEPT; + static decltype(auto) get(const T& t, const Executor& ex) ASIO_NOEXCEPT; #endif // defined(GENERATING_DOCUMENTATION) }; @@ -124,7 +143,7 @@ struct associated_executor * @returns associated_executor::get(t) */ template -inline typename associated_executor::type +ASIO_NODISCARD inline typename associated_executor::type get_associated_executor(const T& t) ASIO_NOEXCEPT { return associated_executor::get(t); @@ -135,11 +154,14 @@ get_associated_executor(const T& t) ASIO_NOEXCEPT * @returns associated_executor::get(t, ex) */ template -inline typename associated_executor::type +ASIO_NODISCARD inline ASIO_AUTO_RETURN_TYPE_PREFIX2( + typename associated_executor::type) get_associated_executor(const T& t, const Executor& ex, typename constraint< is_executor::value || execution::is_executor::value >::type = 0) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_executor::get(t, ex))) { return associated_executor::get(t, ex); } @@ -150,8 +172,8 @@ get_associated_executor(const T& t, const Executor& ex, * ExecutionContext::executor_type>::get(t, ctx.get_executor()) */ template -inline typename associated_executor::type +ASIO_NODISCARD inline typename associated_executor::type get_associated_executor(const T& t, ExecutionContext& ctx, typename constraint::value>::type = 0) ASIO_NOEXCEPT @@ -205,8 +227,17 @@ struct associated_executor, Executor> /// Forwards the request to get the executor to the associator specialisation /// for the unwrapped type @c T. - static type get(reference_wrapper t, - const Executor& ex = Executor()) ASIO_NOEXCEPT + static type get(reference_wrapper t) ASIO_NOEXCEPT + { + return associated_executor::get(t.get()); + } + + /// Forwards the request to get the executor to the associator specialisation + /// for the unwrapped type @c T. + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + reference_wrapper t, const Executor& ex) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_executor::get(t.get(), ex))) { return associated_executor::get(t.get(), ex); } diff --git a/thirdparty/asio/asio/associated_immediate_executor.hpp b/thirdparty/asio/asio/associated_immediate_executor.hpp new file mode 100644 index 00000000..54bced17 --- /dev/null +++ b/thirdparty/asio/asio/associated_immediate_executor.hpp @@ -0,0 +1,297 @@ +// +// associated_immediate_executor.hpp +// ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ +// +// Copyright (c) 2003-2023 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 ASIO_ASSOCIATED_IMMEDIATE_EXECUTOR_HPP +#define ASIO_ASSOCIATED_IMMEDIATE_EXECUTOR_HPP + +#if defined(_MSC_VER) && (_MSC_VER >= 1200) +# pragma once +#endif // defined(_MSC_VER) && (_MSC_VER >= 1200) + +#include "asio/detail/config.hpp" +#include "asio/associator.hpp" +#include "asio/detail/functional.hpp" +#include "asio/detail/type_traits.hpp" +#include "asio/execution/blocking.hpp" +#include "asio/execution/executor.hpp" +#include "asio/execution_context.hpp" +#include "asio/is_executor.hpp" +#include "asio/require.hpp" + +#include "asio/detail/push_options.hpp" + +namespace asio { + +template +struct associated_immediate_executor; + +namespace detail { + +template +struct has_immediate_executor_type : false_type +{ +}; + +template +struct has_immediate_executor_type::type> + : true_type +{ +}; + +template +struct default_immediate_executor +{ + typedef typename require_result::type type; + + static type get(const E& e) ASIO_NOEXCEPT + { + return asio::require(e, execution::blocking.never); + } +}; + +template +struct default_immediate_executor::value + >::type, + typename enable_if< + is_executor::value + >::type> +{ + class type : public E + { + public: + template + explicit type(const Executor1& e, + typename constraint< + conditional< + !is_same::value, + is_convertible, + false_type + >::type::value + >::type = 0) ASIO_NOEXCEPT + : E(e) + { + } + + type(const type& other) ASIO_NOEXCEPT + : E(static_cast(other)) + { + } + +#if defined(ASIO_HAS_MOVE) + type(type&& other) ASIO_NOEXCEPT + : E(ASIO_MOVE_CAST(E)(other)) + { + } +#endif // defined(ASIO_HAS_MOVE) + + template + void dispatch(ASIO_MOVE_ARG(Function) f, const Allocator& a) const + { + this->post(ASIO_MOVE_CAST(Function)(f), a); + } + + friend bool operator==(const type& a, const type& b) ASIO_NOEXCEPT + { + return static_cast(a) == static_cast(b); + } + + friend bool operator!=(const type& a, const type& b) ASIO_NOEXCEPT + { + return static_cast(a) != static_cast(b); + } + }; + + static type get(const E& e) ASIO_NOEXCEPT + { + return type(e); + } +}; + +template +struct associated_immediate_executor_impl +{ + typedef void asio_associated_immediate_executor_is_unspecialised; + + typedef typename default_immediate_executor::type type; + + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + const T&, const E& e) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX((default_immediate_executor::get(e))) + { + return default_immediate_executor::get(e); + } +}; + +template +struct associated_immediate_executor_impl::type> +{ + typedef typename T::immediate_executor_type type; + + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + const T& t, const E&) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX((t.get_immediate_executor())) + { + return t.get_immediate_executor(); + } +}; + +template +struct associated_immediate_executor_impl::value + >::type, + typename void_type< + typename associator::type + >::type> : associator +{ +}; + +} // namespace detail + +/// Traits type used to obtain the immediate executor associated with an object. +/** + * A program may specialise this traits type if the @c T template parameter in + * the specialisation is a user-defined type. The template parameter @c + * Executor shall be a type meeting the Executor requirements. + * + * Specialisations shall meet the following requirements, where @c t is a const + * reference to an object of type @c T, and @c e is an object of type @c + * Executor. + * + * @li Provide a nested typedef @c type that identifies a type meeting the + * Executor requirements. + * + * @li Provide a noexcept static member function named @c get, callable as @c + * get(t) and with return type @c type or a (possibly const) reference to @c + * type. + * + * @li Provide a noexcept static member function named @c get, callable as @c + * get(t,e) and with return type @c type or a (possibly const) reference to @c + * type. + */ +template +struct associated_immediate_executor +#if !defined(GENERATING_DOCUMENTATION) + : detail::associated_immediate_executor_impl +#endif // !defined(GENERATING_DOCUMENTATION) +{ +#if defined(GENERATING_DOCUMENTATION) + /// If @c T has a nested type @c immediate_executor_type, + // T::immediate_executor_type. Otherwise @c Executor. + typedef see_below type; + + /// If @c T has a nested type @c immediate_executor_type, returns + /// t.get_immediate_executor(). Otherwise returns + /// asio::require(ex, asio::execution::blocking.never). + static decltype(auto) get(const T& t, const Executor& ex) ASIO_NOEXCEPT; +#endif // defined(GENERATING_DOCUMENTATION) +}; + +/// Helper function to obtain an object's associated executor. +/** + * @returns associated_immediate_executor::get(t, ex) + */ +template +ASIO_NODISCARD inline ASIO_AUTO_RETURN_TYPE_PREFIX2( + typename associated_immediate_executor::type) +get_associated_immediate_executor(const T& t, const Executor& ex, + typename constraint< + is_executor::value || execution::is_executor::value + >::type = 0) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_immediate_executor::get(t, ex))) +{ + return associated_immediate_executor::get(t, ex); +} + +/// Helper function to obtain an object's associated executor. +/** + * @returns associated_immediate_executor::get(t, ctx.get_executor()) + */ +template +ASIO_NODISCARD inline typename associated_immediate_executor::type +get_associated_immediate_executor(const T& t, ExecutionContext& ctx, + typename constraint::value>::type = 0) ASIO_NOEXCEPT +{ + return associated_immediate_executor::get(t, ctx.get_executor()); +} + +#if defined(ASIO_HAS_ALIAS_TEMPLATES) + +template +using associated_immediate_executor_t = + typename associated_immediate_executor::type; + +#endif // defined(ASIO_HAS_ALIAS_TEMPLATES) + +namespace detail { + +template +struct associated_immediate_executor_forwarding_base +{ +}; + +template +struct associated_immediate_executor_forwarding_base::asio_associated_immediate_executor_is_unspecialised, + void + >::value + >::type> +{ + typedef void asio_associated_immediate_executor_is_unspecialised; +}; + +} // namespace detail + +#if defined(ASIO_HAS_STD_REFERENCE_WRAPPER) \ + || defined(GENERATING_DOCUMENTATION) + +/// Specialisation of associated_immediate_executor for +/// @c std::reference_wrapper. +template +struct associated_immediate_executor, Executor> +#if !defined(GENERATING_DOCUMENTATION) + : detail::associated_immediate_executor_forwarding_base +#endif // !defined(GENERATING_DOCUMENTATION) +{ + /// Forwards @c type to the associator specialisation for the unwrapped type + /// @c T. + typedef typename associated_immediate_executor::type type; + + /// Forwards the request to get the executor to the associator specialisation + /// for the unwrapped type @c T. + static ASIO_AUTO_RETURN_TYPE_PREFIX(type) get( + reference_wrapper t, const Executor& ex) ASIO_NOEXCEPT + ASIO_AUTO_RETURN_TYPE_SUFFIX(( + associated_immediate_executor::get(t.get(), ex))) + { + return associated_immediate_executor::get(t.get(), ex); + } +}; + +#endif // defined(ASIO_HAS_STD_REFERENCE_WRAPPER) + // || defined(GENERATING_DOCUMENTATION) + +} // namespace asio + +#include "asio/detail/pop_options.hpp" + +#endif // ASIO_ASSOCIATED_IMMEDIATE_EXECUTOR_HPP diff --git a/thirdparty/asio/asio/associator.hpp b/thirdparty/asio/asio/associator.hpp index 0f93b120..e954c442 100644 --- a/thirdparty/asio/asio/associator.hpp +++ b/thirdparty/asio/asio/associator.hpp @@ -2,7 +2,7 @@ // associator.hpp // ~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) diff --git a/thirdparty/asio/asio/async_result.hpp b/thirdparty/asio/asio/async_result.hpp index 1750e19e..a7f97b0a 100644 --- a/thirdparty/asio/asio/async_result.hpp +++ b/thirdparty/asio/asio/async_result.hpp @@ -2,7 +2,7 @@ // async_result.hpp // ~~~~~~~~~~~~~~~~ // -// Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com) +// Copyright (c) 2003-2023 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) @@ -311,6 +311,12 @@ struct are_simple_completion_signatures { }; +template <> +struct simple_completion_signature +{ + typedef void type; +}; + template struct simple_completion_signature { @@ -801,6 +807,40 @@ struct async_result_has_initiate_memfn ASIO_INITFN_RESULT_TYPE3(ct, sig0, sig1, sig2) #endif +#if defined(GENERATING_DOCUMENTATION) +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX(ct, sig) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX2(ct, sig0, sig1) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX3(ct, sig0, sig1, sig2) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_SUFFIX(expr) +#elif defined(ASIO_HAS_RETURN_TYPE_DEDUCTION) +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX(ct, sig) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX2(ct, sig0, sig1) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX3(ct, sig0, sig1, sig2) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_SUFFIX(expr) +#elif defined(ASIO_HAS_DECLTYPE) +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX(ct, sig) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX2(ct, sig0, sig1) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX3(ct, sig0, sig1, sig2) \ + auto +# define ASIO_INITFN_AUTO_RESULT_TYPE_SUFFIX(expr) -> decltype expr +#else +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX(ct, sig) \ + ASIO_INITFN_RESULT_TYPE(ct, sig) +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX2(ct, sig0, sig1) \ + ASIO_INITFN_RESULT_TYPE2(ct, sig0, sig1) +# define ASIO_INITFN_AUTO_RESULT_TYPE_PREFIX3(ct, sig0, sig1, sig2) \ + ASIO_INITFN_RESULT_TYPE3(ct, sig0, sig1, sig2) +# define ASIO_INITFN_AUTO_RESULT_TYPE_SUFFIX(expr) +#endif + #if defined(GENERATING_DOCUMENTATION) # define ASIO_INITFN_DEDUCED_RESULT_TYPE(ct, sig, expr) \ void_or_deduced @@ -1195,6 +1235,372 @@ ASIO_CONCEPT completion_token_for = namespace detail { +struct async_operation_probe {}; +struct async_operation_probe_result {}; + +template +struct is_async_operation_call : false_type +{ +}; + +template +struct is_async_operation_call::type, + async_operation_probe_result + >::value + >::type + >::type> : true_type +{ +}; + +} // namespace detail + +#if !defined(GENERATING_DOCUMENTATION) +#if defined(ASIO_HAS_VARIADIC_TEMPLATES) + +template +class async_result +{ +public: + typedef detail::async_operation_probe_result return_type; + + template + static return_type initiate(ASIO_MOVE_ARG(Initiation), + detail::async_operation_probe, ASIO_MOVE_ARG(InitArgs)...) + { + return return_type(); + } +}; + +#else // defined(ASIO_HAS_VARIADIC_TEMPLATES) + +namespace detail { + +struct async_result_probe_base +{ + typedef detail::async_operation_probe_result return_type; + + template + static return_type initiate(ASIO_MOVE_ARG(Initiation), + detail::async_operation_probe) + { + return return_type(); + } + +#define ASIO_PRIVATE_INITIATE_DEF(n) \ + template \ + static return_type initiate(ASIO_MOVE_ARG(Initiation), \ + detail::async_operation_probe, \ + ASIO_VARIADIC_UNNAMED_MOVE_PARAMS(n)) \ + { \ + return return_type(); \ + } \ + /**/ + ASIO_VARIADIC_GENERATE(ASIO_PRIVATE_INITIATE_DEF) +#undef ASIO_PRIVATE_INITIATE_DEF +}; + +} // namespace detail + +template +class async_result + : public detail::async_result_probe_base {}; + +template +class async_result + : public detail::async_result_probe_base {}; + +template +class async_result + : public detail::async_result_probe_base {}; + +#endif // defined(ASIO_HAS_VARIADIC_TEMPLATES) +#endif // !defined(GENERATING_DOCUMENTATION) + +#if defined(GENERATING_DOCUMENTATION) + +/// The is_async_operation trait detects whether a type @c T and arguments +/// @c Args... may be used to initiate an asynchronous operation. +/** + * Class template @c is_async_operation is a trait is derived from @c true_type + * if the expression T(Args..., token) initiates an asynchronous + * operation, where @c token is an unspecified completion token type. Otherwise, + * @c is_async_operation is derived from @c false_type. + */ +template +struct is_async_operation : integral_constant +{ +}; + +#elif defined(ASIO_HAS_VARIADIC_TEMPLATES) + +template +struct is_async_operation : + detail::is_async_operation_call< + T(Args..., detail::async_operation_probe)> +{ +}; + +#else // defined(ASIO_HAS_VARIADIC_TEMPLATES) + +template +struct is_async_operation; + +template +struct is_async_operation : + detail::is_async_operation_call< + T(detail::async_operation_probe)> +{ +}; + +#define ASIO_PRIVATE_IS_ASYNC_OP_DEF(n) \ + template \ + struct is_async_operation : \ + detail::is_async_operation_call< \ + T(ASIO_VARIADIC_TARGS(n), detail::async_operation_probe)> \ + { \ + }; \ + /**/ + ASIO_VARIADIC_GENERATE(ASIO_PRIVATE_IS_ASYNC_OP_DEF) +#undef ASIO_PRIVATE_IS_ASYNC_OP_DEF + +#endif // defined(ASIO_HAS_VARIADIC_TEMPLATES) + +#if defined(ASIO_HAS_CONCEPTS) \ + && defined(ASIO_HAS_VARIADIC_TEMPLATES) + +template +ASIO_CONCEPT async_operation = is_async_operation::value; + +#define ASIO_ASYNC_OPERATION(t) \ + ::asio::async_operation +#define ASIO_ASYNC_OPERATION1(t, a0) \ + ::asio::async_operation +#define ASIO_ASYNC_OPERATION2(t, a0, a1) \ + ::asio::async_operation +#define ASIO_ASYNC_OPERATION3(t, a0, a1, a2) \ + ::asio::async_operation + +#else // defined(ASIO_HAS_CONCEPTS) + // && defined(ASIO_HAS_VARIADIC_TEMPLATES) + +#define ASIO_ASYNC_OPERATION(t) typename +#define ASIO_ASYNC_OPERATION1(t, a0) typename +#define ASIO_ASYNC_OPERATION2(t, a0, a1) typename +#define ASIO_ASYNC_OPERATION3(t, a0, a1, a2) typename + +#endif // defined(ASIO_HAS_CONCEPTS) + // && defined(ASIO_HAS_VARIADIC_TEMPLATES) + +namespace detail { + +struct completion_signature_probe {}; + +#if defined(ASIO_HAS_VARIADIC_TEMPLATES) + +template +struct completion_signature_probe_result +{ + template