| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Delay.kt | 66 public fun <T> Flow<T>.debounce(timeoutMillis: Long): Flow<T> { in <lambda>()
67 require(timeoutMillis >= 0L) { "Debounce timeout should not be negative" } in <lambda>()
68 if (timeoutMillis == 0L) return this in <lambda>()
69 return debounceInternal { timeoutMillis } in <lambda>()
117 public fun <T> Flow<T>.debounce(timeoutMillis: (T) -> Long): Flow<T> = in debounce()
118 debounceInternal(timeoutMillis) in debounce()
219 var timeoutMillis = 0L // will be always computed when lastValue != null in debounceInternal() variable
222 timeoutMillis = timeoutMillisSelector(NULL.unbox(lastValue)) in debounceInternal()
223 require(timeoutMillis >= 0L) { "Debounce timeout should not be negative" } in debounceInternal()
224 if (timeoutMillis == 0L) { in debounceInternal()
[all …]
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/ |
| D | TestScheduledExecutorService.java | 108 private void advanceTimeByMillis(long timeoutMillis) throws Exception { in advanceTimeByMillis() argument
109 millisPast += timeoutMillis; in advanceTimeByMillis()
118 private final long timeoutMillis; field in SimpleScheduledFuture
123 public SimpleScheduledFuture(Callable<T> callable, long timeoutMillis) { in SimpleScheduledFuture() argument
125 this.timeoutMillis = timeoutMillis; in SimpleScheduledFuture()
139 return unit.convert(timeoutMillis, MILLISECONDS); in getDelay()
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | RequestFutureTarget.java | 186 …private synchronized R doGet(Long timeoutMillis) throws ExecutionException, InterruptedException, … in doGet() argument
199 if (timeoutMillis == null) { in doGet()
201 } else if (timeoutMillis > 0) { in doGet()
202 waiter.waitForTimeout(this, timeoutMillis); in doGet()
262 … public void waitForTimeout(Object toWaitOn, long timeoutMillis) throws InterruptedException { in waitForTimeout() argument
263 toWaitOn.wait(timeoutMillis); in waitForTimeout()
|
| /external/connectedappssdk/sdk/src/main/java/com/google/android/enterprise/connectedapps/ |
| D | CrossProfileSender.java | 63 private final long timeoutMillis; field in CrossProfileSender.CrossProfileCall
70 long timeoutMillis) { in CrossProfileCall() argument
78 this.timeoutMillis = timeoutMillis; in CrossProfileCall()
98 && timeoutMillis == that.timeoutMillis; in equals()
104 crossProfileTypeIdentifier, methodIdentifier, params, callback, timeoutMillis); in hashCode()
114 private final long timeoutMillis; field in CrossProfileSender.OngoingCrossProfileCall
118 CrossProfileSender sender, LocalCallback originalCallback, long timeoutMillis) { in OngoingCrossProfileCall() argument
124 this.timeoutMillis = timeoutMillis; in OngoingCrossProfileCall()
135 timeoutExecutor.schedule(this::onTimeout, timeoutMillis, TimeUnit.MILLISECONDS); in scheduleTimeout()
145 "The call timed out after " + timeoutMillis + " milliseconds")); in onTimeout()
[all …]
|
| /external/ims/rcs/presencepolling/tests/src/com/android/service/ims/presence/ |
| D | PresencePollingTestBase.java | 57 protected final void waitForHandlerAction(Handler h, long timeoutMillis) { in waitForHandlerAction() argument
58 waitForHandlerActionDelayed(h, timeoutMillis, 0 /*delayMs*/); in waitForHandlerAction()
61 protected final void waitForHandlerActionDelayed(Handler h, long timeoutMillis, long delayMs) { in waitForHandlerActionDelayed() argument
66 lock.await(timeoutMillis, TimeUnit.MILLISECONDS); in waitForHandlerActionDelayed()
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | JSR166TestCase.java | 262 long timeoutMillis() { in timeoutMillis() method in JSR166TestCase
466 assertThreadStaysAlive(thread, timeoutMillis()); in assertThreadStaysAlive()
485 assertThreadsStayAlive(timeoutMillis(), threads); in assertThreadsStayAlive()
501 assertFutureTimesOut(future, timeoutMillis()); in assertFutureTimesOut()
505 void assertFutureTimesOut(Future future, long timeoutMillis) { in assertFutureTimesOut() argument
508 future.get(timeoutMillis, MILLISECONDS); in assertFutureTimesOut()
516 assertTrue(millisElapsedSince(startTime) >= timeoutMillis); in assertFutureTimesOut()
653 void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) { in waitForThreadToEnterWaitState() argument
660 else if (millisElapsedSince(startTime) > timeoutMillis) { in waitForThreadToEnterWaitState()
697 void awaitTermination(Thread t, long timeoutMillis) { in awaitTermination() argument
[all …]
|
| D | UninterruptiblesTest.java | 638 void tryAcquireSuccessfully(long timeoutMillis) { in tryAcquireSuccessfully() argument
639 assertTrue(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); in tryAcquireSuccessfully()
643 void tryAcquireSuccessfully(int permits, long timeoutMillis) { in tryAcquireSuccessfully() argument
644 assertTrue(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS)); in tryAcquireSuccessfully()
652 private void tryAcquireUnsuccessfully(long timeoutMillis) { in tryAcquireUnsuccessfully() argument
653 assertFalse(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); in tryAcquireUnsuccessfully()
654 completed.assertCompletionNotExpected(timeoutMillis); in tryAcquireUnsuccessfully()
657 private void tryAcquireUnsuccessfully(int permits, long timeoutMillis) { in tryAcquireUnsuccessfully() argument
658 assertFalse(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS)); in tryAcquireUnsuccessfully()
659 completed.assertCompletionNotExpected(timeoutMillis); in tryAcquireUnsuccessfully()
[all …]
|
| /external/connectedappssdk/testing/sdk/src/main/java/com/google/android/enterprise/connectedapps/testing/ |
| D | BlockingPoll.java | 34 public static void poll(BooleanSupplier func, long pollFrequency, long timeoutMillis) { in poll() argument
35 long endTime = System.currentTimeMillis() + timeoutMillis; in poll()
45 throw new IllegalStateException("Timeout after " + timeoutMillis); in poll()
|
| /external/connectedappssdk/processor/src/main/java/com/google/android/enterprise/connectedapps/processor/annotationdiscovery/ |
| D | CrossProfileAnnotationInfoExtractor.java | 57 long timeoutMillis = annotation.timeoutMillis(); in annotationInfoFromAnnotation() local
59 if (timeoutMillis != CrossProfileAnnotation.TIMEOUT_MILLIS_NOT_SET) { in annotationInfoFromAnnotation()
60 builder.setTimeoutMillis(timeoutMillis); in annotationInfoFromAnnotation()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | JSR166TestCase.java | 263 long timeoutMillis() { in timeoutMillis() method in JSR166TestCase
469 assertThreadStaysAlive(thread, timeoutMillis()); in assertThreadStaysAlive()
488 assertThreadsStayAlive(timeoutMillis(), threads); in assertThreadsStayAlive()
504 assertFutureTimesOut(future, timeoutMillis()); in assertFutureTimesOut()
508 void assertFutureTimesOut(Future future, long timeoutMillis) { in assertFutureTimesOut() argument
511 future.get(timeoutMillis, MILLISECONDS); in assertFutureTimesOut()
519 assertTrue(millisElapsedSince(startTime) >= timeoutMillis); in assertFutureTimesOut()
660 void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) { in waitForThreadToEnterWaitState() argument
667 else if (millisElapsedSince(startTime) > timeoutMillis) { in waitForThreadToEnterWaitState()
704 void awaitTermination(Thread t, long timeoutMillis) { in awaitTermination() argument
[all …]
|
| D | UninterruptiblesTest.java | 659 void tryAcquireSuccessfully(long timeoutMillis) { in tryAcquireSuccessfully() argument
660 assertTrue(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); in tryAcquireSuccessfully()
664 void tryAcquireSuccessfully(int permits, long timeoutMillis) { in tryAcquireSuccessfully() argument
665 assertTrue(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS)); in tryAcquireSuccessfully()
673 private void tryAcquireUnsuccessfully(long timeoutMillis) { in tryAcquireUnsuccessfully() argument
674 assertFalse(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); in tryAcquireUnsuccessfully()
675 completed.assertCompletionNotExpected(timeoutMillis); in tryAcquireUnsuccessfully()
678 private void tryAcquireUnsuccessfully(int permits, long timeoutMillis) { in tryAcquireUnsuccessfully() argument
679 assertFalse(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS)); in tryAcquireUnsuccessfully()
680 completed.assertCompletionNotExpected(timeoutMillis); in tryAcquireUnsuccessfully()
[all …]
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
| D | RecordingCallback.java | 48 long timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS; in await() local
59 if (nowMillis >= timeoutMillis) break; in await()
60 wait(timeoutMillis - nowMillis); in await()
|
| /external/skia/tools/perf-canvaskit-puppeteer/ |
| D | benchmark.js | 39 function startTimingFrames(drawFn, surface, warmupFrames, maxFrames, timeoutMillis) { argument
93 if (timeoutMillis && ((beginTest + timeoutMillis) < performance.now())) {
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/robotests/ |
| D | OtherProfileListenableFutureTest.java | 221 long timeoutMillis = 5000; in other_listenableFuture_timeoutSetByCaller_doesNotTimeoutEarly() local
225 .timeout(timeoutMillis) in other_listenableFuture_timeoutSetByCaller_doesNotTimeoutEarly()
228 scheduledExecutorService.advanceTimeBy(timeoutMillis - 1, TimeUnit.MILLISECONDS); in other_listenableFuture_timeoutSetByCaller_doesNotTimeoutEarly()
235 long timeoutMillis = 5000; in other_listenableFuture_timeoutSetByCaller_timesOut() local
239 .timeout(timeoutMillis) in other_listenableFuture_timeoutSetByCaller_timesOut()
242 scheduledExecutorService.advanceTimeBy(timeoutMillis + 1, TimeUnit.MILLISECONDS); in other_listenableFuture_timeoutSetByCaller_timesOut()
|
| D | OtherProfileAsyncTest.java | 254 long timeoutMillis = 5000; in other_async_timeoutSetByCaller_doesNotTimeoutEarly() local
257 .timeout(timeoutMillis) in other_async_timeoutSetByCaller_doesNotTimeoutEarly()
261 scheduledExecutorService.advanceTimeBy(timeoutMillis - 1, TimeUnit.MILLISECONDS); in other_async_timeoutSetByCaller_doesNotTimeoutEarly()
268 long timeoutMillis = 5000; in other_async_timeoutSetByCaller_timesOut() local
271 .timeout(timeoutMillis) in other_async_timeoutSetByCaller_timesOut()
275 scheduledExecutorService.advanceTimeBy(timeoutMillis + 1, TimeUnit.MILLISECONDS); in other_async_timeoutSetByCaller_timesOut()
|
| /external/downloader/src/main/java/com/google/android/downloader/ |
| D | AndroidConnectivityHandler.java | 60 private final long timeoutMillis; field in AndroidConnectivityHandler
76 Context context, ScheduledExecutorService scheduledExecutorService, long timeoutMillis) { in AndroidConnectivityHandler() argument
85 this.timeoutMillis = timeoutMillis; in AndroidConnectivityHandler()
102 return Futures.withTimeout(futureTask, timeoutMillis, MILLISECONDS, scheduledExecutorService); in checkConnectivity()
|
| /external/connectedappssdk/processor/src/main/java/com/google/android/enterprise/connectedapps/processor/containers/ |
| D | CrossProfileMethodInfo.java | 81 public abstract long timeoutMillis(); in timeoutMillis() method in CrossProfileMethodInfo
224 .timeoutMillis() in findTimeoutMillis()
226 .orElse(type.timeoutMillis()); in findTimeoutMillis()
229 return type.timeoutMillis(); in findTimeoutMillis()
|
| D | ValidatorCrossProfileTypeInfo.java | 59 public abstract long timeoutMillis(); in timeoutMillis() method in ValidatorCrossProfileTypeInfo
111 .timeoutMillis() in create()
|
| /external/connectedappssdk/tests/instrumented/src/main/java/com/google/android/enterprise/connectedapps/instrumented/utils/ |
| D | BlockingBroadcastReceiver.java | 73 public Intent awaitForBroadcast(long timeoutMillis) { in awaitForBroadcast() argument
75 return blockingQueue.poll(timeoutMillis, MILLISECONDS); in awaitForBroadcast()
|
| /external/okhttp/repackaged/okhttp-urlconnection/src/main/java/com/android/okhttp/internal/huc/ |
| D | DelegatingHttpsURLConnection.java | 266 @Override public void setConnectTimeout(int timeoutMillis) { in setConnectTimeout() argument
267 delegate.setConnectTimeout(timeoutMillis); in setConnectTimeout()
274 @Override public void setReadTimeout(int timeoutMillis) { in setReadTimeout() argument
275 delegate.setReadTimeout(timeoutMillis); in setReadTimeout()
|
| /external/okhttp/okhttp-urlconnection/src/main/java/com/squareup/okhttp/internal/huc/ |
| D | DelegatingHttpsURLConnection.java | 265 @Override public void setConnectTimeout(int timeoutMillis) { in setConnectTimeout() argument
266 delegate.setConnectTimeout(timeoutMillis); in setConnectTimeout()
273 @Override public void setReadTimeout(int timeoutMillis) { in setReadTimeout() argument
274 delegate.setReadTimeout(timeoutMillis); in setReadTimeout()
|
| /external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/testapp/types/ |
| D | TestCrossProfileType.java | 58 timeoutMillis = 7000,
97 @CrossProfile(timeoutMillis = 5000)
145 @CrossProfile(timeoutMillis = 3000)
180 @CrossProfile(timeoutMillis = 5000)
201 @CrossProfile(timeoutMillis = 50000)
208 @CrossProfile(timeoutMillis = 3000)
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| D | NativeSsl.java | 400 void doHandshake(FileDescriptor fd, int timeoutMillis) in doHandshake() argument
407 NativeCrypto.SSL_do_handshake(ssl, this, fd, handshakeCallbacks, timeoutMillis); in doHandshake()
423 int read(FileDescriptor fd, byte[] buf, int offset, int len, int timeoutMillis) in read() argument
431 .SSL_read(ssl, this, fd, handshakeCallbacks, buf, offset, len, timeoutMillis); in read()
438 void write(FileDescriptor fd, byte[] buf, int offset, int len, int timeoutMillis) in write() argument
446 .SSL_write(ssl, this, fd, handshakeCallbacks, buf, offset, len, timeoutMillis); in write()
|
| /external/conscrypt/repackaged/common/src/main/java/com/android/org/conscrypt/ |
| D | NativeSsl.java | 401 void doHandshake(FileDescriptor fd, int timeoutMillis) in doHandshake() argument
408 NativeCrypto.SSL_do_handshake(ssl, this, fd, handshakeCallbacks, timeoutMillis); in doHandshake()
424 int read(FileDescriptor fd, byte[] buf, int offset, int len, int timeoutMillis) in read() argument
432 .SSL_read(ssl, this, fd, handshakeCallbacks, buf, offset, len, timeoutMillis); in read()
439 void write(FileDescriptor fd, byte[] buf, int offset, int len, int timeoutMillis) in write() argument
447 .SSL_write(ssl, this, fd, handshakeCallbacks, buf, offset, len, timeoutMillis); in write()
|
| /external/junit/src/main/java/org/junit/internal/runners/statements/ |
| D | FailOnTimeout.java | 35 public FailOnTimeout(Statement statement, long timeoutMillis) { in FailOnTimeout() argument
36 this(builder().withTimeout(timeoutMillis, TimeUnit.MILLISECONDS), statement); in FailOnTimeout()
|