node/test/parallel/test-net-server-max-connections.js
Roman Reiss f29762f4dd test: enable linting for tests
Enable linting for the test directory. A number of changes was made so
all tests conform the current rules used by lib and src directories. The
only exception for tests is that unreachable (dead) code is allowed.

test-fs-non-number-arguments-throw had to be excluded from the changes
because of a weird issue on Windows CI.

PR-URL: https://github.com/nodejs/io.js/pull/1721
Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
2015-05-19 21:21:27 +02:00

87 lines
2 KiB
JavaScript

'use strict';
var common = require('../common');
var assert = require('assert');
var net = require('net');
// This test creates 200 connections to a server and sets the server's
// maxConnections property to 100. The first 100 connections make it through
// and the last 100 connections are rejected.
// TODO: test that the server can accept more connections after it reaches
// its maximum and some are closed.
var N = 200;
var count = 0;
var closes = 0;
var waits = [];
var server = net.createServer(function(connection) {
console.error('connect %d', count++);
connection.write('hello');
waits.push(function() { connection.end(); });
});
server.listen(common.PORT, function() {
makeConnection(0);
});
server.maxConnections = N / 2;
console.error('server.maxConnections = %d', server.maxConnections);
function makeConnection(index) {
var c = net.createConnection(common.PORT);
var gotData = false;
c.on('connect', function() {
if (index + 1 < N) {
makeConnection(index + 1);
}
});
c.on('end', function() { c.end(); });
c.on('data', function(b) {
gotData = true;
assert.ok(0 < b.length);
});
c.on('error', function(e) {
console.error('error %d: %s', index, e);
});
c.on('close', function() {
console.error('closed %d', index);
closes++;
if (closes < N / 2) {
assert.ok(server.maxConnections <= index,
index +
' was one of the first closed connections ' +
'but shouldnt have been');
}
if (closes === N / 2) {
var cb;
console.error('calling wait callback.');
while (cb = waits.shift()) {
cb();
}
server.close();
}
if (index < server.maxConnections) {
assert.equal(true, gotData,
index + ' didn\'t get data, but should have');
} else {
assert.equal(false, gotData,
index + ' got data, but shouldn\'t have');
}
});
}
process.on('exit', function() {
assert.equal(N, closes);
});