检测读取器何时关闭命名管道 (FIFO)

Question

有

没有办法让编写器知道读取器已经关闭了命名管道的末端（或退出），而不写入它？

我需要知道这一点，因为我写入管道的初始数据是不同的;读者在其余数据到来之前期待一个初始标头。

目前，当我的write()因EPIPE而失败时，我会检测到这一点。然后我设置了一个标志，上面写着"下次，发送标题"。但是，读者可以在我写任何东西之前关闭并重新打开管道。在这种情况下，我永远不会意识到他做了什么，也不会发送他期望的标题。

是否有任何类型的异步事件类型的东西可能会在这里有所帮助？我没有看到任何信号被发送。

_{请注意，我没有包含任何语言标签，因为这个问题应该被认为是与语言无关的。 我的代码是Python，但答案应该适用于C或任何其他具有系统调用级绑定的语言。}

Answer 1

如果使用基于poll系统调用的事件循环，则可以使用包含EPOLLERR的事件掩码注册管道。在 Python 中，有了 select.poll ，

import select
fd = open("pipe", "w")
poller = select.poll()
poller.register(fd, select.POLLERR)
poller.poll()

将等到管道关闭。

要对此进行测试，请运行 mkfifo pipe ，启动脚本，然后在另一个终端运行中，例如cat pipe 。退出cat进程后，脚本将终止。

Answer 2

奇怪的是，当最后一个读取器关闭管道时，似乎select表示管道是可读的：

writer.py

#!/usr/bin/env python
import os
import select
import time
NAME = 'fifo2'
os.mkfifo(NAME)

def select_test(fd, r=True, w=True, x=True):
    rset = [fd] if r else []
    wset = [fd] if w else []
    xset = [fd] if x else []
    t0 = time.time()
    r,w,x = select.select(rset, wset, xset)
    print 'After {0} sec:'.format(time.time() - t0)
    if fd in r: print ' {0} is readable'.format(fd)
    if fd in w: print ' {0} is writable'.format(fd)
    if fd in x: print ' {0} is exceptional'.format(fd)
try:
    fd = os.open(NAME, os.O_WRONLY)
    print '{0} opened for writing'.format(NAME)
    print 'select 1'
    select_test(fd)
    os.write(fd, 'test')
    print 'wrote data'
    print 'select 2'
    select_test(fd)
    print 'select 3 (no write)'
    select_test(fd, w=False)
finally:
    os.unlink(NAME)

演示：

1号航站楼：

$ ./pipe_example_simple.py
fifo2 opened for writing
select 1
After 1.59740447998e-05 sec:
 3 is writable
wrote data
select 2
After 2.86102294922e-06 sec:
 3 is writable
select 3 (no write)
After 2.15910816193 sec:
 3 is readable

2号航站楼：

$ cat fifo2
test
# (wait a sec, then Ctrl+C)

Answer 3

没有这样的机制。通常，根据UNIX方式，两端都没有流打开或关闭的信号。这只能通过读取或写入它们（相应地）来检测。

我会说这是错误的设计。目前，您正在尝试通过打开管道来让接收器发出其接收可用性的信号。因此，要么以适当的方式实现此信令，要么将"关闭逻辑"合并到管道的发送部分。