| /tools/netsim/testing/tests/wifi/nsd/src/android/test/wifi/nsd/ |
| D | NsdHelper.java | 59 private void await(CountDownLatch latch) throws InterruptedException { in await() method in NsdHelper
60 assertTrue(latch.await(60, TimeUnit.SECONDS)); in await()
66 await(listener.serviceRegistered); in serviceTest()
83 await(listener.serviceUnregistered); in serviceTest()
136 await(listener.serviceFound); in discoverTest()
138 await(callback.serviceResolved); in discoverTest()
140 await(discoveryStopped); in discoverTest()
|
| /tools/test/connectivity/acts/framework/acts/controllers/amarisoft_lib/ |
| D | amarisoft_client.py | 60 await websocket.send(msg)
61 head = await websocket.recv()
62 body = await websocket.recv()
|
| /tools/tradefederation/core/javatests/com/android/tradefed/util/net/ |
| D | HttpHelperFuncTest.java | 50 barrier.await(threadStartTimeout, TimeUnit.MILLISECONDS); in testTimeout()
91 barrier.await(threadStartTimeout, TimeUnit.MILLISECONDS); in testNoTimeout()
148 mBarrier.await(2 * (mDelay + mTimeout), TimeUnit.MILLISECONDS); in run()
|
| /tools/netsim/rust/daemon/src/grpc_server/ |
| D | backend.rs | 86 let request = packet_request.try_next().await?.context("initial info")?; in stream_packets()
93 while let Some(request) = packet_request.try_next().await? { in stream_packets()
|
| /tools/test/graphicsbenchmark/functional_tests/java/src/com/android/game/qualification/tests/ |
| D | TestActivity.java | 50 boolean timeout = latch.await(timeoutMs, TimeUnit.MILLISECONDS); in waitUntilDestroyed()
|
| /tools/netsim/rust/daemon/src/transport/ |
| D | grpc.rs | 71 let _ = self.sink.send((response, WriteFlags::default())).await; in response()
|
| /tools/tradefederation/core/src/com/android/tradefed/command/ |
| D | ICommandScheduler.java | 238 public void await() throws InterruptedException; in await() method
|
| D | Console.java | 1132 mScheduler.await(); in run()
1144 mScheduler.await(); in run()
1225 mScheduler.await(); in awaitScheduler()
|
| D | CommandScheduler.java | 1366 public void await() throws InterruptedException { in await() method in CommandScheduler
1368 mRunLatch.await(); in await()
|
| /tools/tradefederation/core/src/com/android/tradefed/result/proto/ |
| D | StreamProtoReceiver.java | 232 if (!mEventReceiver.getCountDown().await(waitTime, TimeUnit.MILLISECONDS)) { in joinReceiver()
|
| /tools/tradefederation/core/javatests/com/android/tradefed/targetprep/ |
| D | RunCommandTargetPreparerTest.java | 244 if (!latch.await(LONG_WAIT_TIME_MS, TimeUnit.MILLISECONDS)) { in testBgCmd()
298 if (!latch.await(LONG_WAIT_TIME_MS, TimeUnit.MILLISECONDS)) { in testBgCmd_withTestUserToken_propertyNotSet()
|
| /tools/tradefederation/core/common_util/com/android/tradefed/util/ |
| D | ConditionPriorityBlockingQueue.java | 211 myCondition.await(); in blockingPoll()
|
| D | RunUtil.java | 1061 if (!mCountDown.await(PROCESS_DESTROY_TIMEOUT_SEC, TimeUnit.SECONDS)) { in cancel()
1064 mCountDown.await(); in cancel()
|
| /tools/netsim/rust/daemon/src/wireless/ |
| D | uwb.rs | 146 while let Some(packet) = uci_sink_receiver.next().await { in new()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | SubprocessTestResultsParser.java | 143 boolean await(long millis, boolean waitForConnection) throws InterruptedException { in await() method in SubprocessTestResultsParser.EventReceiverThread
221 if (!mEventReceiver.await(millis, waitForConnection)) { in joinReceiver()
|
| /tools/tradefederation/core/javatests/com/android/tradefed/invoker/ |
| D | InvocationExecutionTest.java | 329 latch.await(1L, TimeUnit.SECONDS)); in testRunPreInvocationSetup_parallel()
|
| /tools/tradefederation/core/src/com/android/tradefed/device/ |
| D | DeviceManager.java | 1412 return mFirstDeviceAdded.await(timeout, TimeUnit.MILLISECONDS); in waitForFirstDeviceAdded()
|