2020-11-11 22:22:41 +01:00
|
|
|
'use strict';
|
|
|
|
const common = require('../common');
|
|
|
|
const { promises: dnsPromises } = require('dns');
|
|
|
|
const assert = require('assert');
|
|
|
|
const dgram = require('dgram');
|
|
|
|
|
|
|
|
const server = dgram.createSocket('udp4');
|
|
|
|
const resolver = new dnsPromises.Resolver();
|
|
|
|
|
|
|
|
server.bind(0, common.mustCall(async () => {
|
|
|
|
resolver.setServers([`127.0.0.1:${server.address().port}`]);
|
|
|
|
|
|
|
|
// Single promise
|
|
|
|
{
|
2024-05-11 20:05:59 +02:00
|
|
|
server.once('message', () => {
|
|
|
|
resolver.cancel();
|
|
|
|
});
|
|
|
|
|
2020-11-11 22:22:41 +01:00
|
|
|
const hostname = 'example0.org';
|
|
|
|
|
|
|
|
await assert.rejects(
|
|
|
|
resolver.resolve4(hostname),
|
|
|
|
{
|
|
|
|
code: 'ECANCELLED',
|
|
|
|
syscall: 'queryA',
|
|
|
|
hostname
|
|
|
|
}
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
// Multiple promises
|
|
|
|
{
|
2024-05-11 20:05:59 +02:00
|
|
|
server.once('message', () => {
|
|
|
|
resolver.cancel();
|
|
|
|
});
|
|
|
|
|
2020-11-11 22:22:41 +01:00
|
|
|
const assertions = [];
|
|
|
|
const assertionCount = 10;
|
|
|
|
|
|
|
|
for (let i = 1; i <= assertionCount; i++) {
|
|
|
|
const hostname = `example${i}.org`;
|
|
|
|
|
|
|
|
assertions.push(
|
|
|
|
assert.rejects(
|
|
|
|
resolver.resolve4(hostname),
|
|
|
|
{
|
|
|
|
code: 'ECANCELLED',
|
|
|
|
syscall: 'queryA',
|
|
|
|
hostname: hostname
|
|
|
|
}
|
|
|
|
)
|
|
|
|
);
|
|
|
|
}
|
|
|
|
|
|
|
|
await Promise.all(assertions);
|
|
|
|
}
|
|
|
|
|
|
|
|
server.close();
|
|
|
|
}));
|