'use strict'; // Uploading a big file via HTTPS causes node to drop out of the event loop. // https://github.com/joyent/node/issues/892 // In this test we set up an HTTPS in this process and launch a subprocess // to POST a 32mb file to us. A bug in the pause/resume functionality of the // TLS server causes the child process to exit cleanly before having sent // the entire buffer. var common = require('../common'); var assert = require('assert'); var spawn = require('child_process').spawn; if (!common.hasCrypto) { common.skip('missing crypto'); return; } var https = require('https'); var fs = require('fs'); var bytesExpected = 1024 * 1024 * 32; var started = false; var childScript = require('path').join(common.fixturesDir, 'GH-892-request.js'); function makeRequest() { if (started) return; started = true; var stderrBuffer = ''; // Pass along --trace-deprecation/--throw-deprecation in // process.execArgv to track down nextTick recursion errors // more easily. Also, this is handy when using this test to // view V8 opt/deopt behavior. var args = process.execArgv.concat([ childScript, common.PORT, bytesExpected ]); var child = spawn(process.execPath, args); child.on('exit', function(code) { assert.ok(/DONE/.test(stderrBuffer)); assert.equal(0, code); }); // The following two lines forward the stdio from the child // to parent process for debugging. child.stderr.pipe(process.stderr); child.stdout.pipe(process.stdout); // Buffer the stderr so that we can check that it got 'DONE' child.stderr.setEncoding('ascii'); child.stderr.on('data', function(d) { stderrBuffer += d; }); } var serverOptions = { key: fs.readFileSync(common.fixturesDir + '/keys/agent1-key.pem'), cert: fs.readFileSync(common.fixturesDir + '/keys/agent1-cert.pem') }; var uploadCount = 0; var server = https.Server(serverOptions, function(req, res) { // Close the server immediately. This test is only doing a single upload. // We need to make sure the server isn't keeping the event loop alive // while the upload is in progress. server.close(); req.on('data', function(d) { process.stderr.write('.'); uploadCount += d.length; }); req.on('end', function() { assert.equal(bytesExpected, uploadCount); res.writeHead(200, {'content-type': 'text/plain'}); res.end('successful upload\n'); }); }); server.listen(common.PORT, function() { console.log('expecting %d bytes', bytesExpected); makeRequest(); }); process.on('exit', function() { console.error('got %d bytes', uploadCount); assert.equal(uploadCount, bytesExpected); });