summaryrefslogtreecommitdiffstats
path: root/clustercontroller-reindexer
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-07-09 15:32:54 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-07-09 15:32:54 +0200
commit48d4f8d2efa768fa388af45a5156c0b8aa8ca25e (patch)
tree8d7332573f9657159ce49c3b0584bc3076570023 /clustercontroller-reindexer
parent0d970eb166d94b44af3c6a3c58ee3c8f704e5fb2 (diff)
Avoid thread-unsafe use of ProgressToken
Diffstat (limited to 'clustercontroller-reindexer')
-rw-r--r--clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexing.java10
-rw-r--r--clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java4
2 files changed, 7 insertions, 7 deletions
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexing.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexing.java
index 1b5a685b69c..896b9dfc26e 100644
--- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexing.java
+++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/Reindexing.java
@@ -72,11 +72,11 @@ public class Reindexing {
private final Instant startedAt;
private final Instant endedAt;
- private final ProgressToken progress;
+ private final String progress;
private final State state;
private final String message;
- Status(Instant startedAt, Instant endedAt, ProgressToken progress, State state, String message) {
+ Status(Instant startedAt, Instant endedAt, String progress, State state, String message) {
this.startedAt = startedAt;
this.endedAt = endedAt;
this.progress = progress;
@@ -100,7 +100,9 @@ public class Reindexing {
public Status progressed(ProgressToken progress) {
if (state != State.RUNNING)
throw new IllegalStateException("Current state must be RUNNING when updating progress");
- return new Status(startedAt, null, requireNonNull(progress), state, null);
+ synchronized (progress) {
+ return new Status(startedAt, null, progress.serializeToString(), state, null);
+ }
}
/** Returns a copy of this in state HALTED. */
@@ -133,7 +135,7 @@ public class Reindexing {
}
public Optional<ProgressToken> progress() {
- return Optional.ofNullable(progress);
+ return Optional.ofNullable(progress).map(ProgressToken::fromSerializedString);
}
public State state() {
diff --git a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java
index d46ab812aca..6074ce99101 100644
--- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java
+++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java
@@ -5,7 +5,6 @@ import ai.vespa.reindexing.Reindexing.Status;
import com.google.common.util.concurrent.UncheckedTimeoutException;
import com.yahoo.document.DocumentType;
import com.yahoo.document.DocumentTypeManager;
-import com.yahoo.documentapi.ProgressToken;
import com.yahoo.path.Path;
import com.yahoo.slime.Cursor;
import com.yahoo.slime.Inspector;
@@ -17,7 +16,6 @@ import com.yahoo.yolean.Exceptions;
import java.time.Duration;
import java.time.Instant;
-import java.util.Collection;
import java.util.Map;
import java.util.function.Function;
@@ -126,7 +124,7 @@ public class ReindexingCurator {
.collect(toUnmodifiableMap(object -> require(TYPE, object, field -> types.getDocumentType(field.asString())),
object -> new Status(require(STARTED_MILLIS, object, field -> Instant.ofEpochMilli(field.asLong())),
get(ENDED_MILLIS, object, field -> Instant.ofEpochMilli(field.asLong())),
- get(PROGRESS, object, field -> ProgressToken.fromSerializedString(field.asString())),
+ get(PROGRESS, object, field -> field.asString()),
require(STATE, object, field -> toState(field.asString())),
get(MESSAGE, object, field -> field.asString())))));
}