Searched refs:delayNanos (Results 1 – 4 of 4) sorted by relevance
| /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 | 1348 long delayNanos = nameResolverBackoffPolicy.nextBackoffNanos(); in onError()
1353 new Object[] {logId, delayNanos}); in onError()
1359 .schedule(nameResolverRefresh, delayNanos, TimeUnit.NANOSECONDS); in onError()
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 441 void schedule(long delayNanos) { in schedule() argument
443 scheduledFuture = timerService.schedule(this, delayNanos, TimeUnit.NANOSECONDS); in schedule()
621 long delayNanos = 0; in handleStreamClosed() local
632 delayNanos = in handleStreamClosed()
635 if (delayNanos <= 0) { in handleStreamClosed()
639 lbRpcRetryTimer.schedule(delayNanos); in handleStreamClosed()
|