3e1b1dd4a9
The copyright and license notice is already in the LICENSE file. There is no justifiable reason to also require that it be included in every file, since the individual files are not individually distributed except as part of the entire package.
88 lines
2 KiB
JavaScript
88 lines
2 KiB
JavaScript
var common = require('../common');
|
|
var assert = require('assert');
|
|
var net = require('net');
|
|
|
|
var exchanges = 0;
|
|
var starttime = null;
|
|
var timeouttime = null;
|
|
var timeout = 1000;
|
|
|
|
var echo_server = net.createServer(function(socket) {
|
|
socket.setTimeout(timeout);
|
|
|
|
socket.on('timeout', function() {
|
|
console.log('server timeout');
|
|
timeouttime = new Date;
|
|
console.dir(timeouttime);
|
|
socket.destroy();
|
|
});
|
|
|
|
socket.on('error', function(e) {
|
|
throw new Error('Server side socket should not get error. ' +
|
|
'We disconnect willingly.');
|
|
});
|
|
|
|
socket.on('data', function(d) {
|
|
console.log(d);
|
|
socket.write(d);
|
|
});
|
|
|
|
socket.on('end', function() {
|
|
socket.end();
|
|
});
|
|
});
|
|
|
|
echo_server.listen(common.PORT, function() {
|
|
console.log('server listening at ' + common.PORT);
|
|
|
|
var client = net.createConnection(common.PORT);
|
|
client.setEncoding('UTF8');
|
|
client.setTimeout(0); // disable the timeout for client
|
|
client.on('connect', function() {
|
|
console.log('client connected.');
|
|
client.write('hello\r\n');
|
|
});
|
|
|
|
client.on('data', function(chunk) {
|
|
assert.equal('hello\r\n', chunk);
|
|
if (exchanges++ < 5) {
|
|
setTimeout(function() {
|
|
console.log('client write "hello"');
|
|
client.write('hello\r\n');
|
|
}, 500);
|
|
|
|
if (exchanges == 5) {
|
|
console.log('wait for timeout - should come in ' + timeout + ' ms');
|
|
starttime = new Date;
|
|
console.dir(starttime);
|
|
}
|
|
}
|
|
});
|
|
|
|
client.on('timeout', function() {
|
|
throw new Error("client timeout - this shouldn't happen");
|
|
});
|
|
|
|
client.on('end', function() {
|
|
console.log('client end');
|
|
client.end();
|
|
});
|
|
|
|
client.on('close', function() {
|
|
console.log('client disconnect');
|
|
echo_server.close();
|
|
});
|
|
});
|
|
|
|
process.on('exit', function() {
|
|
assert.ok(starttime != null);
|
|
assert.ok(timeouttime != null);
|
|
|
|
diff = timeouttime - starttime;
|
|
console.log('diff = ' + diff);
|
|
|
|
assert.ok(timeout < diff);
|
|
|
|
// Allow for 800 milliseconds more
|
|
assert.ok(diff < timeout + 800);
|
|
});
|