Skip to content

Commit

Permalink
test: refactor http pipelined socket test
Browse files Browse the repository at this point in the history
In test-http-incoming-pipelined-socket-destory:

* setTimeout() with no duration -> setImmediate()
* eliminate unneeded exit listener
* use common.mustCall()
* var -> const/let

PR-URL: #10189
Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Sakthipriyan Vairamani <thechargingvolcano@gmail.com>
  • Loading branch information
Trott authored and targos committed Dec 28, 2016
1 parent ad742f7 commit dc993ac
Showing 1 changed file with 12 additions and 17 deletions.
29 changes: 12 additions & 17 deletions test/parallel/test-http-incoming-pipelined-socket-destroy.js
Original file line number Diff line number Diff line change
@@ -1,16 +1,17 @@
'use strict';
require('../common');
const common = require('../common');

var http = require('http');
var net = require('net');
const http = require('http');
const net = require('net');

const seeds = [ 3, 1, 2, 3, 4, 1, 2, 3, 4, 1, 2, 3, 4 ];

// Set up some timing issues where sockets can be destroyed
// via either the req or res.
var server = http.createServer(function(req, res) {
const server = http.createServer(common.mustCall(function(req, res) {
switch (req.url) {
case '/1':
return setTimeout(function() {
return setImmediate(function() {
req.socket.destroy();
server.emit('requestDone');
});
Expand All @@ -24,7 +25,7 @@ var server = http.createServer(function(req, res) {
// in one case, actually send a response in 2 chunks
case '/3':
res.write('hello ');
return setTimeout(function() {
return setImmediate(function() {
res.end('world!');
server.emit('requestDone');
});
Expand All @@ -33,7 +34,7 @@ var server = http.createServer(function(req, res) {
res.destroy();
server.emit('requestDone');
}
});
}, seeds.length));


// Make a bunch of requests pipelined on the same socket
Expand All @@ -47,10 +48,9 @@ function generator(seeds) {
}


server.listen(0, function() {
var seeds = [ 3, 1, 2, 3, 4, 1, 2, 3, 4, 1, 2, 3, 4 ];
var client = net.connect({ port: this.address().port });
var done = 0;
server.listen(0, common.mustCall(function() {
const client = net.connect({ port: this.address().port });
let done = 0;
server.on('requestDone', function() {
if (++done === seeds.length) {
server.close();
Expand All @@ -60,9 +60,4 @@ server.listen(0, function() {
// immediately write the pipelined requests.
// Some of these will not have a socket to destroy!
client.write(generator(seeds));
});

process.on('exit', function(c) {
if (!c)
console.log('ok');
});
}));

0 comments on commit dc993ac

Please sign in to comment.