lib/httpx/resolver/resolver.rb in httpx-0.22.2 vs lib/httpx/resolver/resolver.rb in httpx-0.22.3
- old
+ new
@@ -52,11 +52,11 @@
end
# double emission check
return if connection.addresses && !addresses.intersect?(connection.addresses)
- log { "resolver: answer #{connection.origin.host}: #{addresses.inspect}" }
+ log { "resolver: answer #{FAMILY_TYPES[RECORD_TYPES[family]]} #{connection.origin.host}: #{addresses.inspect}" }
if @pool && # if triggered by early resolve, pool may not be here yet
!connection.io &&
connection.options.ip_families.size > 1 &&
family == Socket::AF_INET &&
addresses.first.to_s != connection.origin.host.to_s
@@ -71,14 +71,9 @@
end
private
def emit_resolved_connection(connection, addresses)
- if connection.io && connection.connecting? && @pool
- new_connection = connection.clone_new_connection
- @pool.init_connection(new_connection, connection.options)
- connection = new_connection
- end
connection.addresses = addresses
emit(:resolve, connection)
end