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

handle the special case of system resolver which has to bubble up differently than all other errors

Browse Source
This commit is contained in:
HoneyryderChuck 2020-02-02 09:42:33 +01:00
parent 731db5691b
commit cfc039e32e
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/httpx/resolver/system.rb
View File

@ -34,7 +34,7 @@ module HTTPX
ip_resolve(hostname) || ip_resolve(hostname) ||
system_resolve(hostname) || system_resolve(hostname) ||
@resolver.getaddresses(hostname) @resolver.getaddresses(hostname)
return emit_resolve_error(connection, hostname) if addresses.empty? throw(:resolve_error, resolve_error(hostname)) if addresses.empty?
emit_addresses(connection, addresses) emit_addresses(connection, addresses)
rescue Errno::EHOSTUNREACH, *RESOLV_ERRORS => e rescue Errno::EHOSTUNREACH, *RESOLV_ERRORS => e

11
lib/httpx/session.rb
View File

@ -152,9 +152,14 @@ module HTTPX
request_options = @options.merge(options) request_options = @options.merge(options)
requests.each do |request| requests.each do |request|
connection = find_connection(request, connections, request_options) error = catch(:resolve_error) do
connection.send(request) connection = find_connection(request, connections, request_options)
set_request_timeout(connection, request, request_options) connection.send(request)
set_request_timeout(connection, request, request_options)
end
next unless error.is_a?(ResolveError)
request.emit(:response, ErrorResponse.new(request, error, options))
end end
responses = [] responses = []