diff options
author | Håkon Hallingstad <hakon@verizonmedia.com> | 2021-08-11 10:54:35 +0200 |
---|---|---|
committer | Håkon Hallingstad <hakon@verizonmedia.com> | 2021-08-11 10:54:35 +0200 |
commit | 88dcc6b8c0eb00dc8671499ee5ded29b936f6f51 (patch) | |
tree | ef08d6d214d77aa23b6832925738073acc06f16b /zkfacade | |
parent | fff405dc430ecea41c698470ce557473f7628060 (diff) |
Improve completion waiter debug logging
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java b/zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java index 221674b29b2..4796da32b6c 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java @@ -111,9 +111,15 @@ class CuratorCompletionWaiter implements Curator.CompletionWaiter { public static Curator.CompletionWaiter createAndInitialize(Curator curator, Path parentPath, String waiterNode, String id) { Path waiterPath = parentPath.append(waiterNode); - log.fine("Recreating ZK path: " + waiterPath); + + String debugMessage = log.isLoggable(Level.FINE) ? "Recreating ZK path " + waiterPath : null; + if (debugMessage != null) log.fine(debugMessage); + curator.delete(waiterPath); curator.createAtomically(waiterPath); + + if (debugMessage != null) log.fine(debugMessage + ": Done"); + return new CuratorCompletionWaiter(curator, waiterPath.getAbsolute(), id, Clock.systemUTC()); } |