summaryrefslogtreecommitdiffstats
path: root/controller-server
diff options
context:
space:
mode:
authorJon Marius Venstad <jvenstad@yahoo-inc.com>2018-06-25 10:39:04 +0200
committerJon Marius Venstad <jvenstad@yahoo-inc.com>2018-07-02 13:42:47 +0200
commitb3a8d1bafbafa156468f374b459a18d546bd4aae (patch)
tree6feca35afe1a0c113473d99ececde01d084d40fc /controller-server
parent61e0edbca9756906f1cae34c66365ce62269bca5 (diff)
Move timeout definitions to CuratorDb
Diffstat (limited to 'controller-server')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java2
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java2
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/RunId.java55
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java8
4 files changed, 6 insertions, 61 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
index 57708bfc89c..d3aa051088c 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/ApplicationController.java
@@ -599,7 +599,7 @@ public class ApplicationController {
* and store the application, and finally release (close) the lock.
*/
Lock lock(ApplicationId application) {
- return curator.lock(application, Duration.ofMinutes(10));
+ return curator.lock(application));
}
/** Verify that each of the production zones listed in the deployment spec exist in this system. */
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java
index 2e8fe795fb5..bd746a2fa8d 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java
@@ -203,7 +203,7 @@ public class TenantController {
* and store the tenant, and finally release (close) the lock.
*/
private Lock lock(TenantName tenant) {
- return curator.lock(tenant, Duration.ofMinutes(10));
+ return curator.lock(tenant);
}
private static boolean inDomain(Tenant tenant, AthenzDomain domain) {
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/RunId.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/RunId.java
deleted file mode 100644
index d78dbd6e636..00000000000
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/RunId.java
+++ /dev/null
@@ -1,55 +0,0 @@
-package com.yahoo.vespa.hosted.controller.deployment;
-
-import com.yahoo.config.provision.ApplicationId;
-import com.yahoo.vespa.hosted.controller.api.integration.deployment.JobType;
-
-import java.util.Objects;
-
-/**
- * Immutable ID of a job run by an {@link InternalBuildService}.
- *
- * @author jonmv
- */
-public class RunId {
-
- private final ApplicationId application;
- private final JobType type;
- private final long number;
-
- public RunId(ApplicationId application, JobType type, long number) {
- this.application = Objects.requireNonNull(application, "ApplicationId cannot be null!");
- this.type = Objects.requireNonNull(type, "JobType cannot be null!");
- if (number <= 0) throw new IllegalArgumentException("Build number must be a positive integer!");
- this.number = number;
- }
-
- public ApplicationId application() { return application; }
- public JobType type() { return type; }
- public long number() { return number; }
-
- @Override
- public boolean equals(Object o) {
- if (this == o) return true;
- if ( ! (o instanceof RunId)) return false;
-
- RunId id = (RunId) o;
-
- if (number != id.number) return false;
- if ( ! application.equals(id.application)) return false;
- return type == id.type;
- }
-
- @Override
- public int hashCode() {
- int result = application.hashCode();
- result = 31 * result + type.hashCode();
- result = 31 * result + (int) (number ^ (number >>> 32));
- return result;
- }
-
- @Override
- public String toString() {
- return "Run " + number + " of " + type + " for " + application;
- }
-
-}
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
index 09daaef2af6..22a6233ebe3 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
@@ -95,12 +95,12 @@ public class CuratorDb {
return lock;
}
- public Lock lock(TenantName name, Duration timeout) {
- return lock(lockPath(name), timeout);
+ public Lock lock(TenantName name) {
+ return lock(lockPath(name), defaultLockTimeout.multipliedBy(2));
}
- public Lock lock(ApplicationId id, Duration timeout) {
- return lock(lockPath(id), timeout);
+ public Lock lock(ApplicationId id) {
+ return lock(lockPath(id), defaultLockTimeout.multipliedBy(2));
}
public Lock lockRotations() {