mirror of
https://github.com/nodejs/node.git
synced 2024-12-01 16:10:02 +01:00
d4c91f2814
This removes all internal calls to the deprecated `_extends()` function. It is slower than `Object.assign()` and the object spread notation since V8 6.8 and using the spread notation often also results in shorter code. PR-URL: https://github.com/nodejs/node/pull/25105 Reviewed-By: Michaël Zasso <targos@protonmail.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
46 lines
974 B
JavaScript
46 lines
974 B
JavaScript
'use strict';
|
|
|
|
module.exports = {
|
|
sendHelper,
|
|
internal
|
|
};
|
|
|
|
const callbacks = new Map();
|
|
var seq = 0;
|
|
|
|
function sendHelper(proc, message, handle, cb) {
|
|
if (!proc.connected)
|
|
return false;
|
|
|
|
// Mark message as internal. See INTERNAL_PREFIX in lib/child_process.js
|
|
message = { cmd: 'NODE_CLUSTER', ...message, seq };
|
|
|
|
if (typeof cb === 'function')
|
|
callbacks.set(seq, cb);
|
|
|
|
seq += 1;
|
|
return proc.send(message, handle);
|
|
}
|
|
|
|
// Returns an internalMessage listener that hands off normal messages
|
|
// to the callback but intercepts and redirects ACK messages.
|
|
function internal(worker, cb) {
|
|
return function onInternalMessage(message, handle) {
|
|
if (message.cmd !== 'NODE_CLUSTER')
|
|
return;
|
|
|
|
var fn = cb;
|
|
|
|
if (message.ack !== undefined) {
|
|
const callback = callbacks.get(message.ack);
|
|
|
|
if (callback !== undefined) {
|
|
fn = callback;
|
|
callbacks.delete(message.ack);
|
|
}
|
|
}
|
|
|
|
fn.apply(worker, arguments);
|
|
};
|
|
}
|