Lines Matching defs:const
3 const {
19 const {
33 const {
39 const EventEmitter = require('events');
40 const net = require('net');
41 const dgram = require('dgram');
42 const inspect = require('internal/util/inspect').inspect;
43 const assert = require('internal/assert');
45 const { Process } = internalBinding('process_wrap');
46 const {
53 const { Pipe, constants: PipeConstants } = internalBinding('pipe_wrap');
54 const { TCP } = internalBinding('tcp_wrap');
55 const { TTY } = internalBinding('tty_wrap');
56 const { UDP } = internalBinding('udp_wrap');
57 const SocketList = require('internal/socket_list');
58 const { owner_symbol } = require('internal/async_hooks').symbols;
59 const { convertToValidSignal, deprecate } = require('internal/util');
60 const { isArrayBufferView } = require('internal/util/types');
61 const spawn_sync = internalBinding('spawn_sync');
62 const { kStateSymbol } = require('internal/dgram');
64 const {
75 const { SocketListSend, SocketListReceive } = SocketList;
82 const MAX_HANDLE_RETRANSMISSIONS = 3;
83 const kChannelHandle = Symbol('kChannelHandle');
84 const kIsUsedAsStdio = Symbol('kIsUsedAsStdio');
85 const kPendingMessages = Symbol('kPendingMessages');
89 const handleConversion = {
110 const server = new net.Server();
127 const firstTime = !this[kChannelHandle].sockets.send[message.key];
128 const socketList = getSocketList('send', this, message.key);
140 const handle = socket._handle;
185 const socket = new net.Socket({
195 const socketList = getSocketList('got', this, message.key);
227 const socket = new dgram.Socket(message.dgramType);
237 const options = [];
283 const syscall = this.spawnfile ? 'spawn ' + this.spawnfile : 'spawn';
284 const err = errnoException(exitCode, syscall);
311 const stdio = subprocess.stdio;
316 const stream = stdio[i];
358 const ipc = stdio.ipc;
359 const ipcFd = stdio.ipcFd;
365 const serialization = options.serialization || 'json';
389 const err = this._handle.spawn(options);
406 const stream = stdio[i];
422 const stream = stdio[i];
488 const signal = sig === 0 ? sig :
492 const err = this._handle.kill(signal);
572 const channelDeprecationMsg = '_channel is deprecated. ' +
577 const control = new Control(channel);
598 const {
608 const recvHandle = channel.pendingHandle;
611 const nread = streamBaseState[kReadBytesOrError];
612 const offset = streamBaseState[kArrayBufferOffset];
613 const pool = new Uint8Array(arrayBuffer, offset, nread);
617 for (const message of parseChannelMessages(channel, pool)) {
663 const queue = target._handleQueue;
674 const args = queue[i];
699 const obj = handleConversion[message.type];
718 const messages = target.channel[kPendingMessages];
719 const { length } = messages;
747 const ex = new ERR_IPC_CHANNEL_CLOSED();
843 const req = new WriteWrap();
845 const err = writeChannelMessage(channel, req, message, handle);
846 const wasAsyncWrite = streamBaseState[kLastWriteWasAsync];
872 const ex = errnoException(err, 'write');
958 const eventName = (internal ? 'internalMessage' : 'message');
967 const INTERNAL_PREFIX = 'NODE_';
977 const nop = FunctionPrototype;
1015 const a = {
1055 const handle = getHandleWrapType(stdio) ?
1084 const sockets = worker[kChannelHandle].sockets[type];
1087 const Construct = type === 'send' ? SocketListSend : SocketListReceive;
1103 const result = spawn_sync.spawn(options);