Feature #14832 ยป timeout.patch
| lib/net/protocol.rb (working copy) | ||
|---|---|---|
|
# ReadTimeout, a subclass of Timeout::Error, is raised if a chunk of the
|
||
|
# response cannot be read within the read_timeout.
|
||
|
class ReadTimeout < Timeout::Error; end
|
||
|
class ReadTimeout < Timeout::Error
|
||
|
def initialize(io = nil)
|
||
|
@io = io
|
||
|
@io_inspect = @io.inspect
|
||
|
end
|
||
|
attr_reader :io
|
||
|
def message
|
||
|
msg = super
|
||
|
if @io_inspect
|
||
|
msg = "#{msg} with #{@io_inspect}"
|
||
|
end
|
||
|
msg
|
||
|
end
|
||
|
end
|
||
|
##
|
||
|
# WriteTimeout, a subclass of Timeout::Error, is raised if a chunk of the
|
||
|
# response cannot be read within the read_timeout.
|
||
|
class WriteTimeout < Timeout::Error; end
|
||
|
class WriteTimeout < Timeout::Error
|
||
|
def initialize(io = nil)
|
||
|
@io = io
|
||
|
@io_inspect = @io.inspect
|
||
|
end
|
||
|
attr_reader :io
|
||
|
def message
|
||
|
msg = super
|
||
|
if @io_inspect
|
||
|
msg = "#{msg} with #{@io_inspect}"
|
||
|
end
|
||
|
msg
|
||
|
end
|
||
|
end
|
||
|
class BufferedIO #:nodoc: internal use only
|
||
|
def initialize(io, read_timeout: 60, write_timeout: 60, continue_timeout: nil, debug_output: nil)
|
||
|
@io = io
|
||
| ... | ... | |
|
rv.clear
|
||
|
return
|
||
|
when :wait_readable
|
||
|
@io.to_io.wait_readable(@read_timeout) or raise Net::ReadTimeout
|
||
|
(io = @io.to_io).wait_readable(@read_timeout) or raise Net::ReadTimeout.new(io)
|
||
|
# continue looping
|
||
|
when :wait_writable
|
||
|
# OpenSSL::Buffering#read_nonblock may fail with IO::WaitWritable.
|
||
|
# http://www.openssl.org/support/faq.html#PROG10
|
||
|
@io.to_io.wait_writable(@read_timeout) or raise Net::ReadTimeout
|
||
|
(io = @io.to_io).wait_writable(@read_timeout) or raise Net::ReadTimeout.new(io)
|
||
|
# continue looping
|
||
|
when nil
|
||
|
raise EOFError, 'end of file reached'
|
||
| ... | ... | |
|
end
|
||
|
# continue looping
|
||
|
when :wait_writable
|
||
|
@io.to_io.wait_writable(@write_timeout) or raise Net::WriteTimeout
|
||
|
(io = @io.to_io).wait_writable(@write_timeout) or raise Net::WriteTimeout.new(io)
|
||
|
# continue looping
|
||
|
end while need_retry
|
||
|
end
|
||