diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-07-09 16:05:44 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-07-09 16:05:44 +0200 |
commit | 8163b9f2542386cd0358162c5ce793c87b234135 (patch) | |
tree | 1ac9311ff3a2cd97e521e50eccacf0d17de8b988 /clustercontroller-reindexer/src | |
parent | 48d4f8d2efa768fa388af45a5156c0b8aa8ca25e (diff) |
Add logging to ReindexingCurator
Diffstat (limited to 'clustercontroller-reindexer/src')
-rw-r--r-- | clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java | 12 |
1 files changed, 10 insertions, 2 deletions
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 6074ce99101..67816ad0be1 100644 --- a/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java +++ b/clustercontroller-reindexer/src/main/java/ai/vespa/reindexing/ReindexingCurator.java @@ -18,6 +18,8 @@ import java.time.Duration; import java.time.Instant; import java.util.Map; import java.util.function.Function; +import java.util.logging.Level; +import java.util.logging.Logger; import static java.util.Objects.requireNonNull; import static java.util.stream.Collectors.toUnmodifiableMap; @@ -29,6 +31,8 @@ import static java.util.stream.Collectors.toUnmodifiableMap; */ public class ReindexingCurator { + private static final Logger log = Logger.getLogger(ReindexingCurator.class.getName()); + private final Curator curator; private final ReindexingSerializer serializer; private final Duration lockTimeout; @@ -55,6 +59,7 @@ public class ReindexingCurator { if (ready.get(type).isBefore(now)) reindexing = reindexing.with(type, Status.ready(now).running().successful(now)); + log.log(Level.INFO, "Creating initial reindexing status at '" + statusPath(cluster) + "'"); writeReindexing(reindexing, cluster); } catch (ReindexingLockException ignored) { @@ -64,11 +69,14 @@ public class ReindexingCurator { } public Reindexing readReindexing(String cluster) { - return curator.getData(statusPath(cluster)).map(serializer::deserialize) - .orElse(Reindexing.empty()); + Reindexing reindexing = curator.getData(statusPath(cluster)).map(serializer::deserialize) + .orElse(Reindexing.empty()); + log.log(Level.FINE, () -> "Read reindexing status '" + reindexing + "' from '" + statusPath(cluster) + "'"); + return reindexing; } public void writeReindexing(Reindexing reindexing, String cluster) { + log.log(Level.FINE, () -> "Writing reindexing status '" + reindexing + "' to '" + statusPath(cluster) + "'"); curator.set(statusPath(cluster), serializer.serialize(reindexing)); } |