class HTTPX::Connection::HTTP2

  1. lib/httpx/connection/http2.rb
Superclass: Object

Included modules

  1. Callbacks
  2. Loggable

Constants

MAX_CONCURRENT_REQUESTS = ::HTTP2::DEFAULT_MAX_CONCURRENT_STREAMS  

Public Instance Aliases

reset -> init_connection

Attributes

pending [R]
streams [R]

Public Class methods

new(buffer, options)
[show source] 
   # File lib/httpx/connection/http2.rb
33 def initialize(buffer, options)
34   @options = options
35   @settings = @options.http2_settings
36   @pending = []
37   @streams = {}
38   @drains  = {}
39   @pings = []
40   @buffer = buffer
41   @handshake_completed = false
42   @wait_for_handshake = @settings.key?(:wait_for_handshake) ? @settings.delete(:wait_for_handshake) : true
43   @max_concurrent_requests = @options.max_concurrent_requests || MAX_CONCURRENT_REQUESTS
44   @max_requests = @options.max_requests
45   init_connection
46 end

Public Instance methods

<<(data)
[show source] 
   # File lib/httpx/connection/http2.rb
97 def <<(data)
98   @connection << data
99 end
close()
[show source] 
   # File lib/httpx/connection/http2.rb
81 def close
82   unless @connection.state == :closed
83     @connection.goaway
84     emit(:timeout, @options.timeout[:close_handshake_timeout])
85   end
86   emit(:close, true)
87 end
consume()
[show source] 
    # File lib/httpx/connection/http2.rb
119 def consume
120   @streams.each do |request, stream|
121     next unless request.can_buffer?
122 
123     handle(request, stream)
124   end
125 end
empty?()
[show source] 
   # File lib/httpx/connection/http2.rb
89 def empty?
90   @connection.state == :closed || @streams.empty?
91 end
exhausted?()
[show source] 
   # File lib/httpx/connection/http2.rb
93 def exhausted?
94   !@max_requests.positive?
95 end
handle_error(ex, request = nil)
[show source] 
    # File lib/httpx/connection/http2.rb
127 def handle_error(ex, request = nil)
128   if ex.is_a?(OperationTimeoutError) && !@handshake_completed && @connection.state != :closed
129     @connection.goaway(:settings_timeout, "closing due to settings timeout")
130     emit(:close_handshake)
131     settings_ex = SettingsTimeoutError.new(ex.timeout, ex.message)
132     settings_ex.set_backtrace(ex.backtrace)
133     ex = settings_ex
134   end
135   @streams.each_key do |req|
136     next if request && request == req
137 
138     emit(:error, req, ex)
139   end
140   while (req = @pending.shift)
141     next if request && request == req
142 
143     emit(:error, req, ex)
144   end
145 end
interests()
[show source] 
   # File lib/httpx/connection/http2.rb
54 def interests
55   # waiting for WINDOW_UPDATE frames
56   return :r if @buffer.full?
57 
58   if @connection.state == :closed
59     return unless @handshake_completed
60 
61     return :w
62   end
63 
64   unless @connection.state == :connected && @handshake_completed
65     return @buffer.empty? ? :r : :rw
66   end
67 
68   return :w if !@pending.empty? && can_buffer_more_requests?
69 
70   return :w unless @drains.empty?
71 
72   if @buffer.empty?
73     return if @streams.empty? && @pings.empty?
74 
75     return :r
76   end
77 
78   :rw
79 end
ping()
[show source] 
    # File lib/httpx/connection/http2.rb
147 def ping
148   ping = SecureRandom.gen_random(8)
149   @connection.ping(ping.dup)
150 ensure
151   @pings << ping
152 end
send(request, head = false)
[show source] 
    # File lib/httpx/connection/http2.rb
101 def send(request, head = false)
102   unless can_buffer_more_requests?
103     head ? @pending.unshift(request) : @pending << request
104     return false
105   end
106   unless (stream = @streams[request])
107     stream = @connection.new_stream
108     handle_stream(stream, request)
109     @streams[request] = stream
110     @max_requests -= 1
111   end
112   handle(request, stream)
113   true
114 rescue ::HTTP2::Error::StreamLimitExceeded
115   @pending.unshift(request)
116   false
117 end
timeout()
[show source] 
   # File lib/httpx/connection/http2.rb
48 def timeout
49   return @options.timeout[:operation_timeout] if @handshake_completed
50 
51   @options.timeout[:settings_timeout]
52 end