mirror of https://github.com/lukechilds/node.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
121 lines
3.0 KiB
121 lines
3.0 KiB
var dns = process.binding('cares');
|
|
|
|
|
|
var watchers = {};
|
|
var activeWatchers = {};
|
|
|
|
|
|
var timer = new process.Timer();
|
|
|
|
timer.callback = function () {
|
|
for (var socket in activeWatchers) {
|
|
var s = parseInt(socket);
|
|
channel.processFD( watchers[socket].read ? s : dns.SOCKET_BAD
|
|
, watchers[socket].write ? s : dns.SOCKET_BAD
|
|
);
|
|
}
|
|
updateTimer();
|
|
}
|
|
|
|
|
|
function updateTimer() {
|
|
timer.stop();
|
|
|
|
for (var socket in activeWatchers) { // if !empty(activeWatchers)
|
|
var max = 20000;
|
|
var timeout = channel.timeout(max);
|
|
|
|
timer.start(timeout, 0);
|
|
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
var channel = new dns.Channel({SOCK_STATE_CB: function (socket, read, write) {
|
|
var watcher;
|
|
|
|
if (socket in watchers) {
|
|
watcher = watchers[socket].watcher;
|
|
} else {
|
|
watcher = new process.IOWatcher();
|
|
watchers[socket] = { read: read
|
|
, write: write
|
|
, watcher: watcher
|
|
};
|
|
|
|
watcher.callback = function(read, write) {
|
|
channel.processFD( read ? socket : dns.SOCKET_BAD
|
|
, write ? socket : dns.SOCKET_BAD
|
|
);
|
|
updateTimer();
|
|
}
|
|
}
|
|
|
|
watcher.set(socket, read == 1, write == 1);
|
|
|
|
if (!(read || write)) {
|
|
watcher.stop();
|
|
delete activeWatchers[socket];
|
|
return;
|
|
} else {
|
|
watcher.start();
|
|
activeWatchers[socket] = watcher;
|
|
}
|
|
|
|
updateTimer();
|
|
}});
|
|
|
|
|
|
|
|
exports.resolve = function (domain, type_, callback_) {
|
|
var type, callback;
|
|
if (typeof(type_) == 'string') {
|
|
type = type_;
|
|
callback = callback_;
|
|
} else {
|
|
type = 'A';
|
|
callback = arguments[1];
|
|
}
|
|
|
|
var resolveFunc = resolveMap[type];
|
|
|
|
if (typeof(resolveFunc) == 'function') {
|
|
resolveFunc(domain, callback);
|
|
} else {
|
|
throw new Error('Unknown type "' + type + '"');
|
|
}
|
|
}
|
|
|
|
|
|
exports.resolve4 = function(domain, callback) { channel.query(domain, dns.A, callback) };
|
|
exports.resolve6 = function(domain, callback) { channel.query(domain, dns.AAAA, callback) };
|
|
exports.resolveTxt = function(domain, callback) { channel.query(domain, dns.TXT, callback) };
|
|
exports.resolveSrv = function(domain, callback) { channel.query(domain, dns.SRV, callback) };
|
|
exports.reverse = function(domain, callback) { channel.query(domain, dns.PTR, callback) };
|
|
exports.resolveNs = function(domain, callback) { channel.query(domain, dns.NS, callback) };
|
|
|
|
|
|
var resolveMap = {
|
|
'A' : exports.resolve4,
|
|
'AAAA': exports.resolve6,
|
|
'TXT' : exports.resolveTxt,
|
|
'SRV' : exports.resolveSrv,
|
|
'PTR' : exports.resolvePtr,
|
|
'NS' : exports.resolveNs,
|
|
};
|
|
|
|
// ERROR CODES
|
|
exports.NODATA = dns.NODATA;
|
|
exports.FORMERR = dns.FORMERR;
|
|
exports.BADRESP = dns.BADRESP;
|
|
exports.NOTFOUND = dns.NOTFOUND;
|
|
exports.BADNAME = dns.BADNAME;
|
|
exports.TIMEOUT = dns.TIMEOUT;
|
|
exports.CONNREFUSED = dns.CONNREFUSED;
|
|
exports.NOMEM = dns.NOMEM;
|
|
exports.DESTRUCTION = dns.DESTRUCTION;
|
|
|
|
exports.NOTIMP = dns.NOTIMP;
|
|
exports.EREFUSED = dns.EREFUSED;
|
|
exports.SERVFAIL = dns.SERVFAIL;
|
|
|