summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHÃ¥kon Hallingstad <hakon@verizonmedia.com>2021-08-11 11:10:18 +0200
committerGitHub <noreply@github.com>2021-08-11 11:10:18 +0200
commitcf714fd5072dcf1c11627cff6fea17b86f585e02 (patch)
treec6a80b8814e737e76772ae5a768d039474add3ea /configserver
parent14901467ad821d5dfa0a326ebbdd944c275eb6c9 (diff)
parent88dcc6b8c0eb00dc8671499ee5ded29b936f6f51 (diff)
Merge pull request #18710 from vespa-engine/hakonhall/improve-completion-waiter-debug-logging
Improve completion waiter debug logging
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java16
1 files changed, 9 insertions, 7 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
index e8c652b3152..307ed225d89 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionStateWatcher.java
@@ -46,8 +46,6 @@ public class SessionStateWatcher {
private synchronized void sessionStatusChanged(Status newStatus) {
long sessionId = session.getSessionId();
- log.fine("Session " + sessionId + " for " + session.getApplicationId() + " changed: " + newStatus);
-
switch (newStatus) {
case NEW:
case UNKNOWN:
@@ -69,8 +67,6 @@ public class SessionStateWatcher {
default:
throw new IllegalStateException("Unknown status " + newStatus);
}
-
- log.fine("Session " + sessionId + " for " + session.getApplicationId() + " changed: " + newStatus + " [DONE]");
}
private void createLocalSession(long sessionId) {
@@ -96,10 +92,16 @@ public class SessionStateWatcher {
ChildData node = fileCache.getCurrentData();
if (node != null) {
newStatus = Status.parse(Utf8.toString(node.getData()));
- if (log.isLoggable(Level.FINE))
- log.log(Level.FINE, session.logPre() + "Session change: Session "
- + session.getSessionId() + " changed status to " + newStatus.name());
+
+ String debugMessage = log.isLoggable(Level.FINE) ?
+ session.logPre() + "Session " + session.getSessionId()
+ + " changed status to " + newStatus.name() :
+ null;
+ if (debugMessage != null) log.fine(debugMessage);
+
sessionStatusChanged(newStatus);
+
+ if (debugMessage != null) log.fine(debugMessage + ": Done");
}
} catch (Exception e) {
log.log(Level.WARNING, session.logPre() + "Error handling session change to " +