Home
last modified time | relevance | path

Searched refs:port1 (Results 1 - 25 of 28) sorted by relevance

12

/third_party/node/test/parallel/
H A Dtest-worker-message-port.js8 const { port1, port2 } = new MessageChannel();
9 assert(port1 instanceof MessagePort);
13 port1.postMessage(input);
32 const { port1, port2 } = new MessageChannel();
34 port1.onmessage = common.mustCall((message) => {
36 assert.strictEqual(message.target, port1);
41 port1.postMessage(2);
49 const { port1, port2 } = new MessageChannel();
52 port1.postMessage(input);
64 const { port1, port
[all...]
H A Dtest-worker-message-port-close.js13 const { port1, port2 } = new MessageChannel();
14 port1.close(common.mustCall(() => {
15 port1.on('message', dummy);
16 port1.off('message', dummy);
20 port1.on('message', dummy);
21 port1.off('message', dummy);
27 const { port1 } = new MessageChannel();
28 port1.on('message', dummy);
29 port1.close(common.mustCall(() => {
30 port1
[all...]
H A Dtest-whatwg-webstreams-transfer.js45 const { port1, port2 } = new MessageChannel();
46 port1.onmessageerror = common.mustNotCall();
50 // port1 first, then again to port2, which reads the data.
60 // 3. ReadableStream R2 is passed to the port1.onmessage callback as the
62 // 4. Within port1.onmessage, we transfer ReadableStream R2 to port1, which
100 port1.onmessage = common.mustCall(({ data }) => {
103 port1.postMessage(data, [data]);
116 const { port1, port2 } = new MessageChannel();
117 port1
[all...]
H A Dtest-worker-workerdata-messageport.js11 const workerData = { mesage: channel.port1 };
12 const transferList = [channel.port1];
24 const workerData = { message: channel1.port1, message2: channel2.port1 };
25 const transferList = [channel1.port1, channel2.port1];
51 const workerData = { message: channel1.port1, message2: channel2.port1 };
H A Dtest-worker-message-port-transfer-closed.js10 const { port1, port2 } = new MessageChannel();
13 port1.onmessage = common.mustNotCall();
39 testSingle(port1, port2);
40 testSingle(port2, port1);
47 port1.close(common.mustCall(testBothClosed));
48 testSingle(port1, port2);
H A Dtest-worker-message-port-receive-message.js6 const { port1, port2 } = new MessageChannel();
14 port1.postMessage(message1);
15 port1.postMessage(message2);
23 port1.postMessage(message1);
25 port1.close();
H A Dtest-https-strict.js165 const port1 = server1.address().port;
170 makeReq('/inv1', port1, 'UNABLE_TO_VERIFY_LEAF_SIGNATURE');
171 makeReq('/inv1-ca1', port1, 'ERR_TLS_CERT_ALTNAME_INVALID',
173 makeReq('/inv1-ca1ca2', port1, 'ERR_TLS_CERT_ALTNAME_INVALID',
175 makeReq('/val1-ca1', port1, null, 'agent1', ca1);
176 makeReq('/val1-ca1ca2', port1, null, 'agent1', [ca1, ca2]);
177 makeReq('/inv1-ca2', port1,
H A Dtest-crypto-key-objects-messageport.js49 const { port1, port2 } = new MessageChannel();
51 port1.postMessage({ key });
71 const { port1, port2 } = new MessageChannel();
84 port1.postMessage({ key });
85 port1.close();
H A Dtest-abortsignal-cloneable.js26 mc.port1.onmessage = common.mustCall(({ data }) => {
66 mc.port1.onmessage = common.mustCall(({ data }) => {
70 mc.port1.close();
80 mc.port1.onmessage = common.mustCall();
H A Dtest-worker-message-port-transfer-fake-js-transferable.js29 const { port1, port2 } = new MessageChannel();
30 port1.postMessage(fh, [ fh ]);
H A Dtest-blob.js162 mc.port1.onmessage = common.mustCall(({ data }) => {
166 mc.port1.close();
H A Dtest-crypto-x509.js249 mc.port1.onmessage = common.mustCall(({ data }) => {
252 mc.port1.close();
H A Dtest-whatwg-encoding-custom-textdecoder.js230 new MessageChannel().port1.postMessage(buffer, [buffer]); // buffer is detached
/third_party/node/test/fixtures/wpt/streams/transferable/
H A Dtransfer-with-messageport.window.js60 { port1: channel.port1, stream, port2: channel.port2 },
61 [channel.port1, stream, channel.port2],
70 [channel.port1, stream, channel.port2],
78 { port2: channel.port2, port1: channel.port1, stream },
79 [channel.port1, stream, channel.port2],
87 { port2: channel.port2, port1: channel.port1 },
88 [channel.port1, strea
[all...]
/third_party/node/benchmark/worker/
H A Dmessageport.js26 const { port1, port2 } = new MessageChannel();
32 port1.close();
53 port1.postMessage(payload);
/third_party/node/lib/internal/
H A Dabort_controller.js273 const { port1, port2 } = this[kCloneData];
277 port1.postMessage(this.reason);
278 port1.close();
289 const { port1, port2 } = lazyMessageChannel();
290 port1.unref();
293 port1,
H A Dstructured_clone.js21 channel.port1.unref();
23 channel.port1.postMessage(value, options?.transfer);
H A Dworker.js247 const { port1, port2 } = new MessageChannel();
254 this[kPublicPort] = port1;
/third_party/node/test/sequential/
H A Dtest-dgram-bind-shared-ports.js104 const port1 = socket1.address().port;
105 assert.strictEqual(typeof port1, 'number');
H A Dtest-worker-eventlooputil.js58 worker.postMessage({ metricsCh: metricsCh.port1 }, [ metricsCh.port1 ]);
/third_party/node/lib/internal/modules/esm/
H A Dhooks.js214 port1: insidePreload,
642 response = receiveMessageOnPort(asyncCommChannel.port1);
652 asyncCommChannel.port1.close();
/third_party/node/test/fixtures/wpt/FileAPI/blob/
H A DBlob-constructor.any.js325 channel.port1.postMessage('', [channel2.port1]);
/third_party/node/src/
H A Dnode_messaging.cc1450 MessagePort* port1 = MessagePort::New(env, context); in MessageChannel() local
1451 if (port1 == nullptr) return; in MessageChannel()
1454 port1->Close(); in MessageChannel()
1458 MessagePort::Entangle(port1, port2); in MessageChannel()
1460 args.This()->Set(context, env->port1_string(), port1->object()) in MessageChannel()
/third_party/nghttp2/src/
H A Dutil.cc716 uint16_t port1, port2; in porteq() local
717 port1 = in porteq()
721 return port1 == port2; in porteq()
/third_party/ffmpeg/libavformat/
H A Dhttp.c462 int port1, port2; in ff_http_do_new_request2() local
470 hostname1, sizeof(hostname1), &port1, in ff_http_do_new_request2()
475 if (port1 != port2 || strncmp(hostname1, hostname2, sizeof(hostname2)) != 0) { in ff_http_do_new_request2()
477 hostname1, port1, in ff_http_do_new_request2()

Completed in 14 milliseconds

12