diff options
author | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2019-05-24 10:33:04 +0200 |
---|---|---|
committer | Jon Marius Venstad <jvenstad@yahoo-inc.com> | 2019-05-24 10:33:04 +0200 |
commit | a159b4ce190a42e2c25ad5fae0e010d947bbe89c (patch) | |
tree | 0f60a06843dcd91ac4dbd5f3c147e1e30da2f441 | |
parent | c69ca3cadc9d0702eb603de1b38b93186d2ec60d (diff) |
Run updateTenants in test to simulate watcher reaction
2 files changed, 3 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java index 6dcf9b5efc4..bedf481fdc4 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/tenant/TenantRepository.java @@ -147,7 +147,8 @@ public class TenantRepository { return curator.getChildren(tenantsPath).stream().map(TenantName::from).collect(Collectors.toSet()); } - private synchronized void updateTenants() { + /** Public for testing. */ + public synchronized void updateTenants() { Set<TenantName> allTenants = readTenantsFromZooKeeper(curator); log.log(LogLevel.DEBUG, "Create tenants, tenants found in zookeeper: " + allTenants); checkForRemovedTenants(allTenants); diff --git a/configserver/src/test/java/com/yahoo/vespa/config/server/maintenance/TenantsMaintainerTest.java b/configserver/src/test/java/com/yahoo/vespa/config/server/maintenance/TenantsMaintainerTest.java index a2f52bc5321..fdc6ffeacf0 100644 --- a/configserver/src/test/java/com/yahoo/vespa/config/server/maintenance/TenantsMaintainerTest.java +++ b/configserver/src/test/java/com/yahoo/vespa/config/server/maintenance/TenantsMaintainerTest.java @@ -37,6 +37,7 @@ public class TenantsMaintainerTest { assertNotNull(tenantRepository.getTenant(shouldNotBeDeleted)); new TenantsMaintainer(applicationRepository, tester.curator(), Duration.ofDays(1)).run(); + tenantRepository.updateTenants(); // One tenant should now have been deleted assertNull(tenantRepository.getTenant(shouldBeDeleted)); |