diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-08-10 20:39:34 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-08-10 20:39:34 +0200 |
commit | 5c85893f4890f68252e71ceed23536433f8aa8b6 (patch) | |
tree | dcab445c985abfd9f6fe1fc44e8f479f29ba3a63 | |
parent | 516581084e0068427f9aa03386aab4f788e24c28 (diff) |
Do not add sessions with status DELETE
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java | 3 |
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); |