consume_local_frame -> update_local_window to consume and request…

… window update.
socketry · Jul 1, 2019 · 2840a53 · 2840a53
1 parent 80abd36
commit 2840a53
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/lib/protocol/http2/connection.rb b/lib/protocol/http2/connection.rb
@@ -319,7 +319,7 @@ def receive_ping(frame)
 			end
 
 			def receive_data(frame)
-				consume_local_window(frame)
+				update_local_window(frame)
 
 				if stream = @streams[frame.stream_id]
 					stream.receive_data(frame)

diff --git a/lib/protocol/http2/flow_control.rb b/lib/protocol/http2/flow_control.rb
@@ -56,7 +56,6 @@ def consume_remote_window(frame)
 
 			def update_local_window(frame)
 				consume_local_window(frame)
-
 				request_window_update
 			end
 

diff --git a/lib/protocol/http2/stream.rb b/lib/protocol/http2/stream.rb
@@ -400,15 +400,15 @@ def ignore_data(frame)
 			# DATA frames are subject to flow control and can only be sent when a stream is in the "open" or "half-closed (remote)" state.  The entire DATA frame payload is included in flow control, including the Pad Length and Padding fields if present.  If a DATA frame is received whose stream is not in "open" or "half-closed (local)" state, the recipient MUST respond with a stream error of type STREAM_CLOSED.
 			def receive_data(frame)
 				if @state == :open
-					consume_local_window(frame)
+					update_local_window(frame)
 
 					if frame.end_stream?
 						@state = :half_closed_remote
 					end
 
 					process_data(frame)
 				elsif @state == :half_closed_local
-					consume_local_window(frame)
+					update_local_window(frame)
 
 					process_data(frame)