aboutsummaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2022-10-14 16:40:56 +0200
committerjonmv <venstad@gmail.com>2022-10-14 16:40:56 +0200
commit5bc97841c6138e01266b0f197fe8cb38fa1ca4e7 (patch)
treec5392e56051b238a3482f918982c5db3518629f4 /zkfacade
parent46dbafa9243cc5d76367d9d14e9798b88c9635d6 (diff)
Only log invalidating lease when actually having it
Diffstat (limited to 'zkfacade')
-rw-r--r--zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java18
1 files changed, 9 insertions, 9 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java
index 2658bcce686..04f1f6bbc09 100644
--- a/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java
+++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/SingletonManager.java
@@ -153,7 +153,7 @@ class SingletonManager {
public void unlock() {
doom.set(null);
if (lock != null) try {
- logger.log(INFO, "Releasing lease for " + id);
+ logger.log(INFO, "Relinquishing lease for " + id);
lock.close();
lock = null;
}
@@ -198,7 +198,6 @@ class SingletonManager {
doUnregister(task.singleton);
task.future.complete(null);
}
- default -> throw new AssertionError("unknown task type '" + task.type + "'");
}
}
catch (RuntimeException e) {
@@ -257,10 +256,10 @@ class SingletonManager {
if (e == null) e = f;
else e.addSuppressed(f);
}
- }
- if (singletons.isEmpty()) {
- logger.log(INFO, "No registered singletons, invalidating lease");
- invalidate();
+ if (singletons.isEmpty()) {
+ logger.log(INFO, "No registered singletons, invalidating lease");
+ invalidate();
+ }
}
if (e != null) throw e;
}
@@ -283,7 +282,7 @@ class SingletonManager {
logger.log(INFO, "Acquired lock for ID: " + id);
}
catch (RuntimeException e) {
- logger.log(FINE, "Failed acquiring lock for '" + path + "' within " + tickTimeout, e);
+ logger.log(FINE, e, () -> "Failed acquiring lock for '" + path + "' within " + tickTimeout);
return;
}
try {
@@ -306,7 +305,7 @@ class SingletonManager {
Instant ourDoom = doom.get();
boolean shouldBeActive = ourDoom != null && ourDoom != INVALID && ! clock.instant().isAfter(ourDoom);
if ( ! active && shouldBeActive) {
- logger.log(INFO, "Activating singletons for ID :" + id);
+ logger.log(INFO, "Activating singleton for ID: " + id);
try {
active = true;
if ( ! singletons.isEmpty()) metrics.activation(singletons.peek()::activate);
@@ -317,7 +316,8 @@ class SingletonManager {
}
}
if (active && ! shouldBeActive) {
- logger.log(INFO, "Deactivating singletons due to doom value of '" + ourDoom + "', for ID :" + id);
+ logger.log(INFO, "Deactivating singleton for ID: " + id);
+ logger.log(FINE, () -> "Doom value is " + doom);
try {
if ( ! singletons.isEmpty()) metrics.deactivation(singletons.peek()::deactivate);
active = false;