From 0d75200cc714916f5283fe85cdd38014ff69703b Mon Sep 17 00:00:00 2001
From: Harald Musum <musum@oath.com>
Date: Tue, 26 Sep 2017 08:39:30 +0200
Subject: Check for sessions changed after reconnecting

---
 .../com/yahoo/vespa/config/server/session/RemoteSessionRepo.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

(limited to 'configserver/src')

diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionRepo.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionRepo.java
index d7c973617c2..659a44bb339 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionRepo.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/RemoteSessionRepo.java
@@ -139,7 +139,7 @@ public class RemoteSessionRepo extends SessionRepo<RemoteSession> implements Nod
         return sessions;
     }
 
-    synchronized void sessionsChanged() throws NumberFormatException {
+    private synchronized void sessionsChanged() throws NumberFormatException {
         List<Long> sessions = getSessionList(directoryCache.getCurrentData());
         checkForRemovedSessions(sessions);
         checkForAddedSessions(sessions);
@@ -236,6 +236,9 @@ public class RemoteSessionRepo extends SessionRepo<RemoteSession> implements Nod
             case CHILD_REMOVED:
                 sessionsChanged();
                 break;
+            case CONNECTION_RECONNECTED:
+                sessionsChanged();
+                break;
         }
     }
 
@@ -245,7 +248,6 @@ public class RemoteSessionRepo extends SessionRepo<RemoteSession> implements Nod
             if (session == null) continue; // session might have been deleted after getting session list
             log.log(LogLevel.DEBUG, session.logPre() + "Confirming upload for session " + sessionId);
             session.confirmUpload();
-
         }
     }
 }
-- 
cgit v1.2.3