@@ -519,6 +519,7 @@ module Sockets = struct
519519
520520 let connect ?read_buffer_size :_ (ip, port) =
521521 let description = Fmt. str " tcp:%a:%d" Ipaddr. pp ip port in
522+ Log. info (fun f -> f " %s connecting" description);
522523 let label =
523524 match ip with Ipaddr. V4 _ -> " TCPv4" | Ipaddr. V6 _ -> " TCPv6"
524525 in
@@ -543,8 +544,10 @@ module Sockets = struct
543544 Luv.Handle. close fd (fun () ->
544545 return (Error (`Msg (Luv.Error. strerror err))))
545546 | Ok sockaddr ->
547+ Log. info (fun f -> f " %s created sockaddr" description);
546548 Luv.TCP. connect fd sockaddr (function
547549 | Error err ->
550+ Log. info (fun f -> f " %s connect failed with %s" description (Luv.Error. strerror err));
548551 Connection_limit. deregister idx;
549552 Luv.Handle. close fd (fun () ->
550553 return (Error (`Msg (Luv.Error. strerror err))))
@@ -557,12 +560,15 @@ module Sockets = struct
557560 in
558561 Log. info (fun f -> f " %s" msg);
559562 Lwt. return (Error (`Msg msg))
560- | Ok (fd , idx ) -> Lwt. return (Ok (of_fd ~description ~idx ~label fd))
563+ | Ok (fd , idx ) ->
564+ Log. info (fun f -> f " %s connected" description);
565+ Lwt. return (Ok (of_fd ~description ~idx ~label fd))
561566
562567 let shutdown_read _ = Lwt. return ()
563568
564569 let shutdown_write { label; fd; closed; _ } =
565- if not closed then
570+ if not closed then begin
571+ Log. info (fun f -> f " %s shutdown_write" label);
566572 Luv_lwt. in_luv (fun return ->
567573 Luv.Stream. shutdown fd (function
568574 | Error err ->
@@ -571,7 +577,7 @@ module Sockets = struct
571577 (Luv.Error. strerror err));
572578 return ()
573579 | Ok () -> return () ))
574- else Lwt. return_unit
580+ end else Lwt. return_unit
575581
576582 let read_into t buf = read_into t.fd buf
577583 let read t = read t.fd
0 commit comments