| /external/perfetto/ui/src/test/ |
| D | table_viewer.test.ts | 24 await page
39 await getTableCells(text).nth(0).click();
43 page = await browser.newPage();
48 await pth.openTraceFile('chrome_scroll_without_vsync.pftrace');
51 await pth.searchSlice(sliceName);
52 await page
55 await pth.clickMenuItem('Slices with the same name');
56 await clickTableHeader(/^id/);
57 await pth.clickMenuItem('Sort: lowest first');
58 await pth.waitForIdleAndScreenshot(`slices-with-same-name.png`);
[all …]
|
| D | aggregation.test.ts | 25 page = await browser.newPage();
27 await pth.openTraceFile('api34_startup_cold.perfetto-trace');
31 await page.mouse.move(600, 250);
32 await page.mouse.down();
33 await page.mouse.move(800, 350);
34 await page.mouse.up();
35 await pth.waitForPerfettoIdle();
36 await pth.waitForIdleAndScreenshot('cpu-by-thread.png');
38 await page.click('button[label="CPU by process"]');
39 await pth.waitForIdleAndScreenshot('cpu-by-process.png');
[all …]
|
| D | debug_tracks.test.ts | 27 page = await browser.newPage();
29 await pth.openTraceFile('api34_startup_cold.perfetto-trace');
34 await omnibox.focus();
35 await omnibox.selectText();
36 await omnibox.press(':');
37 await pth.waitForPerfettoIdle();
38 await omnibox.fill(SQL_QUERY);
39 await pth.waitForPerfettoIdle();
40 await omnibox.press('Enter');
41 await pth.waitForPerfettoIdle();
[all …]
|
| D | load_and_tracks.test.ts | 24 page = await browser.newPage();
26 await pth.openTraceFile('api34_startup_cold.perfetto-trace');
30 await pth.waitForIdleAndScreenshot('loaded.png');
34 await pth.navigate('#!/info');
35 await pth.waitForIdleAndScreenshot('into_and_stats.png');
36 await pth.navigate('#!/viewer');
37 await pth.waitForIdleAndScreenshot('back_to_timeline.png');
41 await pth.searchSlice('composite 572441');
42 await pth.resetFocus();
43 await page.keyboard.press('f');
[all …]
|
| D | queries.test.ts | 24 page = await browser.newPage();
26 await pth.openTraceFile('api34_startup_cold.perfetto-trace');
31 await omnibox.focus();
32 await omnibox.fill('foo');
33 await omnibox.selectText();
34 await omnibox.press(':');
35 await pth.waitForPerfettoIdle();
36 await omnibox.fill(
39 await pth.waitForPerfettoIdle();
40 await omnibox.press('Enter');
[all …]
|
| D | wattson.test.ts | 37 page = await browser.newPage();
39 await pth.openTraceFile('wattson_dsu_pmu.pb');
44 await wattsonGrp.scrollIntoViewIfNeeded();
45 await pth.toggleTrackGroup(wattsonGrp);
47 const coords = assertExists(await cpuEstimate.boundingBox());
48 await page.keyboard.press('Escape');
49 await page.mouse.move(600, coords.y + 10);
50 await page.mouse.down();
51 await page.mouse.move(1000, coords.y + 80);
52 await page.mouse.up();
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_locks.py | 33 await lock.acquire()
42 "object Lock can't be used in 'await' expression"
44 await lock
76 await asyncio.sleep(0.01)
80 r"object \w+ can't be used in 'await' expression"
82 with await lock:
90 self.assertTrue(await lock.acquire())
93 if await lock.acquire():
98 if await lock.acquire():
103 if await lock.acquire():
[all …]
|
| D | test_taskgroups.py | 36 await asyncio.sleep(0.1)
40 await asyncio.sleep(0.2)
53 await asyncio.sleep(0.1)
57 await asyncio.sleep(0.2)
62 await asyncio.sleep(0.15)
71 await asyncio.sleep(1)
75 await asyncio.sleep(0.2)
80 await asyncio.sleep(0.15)
97 await asyncio.sleep(0.1)
103 await asyncio.sleep(1)
[all …]
|
| D | test_queues.py | 31 await asyncio.sleep(0)
36 self.assertEqual(0, await getter)
45 await asyncio.sleep(0)
57 await self._test_repr_or_str(repr, True)
60 await self._test_repr_or_str(str, False)
70 await q.put(1)
72 self.assertEqual(1, await q.get())
80 await q.put(1)
86 await q.put(i)
88 items = [await q.get() for _ in range(3)]
[all …]
|
| D | test_waitfor.py | 33 await asyncio.sleep(tosleep)
47 await asyncio.sleep(0)
49 await asyncio.wait({waitfortask})
57 await asyncio.wait_for(t.run(), t.TASK_TIMEOUT / 2)
69 ret = await asyncio.wait_for(fut, 0)
82 await asyncio.wait_for(foo(), 0)
99 await asyncio.sleep(10)
105 await started
108 await asyncio.wait_for(fut, timeout)
122 await asyncio.sleep(support.LONG_TIMEOUT)
[all …]
|
| D | test_server.py | 40 await reader.readline()
44 await writer.wait_closed()
48 await srv.serve_forever()
91 await reader.readline()
95 await writer.wait_closed()
100 await srv.start_serving()
103 await srv.serve_forever()
130 await rd.read()
133 await wr.wait_closed()
135 srv = await asyncio.start_server(serve, socket_helper.HOSTv4, 0)
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | call_test.py | 46 address, self._server = await start_test_server()
51 await self._channel.close()
52 await self._server.stop(None)
62 await call
72 response = await call
76 self.assertEqual(await call.code(), grpc.StatusCode.OK)
80 response_retry = await call
90 await call
97 self.assertEqual(grpc.StatusCode.UNAVAILABLE, await call.code())
101 self.assertEqual(await call.code(), grpc.StatusCode.OK)
[all …]
|
| D | client_unary_unary_interceptor_test.py | 40 self._server_target, self._server = await start_test_server()
43 await self._server.stop(None)
62 call = await continuation(client_call_details, request)
76 response = await call
106 call = await continuation(client_call_details, request)
107 code = await call.code()
125 await multicallable(messages_pb2.SimpleRequest())
143 return await continuation(new_client_call_details, request)
159 await call
168 grpc.StatusCode.DEADLINE_EXCEEDED, await call.code()
[all …]
|
| D | client_stream_unary_interceptor_test.py | 42 return await continuation(client_call_details, request_iterator)
55 call = await continuation(client_call_details, self.request_iterator)
66 self._server_target, self._server = await start_test_server()
69 await self._server.stop(None)
96 response = await call
102 self.assertEqual(await call.code(), grpc.StatusCode.OK)
103 self.assertEqual(await call.initial_metadata(), aio.Metadata())
104 self.assertEqual(await call.trailing_metadata(), aio.Metadata())
105 self.assertEqual(await call.details(), "")
106 self.assertEqual(await call.debug_error_string(), "")
[all …]
|
| D | server_test.py | 115 await asyncio.get_event_loop().create_future()
118 await asyncio.sleep(test_constants.SHORT_TIMEOUT / 2)
127 await context.write(_RESPONSE)
132 await context.write(_RESPONSE)
144 assert _REQUEST == await context.read()
148 assert _REQUEST == await context.read()
168 assert _REQUEST == await context.read()
170 await context.write(_RESPONSE)
173 assert _REQUEST == await context.read()
182 await context.write(_RESPONSE)
[all …]
|
| D | done_callback_test.py | 40 address, self._server = await start_test_server()
45 await self._channel.close()
46 await self._server.stop(None)
50 self.assertEqual(grpc.StatusCode.OK, await call.code())
53 await validation
59 self.assertEqual(grpc.StatusCode.OK, await call.code())
61 await validation
82 self.assertEqual(grpc.StatusCode.OK, await call.code())
84 await validation
97 response = await call
[all …]
|
| D | timeout_test.py | 41 await asyncio.sleep(_SLEEP_TIME_UNIT_S)
47 await asyncio.sleep(_SLEEP_TIME_UNIT_S)
52 assert _REQUEST == await context.read()
53 await asyncio.sleep(_SLEEP_TIME_UNIT_S)
54 assert _REQUEST == await context.read()
59 assert _REQUEST == await context.read()
60 await asyncio.sleep(_SLEEP_TIME_UNIT_S)
61 await context.write(_RESPONSE)
89 await server.start()
95 address, self._server = await _start_test_server()
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests_aio/channelz/ |
| D | channelz_servicer_test.py | 85 await self.server.start()
93 resp = await channelz_stub.GetTopChannels(
100 resp = await channelz_stub.GetServers(
106 await self.channel.close()
107 await self.server.stop(None)
114 await pair.start()
116 await pair.bind_channelz(channelz_stub)
122 await pair.stop()
134 await self._server.start()
144 await self._channel.close()
[all …]
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | udp.rs | 16 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv()
17 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_recv()
19 sender.connect(receiver.local_addr()?).await?; in send_recv()
20 receiver.connect(sender.local_addr()?).await?; in send_recv()
22 sender.send(MSG).await?; in send_recv()
25 let len = receiver.recv(&mut recv_buf[..]).await?; in send_recv()
33 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll()
34 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll()
36 sender.connect(receiver.local_addr()?).await?; in send_recv_poll()
37 receiver.connect(sender.local_addr()?).await?; in send_recv_poll()
[all …]
|
| /external/rust/android-crates-io/crates/mls-rs/tests/ |
| D | client_tests.rs | 51 .await in generate_client()
69 .await in get_test_groups()
93 test(version, cs, 10, encrypt_controls).await; in test_on_all_params()
121 test_on_all_params_plaintext(test).await; in test_on_all_params()
141 test(version, cs, 10, false).await; in test_on_all_params_plaintext()
165 let alice = generate_client(cipher_suite, protocol_version, 0, encrypt_controls).await; in test_create()
166 let bob = generate_client(cipher_suite, protocol_version, 1, encrypt_controls).await; in test_create()
167 let bob_key_pkg = bob.generate_key_package_message().await.unwrap(); in test_create()
172 .await in test_create()
180 .await in test_create()
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_asyncgen.py | 78 return await __anext__(iterator)
89 await abc
106 await abc
181 await awaitable()
184 await awaitable()
186 await awaitable()
193 await awaitable()
195 await awaitable()
222 await awaitable()
224 await awaitable(throw=True)
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests_aio/health_check/ |
| D | health_servicer_test.py | 41 await queue.put(response)
47 await self._servicer.set(
50 await self._servicer.set(
53 await self._servicer.set(
61 await self._server.start()
67 await self._channel.close()
68 await self._server.stop(None)
72 resp = await self._stub.Check(request)
77 resp = await self._stub.Check(request)
82 resp = await self._stub.Check(request)
[all …]
|
| /external/rust/android-crates-io/crates/mls-rs/src/group/ |
| D | proposal_cache.rs | 144 let message_hash = MessageHash::compute(cs, message).await?; in insert_own()
211 let message_hash = MessageHash::compute(cs, message).await?; in get_own()
291 .await in apply_resolved()
311 .await? in apply_resolved()
316 .await? in apply_resolved()
323 .await?; in apply_resolved()
552 .await in receive()
586 get_test_group_context(123, cipher_suite_provider.cipher_suite()).await; in resolve_for_commit_default()
594 ConfirmationTag::empty(cipher_suite_provider).await, in resolve_for_commit_default()
612 .await in resolve_for_commit_default()
[all …]
|
| /external/python/bumble/tests/ |
| D | gatt_test.py | 125 x = await c.read_value(None)
127 await c.write_value(None, bytes([122]))
175 await client.power_on()
176 await server.power_on()
177 connection = await client.connect(server.random_address)
180 await peer.discover_services()
181 await peer.discover_characteristics()
187 v = await cp.read_value()
189 await cp.write_value(124)
190 await async_barrier()
[all …]
|
| /external/python/python-api-core/tests/asyncio/retry/ |
| D | test_retry_streaming_async.py | 39 await retry_target_stream(None, None, [], None).__anext__()
89 await asyncio.sleep(sleep_time)
112 generator = await decorated(num)
136 generator = await retry_(self._generator_mock)(error_on=3)
139 unpacked = [await generator.__anext__() for i in range(10)]
142 await generator.aclose()
181 generator = await decorated(error_on=1)
212 generator = await retry_(self._generator_mock)(sleep_time=0.2)
213 assert await generator.__anext__() == 0
217 await task
[all …]
|