diff options
author | jonmv <venstad@gmail.com> | 2022-04-17 16:26:47 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-04-17 16:26:47 +0200 |
commit | f7bafeba7b05a25c7a1937eb46e8b7095efe24a4 (patch) | |
tree | 55c9f880bb89a22048c983bb3e02bf89a2cf47df | |
parent | 0773124206f4836c02a2b28c8aabbb2224d6d554 (diff) |
Take old locks first
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java | 14 |
1 files changed, 7 insertions, 7 deletions
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 d3b5c3754d5..5e6cfa8b43f 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 @@ -157,8 +157,8 @@ public class CuratorDb { public Mutex lock(TenantAndApplicationId id) { switch (lockScheme.value()) { case "BOTH": - return new MultiplePathsLock(curator.lock(lockPath(id), defaultLockTimeout.multipliedBy(2)), - curator.lock(legacyLockPath(id), defaultLockTimeout.multipliedBy(2))); + return new MultiplePathsLock(curator.lock(legacyLockPath(id), defaultLockTimeout.multipliedBy(2)), + curator.lock(lockPath(id), defaultLockTimeout.multipliedBy(2))); case "OLD": return curator.lock(legacyLockPath(id), defaultLockTimeout.multipliedBy(2)); case "NEW": @@ -171,8 +171,8 @@ public class CuratorDb { public Mutex lockForDeployment(ApplicationId id, ZoneId zone) { switch (lockScheme.value()) { case "BOTH": - return new MultiplePathsLock(curator.lock(lockPath(id, zone), defaultLockTimeout), - curator.lock(legacyLockPath(id, zone), defaultLockTimeout)); + return new MultiplePathsLock(curator.lock(legacyLockPath(id, zone), defaultLockTimeout), + curator.lock(lockPath(id, zone), defaultLockTimeout)); case "OLD": return curator.lock(legacyLockPath(id, zone), deployLockTimeout); case "NEW": @@ -185,8 +185,8 @@ public class CuratorDb { public Mutex lock(ApplicationId id, JobType type) { switch (lockScheme.value()) { case "BOTH": - return new MultiplePathsLock(curator.lock(lockPath(id, type), defaultLockTimeout), - curator.lock(legacyLockPath(id, type), defaultLockTimeout)); + return new MultiplePathsLock(curator.lock(legacyLockPath(id, type), defaultLockTimeout), + curator.lock(lockPath(id, type), defaultLockTimeout)); case "OLD": return curator.lock(legacyLockPath(id, type), defaultLockTimeout); case "NEW": @@ -199,7 +199,7 @@ public class CuratorDb { public Mutex lock(ApplicationId id, JobType type, Step step) throws TimeoutException { switch (lockScheme.value()) { case "BOTH": - return tryLock(lockPath(id, type, step), legacyLockPath(id, type, step)); + return tryLock(legacyLockPath(id, type, step), lockPath(id, type, step)); case "OLD": return tryLock(legacyLockPath(id, type, step)); case "NEW": |