Skip to content
Closed
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions test/common/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -264,9 +264,9 @@ function childShouldThrowAndAbort() {
});
}

function createZeroFilledFile(filename) {
function createZeroFilledFile(filename, size = 10 * 1024 * 1024) {
const fd = fs.openSync(filename, 'w');
fs.ftruncateSync(fd, 10 * 1024 * 1024);
fs.ftruncateSync(fd, size);
fs.closeSync(fd);
}

Expand Down
13 changes: 5 additions & 8 deletions test/parallel/test-pipe-file-to-http.js
Original file line number Diff line number Diff line change
Expand Up @@ -29,16 +29,16 @@ const tmpdir = require('../common/tmpdir');
tmpdir.refresh();

const filename = tmpdir.resolve('big');
const fileSize = 5 * 1024 * 1024;
let count = 0;

const server = http.createServer((req, res) => {
let timeoutId;
assert.strictEqual(req.method, 'POST');
req.pause();

setTimeout(() => {
const timeoutId = setTimeout(() => {
req.resume();
}, 1000);
}, common.platformTimeout(1000));

req.on('data', (chunk) => {
count += chunk.length;
Expand All @@ -55,7 +55,7 @@ const server = http.createServer((req, res) => {
server.listen(0);

server.on('listening', () => {
common.createZeroFilledFile(filename);
common.createZeroFilledFile(filename, fileSize);
makeRequest();
});

Expand All @@ -73,11 +73,8 @@ function makeRequest() {
req.on('response', (res) => {
res.resume();
res.on('end', () => {
assert.strictEqual(count, fileSize);
server.close();
});
});
}

process.on('exit', () => {
assert.strictEqual(count, 1024 * 10240);
});