summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-08-10 20:39:34 +0200
committerHarald Musum <musum@verizonmedia.com>2020-08-10 20:39:34 +0200
commit5c85893f4890f68252e71ceed23536433f8aa8b6 (patch)
treedcab445c985abfd9f6fe1fc44e8f479f29ba3a63
parent516581084e0068427f9aa03386aab4f788e24c28 (diff)
Do not add sessions with status DELETE
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java3
1 files changed, 3 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
index 0d4bd33d75f..389b661909e 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
@@ -341,6 +341,9 @@ public class SessionRepository {
* @param sessionId session id for the new session
*/
public void sessionAdded(long sessionId) {
+ SessionZooKeeperClient sessionZKClient = createSessionZooKeeperClient(sessionId);
+ if (sessionZKClient.readStatus().equals(Session.Status.DELETE)) return;
+
log.log(Level.FINE, () -> "Adding remote session to SessionRepository: " + sessionId);
RemoteSession remoteSession = createRemoteSession(sessionId);
loadSessionIfActive(remoteSession);