1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
local server = require "net.server";
local dns = require "net.dns";
local log = require "util.logger".init("adns");
local coroutine, tostring = coroutine, tostring;
module "adns"
function lookup(handler, qname, qtype, qclass)
return dns.peek(qname, qtype, qclass) or
coroutine.wrap(function ()
log("debug", "Records for "..qname.." not in cache, sending query (%s)...", tostring(coroutine.running()));
dns.query(qname, qtype, qclass);
coroutine.yield(nil); -- Wait for reply
log("debug", "Reply for "..qname.." (%s)", tostring(coroutine.running()));
handler(dns.peek(qname, qtype, qclass));
end)();
end
function new_async_socket(sock)
local newconn = {};
local listener = {};
function listener.incoming(conn, data)
dns.feed(sock, data);
end
function listener.disconnect()
end
newconn.handler, newconn._socket = server.wrapclient(sock, "dns", 53, listener);
newconn.handler.settimeout = function () end
newconn.handler.setsockname = function (_, ...) return sock:setsockname(...); end
newconn.handler.setpeername = function (_, ...) local ret = sock:setpeername(...); _.setsend(sock.send); return ret; end
newconn.handler.connect = function (_, ...) return sock:connect(...) end
newconn.handler.send = function (_, data) return _.write(data) end
return newconn.handler;
end
dns:socket_wrapper_set(new_async_socket);
return _M;
|
