summaryrefslogtreecommitdiffstats
path: root/clustercontroller-reindexer/src/test
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-02-19 17:42:49 +0100
committerJon Marius Venstad <venstad@gmail.com>2021-02-19 17:42:49 +0100
commiteaa8348f763045387ae231be51da1782ffe434ec (patch)
treefec0c5f00c0712a32732460bef8079aabe3734c3 /clustercontroller-reindexer/src/test
parenta219da1a7379606860c874a64f94aafb8973d205 (diff)
Assume reindexing is done for ready types when no data/data lost
Diffstat (limited to 'clustercontroller-reindexer/src/test')
-rw-r--r--clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java10
1 files changed, 7 insertions, 3 deletions
diff --git a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java
index 8cf96fa8c45..cd9cf9f845d 100644
--- a/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java
+++ b/clustercontroller-reindexer/src/test/java/ai/vespa/reindexing/ReindexerTest.java
@@ -91,9 +91,9 @@ class ReindexerTest {
@Test
@Timeout(10)
void testReindexing() throws ReindexingLockException {
- // Reindexer is created without any ready document types, which means nothing should run.
- new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex();
- Reindexing reindexing = Reindexing.empty();
+ // Reindexer is created against en empty database, so any ready document types are assumed already done.
+ new Reindexer(cluster, Map.of(music, Instant.ofEpochMilli(-10)), database, ReindexerTest::failIfCalled, metric, clock).reindex();
+ Reindexing reindexing = Reindexing.empty().with(music, Status.ready(Instant.EPOCH).running().successful(Instant.EPOCH));
assertEquals(reindexing, database.readReindexing("cluster"));
// New config tells reindexer to reindex "music" documents no earlier than at 10 millis after EPOCH, which isn't yet.
@@ -156,6 +156,10 @@ class ReindexerTest {
"clusterid", "cluster",
"state", "pending")));
+ // Reindexer is created without any ready document types, which means nothing should run.
+ new Reindexer(cluster, Map.of(), database, ReindexerTest::failIfCalled, metric, clock).reindex();
+ assertEquals(reindexing, database.readReindexing("cluster"));
+
// Last reindexing fails.
clock.advance(Duration.ofMillis(10));
shutDown.set(false);