# HG changeset patch
# User Matthew Wild <mwild1@gmail.com>
# Date 1278327021 -3600
# Node ID 070c8ba71b7656192a0c09f19ac2f909d4350857
# Parent  5228a395999b059b205494b049d66a7af10f0c41
net.dns: Handle our own timeouts, including falling onto other servers in resolv.conf if necessary

diff -r 5228a395999b -r 070c8ba71b76 net/dns.lua
--- a/net/dns.lua	Mon Jul 05 02:20:37 2010 +0100
+++ b/net/dns.lua	Mon Jul 05 11:50:21 2010 +0100
@@ -16,6 +16,8 @@
 
 local socket = require "socket";
 local ztact = require "util.ztact";
+local timer = require "util.timer";
+
 local _, windows = pcall(require, "util.windows");
 local is_windows = (_ and windows) or os.getenv("WINDIR");
 
@@ -27,6 +29,7 @@
 
 local get, set = ztact.get, ztact.set;
 
+local dns_timeout = 15;
 
 -------------------------------------------------- module dns
 module('dns')
@@ -678,7 +681,28 @@
 		--set(self.yielded, co, qclass, qtype, qname, true);
 	end
 
-	self:getsocket (o.server):send (o.packet)
+	local conn = self:getsocket(o.server)
+	conn:send (o.packet)
+	
+	if timer then
+		local num_servers = #self.server;
+		local i = 1;
+		timer.add_task(dns_timeout, function ()
+			if get(self.wanted, qclass, qtype, qname, co) then
+				if i < num_servers then
+					i = i + 1;
+					self:servfail(conn);
+					o.server = self.best_server;
+					conn = self:getsocket(o.server);
+					conn:send(o.packet);
+					return dns_timeout;
+				else
+					-- Tried everything, failed
+					resolver:cancel({qclass, qtype, qname, co}, true);
+				end
+			end
+		end)
+	end
 end
 
 function resolver:servfail(sock)