From 1ef0bd9b40c4800bf6bdfac6afb7981bb43506aa Mon Sep 17 00:00:00 2001 From: Harald Musum Date: Mon, 12 Oct 2020 16:21:39 +0200 Subject: Rename methods --- .../yahoo/vespa/config/server/application/TenantApplications.java | 2 +- .../com/yahoo/vespa/config/server/session/SessionRepository.java | 8 +++----- .../com/yahoo/vespa/config/server/tenant/TenantRepository.java | 1 - 3 files changed, 4 insertions(+), 7 deletions(-) (limited to 'configserver') diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/application/TenantApplications.java b/configserver/src/main/java/com/yahoo/vespa/config/server/application/TenantApplications.java index 064e945041b..844964fb57c 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/application/TenantApplications.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/application/TenantApplications.java @@ -138,7 +138,7 @@ public class TenantApplications implements RequestHandler, HostValidator Long.parseLong(Utf8.toString(bytes))); } - public boolean hasLocalSession(long sessionId) { + public boolean sessionExistsInFileSystem(long sessionId) { return Files.exists(Paths.get(tenantFileSystemDirs.sessionsPath().getAbsolutePath(), String.valueOf(sessionId))); } 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 9e0d6c3d94d..de42dadaa96 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 @@ -32,7 +32,6 @@ import com.yahoo.vespa.config.server.zookeeper.ConfigCurator; import com.yahoo.vespa.config.server.zookeeper.SessionCounter; import com.yahoo.vespa.curator.Curator; import com.yahoo.vespa.defaults.Defaults; -import com.yahoo.vespa.flags.FlagSource; import org.apache.curator.framework.CuratorFramework; import org.apache.curator.framework.recipes.cache.ChildData; import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent; @@ -93,7 +92,6 @@ public class SessionRepository { public SessionRepository(TenantName tenantName, GlobalComponentRegistry componentRegistry, TenantApplications applicationRepo, - FlagSource flagSource, SessionPreparer sessionPreparer) { this.tenantName = tenantName; this.componentRegistry = componentRegistry; @@ -114,7 +112,7 @@ public class SessionRepository { private void loadSessions() { loadLocalSessions(); - initializeRemoteSessions(); + loadRemoteSessions(); } // ---------------- Local sessions ---------------------------------------------------------------- @@ -291,7 +289,7 @@ public class SessionRepository { return children.stream().map(Long::parseLong).collect(Collectors.toList()); } - private void initializeRemoteSessions() throws NumberFormatException { + private void loadRemoteSessions() throws NumberFormatException { getRemoteSessions().forEach(this::sessionAdded); } @@ -655,7 +653,7 @@ public class SessionRepository { * Will also add the session to the local session cache if necessary */ public void createLocalSessionUsingDistributedApplicationPackage(long sessionId) { - if (applicationRepo.hasLocalSession(sessionId)) { + if (applicationRepo.sessionExistsInFileSystem(sessionId)) { log.log(Level.FINE, () -> "Local session for session id " + sessionId + " already exists"); createSessionFromId(sessionId); return; diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java index 57e49fe365a..5ddad540d8e 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java @@ -246,7 +246,6 @@ public class TenantRepository { SessionRepository sessionRepository = new SessionRepository(tenantName, componentRegistry, applicationRepo, - componentRegistry.getFlagSource(), componentRegistry.getSessionPreparer()); log.log(Level.INFO, "Adding tenant '" + tenantName + "'" + ", created " + created); Tenant tenant = new Tenant(tenantName, sessionRepository, applicationRepo, applicationRepo, created); -- cgit v1.2.3