diff options
Diffstat (limited to 'zkfacade/src/main/java/com/yahoo/vespa/curator/CuratorCompletionWaiter.java')
-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()); } |