Skip to content

Commit

Permalink
test: allow out-of-order replies in dgram tests
Browse files Browse the repository at this point in the history
Allow out of order replies in the flaky
`test-dgram{-upd6,}-send-default-host.js` files by sorting
the incoming replies after receiving them.

PR-URL: #6607
Fixes: #6577
Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
  • Loading branch information
addaleax authored and evanlucas committed May 17, 2016
1 parent be241c3 commit 01f010f
Show file tree
Hide file tree
Showing 2 changed files with 29 additions and 18 deletions.
20 changes: 13 additions & 7 deletions test/parallel/test-dgram-send-default-host.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,20 +11,26 @@ const toSend = [Buffer.alloc(256, 'x'),
Buffer.alloc(256, 'z'),
'hello'];

client.on('listening', function() {
const received = [];

client.on('listening', common.mustCall(() => {
client.send(toSend[0], 0, toSend[0].length, common.PORT);
client.send(toSend[1], common.PORT);
client.send([toSend[2]], common.PORT);
client.send(toSend[3], 0, toSend[3].length, common.PORT);
});
}));

client.on('message', common.mustCall((buf, info) => {
received.push(buf.toString());

client.on('message', function(buf, info) {
const expected = toSend.shift().toString();
assert.ok(buf.toString() === expected, 'message was received correctly');
if (received.length === toSend.length) {
// The replies may arrive out of order -> sort them before checking.
received.sort();

if (toSend.length === 0) {
const expected = toSend.map(String).sort();
assert.deepStrictEqual(received, expected);
client.close();
}
});
}, toSend.length));

client.bind(common.PORT);
27 changes: 16 additions & 11 deletions test/parallel/test-dgram-udp6-send-default-host.js
Original file line number Diff line number Diff line change
Expand Up @@ -11,26 +11,31 @@ if (!common.hasIPv6) {

const client = dgram.createSocket('udp6');

const toSend = [new Buffer(256), new Buffer(256), new Buffer(256), 'hello'];
const toSend = [Buffer.alloc(256, 'x'),
Buffer.alloc(256, 'y'),
Buffer.alloc(256, 'z'),
'hello'];

toSend[0].fill('x');
toSend[1].fill('y');
toSend[2].fill('z');
const received = [];

client.on('listening', function() {
client.on('listening', common.mustCall(() => {
client.send(toSend[0], 0, toSend[0].length, common.PORT);
client.send(toSend[1], common.PORT);
client.send([toSend[2]], common.PORT);
client.send(toSend[3], 0, toSend[3].length, common.PORT);
});
}));

client.on('message', function(buf, info) {
const expected = toSend.shift().toString();
assert.ok(buf.toString() === expected, 'message was received correctly');
client.on('message', common.mustCall((buf, info) => {
received.push(buf.toString());

if (toSend.length === 0) {
if (received.length === toSend.length) {
// The replies may arrive out of order -> sort them before checking.
received.sort();

const expected = toSend.map(String).sort();
assert.deepStrictEqual(received, expected);
client.close();
}
});
}, toSend.length));

client.bind(common.PORT);

0 comments on commit 01f010f

Please sign in to comment.