diff options
Diffstat (limited to 'lib/rainbows/epoll')
-rw-r--r-- | lib/rainbows/epoll/client.rb | 30 | ||||
-rw-r--r-- | lib/rainbows/epoll/response_pipe.rb | 6 |
2 files changed, 18 insertions, 18 deletions
diff --git a/lib/rainbows/epoll/client.rb b/lib/rainbows/epoll/client.rb index 85e504c..6ed141e 100644 --- a/lib/rainbows/epoll/client.rb +++ b/lib/rainbows/epoll/client.rb @@ -39,8 +39,8 @@ module Rainbows::Epoll::Client @wr_queue = [] # may contain String, ResponsePipe, and StreamFile objects post_init on_readable - rescue => e - handle_error(e) + rescue => e + handle_error(e) end def on_readable @@ -56,9 +56,9 @@ module Rainbows::Epoll::Client break end until :close == @state close unless closed? - rescue Errno::ECONNRESET - close - rescue IOError + rescue Errno::ECONNRESET + close + rescue IOError end def app_call input # called by on_read() @@ -146,8 +146,8 @@ module Rainbows::Epoll::Client def handle_error(e) msg = Rainbows::Error.response(e) and kgio_trywrite(msg) rescue nil - ensure - close + ensure + close end def write_deferred(obj) @@ -171,8 +171,8 @@ module Rainbows::Epoll::Client when :deferred return end while true - rescue => e - handle_error(e) + rescue => e + handle_error(e) end def write(buf) @@ -227,9 +227,9 @@ module Rainbows::Epoll::Client else return n # :wait_writable or nil end while true - rescue - sf.close - raise + rescue + sf.close + raise end def defer_file_stream(offset, count, io, body) @@ -263,8 +263,8 @@ module Rainbows::Epoll::Client else # nil => EOF return pipe.close # nil end while true - rescue - pipe.close - raise + rescue + pipe.close + raise end end diff --git a/lib/rainbows/epoll/response_pipe.rb b/lib/rainbows/epoll/response_pipe.rb index 64b1547..87b2818 100644 --- a/lib/rainbows/epoll/response_pipe.rb +++ b/lib/rainbows/epoll/response_pipe.rb @@ -14,9 +14,9 @@ class Rainbows::Epoll::ResponsePipe def epoll_run return close if @client.closed? @client.stream_pipe(self) or @client.on_deferred_write_complete - rescue => e - close - @client.handle_error(e) + rescue => e + close + @client.handle_error(e) end def close |