| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 373 long timeoutNanos = unit.toNanos(time); in enter() local
378 long deadline = System.nanoTime() + timeoutNanos; in enter()
383 return lock.tryLock(timeoutNanos, TimeUnit.NANOSECONDS); in enter()
386 timeoutNanos = deadline - System.nanoTime(); in enter()
472 long timeoutNanos = unit.toNanos(time); in enterWhen() local
479 long deadline = System.nanoTime() + timeoutNanos; in enterWhen()
483 timeoutNanos = deadline - System.nanoTime(); in enterWhen()
489 satisfied = guard.isSatisfied() || awaitNanos(guard, timeoutNanos, reentrant); in enterWhen()
513 long timeoutNanos = unit.toNanos(time); in enterWhenUninterruptibly() local
518 long deadline = System.nanoTime() + timeoutNanos; in enterWhenUninterruptibly()
[all …]
|
| /external/okhttp/okio/okio/src/main/java/okio/ |
| D | AsyncTimeout.java | 63 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()
|
| D | Timeout.java | 67 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()
|
| D | ForwardingTimeout.java | 45 @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/ |
| D | AsyncTimeout.java | 65 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()
|
| D | Timeout.java | 69 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()
|
| D | ForwardingTimeout.java | 47 @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/ |
| D | GrpcUtil.java | 616 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 …]
|
| D | ServiceConfigInterceptor.java | 131 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()
|
| D | ServerImpl.java | 269 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/ |
| D | GrpcCleanupRule.java | 51 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/ |
| D | BinlogHelper.java | 416 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/ |
| D | ServiceConfigInterceptorTest.java | 392 assertThat(info.timeoutNanos).isEqualTo(Long.MAX_VALUE); in methodInfo_saturateDeadline()
|