1berry/nodejs
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: update test/parallel/test-http-pipe-fs.js to use countdown

Browse Source 
PR-URL: https://github.com/nodejs/node/pull/17346
Reviewed-By: Jon Moss <me@jonathanmoss.me>
Reviewed-By: Anna Henningsen <anna@addaleax.net>
This commit is contained in:
ChungNgoops 2017-11-27 17:18:45 +07:00 committed by Anna Henningsen
parent 0f3fd79ee9
commit fa072499a5
No known key found for this signature in database
GPG Key ID: 9C63F3A6CD2AD8F9
1 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
test/parallel/test-http-pipe-fs.js
View File

@ -24,6 +24,10 @@ const common = require('../common');
const http = require('http'); const http = require('http');
const fs = require('fs'); const fs = require('fs');
const path = require('path'); const path = require('path');
const Countdown = require('../common/countdown');
const NUMBER_OF_STREAMS = 2;
const countdown = new Countdown(NUMBER_OF_STREAMS, () => server.close());
common.refreshTmpDir(); common.refreshTmpDir();
@ -39,27 +43,23 @@ const server = http.createServer(common.mustCall(function(req, res) {
}, 2)).listen(0, function() { }, 2)).listen(0, function() {
http.globalAgent.maxSockets = 1; http.globalAgent.maxSockets = 1;
for (let i = 0; i < 2; ++i) { for (let i = 0; i < NUMBER_OF_STREAMS; ++i) {
(function(i) { const req = http.request({
const req = http.request({ port: server.address().port,
port: server.address().port, method: 'POST',
method: 'POST', headers: {
headers: { 'Content-Length': 5
'Content-Length': 5 }
} }, function(res) {
}, function(res) { res.on('end', function() {
res.on('end', function() { console.error(`res${i + 1} end`);
console.error(`res${i} end`); countdown.dec();
if (i === 2) {
server.close();
}
});
res.resume();
}); });
req.on('socket', function(s) { res.resume();
console.error(`req${i} start`); });
}); req.on('socket', function(s) {
req.end('12345'); console.error(`req${i + 1} start`);
}(i + 1)); });
req.end('12345');
} }
}); });