summaryrefslogtreecommitdiffstats
path: root/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java')
-rw-r--r--vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java
index 52b8dcc5884..f5ca70fe291 100644
--- a/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java
+++ b/vespa-feed-client/src/test/java/ai/vespa/feed/client/impl/GracePeriodCircuitBreakerTest.java
@@ -19,39 +19,39 @@ class GracePeriodCircuitBreakerTest {
@Test
void testCircuitBreaker() {
- AtomicLong nowNanos = new AtomicLong(0);
- long SECOND = 1_000_000_000L;
- CircuitBreaker breaker = new GracePeriodCircuitBreaker(nowNanos::get, Duration.ofSeconds(1), Duration.ofMinutes(1));
+ AtomicLong now = new AtomicLong(0);
+ long SECOND = 1000;
+ CircuitBreaker breaker = new GracePeriodCircuitBreaker(now::get, Duration.ofSeconds(1), Duration.ofMinutes(1));
Throwable error = new Error();
assertEquals(CLOSED, breaker.state(), "Initial state is closed");
- nowNanos.addAndGet(100 * SECOND);
+ now.addAndGet(100 * SECOND);
assertEquals(CLOSED, breaker.state(), "State is closed after some time without activity");
breaker.success();
assertEquals(CLOSED, breaker.state(), "State is closed after a success");
- nowNanos.addAndGet(100 * SECOND);
+ now.addAndGet(100 * SECOND);
assertEquals(CLOSED, breaker.state(), "State is closed some time after a success");
breaker.failure(error);
assertEquals(CLOSED, breaker.state(), "State is closed right after a failure");
- nowNanos.addAndGet(SECOND);
+ now.addAndGet(SECOND);
assertEquals(CLOSED, breaker.state(), "State is closed until grace period has passed");
- nowNanos.addAndGet(1);
+ now.addAndGet(1);
assertEquals(HALF_OPEN, breaker.state(), "State is half-open when grace period has passed");
breaker.success();
assertEquals(CLOSED, breaker.state(), "State is closed after a new success");
breaker.failure(error);
- nowNanos.addAndGet(60 * SECOND);
+ now.addAndGet(60 * SECOND);
assertEquals(HALF_OPEN, breaker.state(), "State is half-open until doom period has passed");
- nowNanos.addAndGet(1);
+ now.addAndGet(1);
assertEquals(OPEN, breaker.state(), "State is open when doom period has passed");
breaker.success();