| /external/exoplayer/tree/testutils/src/main/java/com/google/android/exoplayer2/testutil/ |
| D | TestDownloadManagerListener.java | 43 private final int timeoutMs; field in TestDownloadManagerListener
54 DownloadManager downloadManager, DummyMainThread dummyMainThread, int timeoutMs) { in TestDownloadManagerListener() argument
57 this.timeoutMs = timeoutMs; in TestDownloadManagerListener()
64 public Integer pollStateChange(String taskId, long timeoutMs) throws InterruptedException { in pollStateChange() argument
65 return getStateQueue(taskId).poll(timeoutMs, TimeUnit.MILLISECONDS); in pollStateChange()
122 assertThat(downloadFinishedCondition.await(timeoutMs, TimeUnit.MILLISECONDS)).isTrue(); in blockUntilTasksComplete()
136 public void assertRemoved(String taskId, int timeoutMs) { in assertRemoved() argument
137 assertStateInternal(taskId, STATE_REMOVED, timeoutMs); in assertRemoved()
140 public void assertState(String taskId, @State int expectedState, int timeoutMs) { in assertState() argument
141 assertStateInternal(taskId, expectedState, timeoutMs); in assertState()
[all …]
|
| D | HostActivity.java | 66 boolean blockUntilStopped(long timeoutMs); in blockUntilStopped() argument
105 public void runTest(HostedTest hostedTest, long timeoutMs) { in runTest() argument
106 runTest(hostedTest, timeoutMs, /* failOnTimeoutOrForceStop= */ true); in runTest()
118 final HostedTest hostedTest, long timeoutMs, boolean failOnTimeoutOrForceStop) { in runTest() argument
119 Assertions.checkArgument(timeoutMs > 0); in runTest()
142 if (hostedTest.blockUntilStopped(timeoutMs)) { in runTest()
157 String message = "Test timed out after " + timeoutMs + " ms."; in runTest()
|
| D | DummyMainThread.java | 65 public void runOnMainThread(int timeoutMs, final Runnable runnable) { in runOnMainThread() argument
66 runTestOnMainThread(timeoutMs, runnable::run); in runOnMainThread()
86 public void runTestOnMainThread(int timeoutMs, final TestRunnable runnable) { in runTestOnMainThread() argument
106 assertThat(finishedLatch.await(timeoutMs, TimeUnit.MILLISECONDS)).isTrue(); in runTestOnMainThread()
|
| D | ExoPlayerTestRunner.java | 473 public ExoPlayerTestRunner blockUntilEnded(long timeoutMs) throws Exception { in blockUntilEnded() argument
474 if (!endedCountDownLatch.await(timeoutMs, TimeUnit.MILLISECONDS)) { in blockUntilEnded()
494 public ExoPlayerTestRunner blockUntilActionScheduleFinished(long timeoutMs) in blockUntilActionScheduleFinished() argument
496 if (!actionScheduleFinishedCountDownLatch.await(timeoutMs, TimeUnit.MILLISECONDS)) { in blockUntilActionScheduleFinished()
|
| D | ExoHostedTest.java | 153 public final boolean blockUntilStopped(long timeoutMs) { in blockUntilStopped() argument
154 return testFinished.block(timeoutMs); in blockUntilStopped()
|
| /external/webrtc/rtc_base/java/src/org/webrtc/ |
| D | ThreadUtils.java | 82 public static boolean joinUninterruptibly(final Thread thread, long timeoutMs) { in joinUninterruptibly() argument
84 long timeRemainingMs = timeoutMs; in joinUninterruptibly()
95 timeRemainingMs = timeoutMs - elapsedTimeMs; in joinUninterruptibly()
123 public static boolean awaitUninterruptibly(CountDownLatch barrier, long timeoutMs) { in awaitUninterruptibly() argument
125 long timeRemainingMs = timeoutMs; in awaitUninterruptibly()
137 timeRemainingMs = timeoutMs - elapsedTimeMs; in awaitUninterruptibly()
|
| /external/perfetto/ui/src/base/ |
| D | http_utils.ts | 16 input: RequestInfo, init: RequestInit, timeoutMs: number) {
20 new Error(`fetch(${input}) timed out after ${timeoutMs} ms`)),
21 timeoutMs);
|
| /external/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ |
| D | PeerConnectionClientTest.java | 128 public boolean waitForFramesRendered(int timeoutMs) throws InterruptedException { in waitForFramesRendered() argument
129 doneRendering.await(timeoutMs, TimeUnit.MILLISECONDS); in waitForFramesRendered()
214 private boolean waitForLocalSDP(int timeoutMs) throws InterruptedException { in waitForLocalSDP() argument
216 final long endTimeMs = System.currentTimeMillis() + timeoutMs; in waitForLocalSDP()
228 private boolean waitForIceCandidates(int timeoutMs) throws InterruptedException { in waitForIceCandidates() argument
230 final long endTimeMs = System.currentTimeMillis() + timeoutMs; in waitForIceCandidates()
236 iceCandidateEvent.wait(timeoutMs); in waitForIceCandidates()
242 private boolean waitForIceConnected(int timeoutMs) throws InterruptedException { in waitForIceConnected() argument
244 final long endTimeMs = System.currentTimeMillis() + timeoutMs; in waitForIceConnected()
251 iceConnectedEvent.wait(timeoutMs); in waitForIceConnected()
[all …]
|
| /external/volley/src/main/java/com/android/volley/toolbox/ |
| D | RequestFuture.java | 100 private synchronized T doGet(Long timeoutMs) in doGet() argument
110 if (timeoutMs == null) { in doGet()
114 } else if (timeoutMs > 0) { in doGet()
116 long deadlineMs = nowMs + timeoutMs; in doGet()
|
| D | HurlStack.java | 217 int timeoutMs = request.getTimeoutMs(); in openConnection() local
218 connection.setConnectTimeout(timeoutMs); in openConnection()
219 connection.setReadTimeout(timeoutMs); in openConnection()
|
| D | HttpClientStack.java | 86 int timeoutMs = request.getTimeoutMs(); in performRequest() local
90 HttpConnectionParams.setSoTimeout(httpParams, timeoutMs); in performRequest()
|
| /external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/ |
| D | PlayerMessage.java | 312 public synchronized boolean experimental_blockUntilDelivered(long timeoutMs) in experimental_blockUntilDelivered() argument
314 return experimental_blockUntilDelivered(timeoutMs, Clock.DEFAULT); in experimental_blockUntilDelivered()
332 /* package */ synchronized boolean experimental_blockUntilDelivered(long timeoutMs, Clock clock) in experimental_blockUntilDelivered() argument
337 long deadlineMs = clock.elapsedRealtime() + timeoutMs; in experimental_blockUntilDelivered()
338 long remainingMs = timeoutMs; in experimental_blockUntilDelivered()
|
| D | ExoPlayer.java | 236 public Builder experimental_setReleaseTimeoutMs(long timeoutMs) { in experimental_setReleaseTimeoutMs() argument
237 releaseTimeoutMs = timeoutMs; in experimental_setReleaseTimeoutMs()
|
| D | ExoPlayerImpl.java | 184 public void experimental_setReleaseTimeoutMs(long timeoutMs) { in experimental_setReleaseTimeoutMs() argument
185 internalPlayer.experimental_setReleaseTimeoutMs(timeoutMs); in experimental_setReleaseTimeoutMs()
|
| D | ExoPlayerImplInternal.java | 543 private synchronized void waitUntilReleased(long timeoutMs) throws InterruptedException { in waitUntilReleased() argument
544 long deadlineMs = clock.elapsedRealtime() + timeoutMs; in waitUntilReleased()
545 long remainingMs = timeoutMs; in waitUntilReleased()
|
| /external/libchrome/base/test/android/java/src/org/chromium/base/ |
| D | MultiprocessTestClientLauncher.java | 146 private boolean waitForConnection(long timeoutMs) { in waitForConnection() argument
149 long timeoutNs = TimeUnit.MILLISECONDS.toNanos(timeoutMs); in waitForConnection()
168 private Integer getMainReturnCode(long timeoutMs) { in getMainReturnCode() argument
171 long timeoutNs = TimeUnit.MILLISECONDS.toNanos(timeoutMs); in getMainReturnCode()
252 private static MainReturnCodeResult waitForMainToReturn(final int pid, final int timeoutMs) {
256 return waitForMainToReturnOnLauncherThread(pid, timeoutMs);
262 int pid, int timeoutMs) {
269 Integer mainResult = launcher.getMainReturnCode(timeoutMs);
|
| /external/exoplayer/tree/testutils/src/test/java/com/google/android/exoplayer2/testutil/ |
| D | FakeClockTest.java | 179 public boolean waitUntilAsleep(long timeoutMs) throws InterruptedException { in waitUntilAsleep() argument
180 return fallAsleepCountDownLatch.await(timeoutMs, TimeUnit.MILLISECONDS); in waitUntilAsleep()
183 public boolean waitUntilAwake(long timeoutMs) throws InterruptedException { in waitUntilAwake() argument
184 return wakeUpCountDownLatch.await(timeoutMs, TimeUnit.MILLISECONDS); in waitUntilAwake()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-debug/test/junit4/ |
| D | TestFailureValidation.kt | 15 timeoutMs: Long, in TestFailureValidation()
24 timeoutMs,
|
| /external/perfetto/ui/src/service_worker/ |
| D | service_worker.ts | 226 function fetchWithTimeout(req: Request|string, timeoutMs: number) {
231 }, timeoutMs);
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 46 static final int timeoutMs = 3000; field in JavaGrpcTest
196 streamAlive.await(timeoutMs, TimeUnit.MILLISECONDS);
232 streamAlive.await(timeoutMs, TimeUnit.MILLISECONDS);
|
| /external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/ |
| D | EglRendererTest.java | 86 public synchronized boolean waitForBitmap(int timeoutMs) throws InterruptedException { in waitForBitmap() argument
87 final long endTimeMs = System.currentTimeMillis() + timeoutMs; in waitForBitmap()
93 wait(timeoutMs); in waitForBitmap()
|
| /external/angle/src/libANGLE/renderer/vulkan/ |
| D | SyncVk.cpp | 35 int timeoutMs = static_cast<int>(timeoutNs / 1000000); in SyncWaitFd() local
39 timeoutMs = 1; in SyncWaitFd()
49 ret = poll(&fds, 1, timeoutMs); in SyncWaitFd()
|
| /external/python/apitools/samples/bigquery_sample/bigquery_v2/ |
| D | bigquery_v2_messages.py | 141 timeoutMs = _messages.IntegerField(6, variant=_messages.Variant.UINT32) variable in BigqueryJobsGetQueryResultsRequest
1621 timeoutMs = _messages.IntegerField(7, variant=_messages.Variant.UINT32) variable in QueryRequest
|