| /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()
|
| D | PipeKotlinTest.kt | 142 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnWritingWhenItIsSmaller()
157 assertEquals(smallerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingTimeoutOnWritingWhenItIsSmaller()
172 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnFlushingWhenItIsSmaller()
187 assertEquals(smallerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingTimeoutOnFlushingWhenItIsSmaller()
202 assertEquals(biggerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnClosingWhenItIsSmaller()
217 assertEquals(smallerTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingTimeoutOnClosingWhenItIsSmaller()
233 assertEquals(0L, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnWritingWhenUnderlyingSinkTimeoutIsZero()
249 assertEquals(underlyingSinkTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingSinkTimeoutOnWritingWhenPipeSinkTimeoutIsZero()
265 assertEquals(0L, underlying.timeout().timeoutNanos()) in honorsPipeSinkTimeoutOnFlushingWhenUnderlyingSinkTimeoutIsZero()
281 assertEquals(underlyingSinkTimeoutNanos, underlying.timeout().timeoutNanos()) in honorsUnderlyingSinkTimeoutOnFlushingWhenPipeSinkTimeoutIsZero()
[all …]
|
| /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()
|
| /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);
|