mirror of
https://github.com/nodejs/node.git
synced 2025-04-29 22:40:57 +00:00
24dd92e77f
This makes `net.Sockets` use actual Timeout objects in a `[kTimeout]` symbol property, rather than making the socket itself a timer and appending properties to it directly. This should make the code generally easier to understand, and might also prevent some deopts from properties being changes on the socket itself. Also moves the Timeout constructor into an internal module. PR-URL: https://github.com/nodejs/node/pull/17704 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Anatoli Papirovski <apapirovski@mac.com>
108 lines
2.9 KiB
JavaScript
108 lines
2.9 KiB
JavaScript
'use strict';
|
|
|
|
const async_wrap = process.binding('async_wrap');
|
|
// Two arrays that share state between C++ and JS.
|
|
const { async_hook_fields, async_id_fields } = async_wrap;
|
|
const {
|
|
getDefaultTriggerAsyncId,
|
|
// The needed emit*() functions.
|
|
emitInit
|
|
} = require('internal/async_hooks');
|
|
// Grab the constants necessary for working with internal arrays.
|
|
const { kInit, kAsyncIdCounter } = async_wrap.constants;
|
|
// Symbols for storing async id state.
|
|
const async_id_symbol = Symbol('asyncId');
|
|
const trigger_async_id_symbol = Symbol('triggerId');
|
|
|
|
const errors = require('internal/errors');
|
|
|
|
// Timeout values > TIMEOUT_MAX are set to 1.
|
|
const TIMEOUT_MAX = 2 ** 31 - 1;
|
|
|
|
module.exports = {
|
|
TIMEOUT_MAX,
|
|
kTimeout: Symbol('timeout'), // For hiding Timeouts on other internals.
|
|
async_id_symbol,
|
|
trigger_async_id_symbol,
|
|
Timeout,
|
|
setUnrefTimeout,
|
|
};
|
|
|
|
// Timer constructor function.
|
|
// The entire prototype is defined in lib/timers.js
|
|
function Timeout(callback, after, args, isRepeat) {
|
|
after *= 1; // coalesce to number or NaN
|
|
if (!(after >= 1 && after <= TIMEOUT_MAX)) {
|
|
if (after > TIMEOUT_MAX) {
|
|
process.emitWarning(`${after} does not fit into` +
|
|
' a 32-bit signed integer.' +
|
|
'\nTimeout duration was set to 1.',
|
|
'TimeoutOverflowWarning');
|
|
}
|
|
after = 1; // schedule on next tick, follows browser behavior
|
|
}
|
|
|
|
this._called = false;
|
|
this._idleTimeout = after;
|
|
this._idlePrev = this;
|
|
this._idleNext = this;
|
|
this._idleStart = null;
|
|
// this must be set to null first to avoid function tracking
|
|
// on the hidden class, revisit in V8 versions after 6.2
|
|
this._onTimeout = null;
|
|
this._onTimeout = callback;
|
|
this._timerArgs = args;
|
|
this._repeat = isRepeat ? after : null;
|
|
this._destroyed = false;
|
|
|
|
this[async_id_symbol] = ++async_id_fields[kAsyncIdCounter];
|
|
this[trigger_async_id_symbol] = getDefaultTriggerAsyncId();
|
|
if (async_hook_fields[kInit] > 0) {
|
|
emitInit(this[async_id_symbol],
|
|
'Timeout',
|
|
this[trigger_async_id_symbol],
|
|
this);
|
|
}
|
|
}
|
|
|
|
var timers;
|
|
function getTimers() {
|
|
if (timers === undefined) {
|
|
timers = require('timers');
|
|
}
|
|
return timers;
|
|
}
|
|
|
|
function setUnrefTimeout(callback, after, arg1, arg2, arg3) {
|
|
// Type checking identical to setTimeout()
|
|
if (typeof callback !== 'function') {
|
|
throw new errors.TypeError('ERR_INVALID_CALLBACK');
|
|
}
|
|
|
|
let i, args;
|
|
switch (arguments.length) {
|
|
// fast cases
|
|
case 1:
|
|
case 2:
|
|
break;
|
|
case 3:
|
|
args = [arg1];
|
|
break;
|
|
case 4:
|
|
args = [arg1, arg2];
|
|
break;
|
|
default:
|
|
args = [arg1, arg2, arg3];
|
|
for (i = 5; i < arguments.length; i++) {
|
|
// extend array dynamically, makes .apply run much faster in v6.0.0
|
|
args[i - 2] = arguments[i];
|
|
}
|
|
break;
|
|
}
|
|
|
|
const timer = new Timeout(callback, after, args, false);
|
|
getTimers()._unrefActive(timer);
|
|
|
|
return timer;
|
|
}
|