Erlang：如何在控制Erlang进程崩溃时使连接的外部操作系统进程自动终止？

我正在使用 Erlang 端口读取 Linux 进程的输出。我希望每当我连接的 Erlang 进程终止时，Linux 进程就会自动终止。从文档来看，在我看来这应该自动发生，但事实并非如此。

最小的例子。将其放入文件 test.erl 中：

-module(test).
-export([start/0, spawn/0]).

start() ->
    Pid = spawn_link(?MODULE, spawn, []),
    register(test, Pid).

spawn() ->
    Port = open_port({spawn, "watch date"},[stream, exit_status]),
    loop([{port, Port}]).

loop(State) ->
    receive
        die ->
            error("died");
        Any ->
            io:fwrite("Received: ~p~n", [Any]),
            loop(State)
    end.

然后，在 erl shell 中：

1> c(test).
{ok,test}
2> test:start().
true

该进程启动并每 2 秒打印一些从 Linux“watch”命令接收到的数据。

然后，我让 Erlang 进程崩溃：

3> test ! die.
=ERROR REPORT==== 26-May-2021::13:24:01.057065 ===
Error in process <0.95.0> with exit value:
{"died",[{test,loop,1,[{file,"test.erl"},{line,15}]}]}

** exception exit: "died"
     in function  test:loop/1 (test.erl, line 15)

Erlang 进程按预期终止，来自“watch”的数据停止出现，但 watch 进程仍然在后台运行，如 Linux（不是 erl）终端中所示：

fuxoft@frantisek:~$ pidof watch
1880127

在我的现实场景中，我没有使用“watch”命令，而是使用其他输出数据且不接受输入的进程。当我连接的 Erlang 进程崩溃时，如何让它自动死亡？我可以使用 Erlang 管理程序来完成此操作，并在 Erlang 进程崩溃时手动发出“kill”命令，但我认为这可以更简单、更干净地完成。

The open_port函数创建一个port()并将其链接到调用过程。如果拥有进程终止，port() closes.

为了与外部生成的命令进行通信，Erlang 创建了多个管道，默认情况下将它们绑定到stdin and stdout外部进程的（文件描述符）。外部进程通过标准输出写入的任何内容都将作为消息到达所属进程。

当。。。的时候Port关闭时，将其连接到外部进程的管道已损坏，因此尝试读取或写入它们将给您一个 SIGPIPE/EPIPE。

当从 FD 写入或读取并退出该进程时，您可以从外部进程中检测到这一点。

例如：使用当前代码，您可以使用以下命令检索外部进程操作系统 pidproplists:get_value(os_pid, erlang:port_info(Port))。如果你strace它，你会看到：

write(1, ..., 38) = -1 EPIPE (Broken pipe)
--- SIGPIPE {si_signo=SIGPIPE, si_code=SI_USER, si_pid=31297, si_uid=1001} ---

端口和 Erlang 中的 SIGPIPE

看起来虽然 SIGPIPE 的默认操作是终止进程，但 Erlang 将其设置为忽略该信号（因此子进程继承了此配置）。

如果您无法修改外部进程代码来检测 EPIPE，您可以使用此 c 包装器来重置操作：

#include <unistd.h>
#include <signal.h>

int main(int argc, char* argv[]) {
    if (signal(SIGPIPE, SIG_DFL) == SIG_ERR)
        return 1;
    if (argc < 2)
        return 2;
    execv(argv[1], &(argv[1]));
}

只需编译它并运行它wrapper path-to-executable [arg1 [arg2 [...]]] with open_port