diff options
| author | Kim Alvefur <zash@zash.se> | 2014-06-30 12:45:53 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2014-06-30 12:45:53 +0200 |
| commit | 17281a6413be6411c4b6d2c007098886e4c44765 (patch) | |
| tree | 7e6304e340020f8114d8707e07f3af5ee8a476ba /net | |
| parent | 4da1f7a763aa920735dfd82af3fcb638a824fe7f (diff) | |
| download | prosody-17281a6413be6411c4b6d2c007098886e4c44765.tar.gz prosody-17281a6413be6411c4b6d2c007098886e4c44765.zip | |
net.dns: Fix duplicated cache insertions by limiting outstanding queries per name to one
Diffstat (limited to 'net')
| -rw-r--r-- | net/dns.lua | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/net/dns.lua b/net/dns.lua index cdd949a2..492bd1c5 100644 --- a/net/dns.lua +++ b/net/dns.lua @@ -715,6 +715,14 @@ end function resolver:query(qname, qtype, qclass) -- - - - - - - - - - -- query qname, qtype, qclass = standardize(qname, qtype, qclass) + local co = coroutine.running(); + local q = get(self.wanted, qclass, qtype, qname); + if co and q then + -- We are already waiting for a reply to an identical query. + set(self.wanted, qclass, qtype, qname, co, true); + return true; + end + if not self.server then self:adddefaultnameservers(); end local question = encodeQuestion(qname, qtype, qclass); @@ -735,7 +743,6 @@ function resolver:query(qname, qtype, qclass) -- - - - - - - - - - -- query self.active[id][question] = o; -- remember which coroutine wants the answer - local co = coroutine.running(); if co then set(self.wanted, qclass, qtype, qname, co, true); --set(self.yielded, co, qclass, qtype, qname, true); |