summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-10-13 15:31:13 +0200
committerHarald Musum <musum@verizonmedia.com>2020-10-13 15:31:13 +0200
commit570146dd4da3ff5f493344fd67a7f670d207e1c0 (patch)
tree8b76002ed59921d0da3f6aed82aed1d0c55da589 /configserver
parent4cc36c34da9a90732adb51be08ffd3368f0e5f61 (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.java11
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);
}
/**