Module: Seahorse::Client::NetHttp::Patches::Ruby_2 Private

Defined in:
lib/seahorse/client/net_http/patches.rb

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Instance Method Summary collapse

Instance Method Details

#new_transport_request(req) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/seahorse/client/net_http/patches.rb', line 22

def new_transport_request(req)
  count = 0
  begin
    begin_transport req
    res = catch(:response) {
      req.exec @socket, @curr_http_version, edit_path(req.path)
      begin
        res = Net::HTTPResponse.read_new(@socket)
        res.decode_content = req.decode_content
      end while res.kind_of?(Net::HTTPContinue)

      res.uri = req.uri

      res
    }
    res.reading_body(@socket, req.response_body_permitted?) {
      yield res if block_given?
    }
  rescue Net::OpenTimeout
    raise
  rescue Net::ReadTimeout, IOError, EOFError,
         Errno::ECONNRESET, Errno::ECONNABORTED, Errno::EPIPE,
         # avoid a dependency on OpenSSL
         defined?(OpenSSL::SSL) ? OpenSSL::SSL::SSLError : IOError,
         Timeout::Error => exception
    if count == 0 && Net::HTTP::IDEMPOTENT_METHODS_.include?(req.method)
      count += 1
      @socket.close if @socket and not @socket.closed?
      D "Conn close because of error #{exception}, and retry"
      if req.body_stream
        if req.body_stream.respond_to?(:rewind)
          req.body_stream.rewind
        else
          raise
        end
      end
      retry
    end
    D "Conn close because of error #{exception}"
    @socket.close if @socket and not @socket.closed?
    raise
  end

  end_transport req, res
  res
rescue => exception
  D "Conn close because of error #{exception}"
  @socket.close if @socket and not @socket.closed?
  raise exception
end