Làm thế nào để đọc được đặt tên FIFO không bị chặn?

Question

tôi tạo ra một FIFO, và định kỳ mở nó trong read-only và không blockingly chế độ từ a.py:

os.mkfifo(cs_cmd_fifo_file, 0777) 
io = os.open(fifo, os.O_RDONLY | os.O_NONBLOCK) 
buffer = os.read(io, BUFFER_SIZE) 

Từ b.py, mở fifo để viết:

out = open(fifo, 'w') 
out.write('sth') 

Sau đó, a.py sẽ nêu ra một lỗi:

buffer = os.read(io, BUFFER_SIZE) 

OSError: [Errno 11] Resource temporarily unavailable 

Bất cứ ai biết điều gì là sai?

Answer 1

Theo manpage của read(2):

EAGAIN or EWOULDBLOCK 
      The file descriptor fd refers to a socket and has been marked 
      nonblocking (O_NONBLOCK), and the read would block. 
      POSIX.1-2001 allows either error to be returned for this case, 
      and does not require these constants to have the same value, so 
      a portable application should check for both possibilities. 

Vì vậy, những gì bạn đang nhận được là không có sẵn để đọc dữ liệu. Sẽ an toàn khi xử lý lỗi như sau:

try: 
    buffer = os.read(io, BUFFER_SIZE) 
except OSError as err: 
    if err.errno == errno.EAGAIN or err.errno == errno.EWOULDBLOCK: 
     buffer = None 
    else: 
     raise # something else has happened -- better reraise 

if buffer is None: 
    # nothing was received -- do something else 
else: 
    # buffer contains some received data -- do something with it 

Đảm bảo bạn có mô-đun errno được nhập: import errno.

Answer 2

out = open(fifo, 'w') 

Ai sẽ đóng nó cho bạn? Thay mở + ghi của bạn bằng cách này:

with open(fifo, 'w') as fp: 
    fp.write('sth') 

UPD: Ok, hơn là chỉ làm cho điều này:

out = os.open(fifo, os.O_NONBLOCK | os.O_WRONLY) 
os.write(out, 'tetet')