aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorClombrong <cromblong@egregore.fun>2025-06-28 09:49:00 +0200
committerClombrong <cromblong@egregore.fun>2025-06-28 09:49:00 +0200
commit70dacbb4e597aa8ab40b104bdc8c5e29934b88a3 (patch)
treef0e396363e35e9dfc09ab250fe163b3e73f0bbe8
parent39fd1ae1ca9efefb4ebafb9f1c96b20a397f9acb (diff)
fix(portal_tcp): resolve the comment incidentmerged-socket-tcp
-rw-r--r--portal/tcp/portal.ml6
1 files changed, 5 insertions, 1 deletions
diff --git a/portal/tcp/portal.ml b/portal/tcp/portal.ml
index b717d9c..d843020 100644
--- a/portal/tcp/portal.ml
+++ b/portal/tcp/portal.ml
@@ -134,7 +134,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