Searched refs:delayNanos (Results 1 – 5 of 5) sorted by relevance
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/ |
| D | VirtualTime.kt | 25 val delayNanos = ThreadLocalEventLoop.currentOrNull()?.processNextEvent() in <lambda>() constant
27 if (delayNanos <= 0) continue in <lambda>()
28 …if (delayNanos > 0 && delayNanos != Long.MAX_VALUE) error("Unexpected external delay: $delayNanos") in <lambda>()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | Rescheduler.java | 56 long delayNanos = timeUnit.toNanos(delay); in reschedule() local
57 long newRunAtNanos = nanoTime() + delayNanos; in reschedule()
63 wakeUp = scheduler.schedule(new FutureRunnable(), delayNanos, TimeUnit.NANOSECONDS); in reschedule()
|
| D | InternalSubchannel.java | 288 long delayNanos = in scheduleBackoff() local
291 log.log(Level.FINE, "[{0}] Scheduling backoff for {1} ns", new Object[]{logId, delayNanos}); in scheduleBackoff()
297 delayNanos, in scheduleBackoff()
|
| D | ManagedChannelImpl.java | 1345 long delayNanos = nameResolverBackoffPolicy.nextBackoffNanos(); in onError() local
1350 new Object[] {logId, delayNanos}); in onError()
1356 .schedule(nameResolverRefresh, delayNanos, TimeUnit.NANOSECONDS); in onError()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 435 void schedule(long delayNanos) { in schedule() argument
437 scheduledFuture = timerService.schedule(this, delayNanos, TimeUnit.NANOSECONDS); in schedule()
615 long delayNanos = 0; in handleStreamClosed() local
626 delayNanos = in handleStreamClosed()
629 if (delayNanos <= 0) { in handleStreamClosed()
633 lbRpcRetryTimer.schedule(delayNanos); in handleStreamClosed()
|