basic support IOCP Operator

Author: loongs-zhang

core/src/net/event_loop.rs

@@ -30,8 +30,7 @@ cfg_if::cfg_if! {
         use std::ffi::{c_longlong, c_uint};
         use windows_sys::core::{PCSTR, PSTR};
         use windows_sys::Win32::Networking::WinSock::{
-            setsockopt, LPWSAOVERLAPPED_COMPLETION_ROUTINE, SEND_RECV_FLAGS, SOCKADDR, SOCKET, SOL_SOCKET,
-            SO_UPDATE_ACCEPT_CONTEXT, WSABUF,
+            LPWSAOVERLAPPED_COMPLETION_ROUTINE, SEND_RECV_FLAGS, SOCKADDR, SOCKET, WSABUF,
         };
         use windows_sys::Win32::System::IO::OVERLAPPED;
     }
@@ -301,34 +300,10 @@ impl<'e> EventLoop<'e> {
         if count > 0 {
             for cqe in &mut cq {
                 let token = cqe.token;
-                let bytes_transferred = cqe.bytes_transferred;
-                // resolve completed read/write tasks
-                // todo refactor IOCP impl
-                let result = match cqe.syscall_name {
-                    SyscallName::accept => unsafe {
-                        if setsockopt(
-                            cqe.socket,
-                            SOL_SOCKET,
-                            SO_UPDATE_ACCEPT_CONTEXT,
-                            std::ptr::from_ref(&cqe.from_fd).cast(),
-                            c_int::try_from(size_of::<SOCKET>()).expect("overflow"),
-                        ) == 0
-                        {
-                            cqe.socket.try_into().expect("result overflow")
-                        } else {
-                            -c_longlong::from(windows_sys::Win32::Foundation::GetLastError())
-                        }
-                    },
-                    SyscallName::recv
-                    | SyscallName::WSARecv
-                    | SyscallName::send
-                    | SyscallName::WSASend => bytes_transferred.into(),
-                    _ => panic!("unsupported"),
-                };
                 if let Some((_, pair)) = self.syscall_wait_table.remove(&token) {
                     let (lock, cvar) = &*pair;
                     let mut pending = lock.lock().expect("lock failed");
-                    *pending = Some(result);
+                    *pending = Some(cqe.result);
                     cvar.notify_one();
                 }
                 unsafe { self.resume(token) };