summaryrefslogtreecommitdiffstats
path: root/controller-server
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@oath.com>2018-07-06 10:22:43 +0200
committerGitHub <noreply@github.com>2018-07-06 10:22:43 +0200
commit49849f4f0202fc5f4645a414510d48fc8e67b51a (patch)
tree717805927ce74259f714c13d2879d07aec55d724 /controller-server
parenta5b89d214e83d29d6c7f3682e286a5898b4a8a0e (diff)
parent95540cadc561a0d286d9439602d5ecb396e9f8db (diff)
Merge pull request #6350 from vespa-engine/jvenstad/deployment-pipeline
Acquire locks in the same order everywhere
Diffstat (limited to 'controller-server')
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java
index 93b915cc194..9ced75303ff 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/deployment/JobController.java
@@ -228,12 +228,12 @@ public class JobController {
.forEach(id -> {
try {
for (JobType type : jobs(id))
- try (Lock __ = curator.lock(id, type)) {
- locked(id, type, deactivateTester, ___ -> {
+ locked(id, type, deactivateTester, __ -> {
+ try (Lock ___ = curator.lock(id, type)) {
deactivateTester(id, type);
curator.deleteJobData(id, type);
- });
- }
+ }
+ });
}
catch (TimeoutException e) {
return; // Don't remove the data if we couldn't deactivate all testers.