Home
last modified time | relevance | path

Searched refs:port1 (Results 1 – 25 of 69) sorted by relevance

123

/third_party/node/test/parallel/
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);
40 port1.postMessage(2);
48 const { port1, port2 } = new MessageChannel();
51 port1.postMessage(input);
63 const { port1, port2 } = new MessageChannel();
[all …]
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.off('message', dummy);
[all …]
Dtest-worker-message-port-transfer-filehandle.js12 const { port1, port2 } = new MessageChannel();
15 port1.postMessage(fh);
23 port1.postMessage(fh, [ fh ]);
39 const { port1 } = new MessageChannel();
42 port1.postMessage(fh, [ fh ]);
50 const { port1, port2 } = new MessageChannel();
56 port1.close();
67 port1.postMessage(fh, [ fh ]);
70 port1.postMessage('second message');
77 const { port1 } = new MessageChannel();
[all …]
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 };
Dtest-worker-message-port-transfer-duplicate.js10 const { port1, port2 } = new MessageChannel();
13 const port3 = new MessageChannel().port1;
15 port1.postMessage(port3, [port3, port3]);
17 port1.close();
21 const { port1, port2 } = new MessageChannel();
26 port1.postMessage(buf, [buf.buffer, buf.buffer]);
28 port1.close();
Dtest-worker-message-transfer-port-mark-as-untransferable.js12 const { port1, port2 } = new MessageChannel();
13 port1.postMessage(ab, [ ab ]);
23 markAsUntransferable(channel2.port1);
26 channel1.port1.postMessage(channel2.port1, [ channel2.port1 ]);
29 channel2.port1.postMessage('still works, not closed/transferred');
Dtest-eventtarget-memoryleakwarning.js56 setMaxListeners(2, mc.port1);
57 mc.port1.addEventListener('foo', () => {});
58 mc.port1.addEventListener('foo', () => {});
59 mc.port1.addEventListener('foo', () => {});
66 mc.port1.addEventListener('foo', () => {});
67 mc.port1.addEventListener('foo', () => {});
68 mc.port1.addEventListener('foo', () => {});
Dtest-worker-message-port-transfer-self.js9 const { port1, port2 } = new MessageChannel();
12 port1.postMessage(null, [port1]);
30 const inspectedPort1 = util.inspect(port1);
35 port1.close();
38 const inspectedPort1 = util.inspect(port1);
44 port1.postMessage(2);
Dtest-worker-message-port-transfer-native.js12 const { port1, port2 } = new MessageChannel();
16 port1.postMessage(function foo() {});
21 port1.close();
25 const { port1, port2 } = new MessageChannel();
31 port1.postMessage(nativeObject);
36 port1.close();
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);
Dtest-net-listen-exclusive-random-ports.js11 worker1.on('message', function(port1) { argument
12 assert.strictEqual(port1, port1 | 0,
13 `first worker could not listen on port ${port1}`);
19 assert.notStrictEqual(port1, port2, 'ports should not be equal');
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();
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,
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();
Dtest-worker-message-channel.js9 channel.port1.on('message', common.mustCall(({ typedArray }) => {
22 channel.port1.on('close', common.mustCall());
39 assert(channel.port1 instanceof MessagePort);
41 channel.port1.on('message', common.mustCall((message) => {
Dtest-worker-message-port-close-while-receiving.js9 const { port1, port2 } = new MessageChannel();
11 port1.on('message', common.mustCall(() => {
12 port1.close();
Dtest-worker-message-port-infinite-message-loop.js12 const { port1, port2 } = new MessageChannel();
14 port1.on('message', () => {
17 port1.close();
Dtest-perf-hooks-histogram.js41 mc.port1.onmessage = common.mustCall(({ data }) => {
53 mc.port1.close();
62 mc.port1.onmessage = common.mustCall(({ data }) => {
67 mc.port1.close();
Dtest-worker-message-port-constructor.js9 const { port1 } = new MessageChannel();
11 assert(port1 instanceof MessagePort);
12 assert.strictEqual(port1.constructor, MessagePort);
Dtest-worker-message-port-message-before-close.js29 const { port1, port2 } = new MessageChannel();
31 assert.deepStrictEqual(await once(port1, 'message'), ['firstMessage']);
32 assert.deepStrictEqual(await once(port1, 'message'), ['lastMessage']);
Dtest-worker-message-port-jstransferable-nested-untransferable.js18 this.inner = c.port1;
34 const { port1 } = new MessageChannel();
37 port1.postMessage(ot, [ot]);
Dtest-worker-message-port-multiple-sharedarraybuffers.js13 const { port1, port2 } = new MessageChannel();
14 port1.once('message', common.mustCall((message) => {
/third_party/node/benchmark/worker/
Dmessageport.js26 const { port1, port2 } = new MessageChannel();
32 port1.close();
53 port1.postMessage(payload);
/third_party/node/test/known_issues/
Dtest-dgram-bind-shared-ports-after-port-0.js27 if (typeof msg.port1 !== 'number') process.exit(0);
29 const worker2 = cluster.fork({ PRT1: msg.port1 });
54 () => process.send({ message: 'success', port1: socket1.address().port }) property
/third_party/node/test/node-api/test_worker_buffer_callback/
Dtest.js10 const { port1 } = new MessageChannel();
12 port1.postMessage(buffer, [buffer]);

123