aboutsummaryrefslogtreecommitdiffstats
path: root/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java
diff options
context:
space:
mode:
Diffstat (limited to 'configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java8
1 files changed, 6 insertions, 2 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java
index eb4047e5fea..6a56be89c6a 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionStateWatcher.java
@@ -72,13 +72,17 @@ public class RemoteSessionStateWatcher {
private void nodeChanged() {
zkWatcherExecutor.execute(() -> {
+ Session.Status currentStatus = session.getStatus();
+ Session.Status newStatus = Session.Status.NONE;
try {
ChildData node = fileCache.getCurrentData();
if (node != null) {
- sessionChanged(Session.Status.parse(Utf8.toString(node.getData())));
+ newStatus = Session.Status.parse(Utf8.toString(node.getData()));
+ sessionChanged(newStatus);
}
} catch (Exception e) {
- log.log(Level.WARNING, session.logPre() + "Error handling session changed for session " + getSessionId(), e);
+ log.log(Level.WARNING, session.logPre() + "Error handling session change from " + currentStatus.name() +
+ " to " + newStatus.name() + " for session " + getSessionId(), e);
metrics.incSessionChangeErrors();
}
});