diff options
author | HÃ¥kon Hallingstad <hakon@verizonmedia.com> | 2021-08-11 11:10:18 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-08-11 11:10:18 +0200 |
commit | cf714fd5072dcf1c11627cff6fea17b86f585e02 (patch) | |
tree | c6a80b8814e737e76772ae5a768d039474add3ea /configserver | |
parent | 14901467ad821d5dfa0a326ebbdd944c275eb6c9 (diff) | |
parent | 88dcc6b8c0eb00dc8671499ee5ded29b936f6f51 (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.java | 16 |
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 " + |