diff options
author | Harald Musum <musum@yahooinc.com> | 2023-09-18 09:10:49 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-09-18 09:10:49 +0200 |
commit | 24cc103df27df8c90f42240dccabe64371ca7ec0 (patch) | |
tree | ac70e9e2417de354a2f21bc13794446b2aa37d15 /configserver | |
parent | 51d97f62b16b5af66943633ef0880d9b2d314f95 (diff) |
Follow API changes
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java index 85abd937ac0..2bc8cb5bc0a 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionZooKeeperClient.java @@ -118,9 +118,9 @@ public class SessionZooKeeperClient { public long sessionId() { return sessionId; } - public CompletionWaiter createActiveWaiter() { return createCompletionWaiter(ACTIVE_BARRIER); } + public CompletionWaiter createActiveWaiter() { return createCompletionWaiter(getWaiterPath(ACTIVE_BARRIER)); } - CompletionWaiter createPrepareWaiter() { return createCompletionWaiter(PREPARE_BARRIER); } + CompletionWaiter createPrepareWaiter() { return createCompletionWaiter(getWaiterPath(PREPARE_BARRIER)); } CompletionWaiter getPrepareWaiter() { return getCompletionWaiter(getWaiterPath(PREPARE_BARRIER)); } @@ -136,8 +136,8 @@ public class SessionZooKeeperClient { return sessionPath.append(barrierName); } - private CompletionWaiter createCompletionWaiter(String waiterNode) { - return curator.createCompletionWaiter(sessionPath, waiterNode, serverId, barrierWaitForAllTimeout); + private CompletionWaiter createCompletionWaiter(Path path) { + return curator.createCompletionWaiter(path, serverId, barrierWaitForAllTimeout); } private CompletionWaiter getCompletionWaiter(Path path) { |