Home
last modified time | relevance | path

Searched refs:timeoutNanos (Results 1 – 18 of 18) sorted by relevance

/external/guava/guava/src/com/google/common/util/concurrent/
DMonitor.java391 final long timeoutNanos = toSafeNanos(time, unit);
399 for (long remainingNanos = timeoutNanos; ; ) {
404 remainingNanos = remainingNanos(startTime, timeoutNanos);
481 final long timeoutNanos = toSafeNanos(time, unit);
500 startTime = initNanoTime(timeoutNanos);
513 (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos),
561 final long timeoutNanos = toSafeNanos(time, unit);
571 startTime = initNanoTime(timeoutNanos);
572 for (long remainingNanos = timeoutNanos; ; ) {
581 remainingNanos = remainingNanos(startTime, timeoutNanos);
[all …]
DMoreExecutors.java656 long timeoutNanos = unit.toNanos(timeout); in invokeAnyImpl() local
685 f = futureQueue.poll(timeoutNanos, TimeUnit.NANOSECONDS); in invokeAnyImpl()
690 timeoutNanos -= now - lastTime; in invokeAnyImpl()
DAbstractFuture.java400 final long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit. in get() local
401 long remainingNanos = timeoutNanos; in get()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DMonitor.java373 final long timeoutNanos = toSafeNanos(time, unit); in enter() local
381 for (long remainingNanos = timeoutNanos; ; ) { in enter()
386 remainingNanos = remainingNanos(startTime, timeoutNanos); in enter()
463 final long timeoutNanos = toSafeNanos(time, unit); in enterWhen() local
482 startTime = initNanoTime(timeoutNanos); in enterWhen()
495 (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos), in enterWhen()
543 final long timeoutNanos = toSafeNanos(time, unit); in enterWhenUninterruptibly() local
553 startTime = initNanoTime(timeoutNanos); in enterWhenUninterruptibly()
554 for (long remainingNanos = timeoutNanos; ; ) { in enterWhenUninterruptibly()
563 remainingNanos = remainingNanos(startTime, timeoutNanos); in enterWhenUninterruptibly()
[all …]
DMoreExecutors.java656 long timeoutNanos = unit.toNanos(timeout); in invokeAnyImpl() local
685 f = futureQueue.poll(timeoutNanos, TimeUnit.NANOSECONDS); in invokeAnyImpl()
690 timeoutNanos -= now - lastTime; in invokeAnyImpl()
DAbstractFuture.java400 final long timeoutNanos = unit.toNanos(timeout); // we rely on the implicit null check on unit. in get() local
401 long remainingNanos = timeoutNanos; in get()
/external/okhttp/okio/okio/src/main/java/okio/
DAsyncTimeout.java63 long timeoutNanos = timeoutNanos(); in enter() local
65 if (timeoutNanos == 0 && !hasDeadline) { in enter()
69 scheduleTimeout(this, timeoutNanos, hasDeadline); in enter()
73 AsyncTimeout node, long timeoutNanos, boolean hasDeadline) { in scheduleTimeout() argument
81 if (timeoutNanos != 0 && hasDeadline) { in scheduleTimeout()
84 node.timeoutAt = now + Math.min(timeoutNanos, node.deadlineNanoTime() - now); in scheduleTimeout()
85 } else if (timeoutNanos != 0) { in scheduleTimeout()
86 node.timeoutAt = now + timeoutNanos; in scheduleTimeout()
DTimeout.java67 private long timeoutNanos; field in Timeout
83 this.timeoutNanos = unit.toNanos(timeout); in timeout()
88 public long timeoutNanos() { in timeoutNanos() method in Timeout
89 return timeoutNanos; in timeoutNanos()
128 this.timeoutNanos = 0; in clearTimeout()
DForwardingTimeout.java45 @Override public long timeoutNanos() { in timeoutNanos() method in ForwardingTimeout
46 return delegate.timeoutNanos(); in timeoutNanos()
/external/okhttp/repackaged/okio/okio/src/main/java/com/android/okhttp/okio/
DAsyncTimeout.java65 long timeoutNanos = timeoutNanos(); in enter() local
67 if (timeoutNanos == 0 && !hasDeadline) { in enter()
71 scheduleTimeout(this, timeoutNanos, hasDeadline); in enter()
75 AsyncTimeout node, long timeoutNanos, boolean hasDeadline) { in scheduleTimeout() argument
83 if (timeoutNanos != 0 && hasDeadline) { in scheduleTimeout()
86 node.timeoutAt = now + Math.min(timeoutNanos, node.deadlineNanoTime() - now); in scheduleTimeout()
87 } else if (timeoutNanos != 0) { in scheduleTimeout()
88 node.timeoutAt = now + timeoutNanos; in scheduleTimeout()
DTimeout.java69 private long timeoutNanos; field in Timeout
85 this.timeoutNanos = unit.toNanos(timeout); in timeout()
90 public long timeoutNanos() { in timeoutNanos() method in Timeout
91 return timeoutNanos; in timeoutNanos()
130 this.timeoutNanos = 0; in clearTimeout()
DForwardingTimeout.java47 @Override public long timeoutNanos() { in timeoutNanos() method in ForwardingTimeout
48 return delegate.timeoutNanos(); in timeoutNanos()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DGrpcUtil.java616 public String toAsciiString(Long timeoutNanos) { in toAsciiString() argument
619 if (timeoutNanos < 0) { in toAsciiString()
621 } else if (timeoutNanos < cutoff) { in toAsciiString()
622 return timeoutNanos + "n"; in toAsciiString()
623 } else if (timeoutNanos < cutoff * 1000L) { in toAsciiString()
624 return unit.toMicros(timeoutNanos) + "u"; in toAsciiString()
625 } else if (timeoutNanos < cutoff * 1000L * 1000L) { in toAsciiString()
626 return unit.toMillis(timeoutNanos) + "m"; in toAsciiString()
627 } else if (timeoutNanos < cutoff * 1000L * 1000L * 1000L) { in toAsciiString()
628 return unit.toSeconds(timeoutNanos) + "S"; in toAsciiString()
[all …]
DServiceConfigInterceptor.java131 final Long timeoutNanos; field in ServiceConfigInterceptor.MethodInfo
146 timeoutNanos = ServiceConfigUtil.getTimeoutFromMethodConfig(methodConfig); in MethodInfo()
177 timeoutNanos, waitForReady, maxInboundMessageSize, maxOutboundMessageSize, retryPolicy); in hashCode()
186 return Objects.equal(this.timeoutNanos, that.timeoutNanos) in equals()
196 .add("timeoutNanos", timeoutNanos) in toString()
365 if (info.timeoutNanos != null) { in interceptCall()
366 Deadline newDeadline = Deadline.after(info.timeoutNanos, TimeUnit.NANOSECONDS); in interceptCall()
DServerImpl.java269 long timeoutNanos = unit.toNanos(timeout); in awaitTermination() local
270 long endTimeNanos = System.nanoTime() + timeoutNanos; in awaitTermination()
271 while (!terminated && (timeoutNanos = endTimeNanos - System.nanoTime()) > 0) { in awaitTermination()
272 NANOSECONDS.timedWait(lock, timeoutNanos); in awaitTermination()
500 Long timeoutNanos = headers.get(TIMEOUT_KEY); in createContext() local
504 if (timeoutNanos == null) { in createContext()
509 timeoutNanos, NANOSECONDS, transport.getScheduledExecutorService()); in createContext()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/
DGrpcCleanupRule.java51 private long timeoutNanos = TimeUnit.SECONDS.toNanos(10L); field in GrpcCleanupRule
68 timeoutNanos = timeUnit.toNanos(timeout); in setTimeout()
166 timeoutNanos - stopwatch.elapsed(TimeUnit.NANOSECONDS), TimeUnit.NANOSECONDS);
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinlogHelper.java416 Long timeoutNanos = headers.get(GrpcUtil.TIMEOUT_KEY);
418 timeoutNanos == null ? null : Durations.fromNanos(timeoutNanos);
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServiceConfigInterceptorTest.java392 assertThat(info.timeoutNanos).isEqualTo(Long.MAX_VALUE); in methodInfo_saturateDeadline()