hook connect

Author: loongs-zhang

core/src/syscall/unix/connect.rs

@@ -62,6 +62,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
             set_non_blocking(fd);
         }
         let mut r = self.inner.connect(fn_ptr, fd, address, len);
+        eprintln!("connect {r} error:{}", Error::last_os_error());
         loop {
             if r == 0 {
                 reset_errno();
@@ -85,6 +86,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
                         &mut len,
                     );
                 }
+                eprintln!("connect getsockopt {r} error:{}", Error::last_os_error());
                 if r != 0 {
                     r = -1;
                     break;
@@ -99,6 +101,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
                     let mut address_len = std::mem::zeroed();
                     r = libc::getpeername(fd, &mut address, &mut address_len);
                 }
+                eprintln!("getpeername {r} error:{}", Error::last_os_error());
             } else if errno != Some(libc::EINTR) {
                 break;
             }

core/src/syscall/windows/connect.rs

@@ -3,7 +3,7 @@ use crate::syscall::common::{is_blocking, reset_errno, set_blocking, set_errno,
 use once_cell::sync::Lazy;
 use std::ffi::c_int;
 use std::io::Error;
-use windows_sys::Win32::Networking::WinSock::{getpeername, getsockopt, SO_ERROR, SOCKADDR, SOCKET, SOL_SOCKET, WSAEALREADY, WSAEINPROGRESS, WSAEINTR, WSAETIMEDOUT};
+use windows_sys::Win32::Networking::WinSock::{getpeername, getsockopt, SO_ERROR, SOCKADDR, SOCKET, SOL_SOCKET, WSAEALREADY, WSAEINPROGRESS, WSAEINTR, WSAETIMEDOUT, WSAEWOULDBLOCK};
 
 #[must_use]
 pub extern "system" fn connect(
@@ -57,7 +57,7 @@ impl<I: ConnectSyscall> ConnectSyscall for NioConnectSyscall<I> {
                 break;
             }
             let errno = Error::last_os_error().raw_os_error();
-            if errno == Some(WSAEINPROGRESS) || errno == Some(WSAEALREADY) {
+            if errno == Some(WSAEINPROGRESS) || errno == Some(WSAEALREADY) || errno == Some(WSAEWOULDBLOCK) {
                 //阻塞，直到写事件发生
                 if EventLoops::wait_write_event(
                     fd as _,