Class: HTTPX::Connection::HTTP2

Inherits:
Object
  • Object
show all
Includes:
HTTPX::Callbacks, Loggable
Defined in:
lib/httpx/connection/http2.rb

Direct Known Subclasses

Plugins::H2C::H2CParser

Constant Summary collapse

MAX_CONCURRENT_REQUESTS = 
HTTP2Next::DEFAULT_MAX_CONCURRENT_STREAMS
Error = 
Class.new(Error) do
  def initialize(id, code)
    super("stream #{id} closed with error: #{code}")
  end
end

Constants included from Loggable

Loggable::COLORS

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Loggable

#log, #log_exception

Methods included from HTTPX::Callbacks

#emit, #on, #once

Constructor Details

#initialize(buffer, options) ⇒ HTTP2

Returns a new instance of HTTP2.



22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/httpx/connection/http2.rb', line 22

def initialize(buffer, options)
  @options = Options.new(options)
  @max_concurrent_requests = @options.max_concurrent_requests || MAX_CONCURRENT_REQUESTS
  @max_requests = @options.max_requests || 0
  @pending = []
  @streams = {}
  @drains  = {}
  @pings = []
  @buffer = buffer
  @handshake_completed = false
  init_connection
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(meth, *args, &blk) ⇒ Object (private) 



331
332
333
334
335
336
337
 
# File 'lib/httpx/connection/http2.rb', line 331

def method_missing(meth, *args, &blk)
  if @connection.respond_to?(meth)
    @connection.__send__(meth, *args, &blk)
  else
    super
  end
end

Instance Attribute Details

#pending ⇒ Object (readonly)

Returns the value of attribute pending.



20
21
22
 
# File 'lib/httpx/connection/http2.rb', line 20

def pending
  @pending
end

#streams ⇒ Object (readonly)

Returns the value of attribute streams.



20
21
22
 
# File 'lib/httpx/connection/http2.rb', line 20

def streams
  @streams
end

Instance Method Details

#<<(data) ⇒ Object 



73
74
75
 
# File 'lib/httpx/connection/http2.rb', line 73

def <<(data)
  @connection << data
end

#close(*args) ⇒ Object 



58
59
60
61
 
# File 'lib/httpx/connection/http2.rb', line 58

def close(*args)
  @connection.goaway(*args) unless @connection.state == :closed
  emit(:close)
end

#consume ⇒ Object 



97
98
99
100
101
102
103
 
# File 'lib/httpx/connection/http2.rb', line 97

def consume
  @streams.each do |request, stream|
    next if request.state == :done

    handle(request, stream)
  end
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


63
64
65
 
# File 'lib/httpx/connection/http2.rb', line 63

def empty?
  @connection.state == :closed || @streams.empty?
end

#exhausted? ⇒ Boolean

Returns:

  • (Boolean) 


67
68
69
70
71
 
# File 'lib/httpx/connection/http2.rb', line 67

def exhausted?
  return false if @max_requests.zero? && @connection.active_stream_count.zero?

  @connection.active_stream_count >= @max_requests
end

#handle_error(ex) ⇒ Object 



105
106
107
108
109
110
111
112
 
# File 'lib/httpx/connection/http2.rb', line 105

def handle_error(ex)
  @streams.each_key do |request|
    emit(:error, request, ex)
  end
  @pending.each do |request|
    emit(:error, request, ex)
  end
end

#interests ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
 
# File 'lib/httpx/connection/http2.rb', line 35

def interests
  # waiting for WINDOW_UPDATE frames
  return :r if @buffer.full?

  return :w if @connection.state == :closed

  unless (@connection.state == :connected && @handshake_completed)
    return @buffer.empty? ? :r : :rw
  end

  return :w unless @pending.empty?

  return :w if @streams.each_key.any? { |r| r.interests == :w }

  return :r if @buffer.empty?

  :rw
end

#ping ⇒ Object 



114
115
116
117
118
119
 
# File 'lib/httpx/connection/http2.rb', line 114

def ping
  ping = SecureRandom.gen_random(8)
  @connection.ping(ping)
ensure
  @pings << ping
end

#reset ⇒ Object 



54
55
56
 
# File 'lib/httpx/connection/http2.rb', line 54

def reset
  init_connection
end

#send(request) ⇒ Object 



77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/httpx/connection/http2.rb', line 77

def send(request)
  if !@handshake_completed ||
     @streams.size >= @max_concurrent_requests ||
     @streams.size >= @max_requests
    @pending << request
    return
  end
  unless (stream = @streams[request])
    stream = @connection.new_stream
    handle_stream(stream, request)
    @streams[request] = stream
    @max_requests -= 1
  end
  handle(request, stream)
  true
rescue HTTP2Next::Error::StreamLimitExceeded
  @pending.unshift(request)
  emit(:exhausted)
end