| /external/okio/okio/src/jvmMain/kotlin/okio/ |
| D | Timeout.kt | 29 private var timeoutNanos = 0L variable
40 timeoutNanos = unit.toNanos(timeout) in timeout()
45 open fun timeoutNanos(): Long = timeoutNanos in timeoutNanos() method in okio.Timeout
79 timeoutNanos = 0 in clearTimeout()
145 val timeoutNanos = timeoutNanos() in waitUntilNotified() constant
147 if (!hasDeadline && timeoutNanos == 0L) { in waitUntilNotified()
154 val waitNanos = if (hasDeadline && timeoutNanos != 0L) { in waitUntilNotified()
156 minOf(timeoutNanos, deadlineNanos) in waitUntilNotified()
160 timeoutNanos in waitUntilNotified()
186 val originalTimeout = this.timeoutNanos() in intersectWith()
[all …]
|
| D | AsyncTimeout.kt | 49 val timeoutNanos = timeoutNanos() in enter() constant
51 if (timeoutNanos == 0L && !hasDeadline) { in enter()
54 scheduleTimeout(this, timeoutNanos, hasDeadline) in enter()
223 private fun scheduleTimeout(node: AsyncTimeout, timeoutNanos: Long, hasDeadline: Boolean) { in scheduleTimeout()
235 if (timeoutNanos != 0L && hasDeadline) { in scheduleTimeout()
238 node.timeoutAt = now + minOf(timeoutNanos, node.deadlineNanoTime() - now) in scheduleTimeout()
239 } else if (timeoutNanos != 0L) { in scheduleTimeout()
240 node.timeoutAt = now + timeoutNanos in scheduleTimeout()
|
| D | ForwardingTimeout.kt | 36 override fun timeoutNanos() = delegate.timeoutNanos() method in okio.ForwardingTimeout
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 374 final long timeoutNanos = toSafeNanos(time, unit); in enter() local
382 for (long remainingNanos = timeoutNanos; ; ) { in enter()
387 remainingNanos = remainingNanos(startTime, timeoutNanos); in enter()
464 final long timeoutNanos = toSafeNanos(time, unit); in enterWhen() local
483 startTime = initNanoTime(timeoutNanos); in enterWhen()
496 (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos), in enterWhen()
544 final long timeoutNanos = toSafeNanos(time, unit); in enterWhenUninterruptibly() local
554 startTime = initNanoTime(timeoutNanos); in enterWhenUninterruptibly()
555 for (long remainingNanos = timeoutNanos; ; ) { in enterWhenUninterruptibly()
564 remainingNanos = remainingNanos(startTime, timeoutNanos); in enterWhenUninterruptibly()
[all …]
|
| D | ListenableFutureTask.java | 95 long timeoutNanos = unit.toNanos(timeout); in get() local
96 if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { in get()
101 min(timeoutNanos, OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD), NANOSECONDS); in get()
|
| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ForwardingTimeoutKotlinTest.kt | 29 assertThat(timeout1.timeoutNanos()).isNotEqualTo(0L) in getAndSetDelegate()
30 assertThat(timeout2.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
32 assertThat(timeout1.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
33 assertThat(timeout2.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
38 assertThat(timeout1.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
39 assertThat(timeout2.timeoutNanos()).isNotEqualTo(0L) in getAndSetDelegate()
41 assertThat(timeout1.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
42 assertThat(timeout2.timeoutNanos()).isEqualTo(0L) in getAndSetDelegate()
|
| /external/okio/okio/src/jvmTest/java/okio/ |
| D | ForwardingTimeoutTest.java | 30 assertThat(timeout1.timeoutNanos()).isNotEqualTo(0L); in getAndSetDelegate()
31 assertThat(timeout2.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
33 assertThat(timeout1.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
34 assertThat(timeout2.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
39 assertThat(timeout1.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
40 assertThat(timeout2.timeoutNanos()).isNotEqualTo(0L); in getAndSetDelegate()
42 assertThat(timeout1.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
43 assertThat(timeout2.timeoutNanos()).isEqualTo(0L); in getAndSetDelegate()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Monitor.java | 404 final long timeoutNanos = toSafeNanos(time, unit);
412 for (long remainingNanos = timeoutNanos; ; ) {
417 remainingNanos = remainingNanos(startTime, timeoutNanos);
518 final long timeoutNanos = toSafeNanos(time, unit);
537 startTime = initNanoTime(timeoutNanos);
550 (startTime == 0L) ? timeoutNanos : remainingNanos(startTime, timeoutNanos),
609 final long timeoutNanos = toSafeNanos(time, unit);
619 startTime = initNanoTime(timeoutNanos);
620 for (long remainingNanos = timeoutNanos; ; ) {
629 remainingNanos = remainingNanos(startTime, timeoutNanos);
[all …]
|
| D | ListenableFutureTask.java | 95 long timeoutNanos = unit.toNanos(timeout); in get() local
96 if (timeoutNanos <= OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD) { in get()
101 min(timeoutNanos, OverflowAvoidingLockSupport.MAX_NANOSECONDS_THRESHOLD), NANOSECONDS); in get()
|
| D | MoreExecutors.java | 757 long timeoutNanos = unit.toNanos(timeout); in invokeAnyImpl() local
786 f = futureQueue.poll(timeoutNanos, TimeUnit.NANOSECONDS); in invokeAnyImpl()
791 timeoutNanos -= now - lastTime; in invokeAnyImpl()
|
| /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/oboe/src/common/ |
| D | AudioSourceCaller.h | 59 void setTimeoutNanos(int64_t timeoutNanos) { in setTimeoutNanos() argument
60 mTimeoutNanos = timeoutNanos; in setTimeoutNanos()
|
| D | DataConversionFlowGraph.cpp | 214 int32_t DataConversionFlowGraph::read(void *buffer, int32_t numFrames, int64_t timeoutNanos) { in read() argument
216 mSourceCaller->setTimeoutNanos(timeoutNanos); in read()
|
| D | DataConversionFlowGraph.h | 59 int32_t read(void *buffer, int32_t numFrames, int64_t timeoutNanos);
|
| /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/oboe/apps/fxlab/app/src/main/cpp/ |
| D | DuplexEngine.cpp | 76 int64_t timeoutNanos = 500 * 1000000; // arbitrary 1/2 second in startStreams() local
80 result = outStream->waitForStateChange(currentState, &nextState, timeoutNanos); in startStreams()
|
| /external/oboe/docs/ |
| D | FullGuide.md | 257 int64_t timeoutNanos = 100 * kNanosPerMillisecond;
259 result = stream->waitForStateChange(inputState, &nextState, timeoutNanos);
288 `AudioStream::read(buffer, numFrames, timeoutNanos)`
290 `AudioStream::write(buffer, numFrames, timeoutNanos)`.
292 …ers the specified number of frames, set timeoutNanos greater than zero. For a non-blocking call, s…
309 …ng data or silence into it. This must be done in a non-blocking call with timeoutNanos set to zero.
412 const int64_t timeoutNanos = 0; // for a non-blocking read
413 auto result = recordingStream->read(audioData, numFrames, timeoutNanos);
|