diff options
author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2019-03-12 16:19:45 +0100 |
---|---|---|
committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2019-03-17 13:24:12 +0100 |
commit | c8769d77ef32f74a1ab72d16f2bd5d2cc124ebe2 (patch) | |
tree | f8d40fb2e0f5c68b4e63a8b647bc987801a89f14 /controller-server | |
parent | c27b4c34fc7b225e5b99629861fce5f5929af824 (diff) |
Simplify now that tenant curator is simpler
Diffstat (limited to 'controller-server')
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/TenantController.java | 15 |
1 files changed, 1 insertions, 14 deletions
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 e274fc2fe87..3b6317efa52 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 @@ -58,20 +58,7 @@ public class TenantController { Instant start = controller.clock().instant(); int count = 0; for (TenantName name : curator.readTenantNames()) { - try (Lock lock = lock(name)) { - // Get while holding lock so that we know we're operating on a current version - Optional<Tenant> optionalTenant = get(name); - if (!optionalTenant.isPresent()) continue; // Deleted while updating, skip - - Tenant tenant = optionalTenant.get(); - if (tenant instanceof AthenzTenant) { - curator.writeTenant((AthenzTenant) tenant); - } else if (tenant instanceof UserTenant) { - curator.writeTenant((UserTenant) tenant); - } else { - throw new IllegalArgumentException("Unknown tenant type: " + tenant.getClass().getSimpleName()); - } - } + lockIfPresent(name, LockedTenant.class, this::store); count++; } log.log(Level.INFO, String.format("Wrote %d tenants in %s", count, |