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.
112 lines
3.0 KiB
112 lines
3.0 KiB
'use strict';
|
|
const common = require('../common');
|
|
const assert = require('assert');
|
|
const net = require('net');
|
|
|
|
function pingPongTest(port, host) {
|
|
const N = 1000;
|
|
var count = 0;
|
|
var sentPongs = 0;
|
|
var sent_final_ping = false;
|
|
|
|
const server = net.createServer(
|
|
{ allowHalfOpen: true },
|
|
common.mustCall(onSocket)
|
|
);
|
|
|
|
function onSocket(socket) {
|
|
assert.strictEqual(socket.server, server);
|
|
server.getConnections(common.mustCall(function(err, connections) {
|
|
assert.ifError(err);
|
|
assert.strictEqual(connections, 1);
|
|
}));
|
|
|
|
socket.setNoDelay();
|
|
socket.timeout = 0;
|
|
|
|
socket.setEncoding('utf8');
|
|
socket.on('data', common.mustCall(function(data) {
|
|
// Since we never queue data (we're always waiting for the PING
|
|
// before sending a pong) the writeQueueSize should always be less
|
|
// than one message.
|
|
assert.ok(0 <= socket.bufferSize && socket.bufferSize <= 4);
|
|
|
|
assert.strictEqual(socket.writable, true);
|
|
assert.strictEqual(socket.readable, true);
|
|
assert.ok(count <= N);
|
|
assert.strictEqual(data, 'PING');
|
|
|
|
socket.write('PONG', common.mustCall(function() {
|
|
sentPongs++;
|
|
}));
|
|
}, N + 1));
|
|
|
|
socket.on('end', common.mustCall(function() {
|
|
assert.strictEqual(socket.allowHalfOpen, true);
|
|
assert.strictEqual(socket.writable, true); // because allowHalfOpen
|
|
assert.strictEqual(socket.readable, false);
|
|
socket.end();
|
|
}));
|
|
|
|
socket.on('error', common.fail);
|
|
|
|
socket.on('close', common.mustCall(function() {
|
|
assert.strictEqual(socket.writable, false);
|
|
assert.strictEqual(socket.readable, false);
|
|
socket.server.close();
|
|
}));
|
|
}
|
|
|
|
|
|
server.listen(port, host, common.mustCall(function() {
|
|
if (this.address().port)
|
|
port = this.address().port;
|
|
|
|
const client = net.createConnection(port, host);
|
|
|
|
client.setEncoding('ascii');
|
|
client.on('connect', common.mustCall(function() {
|
|
assert.strictEqual(client.readable, true);
|
|
assert.strictEqual(client.writable, true);
|
|
client.write('PING');
|
|
}));
|
|
|
|
client.on('data', common.mustCall(function(data) {
|
|
assert.strictEqual(data, 'PONG');
|
|
count += 1;
|
|
|
|
if (sent_final_ping) {
|
|
assert.strictEqual(client.writable, false);
|
|
assert.strictEqual(client.readable, true);
|
|
return;
|
|
} else {
|
|
assert.strictEqual(client.writable, true);
|
|
assert.strictEqual(client.readable, true);
|
|
}
|
|
|
|
if (count < N) {
|
|
client.write('PING');
|
|
} else {
|
|
sent_final_ping = true;
|
|
client.write('PING');
|
|
client.end();
|
|
}
|
|
}, N + 1));
|
|
|
|
client.on('close', common.mustCall(function() {
|
|
assert.strictEqual(count, N + 1);
|
|
assert.strictEqual(sentPongs, N + 1);
|
|
assert.strictEqual(sent_final_ping, true);
|
|
}));
|
|
|
|
client.on('error', common.fail);
|
|
}));
|
|
}
|
|
|
|
/* All are run at once, so run on different ports */
|
|
common.refreshTmpDir();
|
|
pingPongTest(common.PIPE);
|
|
pingPongTest(0);
|
|
pingPongTest(0, 'localhost');
|
|
if (common.hasIPv6)
|
|
pingPongTest(0, '::1');
|
|
|