feat(native): complete async-op shadowing across all I/O types

include/boost/corosio/backend.hpp

@@ -45,6 +45,10 @@ class posix_signal;
 class posix_signal_service;
 class posix_resolver;
 class posix_resolver_service;
+class posix_stream_file;
+class posix_stream_file_service;
+class posix_random_access_file;
+class posix_random_access_file_service;
 
 } // namespace detail
 
@@ -71,6 +75,11 @@ struct epoll_t
     using resolver_type         = detail::posix_resolver;
     using resolver_service_type = detail::posix_resolver_service;
 
+    using stream_file_type                  = detail::posix_stream_file;
+    using stream_file_service_type          = detail::posix_stream_file_service;
+    using random_access_file_type           = detail::posix_random_access_file;
+    using random_access_file_service_type   = detail::posix_random_access_file_service;
+
     /// Create the scheduler and services for this backend.
     BOOST_COROSIO_DECL static detail::scheduler&
     construct(capy::execution_context&, unsigned concurrency_hint);
@@ -103,6 +112,10 @@ class posix_signal;
 class posix_signal_service;
 class posix_resolver;
 class posix_resolver_service;
+class posix_stream_file;
+class posix_stream_file_service;
+class posix_random_access_file;
+class posix_random_access_file_service;
 
 } // namespace detail
 
@@ -129,6 +142,11 @@ struct select_t
     using resolver_type         = detail::posix_resolver;
     using resolver_service_type = detail::posix_resolver_service;
 
+    using stream_file_type                  = detail::posix_stream_file;
+    using stream_file_service_type          = detail::posix_stream_file_service;
+    using random_access_file_type           = detail::posix_random_access_file;
+    using random_access_file_service_type   = detail::posix_random_access_file_service;
+
     /// Create the scheduler and services for this backend.
     BOOST_COROSIO_DECL static detail::scheduler&
     construct(capy::execution_context&, unsigned concurrency_hint);
@@ -161,6 +179,10 @@ class posix_signal;
 class posix_signal_service;
 class posix_resolver;
 class posix_resolver_service;
+class posix_stream_file;
+class posix_stream_file_service;
+class posix_random_access_file;
+class posix_random_access_file_service;
 
 } // namespace detail
 
@@ -187,6 +209,11 @@ struct kqueue_t
     using resolver_type         = detail::posix_resolver;
     using resolver_service_type = detail::posix_resolver_service;
 
+    using stream_file_type                  = detail::posix_stream_file;
+    using stream_file_service_type          = detail::posix_stream_file_service;
+    using random_access_file_type           = detail::posix_random_access_file;
+    using random_access_file_service_type   = detail::posix_random_access_file_service;
+
     /// Create the scheduler and services for this backend.
     BOOST_COROSIO_DECL static detail::scheduler&
     construct(capy::execution_context&, unsigned concurrency_hint);
@@ -260,6 +287,11 @@ struct iocp_t
     using resolver_type         = detail::win_resolver;
     using resolver_service_type = detail::win_resolver_service;
 
+    using stream_file_type                = detail::win_stream_file;
+    using stream_file_service_type        = detail::win_file_service;
+    using random_access_file_type         = detail::win_random_access_file;
+    using random_access_file_service_type = detail::win_random_access_file_service;
+
     /** Create the scheduler and services for this backend.
 
         @param ctx The execution context that owns the scheduler.

include/boost/corosio/native/detail/iocp/win_local_stream_service.hpp

@@ -17,6 +17,7 @@
 #include <boost/corosio/detail/config.hpp>
 #include <boost/corosio/detail/local_stream_service.hpp>
 
+#include <boost/corosio/native/detail/iocp/win_local_stream_acceptor.hpp>
 #include <boost/corosio/native/detail/iocp/win_local_stream_socket.hpp>
 #include <boost/corosio/native/detail/iocp/win_tcp_service.hpp>
 #include <boost/corosio/native/detail/iocp/win_scheduler.hpp>

include/boost/corosio/native/detail/iocp/win_tcp_acceptor_service.hpp

@@ -1101,18 +1101,6 @@ win_tcp_service::native_handle() const noexcept
     return iocp_;
 }
 
-inline LPFN_CONNECTEX
-win_tcp_service::connect_ex() const noexcept
-{
-    return connect_ex_;
-}
-
-inline LPFN_ACCEPTEX
-win_tcp_service::accept_ex() const noexcept
-{
-    return accept_ex_;
-}
-
 inline void
 win_tcp_service::post(overlapped_op* op)
 {

include/boost/corosio/native/detail/iocp/win_tcp_service.hpp

@@ -152,10 +152,16 @@ class BOOST_COROSIO_DECL win_tcp_service final
     void* native_handle() const noexcept;
 
     /** Return the ConnectEx function pointer. */
-    LPFN_CONNECTEX connect_ex() const noexcept;
+    LPFN_CONNECTEX connect_ex() const noexcept
+    {
+        return connect_ex_;
+    }
 
     /** Return the AcceptEx function pointer. */
-    LPFN_ACCEPTEX accept_ex() const noexcept;
+    LPFN_ACCEPTEX accept_ex() const noexcept
+    {
+        return accept_ex_;
+    }
 
     /** Post an overlapped operation for completion. */
     void post(overlapped_op* op);

include/boost/corosio/native/native.hpp

@@ -19,10 +19,16 @@
 
 #include <boost/corosio/native/native_cancel.hpp>
 #include <boost/corosio/native/native_io_context.hpp>
+#include <boost/corosio/native/native_local_datagram_socket.hpp>
+#include <boost/corosio/native/native_local_stream_acceptor.hpp>
+#include <boost/corosio/native/native_local_stream_socket.hpp>
+#include <boost/corosio/native/native_random_access_file.hpp>
 #include <boost/corosio/native/native_resolver.hpp>
 #include <boost/corosio/native/native_signal_set.hpp>
+#include <boost/corosio/native/native_stream_file.hpp>
 #include <boost/corosio/native/native_tcp_acceptor.hpp>
 #include <boost/corosio/native/native_tcp_socket.hpp>
 #include <boost/corosio/native/native_timer.hpp>
+#include <boost/corosio/native/native_udp_socket.hpp>
 
 #endif