diff options
Diffstat (limited to 'lib/rainbows/epoll/client.rb')
-rw-r--r-- | lib/rainbows/epoll/client.rb | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/lib/rainbows/epoll/client.rb b/lib/rainbows/epoll/client.rb index a243d5d..b7b0c9e 100644 --- a/lib/rainbows/epoll/client.rb +++ b/lib/rainbows/epoll/client.rb @@ -183,15 +183,16 @@ module Rainbows::Epoll::Client # returns +nil+ on EOF, :wait_writable if the client blocks def stream_file(sf) # +sf+ is a Rainbows::StreamFile object - begin - sf.offset += (n = sendfile_nonblock(sf, sf.offset, sf.count)) + case n = trysendfile(sf, sf.offset, sf.count) + when Integer + sf.offset += n 0 == (sf.count -= n) and return sf.close - rescue Errno::EAGAIN - return :wait_writable + else + return n # :wait_writable or nil + end while true rescue sf.close raise - end while true end def defer_file_stream(offset, count, io, body) |