diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2019-02-07 16:21:54 +0100 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2019-02-07 16:21:54 +0100 |
commit | 7d6cc76f9493f8d799ce7e06a6c4d2504a52e7d9 (patch) | |
tree | 6cbdcdfc798e7ae8c203e8800a9ae8334201102c /orchestrator/src/main/java/com/yahoo | |
parent | 7dd4287830ec74a054e1251ae7b63b53481ae8af (diff) |
Remove unused or pointless code
Diffstat (limited to 'orchestrator/src/main/java/com/yahoo')
-rw-r--r-- | orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java | 20 |
1 files changed, 0 insertions, 20 deletions
diff --git a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java index c56ff661bba..0d00ab7becd 100644 --- a/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java +++ b/orchestrator/src/main/java/com/yahoo/vespa/orchestrator/status/ZookeeperStatusService.java @@ -9,7 +9,6 @@ import com.yahoo.vespa.curator.Curator; import com.yahoo.vespa.curator.Lock; import com.yahoo.vespa.orchestrator.OrchestratorContext; import com.yahoo.vespa.orchestrator.OrchestratorUtil; -import org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex; import org.apache.zookeeper.KeeperException.NoNodeException; import org.apache.zookeeper.KeeperException.NodeExistsException; import org.apache.zookeeper.data.Stat; @@ -18,8 +17,6 @@ import javax.inject.Inject; import java.time.Duration; import java.util.HashSet; import java.util.Set; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; import java.util.logging.Logger; /** @@ -107,19 +104,6 @@ public class ZookeeperStatusService implements StatusService { } } - private InterProcessSemaphoreMutex acquireMutexOrThrow(long timeout, TimeUnit timeoutTimeUnit, String lockPath) throws Exception { - InterProcessSemaphoreMutex mutex = new InterProcessSemaphoreMutex(curator.framework(), lockPath); - - log.log(LogLevel.DEBUG, "Waiting for lock on " + lockPath); - boolean acquired = mutex.acquire(timeout, timeoutTimeUnit); - if (!acquired) { - log.log(LogLevel.DEBUG, "Timed out waiting for lock on " + lockPath); - throw new TimeoutException("Timed out waiting for lock on " + lockPath); - } - log.log(LogLevel.DEBUG, "Successfully acquired lock on " + lockPath); - return mutex; - } - private void setHostStatus(ApplicationInstanceReference applicationInstanceReference, HostName hostName, HostStatus status) { @@ -198,10 +182,6 @@ public class ZookeeperStatusService implements StatusService { return applicationInstancePath(applicationInstanceReference) + "/hosts-allowed-down"; } - private static String applicationInstanceLockPath(ApplicationInstanceReference applicationInstanceReference) { - return applicationInstancePath(applicationInstanceReference) + "/lock"; - } - private static String applicationInstanceLock2Path(ApplicationInstanceReference applicationInstanceReference) { return applicationInstancePath(applicationInstanceReference) + "/lock2"; } |