summaryrefslogtreecommitdiffstats
path: root/configserver/src/main
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-12-14 10:13:51 +0100
committerHarald Musum <musum@yahooinc.com>2022-12-14 10:13:51 +0100
commit58460f14d4d8a793f6df0c757978e9c9264b9260 (patch)
treedf7e2425dd6b4c0644656c62fbc220cc2afb38af /configserver/src/main
parent84e7048acbc7750ab5096a9cc09480e9d520977d (diff)
Move check and throwing into method, no need for optional
Diffstat (limited to 'configserver/src/main')
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java6
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java3
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java5
3 files changed, 5 insertions, 9 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
index 903323fcd58..835381b316d 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
@@ -17,7 +17,6 @@ import com.yahoo.config.provision.Tags;
import com.yahoo.config.provision.TenantName;
import com.yahoo.path.Path;
import com.yahoo.transaction.Transaction;
-import com.yahoo.vespa.config.server.NotFoundException;
import com.yahoo.vespa.config.server.application.ApplicationSet;
import com.yahoo.vespa.config.server.tenant.TenantRepository;
import java.security.cert.X509Certificate;
@@ -158,10 +157,7 @@ public abstract class Session implements Comparable<Session> {
}
/** Returns application id read from ZooKeeper. Will throw RuntimeException if not found */
- public ApplicationId getApplicationId() {
- return sessionZooKeeperClient.readApplicationId()
- .orElseThrow(() -> new NotFoundException("Unable to read application id for session " + sessionId));
- }
+ public ApplicationId getApplicationId() { return sessionZooKeeperClient.readApplicationId(); }
public Tags getTags() {
return sessionZooKeeperClient.readTags();
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 07aca116683..d3ac3ec3100 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
@@ -873,8 +873,7 @@ public class SessionRepository {
log.log(Level.FINE, () -> "File reference for session id " + sessionId + ": " + fileReference + " not found");
return;
}
- ApplicationId applicationId = sessionZKClient.readApplicationId()
- .orElseThrow(() -> new RuntimeException("Could not find application id for session " + sessionId));
+ ApplicationId applicationId = sessionZKClient.readApplicationId();
log.log(Level.FINE, () -> "Creating local session for tenant '" + tenantName + "' with session id " + sessionId);
try {
createLocalSession(sessionDir, applicationId, sessionZKClient.readTags(), sessionId);
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
index 9218b03af1e..37688e2676c 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java
@@ -169,8 +169,9 @@ public class SessionZooKeeperClient {
curator.set(applicationIdPath(), Utf8.toBytes(id.serializedForm()));
}
- public Optional<ApplicationId> readApplicationId() {
- return curator.getData(applicationIdPath()).map(d -> ApplicationId.fromSerializedForm(Utf8.toString(d)));
+ public ApplicationId readApplicationId() {
+ return curator.getData(applicationIdPath()).map(d -> ApplicationId.fromSerializedForm(Utf8.toString(d)))
+ .orElseThrow(() -> new RuntimeException("Could not find application id for session " + sessionId));
}
private Path tagsPath() {