summaryrefslogtreecommitdiffstats
path: root/configserver
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-10-12 16:21:39 +0200
committerHarald Musum <musum@verizonmedia.com>2020-10-12 16:21:39 +0200
commit1ef0bd9b40c4800bf6bdfac6afb7981bb43506aa (patch)
treeae139d793cc73388f804addb0026a0c265e5b65c /configserver
parent12895da5969bc194656955e97363441d8edbc8cf (diff)
Rename methods
Diffstat (limited to 'configserver')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/application/TenantApplications.java2
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java8
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java1
3 files changed, 4 insertions, 7 deletions
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<Applica
: data.map(bytes -> 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);