mirror of
https://github.com/nodejs/node.git
synced 2025-05-01 17:03:34 +00:00
82c43aed16
Use `DoTryWrite()` to write data to the underlying socket. This does probably not make any difference in performance because the callback is still deferred (for now), but brings TLSWrap in line with other things that write to streams. PR-URL: https://github.com/nodejs/node/pull/18676 Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl> Reviewed-By: Anatoli Papirovski <apapirovski@mac.com> Reviewed-By: James M Snell <jasnell@gmail.com>
93 lines
2.2 KiB
JavaScript
93 lines
2.2 KiB
JavaScript
'use strict';
|
|
|
|
const common = require('../common');
|
|
const assert = require('assert');
|
|
const initHooks = require('./init-hooks');
|
|
const { checkInvocations } = require('./hook-checks');
|
|
const net = require('net');
|
|
|
|
const hooks = initHooks();
|
|
hooks.enable();
|
|
|
|
//
|
|
// Creating server and listening on port
|
|
//
|
|
const server = net.createServer()
|
|
.on('listening', common.mustCall(onlistening))
|
|
.on('connection', common.mustCall(onconnection))
|
|
.listen(0);
|
|
|
|
assert.strictEqual(hooks.activitiesOfTypes('WRITEWRAP').length, 0);
|
|
|
|
function onlistening() {
|
|
assert.strictEqual(hooks.activitiesOfTypes('WRITEWRAP').length, 0);
|
|
//
|
|
// Creating client and connecting it to server
|
|
//
|
|
net
|
|
.connect(server.address().port)
|
|
.on('connect', common.mustCall(onconnect));
|
|
|
|
assert.strictEqual(hooks.activitiesOfTypes('WRITEWRAP').length, 0);
|
|
}
|
|
|
|
function checkDestroyedWriteWraps(n, stage) {
|
|
const as = hooks.activitiesOfTypes('WRITEWRAP');
|
|
assert.strictEqual(as.length, n,
|
|
`${as.length} out of ${n} WRITEWRAPs when ${stage}`);
|
|
|
|
function checkValidWriteWrap(w) {
|
|
assert.strictEqual(w.type, 'WRITEWRAP');
|
|
assert.strictEqual(typeof w.uid, 'number');
|
|
assert.strictEqual(typeof w.triggerAsyncId, 'number');
|
|
|
|
checkInvocations(w, { init: 1 }, `when ${stage}`);
|
|
}
|
|
as.forEach(checkValidWriteWrap);
|
|
}
|
|
|
|
function onconnection(conn) {
|
|
conn.resume();
|
|
//
|
|
// Server received client connection
|
|
//
|
|
checkDestroyedWriteWraps(0, 'server got connection');
|
|
}
|
|
|
|
function onconnect() {
|
|
//
|
|
// Client connected to server
|
|
//
|
|
checkDestroyedWriteWraps(0, 'client connected');
|
|
|
|
//
|
|
// Destroying client socket
|
|
//
|
|
this.write('f'.repeat(128000), () => onafterwrite(this));
|
|
}
|
|
|
|
function onafterwrite(self) {
|
|
checkDestroyedWriteWraps(1, 'client destroyed');
|
|
self.destroy();
|
|
|
|
checkDestroyedWriteWraps(1, 'client destroyed');
|
|
|
|
//
|
|
// Closing server
|
|
//
|
|
server.close(common.mustCall(onserverClosed));
|
|
checkDestroyedWriteWraps(1, 'server closing');
|
|
}
|
|
|
|
function onserverClosed() {
|
|
checkDestroyedWriteWraps(1, 'server closed');
|
|
}
|
|
|
|
process.on('exit', onexit);
|
|
|
|
function onexit() {
|
|
hooks.disable();
|
|
hooks.sanityCheck('WRITEWRAP');
|
|
checkDestroyedWriteWraps(1, 'process exits');
|
|
}
|