IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix timetout unit test running on slow machines

Browse Source
This commit is contained in:
Madhavan Sridharan
2024-04-12 17:11:16 -04:00
parent ac61a817c1
commit af3928beed
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
nb-apis/adapters-api/src/test/java/io/nosqlbench/adapters/api/scheduling/TimeoutPredicateTest.java
View File

@@ -1,5 +1,5 @@
/* /*
* Copyright (c) 2024 nosqlbench * Copyright (c) 2020-2024 nosqlbench
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@@ -26,11 +26,11 @@ public class TimeoutPredicateTest {
@Test @Test
public void testNeverCompletablePreciate() { public void testNeverCompletablePreciate() {
int interval=10; int interval = 10;
int timeout=500; int timeout = 500;
TimeoutPredicate<Boolean> wontMakeIt = TimeoutPredicate.of( TimeoutPredicate<Boolean> wontMakeIt = TimeoutPredicate.of(
()->false, () -> false,
l -> l, l -> l,
Duration.ofMillis(timeout), Duration.ofMillis(timeout),
Duration.ofMillis(interval), Duration.ofMillis(interval),
@@ -43,12 +43,12 @@ public class TimeoutPredicateTest {
assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.pending); assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.pending);
resultNow = wontMakeIt.test(); resultNow = wontMakeIt.test();
assertThat(resultNow.duration_ns()).isBetween(10*1_000_000L,50*1_000_000L); assertThat(resultNow.duration_ns()).isBetween(10 * 1_000_000L, 50 * 1_000_000_000L);
assertThat(resultNow.value()).isFalse(); assertThat(resultNow.value()).isFalse();
assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.pending); assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.pending);
while (resultNow.status()== TimeoutPredicate.Status.pending) { while (resultNow.status() == TimeoutPredicate.Status.pending) {
resultNow=wontMakeIt.test(); resultNow = wontMakeIt.test();
} }
assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.incomplete); assertThat(resultNow.status()).isEqualTo(TimeoutPredicate.Status.incomplete);
@@ -57,10 +57,10 @@ public class TimeoutPredicateTest {
@Test @Test
public void testImmediatelyCompletablePreciate() { public void testImmediatelyCompletablePreciate() {
int interval=10; int interval = 10;
int timeout=5000; int timeout = 5000;
TimeoutPredicate<Boolean> canMakeIt = TimeoutPredicate.of( TimeoutPredicate<Boolean> canMakeIt = TimeoutPredicate.of(
()->true, () -> true,
l -> l, l -> l,
Duration.ofMillis(timeout), Duration.ofMillis(timeout),
Duration.ofMillis(interval), Duration.ofMillis(interval),
@@ -77,13 +77,13 @@ public class TimeoutPredicateTest {
@Test @Test
public void testEventuallyCompletePredicate() { public void testEventuallyCompletePredicate() {
int interval=250; int interval = 250;
int timeout=5000; int timeout = 5000;
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
long inASec = now+1000; long inASec = now + 1000;
TimeoutPredicate<Long> canMakeIt = TimeoutPredicate.of( TimeoutPredicate<Long> canMakeIt = TimeoutPredicate.of(
System::currentTimeMillis, System::currentTimeMillis,
l -> l>inASec, l -> l > inASec,
Duration.ofMillis(timeout), Duration.ofMillis(timeout),
Duration.ofMillis(interval), Duration.ofMillis(interval),
true true
@@ -92,9 +92,9 @@ public class TimeoutPredicateTest {
TimeoutPredicate.Result<Long> result = canMakeIt.test(); TimeoutPredicate.Result<Long> result = canMakeIt.test();
System.out.println(result); System.out.println(result);
while (result.status()== TimeoutPredicate.Status.pending) { while (result.status() == TimeoutPredicate.Status.pending) {
// canMakeIt.blockUntilNextInterval(); // canMakeIt.blockUntilNextInterval();
result=canMakeIt.test(); result = canMakeIt.test();
System.out.println(canMakeIt); System.out.println(canMakeIt);
System.out.println(result); System.out.println(result);
} }