diff options
| author | Kim Alvefur <zash@zash.se> | 2014-06-30 13:12:16 +0200 |
|---|---|---|
| committer | Kim Alvefur <zash@zash.se> | 2014-06-30 13:12:16 +0200 |
| commit | 6c75e23434fd4ba3eed580582ade3ad8337fd585 (patch) | |
| tree | 188fe2fddec81c249b952dca48e7f61546e44351 | |
| parent | 55a097981ec6c98f4dd3115e143c066fbe90d8e3 (diff) | |
| parent | 7dd5829ef95b16d62e45a7cfec5986b023342670 (diff) | |
| download | prosody-6c75e23434fd4ba3eed580582ade3ad8337fd585.tar.gz prosody-6c75e23434fd4ba3eed580582ade3ad8337fd585.zip | |
Merge 0.10->trunk
| -rw-r--r-- | net/adns.lua | 1 | ||||
| -rw-r--r-- | net/dns.lua | 9 |
2 files changed, 9 insertions, 1 deletions
diff --git a/net/adns.lua b/net/adns.lua index 08421f77..15814fe7 100644 --- a/net/adns.lua +++ b/net/adns.lua @@ -52,6 +52,7 @@ function new_async_socket(sock, resolver) local peername = "<unknown>"; local listener = {}; local handler = {}; + local err; function listener.onincoming(conn, data) if data then dns.feed(handler, data); diff --git a/net/dns.lua b/net/dns.lua index bd5c260e..088067ae 100644 --- a/net/dns.lua +++ b/net/dns.lua @@ -722,6 +722,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); @@ -742,7 +750,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); |