diff options
author | jonmv <venstad@gmail.com> | 2022-04-19 17:03:12 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-04-19 17:03:12 +0200 |
commit | a497897c701bc6f9c7579841df6d1d1dde1a13c5 (patch) | |
tree | 1fc079cb9d80c4b5c94710bf0198fcd4919d13fe /node-admin | |
parent | 281706c90b8946e05f583d4700716ae65b79f1d6 (diff) |
Arrive instead, when stopping for suspension
Diffstat (limited to 'node-admin')
-rw-r--r-- | node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integration/ContainerTester.java | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integration/ContainerTester.java b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integration/ContainerTester.java index c5ab858220f..8d3df700c2d 100644 --- a/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integration/ContainerTester.java +++ b/node-admin/src/test/java/com/yahoo/vespa/hosted/node/admin/integration/ContainerTester.java @@ -93,16 +93,13 @@ public class ContainerTester implements AutoCloseable { storageMaintainer, flagSource, Collections.emptyList(), Optional.empty(), Optional.empty(), clock, Duration.ofSeconds(-1), VespaServiceDumper.DUMMY_INSTANCE) { - AtomicBoolean stopped = new AtomicBoolean(); @Override public void converge(NodeAgentContext context) { super.converge(context); phaser.arriveAndAwaitAdvance(); } @Override public void stopForHostSuspension(NodeAgentContext context) { - if (stopped.compareAndSet(false, true)) { - super.stopForHostSuspension(context); - phaser.arriveAndDeregister(); - } + super.stopForHostSuspension(context); + phaser.arriveAndAwaitAdvance(); } }; nodeAdmin = new NodeAdminImpl(nodeAgentFactory, metrics, clock, Duration.ofMillis(10), Duration.ZERO); @@ -113,7 +110,7 @@ public class ContainerTester implements AutoCloseable { loopThread = new Thread(() -> { nodeAdminStateUpdater.start(); - while ( !phaser.isTerminated()) { + while ( ! phaser.isTerminated()) { try { nodeAdminStateUpdater.converge(wantedState); } catch (RuntimeException e) { |