summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorValerij Fredriksen <valerijf@oath.com>2017-09-20 18:32:14 +0200
committerValerij Fredriksen <valerijf@oath.com>2017-09-20 18:32:14 +0200
commit3ea481d9ee1271feae1814884497b1394836b81d (patch)
treed4d395ded1c8b74fb393a70496a0add50d55ffd9
parent951171116c4c4449e01fd41f3da2509d9812eb22 (diff)
Moved log
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java7
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/NodeAdminProvider.java14
2 files changed, 14 insertions, 7 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
index d5810f14ea2..d1f23b13e6c 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
@@ -68,7 +68,6 @@ public class NodeAdminStateUpdater {
String dockerHostHostName,
Clock clock,
Duration nodeAdminConvergeStateInterval) {
- log.log(LogLevel.INFO, objectToString() + ": Creating object");
this.nodeRepository = nodeRepository;
this.orchestrator = orchestrator;
this.storageMaintainer = storageMaintainer;
@@ -79,10 +78,6 @@ public class NodeAdminStateUpdater {
this.lastTick = clock.instant();
}
- private String objectToString() {
- return this.getClass().getSimpleName() + "@" + Integer.toString(System.identityHashCode(this));
- }
-
public enum State { RESUMED, SUSPENDED_NODE_ADMIN, SUSPENDED}
public Map<String, Object> getDebugPage() {
@@ -281,7 +276,6 @@ public class NodeAdminStateUpdater {
if (!terminated.compareAndSet(false, true)) {
throw new RuntimeException("Can not re-stop a node agent.");
}
- log.log(LogLevel.INFO, objectToString() + ": Stop called");
// First we need to stop NodeAdminStateUpdater thread to make sure no new NodeAgents are spawned
signalWorkToBeDone();
@@ -297,6 +291,5 @@ public class NodeAdminStateUpdater {
// Finally, stop NodeAdmin and all the NodeAgents
nodeAdmin.stop();
- log.log(LogLevel.INFO, objectToString() + ": Stop complete");
}
}
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/NodeAdminProvider.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/NodeAdminProvider.java
index 5d3e4cd3ec6..f93f089254d 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/NodeAdminProvider.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/provider/NodeAdminProvider.java
@@ -5,6 +5,7 @@ import com.google.inject.Inject;
import com.yahoo.concurrent.lock.Lock;
import com.yahoo.concurrent.lock.Locking;
import com.yahoo.container.di.componentgraph.Provider;
+import com.yahoo.log.LogLevel;
import com.yahoo.net.HostName;
import com.yahoo.system.ProcessExecuter;
@@ -29,6 +30,7 @@ import com.yahoo.vespa.hosted.node.admin.util.Environment;
import java.time.Clock;
import java.time.Duration;
import java.util.function.Function;
+import java.util.logging.Logger;
import static com.yahoo.vespa.defaults.Defaults.getDefaults;
@@ -42,12 +44,15 @@ public class NodeAdminProvider implements Provider<NodeAdminStateUpdater> {
private static final Duration NODE_AGENT_SCAN_INTERVAL = Duration.ofSeconds(30);
private static final Duration NODE_ADMIN_CONVERGE_STATE_INTERVAL = Duration.ofSeconds(30);
+ private final Logger log = Logger.getLogger(NodeAdminProvider.class.getName());
private final NodeAdminStateUpdater nodeAdminStateUpdater;
private final Lock classLock;
@Inject
public NodeAdminProvider(Docker docker, MetricReceiverWrapper metricReceiver, Locking locking) {
+ log.log(LogLevel.INFO, objectToString() + ": Creating object, acquiring lock...");
classLock = locking.lock(this.getClass());
+ log.log(LogLevel.INFO, objectToString() + ": Lock acquired");
Clock clock = Clock.systemUTC();
String dockerHostHostName = HostName.getLocalhost();
@@ -80,7 +85,16 @@ public class NodeAdminProvider implements Provider<NodeAdminStateUpdater> {
@Override
public void deconstruct() {
+ log.log(LogLevel.INFO, objectToString() + ": Stop called");
+
nodeAdminStateUpdater.stop();
+ log.log(LogLevel.INFO, objectToString() + ": Stop complete");
+
classLock.close();
+ log.log(LogLevel.INFO, objectToString() + ": Lock released");
+ }
+
+ private String objectToString() {
+ return this.getClass().getSimpleName() + "@" + Integer.toString(System.identityHashCode(this));
}
}