summaryrefslogtreecommitdiff
path: root/lib/resolv.rb
diff options
context:
space:
mode:
authorIgor Pstyga <[email protected]>2024-04-23 21:04:52 -0700
committergit <[email protected]>2024-08-13 21:09:08 +0000
commit4be9b72fbb44e7754337f4957f2c7bfe3cd41891 ()
treef5ddaf35adeec45d3a31d85f1932dc9b754c4dd7 /lib/resolv.rb
parent525008cd7879a047e3c310eb63dcef901b23be56 (diff)
[ruby/resolv] Fix TCP fallback with multiple nameservers
Under the following conditions the exception `Resolv::DNS::Requester::RequestError: host/port don't match` is raised: - Multiple nameservers are configured for Resolv::DNS - A nameserver falls back from UDP to TCP - TCP request hits Resolv::DNS timeout - Resolv::DNS retries the next nameserver More details here https://bugs.ruby-lang.org/issues/8285 https://.com/ruby/resolv/commit/7d524df80e Co-authored-by: Julian Mehnle <[email protected]>
-rw-r--r--lib/resolv.rb47
1 files changed, 27 insertions, 20 deletions
@@ -513,22 +513,32 @@ class Resolv
def fetch_resource(name, typeclass)
lazy_initialize
- begin
- requester = make_udp_requester
- rescue Errno::EACCES
- # fall back to TCP
- end
senders = {}
begin
- @config.resolv(name) {|candidate, tout, nameserver, port|
- requester ||= make_tcp_requester(nameserver, port)
msg = Message.new
msg.rd = 1
msg.add_question(candidate, typeclass)
- unless sender = senders[[candidate, nameserver, port]]
sender = requester.sender(msg, candidate, nameserver, port)
next if !sender
- senders[[candidate, nameserver, port]] = sender
end
reply, reply_name = requester.request(sender, tout)
case reply.rcode
@@ -536,12 +546,7 @@ class Resolv
if reply.tc == 1 and not Requester::TCP === requester
requester.close
# Retry via TCP:
- requester = make_tcp_requester(nameserver, port)
- senders = {}
- # This will use TCP for all remaining candidates (assuming the
- # current candidate does not already respond successfully via
- # TCP). This makes sense because we already know the full
- # response will not fit in an untruncated UDP packet.
redo
else
yield(reply, reply_name)
@@ -552,9 +557,9 @@ class Resolv
else
raise Config::OtherResolvError.new(reply_name.to_s)
end
- }
ensure
- requester&.close
end
end
@@ -569,6 +574,11 @@ class Resolv
def make_tcp_requester(host, port) # :nodoc:
return Requester::TCP.new(host, port)
end
def extract_resources(msg, name, typeclass) # :nodoc:
@@ -1800,7 +1810,6 @@ class Resolv
end
end
-
##
# Base class for SvcParam. [RFC9460]
@@ -2499,7 +2508,6 @@ class Resolv
attr_reader :altitude
-
def encode_rdata(msg) # :nodoc:
msg.put_bytes(@version)
msg.put_bytes(@ssize.scalar)
@@ -3439,4 +3447,3 @@ class Resolv
AddressRegex = /(?:#{IPv4::Regex})|(?:#{IPv6::Regex})/
end
-