(交叉发布到 lwt github 问题)
我已经将我的用法归结为这个代码示例,它会泄漏文件描述符。
说你有:
#require "lwt.unix"
open Lwt.Infix
let echo ic oc = Lwt_io.(write_chars oc (read_chars ic))
let program =
let server_address = Unix.(ADDR_INET (inet_addr_loopback, 2000)) in
let other_addr = Unix.(ADDR_INET (inet_addr_loopback, 2001)) in
let server = Lwt_io.establish_server server_address begin fun (tcp_ic, tcp_oc) ->
Lwt_io.with_connection other_addr begin fun (nc_ic, nc_oc) ->
Lwt_io.printl "Created connection" >>= fun () ->
echo tcp_ic nc_oc <&> echo nc_ic tcp_oc >>= fun () ->
Lwt_io.printl "finished"
end
|> Lwt.ignore_result
end
in
fst (Lwt.wait ())
let () =
Lwt_main.run program
然后你创建一个简单的服务器:
nc -l 2001
然后让我们启动 OCaml 代码
utop example.ml
然后打开一个客户端
nc localhost 2000
blah blah
^c
然后使用 lsof 查看端口 2000 的连接,我们看到
ocamlrun 71109 Edgar 6u IPv4 0x7ff3e309cb80aead 0t0 TCP 127.0.0.1:callbook (LISTEN)
ocamlrun 71109 Edgar 7u IPv4 0x7ff3e309c9dc8ead 0t0 TCP 127.0.0.1:callbook->127.0.0.1:54872 (CLOSE_WAIT)
事实上,对于 的每次使用nc localhost 2000
,我们都会CLOSE_WAIT
从 lsof 使用中得到一个剩余的记录。
最终这将导致系统用尽文件描述符,这不会让程序崩溃,但会导致 Lwt 挂起。
我不知道我做错了什么,或者这是一个真正的错误,无论如何这对我来说是一个严重的错误,我在 10 小时内用完了文件描述符......
编辑:在我看来,问题在于连接的一侧已关闭,但另一侧未关闭,我原以为with_connection
只要任一侧关闭,也就是无论何时关闭,都应该清理/nc_ic
关闭nc_oc
。
编辑二:我已经尝试了所有手动关闭描述符的方式Lwt_io.close
,但我仍然有 CLOSE_WAIT 消息。
编辑三:甚至Lwt_unix.close
在给 with_connection 的可选fd
参数的原始 fd 上使用类似的坏结果。
编辑四:最阴险的是,如果我使用Lwt_daemon.daemonize
,那么这个问题似乎就消失了