diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-07-06 10:22:43 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-07-06 10:22:43 +0200 |
commit | 49849f4f0202fc5f4645a414510d48fc8e67b51a (patch) | |
tree | 717805927ce74259f714c13d2879d07aec55d724 /controller-server | |
parent | a5b89d214e83d29d6c7f3682e286a5898b4a8a0e (diff) | |
parent | 95540cadc561a0d286d9439602d5ecb396e9f8db (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.java | 8 |
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. |