fix windows

lib_eio_windows/low_level.ml

@@ -60,15 +60,24 @@ let socket ~sw socket_domain socket_type protocol =
   Unix.set_nonblock sock_unix;
   Fd.of_unix ~sw ~blocking:false ~close_unix:true sock_unix
 
-let connect fd addr =
+let try_bind fd = function
+  | None -> ()
+  | Some bind_addr ->
+    try Unix.bind fd bind_addr
+    with Unix.Unix_error (code, name, arg) -> raise @@ Err.wrap_fs code name arg
+
+let connect fd ?bind addr =
   try
-    Fd.use_exn "connect" fd (fun fd -> Unix.connect fd addr)
+    Fd.use_exn "connect" fd @@ fun fd ->
+    try_bind fd bind ;
+    Unix.connect fd addr
   with
   | Unix.Unix_error ((EINTR | EAGAIN | EWOULDBLOCK | EINPROGRESS), _, _) ->
     await_writable fd;
     match Fd.use_exn "connect" fd Unix.getsockopt_error with
     | None -> ()
     | Some code -> raise (Err.wrap code "connect-in-progress" "")
+  | Unix.Unix_error (code, name, arg) -> raise (Err.wrap code name arg)
 
 let accept ~sw sock =
   Fd.use_exn "accept" sock @@ fun sock ->

lib_eio_windows/net.ml

@@ -142,7 +142,7 @@ let listen ~reuse_addr ~reuse_port ~backlog ~sw (listen_addr : Eio.Net.Sockaddr.
     );
   (listening_socket ~hook sock :> _ Eio.Net.listening_socket_ty r)
 
-let connect ~sw connect_addr =
+let connect ~sw ?bind connect_addr =
   let socket_type, addr =
     match connect_addr with
     | `Unix path         -> Unix.SOCK_STREAM, Unix.ADDR_UNIX path
@@ -151,8 +151,9 @@ let connect ~sw connect_addr =
       Unix.SOCK_STREAM, Unix.ADDR_INET (host, port)
   in
   let sock = Low_level.socket ~sw (socket_domain_of connect_addr) socket_type 0 in
+  let bind = Option.map Eio_unix.Net.sockaddr_to_unix bind in
   try
-    Low_level.connect sock addr;
+    Low_level.connect sock ?bind addr;
     (Flow.of_fd sock :> _ Eio_unix.Net.stream_socket)
   with Unix.Unix_error (code, name, arg) -> raise (Err.wrap code name arg)