sharpetronics/httpx
1
0
Fork 0
mirror of https://github.com/HoneyryderChuck/httpx.git synced 2025-08-10 00:01:27 -04:00
Code Issues Projects Releases Wiki Activity

setting up max requests for http2 connections; these will be set to the remote max allowed streams, when setting is received; max_concurrent_requests goes back to what it was

Browse Source
This commit is contained in:
HoneyryderChuck 2020-03-14 22:26:11 +00:00
parent d5bd1c7249
commit 885df66067
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
lib/httpx/connection/http2.rb
View File

@ -20,7 +20,8 @@ module HTTPX
def initialize(buffer, options)
@options = Options.new(options)
@max_concurrent_requests = @options.max_concurrent_requests
@max_concurrent_requests = @options.max_concurrent_requests || MAX_CONCURRENT_REQUESTS
@max_requests = 0
@pending = []
@streams = {}
@drains = {}
@ -38,7 +39,7 @@ module HTTPX
end
def exhausted?
@connection.active_stream_count >= @max_concurrent_requests
@connection.active_stream_count >= @max_requests
end
def <<(data)
@ -47,7 +48,8 @@ module HTTPX
def send(request)
if !@handshake_completed ||
@streams.size >= @max_concurrent_requests
@streams.size >= @max_concurrent_requests ||
@streams.size >= @max_requests
@pending << request
return
end
@ -55,6 +57,7 @@ module HTTPX
stream = @connection.new_stream
handle_stream(stream, request)
@streams[request] = stream
@max_requests -= 1
end
handle(request, stream)
true
@ -216,8 +219,10 @@ module HTTPX
def on_settings(*)
@handshake_completed = true
@max_concurrent_requests = [@max_concurrent_requests,
@connection.remote_settings[:settings_max_concurrent_streams]].min
@max_requests = @connection.remote_settings[:settings_max_concurrent_streams]
@max_concurrent_requests = [@max_concurrent_requests, @max_requests].min
send_pending
end