diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-08-18 12:41:59 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-08-18 12:41:59 +0200 |
commit | 03d3f98f61197b120be99dd40bfae5aff5de1bce (patch) | |
tree | 4938eea044ca90a61f87934282788e21c9f31198 /configserver | |
parent | 8ea8dc943c8efc12fb4f4026457b87dbbe614a93 (diff) |
Revert "Avoid getting session list two times"
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java | 11 |
1 files changed, 6 insertions, 5 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 b38d90d470f..03769d0a537 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 @@ -47,6 +47,7 @@ import java.time.Clock; import java.time.Duration; import java.time.Instant; import java.util.ArrayList; +import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -316,7 +317,8 @@ public class SessionRepository { getRemoteSessions().forEach(this::sessionAdded); } - private synchronized void sessionsChanged(List<Long> sessions) throws NumberFormatException { + private synchronized void sessionsChanged() throws NumberFormatException { + List<Long> sessions = getSessionListFromDirectoryCache(directoryCache.getCurrentData()); checkForRemovedSessions(sessions); checkForAddedSessions(sessions); } @@ -416,15 +418,14 @@ public class SessionRepository { private void childEvent(CuratorFramework ignored, PathChildrenCacheEvent event) { zkWatcherExecutor.execute(() -> { log.log(Level.FINE, () -> "Got child event: " + event); - List<Long> sessions = getSessionListFromDirectoryCache(directoryCache.getCurrentData()); switch (event.getType()) { case CHILD_ADDED: - sessionsChanged(sessions); - synchronizeOnNew(sessions); + sessionsChanged(); + synchronizeOnNew(getSessionListFromDirectoryCache(Collections.singletonList(event.getData()))); break; case CHILD_REMOVED: case CONNECTION_RECONNECTED: - sessionsChanged(sessions); + sessionsChanged(); break; } }); |