Lines Matching defs:target
166 postSend(message, handle, options, callback, target) {
171 if (target) {
175 assert(!target._pendingMessage);
176 target._pendingMessage =
342 function closePendingHandle(target) {
343 target._pendingMessage.handle.close();
344 target._pendingMessage = null;
576 function setupChannel(target, channel, serializationMode) {
578 target.channel = control;
579 target[kChannelHandle] = channel;
581 ObjectDefineProperty(target, '_channel', {
584 return target.channel;
587 target.channel = val;
593 target._handleQueue = null;
594 target._pendingMessage = null;
634 target.disconnect();
637 target.channel = null;
638 maybeClose(target);
646 target.on('internalMessage', function(message, handle) {
651 if (target._pendingMessage) {
653 closePendingHandle(target);
654 } else if (target._pendingMessage.retransmissions++ ===
656 closePendingHandle(target);
662 assert(ArrayIsArray(target._handleQueue));
663 const queue = target._handleQueue;
664 target._handleQueue = null;
666 if (target._pendingMessage) {
667 target._send(target._pendingMessage.message,
668 target._pendingMessage.handle,
669 target._pendingMessage.options,
670 target._pendingMessage.callback);
675 target._send(args.message, args.handle, args.options, args.callback);
679 if (!target.connected && target.channel && !target._handleQueue)
680 target._disconnect();
691 return target._send({ cmd: 'NODE_HANDLE_NACK' }, null, true);
697 target._send({ cmd: 'NODE_HANDLE_ACK' }, null, true);
712 target.on('newListener', function() {
715 if (!target.channel || !target.listenerCount('message'))
718 const messages = target.channel[kPendingMessages];
723 ReflectApply(target.emit, target, messages[i]);
726 target.channel[kPendingMessages] = [];
730 target.send = function(message, handle, options, callback) {
756 target._send = function(message, handle, options, callback) {
819 target, [message, handle, options]);
853 obj.postSend(message, handle, options, callback, target);
894 target.connected = true;
896 target.disconnect = function() {
912 target._disconnect = function() {
928 target.emit('disconnect');
943 if ('internalMessage' === event || target.listenerCount('message')) {
944 target.emit(event, message, handle);
949 target.channel[kPendingMessages],
955 if (!target.channel)