_addresses_equal() needs the af

diff --git a/dns/query.py b/dns/query.py
index 81a78b43bfd3781a0e53aed3e10375b25c1203fe..15b5a90e29163b8f52be0b416c330a5688e71303 100644 (file)
--- a/dns/query.py
+++ b/dns/query.py
@@ -135,7 +135,7 @@ def udp(q, where, timeout=None, port=53, af=None, source=None, source_port=0,
         while 1:
             _wait_for_readable(s, expiration)
             (wire, from_address) = s.recvfrom(65535)
-            if _addresses_equal(from_address, destination) or \
+            if _addresses_equal(af, from_address, destination) or \
                     (dns.inet.is_multicast(where) and \
                          from_address[1:] == destination[1:]):
                 break