未在 Tornado 中接收所有命名管道输出

Question

我正在使用 Tornado 运行一个小型 python 程序，它收集由另一个程序编写的多个 linux 命名管道 (FIFO) 输出。不幸的是，由于某种原因，并没有收到管道的所有输出。

我像这样添加管道：

for pipe in pipe_files:
    pipe_file = open(pipe, 'r')
    try:
        pipe_stream = PipeIOStream(pipe_file.fileno())
        self.output_streams.append(pipe_stream)
    except IOError:
        logging.warn("Can't open pipe %s", pipe)
        continue
    self.read_lines(pipe_stream, self.new_output)

Read lines 像这样注册一个回调：

def read_lines(self, stream, callback):
    """
    Read lines forever from the given stream, calling the callback on each line.

    :param stream: a tornado.BaseIOStream
    :param callback: callback method to be called for each line.
    """
    def wrapper(line):
        if not self.output_streams:
            # Output streams have been removed, no need to continue.
            return

        callback(line.strip())
        # Reregister the callback, if the stream hasn't closed yet.
        if not stream.closed():
            stream.read_until(os.linesep, callback=wrapper)
    stream.read_until(os.linesep, callback=wrapper)

我最终使用 tornado 的子进程运行程序（也以相同的方式捕获其 stdout/err）并在子进程结束时退出。

我没有收到所有预期的输出（例如，我将在程序中打印 10000 行，但在 python 程序中只收到 ~7000 行）。当我简单地使用“cat”来获取fifo输出时，我可以看到它。

我确保程序正确刷新输出。我尝试在程序中永远休眠以让 Tornado 有时间获得输出，但结果相同。

有什么想法吗？

Answer 1

stream.closed() 可能在缓冲区中仍有数据时变为真。为确保您已阅读所有内容，请使用 set_close_callback() 并阅读直到运行该回调，或使用协程样式接口并阅读直到收到 StreamClosedError。

一般情况下，写的时候应该用stream.closed()，这样你就不要尝试写一个已经不在的客户端了，但是读close回调更合适。

Answer 2

通过在我的 C 程序中更改管道的开口来解决问题：

open(fifo_path, O_WRONLY | O_NONBLOCK);

收件人：

open(fifo_path, O_RDWR);

见thesequestions。