如何调试一个奇怪的线程开放FIFO问题?

Web服务配置为在接收USR1信号时公开其部分数据。当xinetd服务器从远程客户端(如nc myserver 50666)收到请求时,该信号将由xinetd服务器发送。当Web服务器接收到USR1信号时,它打开一个专用的FIFO管道,将其数据写入管道,然后关闭管道。同时,xinetd服务器读取管道并向远程客户机提供数据。

在大多数情况下,它们工作得很好,但有时出于某种原因,客户会收到DUP记录。从日志中可以看出,管道似乎没有正确关闭,缓存被遗留下来,所以下次使用时,前一个和当前的都会发送到客户机。问题是,当我试图繁殖的时候,它不会经常发生,不幸的是,我不能繁殖一次。

以下是演示流程的简单片段:

Web服务器:(web server.py)

def SendStream(data, pipe):
  try:
    for i in data:
      pipe.write(i + '\n') 
      pipe.flush()
  finally:
      pipe.close()

def Serve():
  threading.Thread(target=SendStream, args=(data, pipe)).start()

xinetd.d服务器:(spitter.py)

def Serve():
  if not os.path.exists(PIPE_FILE):
    os.mkfifo(PIPE_FILE)
  os.kill(server_pid, signal.SIGUSR1)
  for i in open(PIPE_FILE):
    print i,

那么究竟是什么导致了这个骗局?如何触发?当前的修复方法是断开管道文件的链接,每次都重新创建它以避免任何遗留问题,但我不知道这是否是正确的解决方案。