| /third_party/node/typings/internalBinding/ |
| D | messaging.d.ts | 3 port1: MessagePort;
4 port2: MessagePort;
7 class MessagePort { class
23 MessagePort: typeof InternalMessagingBinding.MessagePort;
25 stopMessagePort(port: typeof InternalMessagingBinding.MessagePort): void;
27 drainMessagePort(port: typeof InternalMessagingBinding.MessagePort): void;
28 receiveMessageOnPort(port: typeof InternalMessagingBinding.MessagePort): any;
29 …xt(port: typeof InternalMessagingBinding.MessagePort, context: any): typeof InternalMessagingBindi…
31 broadcastChannel(name: string): typeof InternalMessagingBinding.MessagePort;
|
| D | worker.d.ts | 23 getEnvMessagePort(): InternalMessagingBinding.MessagePort;
|
| /third_party/node/src/ |
| D | node_messaging.cc | 506 static_cast<MessagePort*>(host_object.get())->IsDetached())) { in Serialize()
569 MessagePortData::MessagePortData(MessagePort* owner) in MessagePortData()
605 MessagePort::~MessagePort() { in ~MessagePort()
609 MessagePort::MessagePort(Environment* env, in MessagePort() function in node::worker::MessagePort
619 MessagePort* channel = ContainerOf(&MessagePort::async_, handle); in MessagePort()
649 bool MessagePort::IsDetached() const { in IsDetached()
653 void MessagePort::TriggerAsync() { in TriggerAsync()
658 void MessagePort::Close(v8::Local<v8::Value> close_callback) { in Close()
671 void MessagePort::New(const FunctionCallbackInfo<Value>& args) { in New()
679 MessagePort* MessagePort::New( in New()
[all …]
|
| D | node_messaging.h | 18 class MessagePort; variable
118 friend class MessagePort; variable
170 explicit MessagePortData(MessagePort* owner);
212 MessagePort* owner_ = nullptr;
214 friend class MessagePort; variable
221 class MessagePort : public HandleWrap {
227 MessagePort(Environment* env,
232 ~MessagePort() override;
236 static MessagePort* New(Environment* env,
269 static void Entangle(MessagePort* a, MessagePort* b);
[all …]
|
| D | node_worker.cc | 68 MessagePort* parent_port = MessagePort::New(env, env->context()); in Worker()
75 MessagePort::Entangle(parent_port, child_port_data_.get()); in Worker()
388 MessagePort* child_port = MessagePort::New(env, in CreateEnvMessagePort()
|
| /third_party/node/lib/internal/worker/ |
| D | io.js | 33 MessagePort,
99 const messagePortPrototypePropertyDescriptors = ObjectGetOwnPropertyDescriptors(MessagePort.prototy…
108 ObjectGetPrototypeOf(MessagePort.prototype),
111 ObjectSetPrototypeOf(MessagePort, NodeEventTarget);
112 ObjectSetPrototypeOf(MessagePort.prototype, NodeEventTarget.prototype);
115 MessagePort.prototype.ref = MessagePortPrototype.ref; class
116 MessagePort.prototype.unref = MessagePortPrototype.unref;
117 MessagePort.prototype.hasRef = function() {
212 MessagePort.prototype,
236 defineEventHandler(MessagePort.prototype, 'message');
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-worker-message-port-constructor.js | 5 const { MessageChannel, MessagePort } = require('worker_threads');
11 assert(port1 instanceof MessagePort);
12 assert.strictEqual(port1.constructor, MessagePort);
14 assert.throws(() => MessagePort(), {
19 assert.throws(() => new MessagePort(), {
|
| D | test-worker-message-port-move.js | 7 MessagePort, MessageChannel, moveMessagePortToContext
17 MessagePort, property
35 assert(!(port instanceof MessagePort));
42 assert(!(data.p instanceof MessagePort));
|
| D | test-worker-message-channel.js | 4 const { MessageChannel, MessagePort, Worker } = require('worker_threads');
39 assert(channel.port1 instanceof MessagePort);
40 assert(channel.port2 instanceof MessagePort);
|
| D | test-worker-message-port.js | 5 const { MessageChannel, MessagePort } = require('worker_threads');
9 assert(port1 instanceof MessagePort);
10 assert(port2 instanceof MessagePort);
172 assert.strictEqual(ev.ports[0].constructor, MessagePort);
180 Object.getOwnPropertyNames(MessagePort.prototype).sort(),
|
| /third_party/node/deps/undici/src/types/ |
| D | websocket.d.ts | 4 import type { MessagePort } from 'worker_threads'
100 ports?: (typeof MessagePort)[]
101 source?: typeof MessagePort | null
108 readonly ports: ReadonlyArray<typeof MessagePort>
109 readonly source: typeof MessagePort | null
117 source?: typeof MessagePort | null,
118 ports?: (typeof MessagePort)[]
|
| /third_party/node/deps/undici/src/lib/websocket/ |
| D | events.js | 5 const { MessagePort } = require('worker_threads')
195 webidl.converters.MessagePort = webidl.interfaceConverter(MessagePort)
198 webidl.converters.MessagePort
240 converter: webidl.nullableConverter(webidl.converters.MessagePort),
|
| /third_party/node/lib/ |
| D | worker_threads.js | 14 MessagePort,
27 MessagePort, property
|
| /third_party/node/doc/api/ |
| D | worker_threads.md | 169 * `port` {MessagePort} The message port to transfer.
174 * Returns: {MessagePort}
176 Transfer a `MessagePort` to a different [`vm`][] Context. The original `port`
177 object is rendered unusable, and the returned `MessagePort` instance
180 The returned `MessagePort` is an object in the target context and
185 However, the created `MessagePort` no longer inherits from
195 * {null|MessagePort}
197 If this thread is a [`Worker`][], this is a [`MessagePort`][]
231 * `port` {MessagePort|BroadcastChannel}
235 Receive a single message from a given `MessagePort`. If no message is available,
[all …]
|
| D | globals.md | 530 ## `MessagePort`
538 The `MessagePort` class. See [`MessagePort`][] for more details.
901 [`MessagePort`]: worker_threads.md#class-messageport
|
| /third_party/node/test/sequential/ |
| D | test-worker-eventlooputil.js | 9 MessagePort,
21 assert.ok(msg.metricsCh instanceof MessagePort);
|
| /third_party/node/lib/internal/bootstrap/ |
| D | browser.js | 55 MessagePort,
59 exposeInterface(globalThis, 'MessagePort', MessagePort);
|
| /third_party/node/test/fixtures/wpt/streams/transferable/ |
| D | transfer-with-messageport.window.js | 17 const messagePortCount = transfer.filter(i => i instanceof MessagePort)
27 port instanceof MessagePort,
|
| /third_party/typescript/lib/ |
| D | lib.webworker.d.ts | 196 ports?: MessagePort[];
197 source?: Client | ServiceWorker | MessagePort | null;
378 ports?: MessagePort[];
1637 readonly ports: ReadonlyArray<MessagePort>;
1638 readonly source: Client | ServiceWorker | MessagePort | null;
2359 readonly port1: MessagePort;
2361 readonly port2: MessagePort;
2378 readonly ports: ReadonlyArray<MessagePort>;
2382 …n?: string, lastEventId?: string, source?: MessageEventSource | null, ports?: MessagePort[]): void;
2396 interface MessagePort extends EventTarget { interface
[all …]
|
| D | lib.webworker.iterable.d.ts | 84 …ng, lastEventId?: string, source?: MessageEventSource | null, ports?: Iterable<MessagePort>): void;
|
| D | lib.dom.iterable.d.ts | 153 …ng, lastEventId?: string, source?: MessageEventSource | null, ports?: Iterable<MessagePort>): void;
|
| /third_party/typescript/src/lib/ |
| D | webworker.generated.d.ts | 176 ports?: MessagePort[];
177 source?: Client | ServiceWorker | MessagePort | null;
358 ports?: MessagePort[];
1617 readonly ports: ReadonlyArray<MessagePort>;
1618 readonly source: Client | ServiceWorker | MessagePort | null;
2339 readonly port1: MessagePort;
2341 readonly port2: MessagePort;
2358 readonly ports: ReadonlyArray<MessagePort>;
2362 …n?: string, lastEventId?: string, source?: MessageEventSource | null, ports?: MessagePort[]): void;
2376 interface MessagePort extends EventTarget { interface
[all …]
|
| D | webworker.iterable.generated.d.ts | 64 …ng, lastEventId?: string, source?: MessageEventSource | null, ports?: Iterable<MessagePort>): void;
|
| D | dom.iterable.generated.d.ts | 133 …ng, lastEventId?: string, source?: MessageEventSource | null, ports?: Iterable<MessagePort>): void;
|
| /third_party/node/test/fixtures/wpt/interfaces/ |
| D | html.idl | 2095 readonly attribute FrozenArray<MessagePort> ports;
2097 …entId = "", optional MessageEventSource? source = null, optional sequence<MessagePort> ports = []);
2105 sequence<MessagePort> ports = [];
2108 typedef (WindowProxy or MessagePort or ServiceWorker) MessageEventSource;
2185 readonly attribute MessagePort port1;
2186 readonly attribute MessagePort port2;
2190 interface MessagePort : EventTarget {
2283 readonly attribute MessagePort port;
|