| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | DefaultExecutor.kt | 69 var parkNanos = processNextEvent() in invokeOnTimeout() variable
70 if (parkNanos == Long.MAX_VALUE) { in invokeOnTimeout()
76 parkNanos = parkNanos.coerceAtMost(tillShutdown) in invokeOnTimeout()
79 if (parkNanos > 0) { in invokeOnTimeout()
82 parkNanos(this, parkNanos) in invokeOnTimeout()
|
| D | TimeSource.kt | 21 fun parkNanos(blocker: Any, nanos: Long) // should return immediately when nanos <= 0 in currentTimeMillis() method
62 internal inline fun parkNanos(blocker: Any, nanos: Long) { in parkNanos() method
63 timeSource?.parkNanos(blocker, nanos) ?: LockSupport.parkNanos(blocker, nanos) in parkNanos()
|
| D | Builders.kt | 84 val parkNanos = eventLoop?.processNextEvent() ?: Long.MAX_VALUE in joinBlocking() constant
87 parkNanos(this, parkNanos) in joinBlocking()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 65 val parkNanos = eventLoop?.processNextEvent() ?: Long.MAX_VALUE in <lambda>() constant
68 timespec.tv_sec = (parkNanos / 1000000000L).convert() // 1e9 ns -> sec in <lambda>()
69 timespec.tv_nsec = (parkNanos % 1000000000L).convert() // % 1e9 in <lambda>()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | OverflowAvoidingLockSupport.java | 32 static void parkNanos(@NullableDecl Object blocker, long nanos) { in parkNanos() method in OverflowAvoidingLockSupport
35 LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); in parkNanos()
|
| D | AbstractFuture.java | 434 OverflowAvoidingLockSupport.parkNanos(this, remainingNanos); in get()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | OverflowAvoidingLockSupport.java | 32 static void parkNanos(@Nullable Object blocker, long nanos) { in parkNanos() method in OverflowAvoidingLockSupport
35 LockSupport.parkNanos(blocker, min(nanos, MAX_NANOSECONDS_THRESHOLD)); in parkNanos()
|
| D | AbstractFuture.java | 434 OverflowAvoidingLockSupport.parkNanos(this, remainingNanos); in get()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | VirtualTimeSource.kt | 97 override fun parkNanos(blocker: Any, nanos: Long) { in toString() method in kotlinx.coroutines.VirtualTimeSource
109 LockSupport.parkNanos(blocker, REAL_PARK_NANOS) in toString()
|
| D | EventLoopsTest.kt | 145 LockSupport.parkNanos(time) in blockingAwait()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | StressTestClientTest.java | 144 LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(100)); in gaugesShouldBeExported()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/ |
| D | CoroutineScheduler.kt | 701 LockSupport.parkNanos(minDelayUntilStealableTaskNs) in <lambda>()
783 LockSupport.parkNanos(idleWorkerKeepAliveNs) in <lambda>()
|
| /external/kotlinx.atomicfu/atomicfu/src/jvmMain/kotlin/kotlinx/atomicfu/ |
| D | LockFreedomTestEnvironment.kt | 293 while (status.get() == newStatus) LockSupport.parkNanos(MAX_PARK_NANOS) // wait in <lambda>()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 295 LockSupport.parkNanos(nextPermitted - alreadyElapsed); in delay()
|
| /external/kotlinc/lib/ |
| D | kotlinx-coroutines-core.jar | META-INF/
META-INF/MANIFEST.MF
kotlinx/
kotlinx/coroutines/
kotlinx/ ... |
| D | kotlin-main-kts.jar | META-INF/
META-INF/MANIFEST.MF
DebugProbesKt.bin
META-INF/LICENSE
... |