Lines Matching defs:channel
236 function stdioStringToArray(stdio, channel) {
248 if (channel) ArrayPrototypePush(options, channel);
368 // Let child process know about opened IPC channel
530 #channel = null;
534 constructor(channel) {
536 this.#channel = channel;
546 this.#channel.ref();
552 this.#channel.unref();
559 this.#channel.ref();
564 this.#channel.unref();
568 return this.#channel ? this.#channel.fd : undefined;
573 'Use ChildProcess.channel instead.';
576 function setupChannel(target, channel, serializationMode) {
577 const control = new Control(channel);
578 target.channel = control;
579 target[kChannelHandle] = channel;
584 return target.channel;
587 target.channel = val;
605 initMessageChannel(channel);
606 channel.pendingHandle = null;
607 channel.onread = function(arrayBuffer) {
608 const recvHandle = channel.pendingHandle;
609 channel.pendingHandle = null;
617 for (const message of parseChannelMessages(channel, pool)) {
635 channel.onread = nop;
636 channel.close();
637 target.channel = null;
643 channel.sockets = { got: {}, send: {} };
679 if (!target.connected && target.channel && !target._handleQueue)
715 if (!target.channel || !target.listenerCount('message'))
718 const messages = target.channel[kPendingMessages];
726 target.channel[kPendingMessages] = [];
757 assert(this.connected || this.channel);
845 const err = writeChannelMessage(channel, req, message, handle);
882 return channel.writeQueueSize < (65536 * 2);
886 // requested, even though the channel might still be alive internally to
888 // - disconnect() never requested: channel is not null and connected
890 // - disconnect() requested, messages in the queue: channel is not null
892 // - disconnect() requested, channel actually disconnected: channel is
913 assert(this.channel);
915 // This marks the fact that the channel is actually disconnected.
916 this.channel = null;
927 channel.close();
932 if (channel.buffering) {
949 target.channel[kPendingMessages],
955 if (!target.channel)
963 channel.readStart();