Home
last modified time | relevance | path

Searched refs:timeMillis (Results 1 – 25 of 30) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DDelay.kt51 … public fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit>) in <lambda>()
60 …public fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Disposab… in <lambda>()
61 DefaultDelay.invokeOnTimeout(timeMillis, block, context) in <lambda>()
116 public suspend fun delay(timeMillis: Long) { in delay()
117 if (timeMillis <= 0) return // don't delay in delay()
120 if (timeMillis < Long.MAX_VALUE) { in delay()
121 cont.context.delay.scheduleResumeAfterDelay(timeMillis, cont) in delay()
DTimeout.kt38 public suspend fun <T> withTimeout(timeMillis: Long, block: suspend CoroutineScope.() -> T): T { in <lambda>()
42 if (timeMillis <= 0L) throw TimeoutCancellationException("Timed out immediately") in <lambda>()
44 setupTimeout(TimeoutCoroutine(timeMillis, uCont), block) in <lambda>()
96 public suspend fun <T> withTimeoutOrNull(timeMillis: Long, block: suspend CoroutineScope.() -> T): … in withTimeoutOrNull()
97 if (timeMillis <= 0L) return null in withTimeoutOrNull()
102 val timeoutCoroutine = TimeoutCoroutine(timeMillis, uCont) in withTimeoutOrNull()
DEventLoop.common.kt157 internal fun delayToNanos(timeMillis: Long): Long = when { in delayToNanos()
158 timeMillis <= 0 -> 0L in delayToNanos()
159 timeMillis >= MAX_MS -> Long.MAX_VALUE in delayToNanos()
160 else -> timeMillis * MS_TO_NS in delayToNanos()
229 …public override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuati… in scheduleResumeAfterDelay()
230 val timeNanos = delayToNanos(timeMillis) in scheduleResumeAfterDelay()
240 protected fun scheduleInvokeOnTimeout(timeMillis: Long, block: Runnable): DisposableHandle { in scheduleInvokeOnTimeout()
241 val timeNanos = delayToNanos(timeMillis) in scheduleInvokeOnTimeout()
/external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/
DJSDispatcher.kt14 private fun delayToInt(timeMillis: Long): Int = in <lambda>()
15 timeMillis.coerceIn(0, MAX_DELAY).toInt() in <lambda>()
38 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in <lambda>()
39 val handle = setTimeout({ block.run() }, delayToInt(timeMillis)) in <lambda>()
43 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
44 …al handle = setTimeout({ with(continuation) { resumeUndispatched(Unit) } }, delayToInt(timeMillis)) in <lambda>()
80 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in toString()
81 … window.setTimeout({ with(continuation) { resumeUndispatched(Unit) } }, delayToInt(timeMillis)) in toString()
84 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in toString()
85 val handle = window.setTimeout({ block.run() }, delayToInt(timeMillis)) in toString()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/
DVirtualTime.kt54 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in isDispatchNeeded()
55 val task = TimedTask(block, deadline(timeMillis)) in isDispatchNeeded()
60 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
61 …ask = TimedTask(Runnable { with(continuation) { resumeUndispatched(Unit) } }, deadline(timeMillis)) in scheduleResumeAfterDelay()
66 private fun deadline(timeMillis: Long) = in deadline()
67 if (timeMillis == Long.MAX_VALUE) Long.MAX_VALUE else currentTime + timeMillis in deadline()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/
DExecutors.kt107 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
109 … scheduleBlock(ResumeUndispatchedRunnable(this, continuation), continuation.context, timeMillis) in scheduleResumeAfterDelay()
119 DefaultExecutor.scheduleResumeAfterDelay(timeMillis, continuation) in scheduleResumeAfterDelay()
122 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in invokeOnTimeout()
124 scheduleBlock(block, context, timeMillis) in invokeOnTimeout()
130 else -> DefaultExecutor.invokeOnTimeout(timeMillis, block, context) in invokeOnTimeout()
134 …private fun scheduleBlock(block: Runnable, context: CoroutineContext, timeMillis: Long): Scheduled… in scheduleBlock()
136 … (executor as? ScheduledExecutorService)?.schedule(block, timeMillis, TimeUnit.MILLISECONDS) in scheduleBlock()
DDefaultExecutor.kt58 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in invokeOnTimeout()
59 scheduleInvokeOnTimeout(timeMillis, block) in invokeOnTimeout()
/external/apache-commons-compress/src/test/java/org/apache/commons/compress/archivers/zip/
DX5455_ExtendedTimestampTest.java236 final long timeMillis = cal.getTimeInMillis(); in testGettersSetters() local
237 final ZipLong time = new ZipLong(timeMillis / 1000); in testGettersSetters()
252 assertEquals(timeMillis, xfModifyJavaTime.getTime()); in testGettersSetters()
253 xf.setModifyJavaTime(new Date(timeMillis)); in testGettersSetters()
255 assertEquals(timeMillis, xf.getModifyJavaTime().getTime()); in testGettersSetters()
257 xf.setModifyJavaTime(new Date(timeMillis + 123)); in testGettersSetters()
259 assertEquals(timeMillis, xf.getModifyJavaTime().getTime()); in testGettersSetters()
269 assertEquals(timeMillis, xf.getAccessJavaTime().getTime()); in testGettersSetters()
270 xf.setAccessJavaTime(new Date(timeMillis)); in testGettersSetters()
272 assertEquals(timeMillis, xf.getAccessJavaTime().getTime()); in testGettersSetters()
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxScheduler.kt33 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
36 }, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
41 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in asCoroutineDispatcher()
42 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxScheduler.kt33 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
36 }, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
41 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in asCoroutineDispatcher()
42 val disposable = scheduler.scheduleDirect(block, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
/external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/
DCoroutineContext.kt17 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in takeEventLoop()
18 takeEventLoop().scheduleResumeAfterDelay(timeMillis, continuation) in takeEventLoop()
19 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in takeEventLoop()
20 takeEventLoop().invokeOnTimeout(timeMillis, block, context) in takeEventLoop()
DEventLoop.kt17 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in reschedule()
18 scheduleInvokeOnTimeout(timeMillis, block) in reschedule()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DScheduler.kt34 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in asCoroutineDispatcher()
37 }, timeMillis, TimeUnit.MILLISECONDS) in asCoroutineDispatcher()
42 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in asCoroutineDispatcher()
43 scheduler.schedule(block, timeMillis, TimeUnit.MILLISECONDS).asDisposableHandle() in asCoroutineDispatcher()
/external/kotlinx.coroutines/kotlinx-coroutines-test/src/internal/
DMainTestDispatcher.kt41 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in isDispatchNeeded()
42 delay.scheduleResumeAfterDelay(timeMillis, continuation) in isDispatchNeeded()
49 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in invokeOnTimeout()
50 return delay.invokeOnTimeout(timeMillis, block, context) in invokeOnTimeout()
/external/kotlinx.coroutines/ui/kotlinx-coroutines-swing/src/
DSwingDispatcher.kt31 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in dispatch()
32 val timer = schedule(timeMillis, TimeUnit.MILLISECONDS, ActionListener { in dispatch()
39 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in invokeOnTimeout()
40 val timer = schedule(timeMillis, TimeUnit.MILLISECONDS, ActionListener { in invokeOnTimeout()
/external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/
DJavaFxDispatcher.kt37 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
38 val timeline = schedule(timeMillis, TimeUnit.MILLISECONDS, EventHandler { in <lambda>()
45 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in <lambda>()
46 val timeline = schedule(timeMillis, TimeUnit.MILLISECONDS, EventHandler { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-test/src/
DTestCoroutineDispatcher.kt63 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
64 …postDelayed(CancellableContinuationRunnable(continuation) { resumeUndispatched(Unit) }, timeMillis) in <lambda>()
68 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in <lambda>()
69 val node = postDelayed(block, timeMillis) in <lambda>()
/external/kotlinx.coroutines/ui/kotlinx-coroutines-android/src/
DHandlerDispatcher.kt135 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in scheduleResumeAfterDelay()
139 handler.postDelayed(block, timeMillis.coerceAtMost(MAX_DELAY)) in scheduleResumeAfterDelay()
143 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in invokeOnTimeout()
144 handler.postDelayed(block, timeMillis.coerceAtMost(MAX_DELAY)) in invokeOnTimeout()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/test_/
DTestCoroutineContext.kt227 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in <lambda>()
230 }, timeMillis) in <lambda>()
233 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in <lambda>()
234 val node = postDelayed(block, timeMillis) in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/selects/
DSelectUnbiased.kt66 override fun onTimeout(timeMillis: Long, block: suspend () -> R) { in onTimeout()
67 clauses += { instance.onTimeout(timeMillis, block) } in onTimeout()
DSelect.kt55 public fun onTimeout(timeMillis: Long, block: suspend () -> R) in <lambda>()
640 override fun onTimeout(timeMillis: Long, block: suspend () -> R) { in next()
641 if (timeMillis <= 0L) { in next()
652 disposeOnSelect(context.delay.invokeOnTimeout(timeMillis, action, context)) in next()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/internal/
DMainDispatchers.kt96 …override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): Dispos… in isDispatchNeeded()
102 …override fun scheduleResumeAfterDelay(timeMillis: Long, continuation: CancellableContinuation<Unit… in isDispatchNeeded()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DMigration.kt411 public fun <T> Flow<T>.delayFlow(timeMillis: Long): Flow<T> = onStart { delay(timeMillis) } in startWith()
423 public fun <T> Flow<T>.delayEach(timeMillis: Long): Flow<T> = onEach { delay(timeMillis) } in <lambda>()
/external/nist-sip/java/gov/nist/javax/sip/header/
DSIPDate.java166 public SIPDate(long timeMillis) { in SIPDate() argument
171 java.util.Date date = new java.util.Date(timeMillis); in SIPDate()
/external/guice/extensions/struts2/lib/
Dcommons-io-1.3.2.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/ ...

12