diff --git a/lib/internal/child_process.js b/lib/internal/child_process.js index 40592146ada6de..1ce3dc776dfbe8 100644 --- a/lib/internal/child_process.js +++ b/lib/internal/child_process.js @@ -10,6 +10,7 @@ const { ObjectDefineProperty, ObjectSetPrototypeOf, ReflectApply, + SafeSet, StringPrototypeSlice, Symbol, Uint8Array, @@ -81,6 +82,7 @@ let HTTPParser; const MAX_HANDLE_RETRANSMISSIONS = 3; const kChannelHandle = Symbol('kChannelHandle'); const kIsUsedAsStdio = Symbol('kIsUsedAsStdio'); +const kPendingMessages = Symbol('pendingMessages'); // This object contain function to convert TCP objects to native handle objects // and back again. @@ -526,6 +528,7 @@ class Control extends EventEmitter { constructor(channel) { super(); this.#channel = channel; + this[kPendingMessages] = new SafeSet(); } // The methods keeping track of the counter are being used to track the @@ -699,6 +702,19 @@ function setupChannel(target, channel, serializationMode) { }); }); + target.on('newListener', function() { + if (!target.channel) return; + + const messages = target.channel[kPendingMessages]; + if (!messages.size) return; + + for (const messageParams of messages) { + process.nextTick(() => ReflectApply(target.emit, target, messageParams)); + } + + messages.clear(); + }); + target.send = function(message, handle, options, callback) { if (typeof handle === 'function') { callback = handle; @@ -912,7 +928,14 @@ function setupChannel(target, channel, serializationMode) { }; function emit(event, message, handle) { - target.emit(event, message, handle); + const isInternalMessage = 'internalMessage' === event; + const hasListenersInstalled = target.listenerCount('message'); + if (hasListenersInstalled || isInternalMessage) { + target.emit(event, message, handle); + return; + } + + target.channel[kPendingMessages].add([event, message, handle]); } function handleMessage(message, handle, internal) {