diff options
author | Harald Musum <musum@verizonmedia.com> | 2020-10-13 15:31:13 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2020-10-13 15:31:13 +0200 |
commit | 570146dd4da3ff5f493344fd67a7f670d207e1c0 (patch) | |
tree | 8b76002ed59921d0da3f6aed82aed1d0c55da589 /configserver | |
parent | 4cc36c34da9a90732adb51be08ffd3368f0e5f61 (diff) |
Split out method for creating local session
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java | 11 |
1 files changed, 8 insertions, 3 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 155d3093fc5..497560386b1 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 @@ -139,7 +139,7 @@ public class SessionRepository { for (File session : sessions) { try { - addLocalSession(createSessionFromId(Long.parseLong(session.getName()))); + createSessionFromId(Long.parseLong(session.getName())); } catch (IllegalArgumentException e) { log.log(Level.WARNING, "Could not load session '" + session.getAbsolutePath() + "':" + e.getMessage() + ", skipping it."); @@ -604,11 +604,16 @@ public class SessionRepository { /** * Returns a new session instance for the given session id. */ - LocalSession createSessionFromId(long sessionId) { + void createSessionFromId(long sessionId) { File sessionDir = getAndValidateExistingSessionAppDir(sessionId); ApplicationPackage applicationPackage = FilesApplicationPackage.fromFile(sessionDir); + createLocalSession(sessionId, applicationPackage); + } + + void createLocalSession(long sessionId, ApplicationPackage applicationPackage) { SessionZooKeeperClient sessionZKClient = createSessionZooKeeperClient(sessionId); - return new LocalSession(tenantName, sessionId, applicationPackage, sessionZKClient); + LocalSession session = new LocalSession(tenantName, sessionId, applicationPackage, sessionZKClient); + addLocalSession(session); } /** |