mirror of
https://github.com/HoneyryderChuck/httpx.git
synced 2025-10-04 00:00:37 -04:00
Merge branch 'issue-159' into 'master'
Fix for HTTP/1 logging on pipelining Closes #159 See merge request honeyryderchuck/httpx!175
This commit is contained in:
commit
7e73c3a066
@ -36,6 +36,8 @@ module HTTPX
|
|||||||
|
|
||||||
request = @requests.first
|
request = @requests.first
|
||||||
|
|
||||||
|
return unless request
|
||||||
|
|
||||||
return :w if request.interests == :w || !@buffer.empty?
|
return :w if request.interests == :w || !@buffer.empty?
|
||||||
|
|
||||||
:r
|
:r
|
||||||
@ -313,8 +315,9 @@ module HTTPX
|
|||||||
end
|
end
|
||||||
|
|
||||||
def join_headers(request)
|
def join_headers(request)
|
||||||
@buffer << "#{request.verb.to_s.upcase} #{headline_uri(request)} HTTP/#{@version.join(".")}" << CRLF
|
headline = "#{request.verb.to_s.upcase} #{headline_uri(request)} HTTP/#{@version.join(".")}"
|
||||||
log(color: :yellow) { "<- HEADLINE: #{@buffer.to_s.chomp.inspect}" }
|
@buffer << headline << CRLF
|
||||||
|
log(color: :yellow) { "<- HEADLINE: #{headline.chomp.inspect}" }
|
||||||
extra_headers = set_protocol_headers(request)
|
extra_headers = set_protocol_headers(request)
|
||||||
join_headers2(request.headers.each(extra_headers))
|
join_headers2(request.headers.each(extra_headers))
|
||||||
log { "<- " }
|
log { "<- " }
|
||||||
|
@ -15,6 +15,11 @@ module HTTPX
|
|||||||
@max_requests: Integer
|
@max_requests: Integer
|
||||||
@parser: Parser::HTTP1
|
@parser: Parser::HTTP1
|
||||||
@buffer: Buffer
|
@buffer: Buffer
|
||||||
|
@version: [Integer, Integer]
|
||||||
|
@handshake_completed: bool
|
||||||
|
@pipelining: bool
|
||||||
|
|
||||||
|
@request: Request?
|
||||||
|
|
||||||
def interests: () -> io_interests?
|
def interests: () -> io_interests?
|
||||||
|
|
||||||
|
@ -60,7 +60,7 @@ fi
|
|||||||
bundle install --quiet
|
bundle install --quiet
|
||||||
|
|
||||||
echo "Waiting for S3 at address ${AMZ_HOST}/health, attempting every 5s"
|
echo "Waiting for S3 at address ${AMZ_HOST}/health, attempting every 5s"
|
||||||
until $(curl --silent --fail ${AMZ_HOST}/health | grep "\"s3\": \"running\"" > /dev/null); do
|
until $(curl --silent --fail ${AMZ_HOST}/health | grep "\"s3\": \"available\"" > /dev/null); do
|
||||||
printf '.'
|
printf '.'
|
||||||
sleep 5
|
sleep 5
|
||||||
done
|
done
|
||||||
|
Loading…
x
Reference in New Issue
Block a user