Module: Protocol::HTTP2::FlowControlled
- Included in:
- Connection, Stream
- Defined in:
- lib/protocol/http2/flow_controlled.rb
Instance Method Summary collapse
-
#available_frame_size(maximum_frame_size = self.maximum_frame_size) ⇒ Object
This could be negative if the window has been overused due to a change in initial window size.
- #available_size ⇒ Object
- #consume_local_window(frame) ⇒ Object
-
#consume_remote_window(frame) ⇒ Object
Keep track of the amount of data sent, and fail if is too much.
- #receive_window_update(frame) ⇒ Object
- #request_window_update ⇒ Object
-
#send_window_update(window_increment) ⇒ Object
Notify the remote end that we are prepared to receive more data:.
- #update_local_window(frame) ⇒ Object
-
#window_updated(size) ⇒ Boolean
The window has been expanded by the given amount.
Instance Method Details
#available_frame_size(maximum_frame_size = self.maximum_frame_size) ⇒ Object
This could be negative if the window has been overused due to a change in initial window size.
31 32 33 34 35 36 37 38 39 40 41 |
# File 'lib/protocol/http2/flow_controlled.rb', line 31 def available_frame_size(maximum_frame_size = self.maximum_frame_size) available_size = self.available_size # puts "available_size=#{available_size} maximum_frame_size=#{maximum_frame_size}" if available_size < maximum_frame_size return available_size else return maximum_frame_size end end |
#available_size ⇒ Object
26 27 28 |
# File 'lib/protocol/http2/flow_controlled.rb', line 26 def available_size @remote_window.available end |
#consume_local_window(frame) ⇒ Object
62 63 64 65 66 |
# File 'lib/protocol/http2/flow_controlled.rb', line 62 def consume_local_window(frame) # For flow-control calculations, the 9-octet frame header is not counted. amount = frame.length @local_window.consume(amount) end |
#consume_remote_window(frame) ⇒ Object
Keep track of the amount of data sent, and fail if is too much.
44 45 46 47 48 49 50 51 52 53 54 55 |
# File 'lib/protocol/http2/flow_controlled.rb', line 44 def consume_remote_window(frame) amount = frame.length # Frames with zero length with the END_STREAM flag set (that is, an empty DATA frame) MAY be sent if there is no available space in either flow-control window. if amount.zero? and frame.end_stream? # It's okay, we can send. No need to consume, it's empty anyway. elsif amount >= 0 and amount <= @remote_window.available @remote_window.consume(amount) else raise FlowControlError, "Trying to send #{frame.length} bytes, exceeded window size: #{@remote_window.available} (#{@remote_window})" end end |
#receive_window_update(frame) ⇒ Object
84 85 86 87 88 89 90 91 92 93 94 95 96 |
# File 'lib/protocol/http2/flow_controlled.rb', line 84 def receive_window_update(frame) amount = frame.unpack # Async.logger.info(self) {"expanding remote_window=#{@remote_window} by #{amount}"} if amount != 0 @remote_window.(amount) else raise ProtocolError, "Invalid window size increment: #{amount}!" end # puts "expanded remote_window=#{@remote_window} by #{amount}" end |
#request_window_update ⇒ Object
68 69 70 71 72 |
# File 'lib/protocol/http2/flow_controlled.rb', line 68 def request_window_update if @local_window.limited? self.send_window_update(@local_window.wanted) end end |
#send_window_update(window_increment) ⇒ Object
Notify the remote end that we are prepared to receive more data:
75 76 77 78 79 80 81 82 |
# File 'lib/protocol/http2/flow_controlled.rb', line 75 def send_window_update(window_increment) frame = WindowUpdateFrame.new(self.id) frame.pack window_increment write_frame(frame) @local_window.(window_increment) end |
#update_local_window(frame) ⇒ Object
57 58 59 60 |
# File 'lib/protocol/http2/flow_controlled.rb', line 57 def update_local_window(frame) consume_local_window(frame) request_window_update end |
#window_updated(size) ⇒ Boolean
The window has been expanded by the given amount.
101 102 103 |
# File 'lib/protocol/http2/flow_controlled.rb', line 101 def window_updated(size) return false end |