mirror of
https://github.com/nodejs/node.git
synced 2024-12-01 16:10:02 +01:00
d36e1b4fed
Currently, writeQueueSize is never used in C++ and barely used within JS. Instead of constantly updating the value on the JS object, create a getter that will retrieve the most up-to-date value from C++. For the vast majority of cases though, create a new prop on Socket.prototype[kLastWriteQueueSize] using a Symbol. Use this to track the current write size, entirely in JS land. PR-URL: https://github.com/nodejs/node/pull/17650 Reviewed-By: Anna Henningsen <anna@addaleax.net>
48 lines
1.2 KiB
JavaScript
48 lines
1.2 KiB
JavaScript
'use strict';
|
|
const common = require('../common');
|
|
if (!common.hasCrypto)
|
|
common.skip('missing crypto');
|
|
const fixtures = require('../common/fixtures');
|
|
const https = require('https');
|
|
|
|
// This test assesses whether long-running writes can complete
|
|
// or timeout because the socket is not aware that the backing
|
|
// stream is still writing.
|
|
|
|
const writeSize = 30000000;
|
|
let socket;
|
|
|
|
const server = https.createServer({
|
|
key: fixtures.readKey('agent1-key.pem'),
|
|
cert: fixtures.readKey('agent1-cert.pem')
|
|
}, common.mustCall((req, res) => {
|
|
const content = Buffer.alloc(writeSize, 0x44);
|
|
|
|
res.writeHead(200, {
|
|
'Content-Type': 'application/octet-stream',
|
|
'Content-Length': content.length.toString(),
|
|
'Vary': 'Accept-Encoding'
|
|
});
|
|
|
|
socket = res.socket;
|
|
const onTimeout = socket._onTimeout;
|
|
socket._onTimeout = common.mustCallAtLeast(() => onTimeout.call(socket), 1);
|
|
res.write(content);
|
|
res.end();
|
|
}));
|
|
server.on('timeout', common.mustNotCall());
|
|
|
|
server.listen(0, common.mustCall(() => {
|
|
https.get({
|
|
path: '/',
|
|
port: server.address().port,
|
|
rejectUnauthorized: false
|
|
}, (res) => {
|
|
res.once('data', () => {
|
|
socket._onTimeout();
|
|
res.on('data', () => {});
|
|
});
|
|
res.on('end', () => server.close());
|
|
});
|
|
}));
|