77cf41c189
KT-46132
156 lines
5.5 KiB
Kotlin
156 lines
5.5 KiB
Kotlin
/*
|
|
* Copyright 2010-2022 JetBrains s.r.o. and Kotlin Programming Language contributors.
|
|
* Use of this source code is governed by the Apache 2.0 license that can be found in the license/LICENSE.txt file.
|
|
*/
|
|
|
|
@file:OptIn(ExperimentalTime::class)
|
|
package test.time
|
|
|
|
import kotlin.test.*
|
|
import kotlin.time.*
|
|
import kotlin.time.Duration.Companion.microseconds
|
|
import kotlin.time.Duration.Companion.milliseconds
|
|
import kotlin.time.Duration.Companion.nanoseconds
|
|
|
|
class TimeMarkTest {
|
|
|
|
@Test
|
|
fun adjustment() {
|
|
val timeSource = TestTimeSource()
|
|
|
|
fun TimeMark.assertHasPassed(hasPassed: Boolean) {
|
|
assertEquals(!hasPassed, this.hasNotPassedNow(), "Expected mark in the future")
|
|
assertEquals(hasPassed, this.hasPassedNow(), "Expected mark in the past")
|
|
|
|
assertEquals(
|
|
!hasPassed,
|
|
this.elapsedNow() < Duration.ZERO,
|
|
"Mark elapsed: ${this.elapsedNow()}, expected hasPassed: $hasPassed"
|
|
)
|
|
}
|
|
|
|
val mark = timeSource.markNow()
|
|
val markFuture1 = (mark + 1.milliseconds).apply { assertHasPassed(false) }
|
|
val markFuture2 = (mark - (-1).milliseconds).apply { assertHasPassed(false) }
|
|
|
|
val markPast1 = (mark - 1.milliseconds).apply { assertHasPassed(true) }
|
|
val markPast2 = (markFuture1 + (-2).milliseconds).apply { assertHasPassed(true) }
|
|
|
|
timeSource += 500_000.nanoseconds
|
|
|
|
val elapsed = mark.elapsedNow()
|
|
val elapsedFromFuture = elapsed - 1.milliseconds
|
|
val elapsedFromPast = elapsed + 1.milliseconds
|
|
|
|
assertEquals(0.5.milliseconds, elapsed)
|
|
assertEquals(elapsedFromFuture, markFuture1.elapsedNow())
|
|
assertEquals(elapsedFromFuture, markFuture2.elapsedNow())
|
|
|
|
assertEquals(elapsedFromPast, markPast1.elapsedNow())
|
|
assertEquals(elapsedFromPast, markPast2.elapsedNow())
|
|
|
|
markFuture1.assertHasPassed(false)
|
|
markPast1.assertHasPassed(true)
|
|
|
|
timeSource += 1.milliseconds
|
|
|
|
markFuture1.assertHasPassed(true)
|
|
markPast1.assertHasPassed(true)
|
|
|
|
}
|
|
|
|
fun testAdjustmentInfinite(timeSource: TimeSource) {
|
|
val baseMark = timeSource.markNow()
|
|
val infiniteFutureMark = baseMark + Duration.INFINITE
|
|
val infinitePastMark = baseMark - Duration.INFINITE
|
|
|
|
assertEquals(-Duration.INFINITE, infiniteFutureMark.elapsedNow())
|
|
assertTrue(infiniteFutureMark.hasNotPassedNow())
|
|
|
|
assertEquals(Duration.INFINITE, infinitePastMark.elapsedNow())
|
|
assertTrue(infinitePastMark.hasPassedNow())
|
|
|
|
assertFailsWith<IllegalArgumentException> { infiniteFutureMark - Duration.INFINITE }
|
|
assertFailsWith<IllegalArgumentException> { infinitePastMark + Duration.INFINITE }
|
|
|
|
|
|
val longDuration = Long.MAX_VALUE.nanoseconds
|
|
val long2Duration = longDuration * 2
|
|
|
|
val pastMark = baseMark - longDuration
|
|
val futureMark = pastMark + long2Duration
|
|
val sameMark = futureMark - longDuration
|
|
val elapsedDiff = sameMark.elapsedNow() - baseMark.elapsedNow()
|
|
assertTrue(elapsedDiff < 1.milliseconds, "$elapsedDiff")
|
|
}
|
|
|
|
@Test
|
|
fun adjustmentInfinite() {
|
|
testAdjustmentInfinite(TestTimeSource())
|
|
}
|
|
|
|
fun testLongDisplacement(timeSource: TimeSource, wait: (Duration) -> Unit) {
|
|
val baseMark = timeSource.markNow()
|
|
val longDuration = Long.MAX_VALUE.nanoseconds
|
|
val waitDuration = 10.milliseconds
|
|
val pastMark = baseMark - longDuration
|
|
wait(waitDuration)
|
|
val elapsed = pastMark.elapsedNow()
|
|
assertTrue(elapsed > longDuration)
|
|
assertTrue(elapsed >= longDuration + waitDuration)
|
|
}
|
|
|
|
@Test
|
|
fun longDisplacement() {
|
|
val timeSource = TestTimeSource()
|
|
testLongDisplacement(timeSource, { waitDuration -> timeSource += waitDuration })
|
|
}
|
|
|
|
@Test
|
|
fun defaultTimeMarkAdjustment() {
|
|
val baseMark = TimeSource.Monotonic.markNow()
|
|
|
|
var markBefore = baseMark
|
|
markBefore -= 100.microseconds
|
|
markBefore -= 100.microseconds
|
|
|
|
val markAfter = baseMark + 100.microseconds
|
|
|
|
MeasureTimeTest.longRunningCalc()
|
|
|
|
val elapsedAfter = markAfter.elapsedNow()
|
|
val elapsedBase = baseMark.elapsedNow()
|
|
val elapsedBefore = markBefore.elapsedNow()
|
|
assertTrue(elapsedBefore >= elapsedBase + 200.microseconds)
|
|
assertTrue(elapsedAfter <= elapsedBase - 100.microseconds)
|
|
}
|
|
|
|
@Test
|
|
fun defaultTimeMarkAdjustmentInfinite() {
|
|
testAdjustmentInfinite(TimeSource.Monotonic)
|
|
|
|
// do the same with specialized methods
|
|
val baseMark = TimeSource.Monotonic.markNow()
|
|
val infiniteFutureMark = baseMark + Duration.INFINITE
|
|
val infinitePastMark = baseMark - Duration.INFINITE
|
|
|
|
assertEquals(-Duration.INFINITE, infiniteFutureMark.elapsedNow())
|
|
assertTrue(infiniteFutureMark.hasNotPassedNow())
|
|
|
|
assertEquals(Duration.INFINITE, infinitePastMark.elapsedNow())
|
|
assertTrue(infinitePastMark.hasPassedNow())
|
|
|
|
assertFailsWith<IllegalArgumentException> { infiniteFutureMark - Duration.INFINITE }
|
|
assertFailsWith<IllegalArgumentException> { infinitePastMark + Duration.INFINITE }
|
|
|
|
val longDuration = Long.MAX_VALUE.nanoseconds
|
|
val long2Duration = longDuration * 2
|
|
|
|
val pastMark = baseMark - longDuration
|
|
val futureMark = pastMark + long2Duration
|
|
val sameMark = futureMark - longDuration
|
|
val elapsedDiff = sameMark.elapsedNow() - baseMark.elapsedNow()
|
|
assertTrue(elapsedDiff < 1.milliseconds, "$elapsedDiff")
|
|
}
|
|
}
|