aboutsummaryrefslogtreecommitdiffstats
path: root/container-disc/src
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-11-30 10:04:50 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2022-11-30 10:04:50 +0100
commit448231f18ba53edf5c0e7ab4b6732ef69328281c (patch)
tree289f528fd6adac2a39e636c449c633c26fdb838e /container-disc/src
parent711362f17d4bbece0dc2d0833a22063374ae3e04 (diff)
Reduce the simple usage of guava where java has caught up
Diffstat (limited to 'container-disc/src')
-rw-r--r--container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java14
1 files changed, 6 insertions, 8 deletions
diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
index 9c2d703e1a8..0b8c0c8c48c 100644
--- a/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
+++ b/container-disc/src/main/java/com/yahoo/container/jdisc/ConfiguredApplication.java
@@ -1,7 +1,6 @@
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.container.jdisc;
-import com.google.common.util.concurrent.AtomicDouble;
import com.google.inject.AbstractModule;
import com.google.inject.Inject;
import com.google.inject.Injector;
@@ -58,7 +57,6 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.Phaser;
-import java.util.concurrent.atomic.AtomicBoolean;
import java.util.logging.Level;
import java.util.logging.Logger;
@@ -79,8 +77,8 @@ public final class ConfiguredApplication implements Application {
private final String configId;
private final OsgiFramework osgiFramework;
private final com.yahoo.jdisc.Timer timerSingleton;
- private final AtomicBoolean dumpHeapOnShutdownTimeout = new AtomicBoolean(false);
- private final AtomicDouble shutdownTimeoutS = new AtomicDouble(50.0);
+ private volatile boolean dumpHeapOnShutdownTimeout = false;
+ private volatile double shutdownTimeoutS = 50.0;
// Subscriber that is used when this is not a standalone-container. Subscribes
// to config to make sure that container will be registered in slobrok (by {@link com.yahoo.jrt.slobrok.api.Register})
// if slobrok config changes (typically slobroks moving to other nodes)
@@ -286,8 +284,8 @@ public final class ConfiguredApplication implements Application {
}
private void reconfigure(QrConfig.Shutdown shutdown) {
- dumpHeapOnShutdownTimeout.set(shutdown.dumpHeapOnTimeout());
- shutdownTimeoutS.set(shutdown.timeout());
+ dumpHeapOnShutdownTimeout = shutdown.dumpHeapOnTimeout();
+ shutdownTimeoutS = shutdown.timeout();
}
private void initializeAndActivateContainer(ContainerBuilder builder, Runnable cleanupTask) {
@@ -429,7 +427,7 @@ public final class ConfiguredApplication implements Application {
@Override
public void stop() {
log.info("Stop: Initiated");
- shutdownDeadline.schedule((long)(shutdownTimeoutS.get() * 1000), dumpHeapOnShutdownTimeout.get());
+ shutdownDeadline.schedule((long)(shutdownTimeoutS * 1000), dumpHeapOnShutdownTimeout);
stopServersAndAwaitTermination();
log.info("Stop: Finished");
}
@@ -438,7 +436,7 @@ public final class ConfiguredApplication implements Application {
log.info("PrepareStop: Initiated");
long timeoutMillis = (long) (request.parameters().get(0).asDouble() * 1000);
try (ShutdownDeadline ignored =
- new ShutdownDeadline(configId).schedule(timeoutMillis, dumpHeapOnShutdownTimeout.get())) {
+ new ShutdownDeadline(configId).schedule(timeoutMillis, dumpHeapOnShutdownTimeout)) {
stopServersAndAwaitTermination();
log.info("PrepareStop: Finished");
} catch (Exception e) {