From 52df0ce483eb7d7e76a67ad5e70bc586de2fd6e8 Mon Sep 17 00:00:00 2001 From: Clombrong Date: Sat, 28 Jun 2025 09:49:00 +0200 Subject: fix(portal_tcp): resolve the comment incident --- portal/tcp/portal.ml | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'portal') diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml index fc19fc0..9241312 100644 --- a/portal/tcp/portal.ml +++ b/portal/tcp/portal.ml @@ -133,7 +133,11 @@ let socket_to_stream (sock : socket) = if len > 0 then begin send_pos := 0; - flush_socket len + if (Lwt_bytes.proxy send_buffer (len-7) len |> Lwt_bytes.to_string) = "" + then if (len - 7) > 0 + then flush_socket (len - 7) + else Lwt.return_unit + else flush_socket len end else Lwt.return_unit in -- cgit v1.2.3