aboutsummaryrefslogtreecommitdiffstats
path: root/configserver/src/test/java/com/yahoo
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-08-29 10:49:33 +0200
committerHarald Musum <musum@yahooinc.com>2023-08-29 10:49:33 +0200
commit02fd4b6ffed00deef6dacf6d76687762388385eb (patch)
tree1ed0c6f6cd8d72752cc5e3ae380c9257e9a76105 /configserver/src/test/java/com/yahoo
parent1057007296b8888aaa87ae4b263509d809fc21ce (diff)
Read session data in just one place and always fallback to reading old format if new is unreadable
Diffstat (limited to 'configserver/src/test/java/com/yahoo')
-rw-r--r--configserver/src/test/java/com/yahoo/vespa/config/server/application/ApplicationCuratorDatabaseTest.java32
1 files changed, 16 insertions, 16 deletions
diff --git a/configserver/src/test/java/com/yahoo/vespa/config/server/application/ApplicationCuratorDatabaseTest.java b/configserver/src/test/java/com/yahoo/vespa/config/server/application/ApplicationCuratorDatabaseTest.java
index 8d1b22c94c5..80f705dcbad 100644
--- a/configserver/src/test/java/com/yahoo/vespa/config/server/application/ApplicationCuratorDatabaseTest.java
+++ b/configserver/src/test/java/com/yahoo/vespa/config/server/application/ApplicationCuratorDatabaseTest.java
@@ -51,15 +51,8 @@ public class ApplicationCuratorDatabaseTest {
assertEquals(Optional.empty(), db.applicationData(id)); // still empty, as no data has been written to node
db.createApplication(id, true);
- try {
- Optional<ApplicationData> applicationData = db.applicationData(id);
- fail("Expected exception, got " + applicationData);
- } catch (NumberFormatException e) {
- // expected
- }
-
// Can be read as json, but no active session or last deployed session
- Optional<ApplicationData> applicationData = db.applicationData(id, true);
+ Optional<ApplicationData> applicationData = db.applicationData(id);
assertTrue(applicationData.isPresent());
assertEquals(id, applicationData.get().applicationId());
assertFalse(applicationData.get().activeSession().isPresent());
@@ -74,11 +67,18 @@ public class ApplicationCuratorDatabaseTest {
t.commit();
}
// Can be read as session id only
- applicationData = db.applicationData(id, false);
+ applicationData = db.applicationData(id);
+ assertTrue(applicationData.isPresent());
+ assertEquals(id, applicationData.get().applicationId());
+ assertTrue(applicationData.get().activeSession().isPresent());
+ assertEquals(2, applicationData.get().activeSession().get().longValue());
+ assertFalse(applicationData.get().lastDeployedSession().isPresent());
+ // Can be read as session data as well
+ applicationData = db.applicationData(id);
assertTrue(applicationData.isPresent());
assertEquals(id, applicationData.get().applicationId());
assertTrue(applicationData.get().activeSession().isPresent());
- assertEquals(2, applicationData.get().activeSession().getAsLong());
+ assertEquals(2, applicationData.get().activeSession().get().longValue());
assertFalse(applicationData.get().lastDeployedSession().isPresent());
// Prepare session 3, last deployed session is still 2
@@ -86,25 +86,25 @@ public class ApplicationCuratorDatabaseTest {
t.commit();
}
// Can be read as json, active session is still 2 and last deployed session is 3
- applicationData = db.applicationData(id, true);
+ applicationData = db.applicationData(id);
assertTrue(applicationData.isPresent());
assertEquals(id, applicationData.get().applicationId());
assertTrue(applicationData.get().activeSession().isPresent());
- assertEquals(2, applicationData.get().activeSession().getAsLong());
+ assertEquals(2L, applicationData.get().activeSession().get().longValue());
assertTrue(applicationData.get().lastDeployedSession().isPresent());
- assertEquals(3, applicationData.get().lastDeployedSession().getAsLong());
+ assertEquals(3, applicationData.get().lastDeployedSession().get().longValue());
try (var t = db.createWriteActiveTransaction(new CuratorTransaction(curator), id, 3, true)) {
t.commit();
}
// Can be read as json, active session and last deployed session present
- applicationData = db.applicationData(id, true);
+ applicationData = db.applicationData(id);
assertTrue(applicationData.isPresent());
assertEquals(id, applicationData.get().applicationId());
assertTrue(applicationData.get().activeSession().isPresent());
- assertEquals(3, applicationData.get().activeSession().getAsLong());
+ assertEquals(3, applicationData.get().activeSession().get().longValue());
assertTrue(applicationData.get().lastDeployedSession().isPresent());
- assertEquals(3, applicationData.get().lastDeployedSession().getAsLong());
+ assertEquals(3, applicationData.get().lastDeployedSession().get().longValue());
}
}