diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-09-04 00:13:28 +0200 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2019-09-04 00:13:28 +0200 |
commit | af3c9a5995a8129ad4370ed5b5683d1ceb4911a0 (patch) | |
tree | 8b5186ff04ff0ea87255286426b9e283aae04627 /config-model | |
parent | 60fd75a278e732e0620d71dbfc16853d819309de (diff) |
Do not use RestrictedServerCnxnFactory
Do not use it for self-hosted, feature cannot be supported
with ZooKeeper 3.5 (but secure communications can be setup with
ZooKeeper 3.5, which is supported from that version on)
Diffstat (limited to 'config-model')
6 files changed, 5 insertions, 15 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerCluster.java index 84ca6416269..675ec22dc2b 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/admin/clustercontroller/ClusterControllerCluster.java @@ -4,7 +4,6 @@ package com.yahoo.vespa.model.admin.clustercontroller; import com.google.common.base.Joiner; import com.yahoo.cloud.config.ZookeeperServerConfig; import com.yahoo.cloud.config.ZookeepersConfig; -import com.yahoo.config.model.deploy.DeployState; import com.yahoo.config.model.producer.AbstractConfigProducer; import com.yahoo.vespa.model.Service; import com.yahoo.vespa.model.admin.Configserver; @@ -25,11 +24,9 @@ public class ClusterControllerCluster extends AbstractConfigProducer<ClusterCont private static final int ZK_CLIENT_PORT = 2181; private ClusterControllerContainerCluster containerCluster = null; - private final DeployState deployState; - public ClusterControllerCluster(AbstractConfigProducer parent, String subId, DeployState deployState) { + public ClusterControllerCluster(AbstractConfigProducer parent, String subId) { super(parent, subId); - this.deployState = deployState; } @Override @@ -41,7 +38,6 @@ public class ClusterControllerCluster extends AbstractConfigProducer<ClusterCont serverBuilder.id(container.index()); builder.server(serverBuilder); } - builder.useRestrictedServerCnxnFactory( ! deployState.isHosted()); } @Override diff --git a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java index cd49e16dc56..1b0e04b50a8 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/builder/xml/dom/DomAdminV2Builder.java @@ -89,7 +89,7 @@ public class DomAdminV2Builder extends DomAdminBuilderBase { boolean standaloneZooKeeper = "true".equals(controllersElements.getAttribute(ATTRIBUTE_CLUSTER_CONTROLLER_STANDALONE_ZK)) || multitenant; if (standaloneZooKeeper) { - parent = new ClusterControllerCluster(parent, "standalone", deployState); + parent = new ClusterControllerCluster(parent, "standalone"); } var cluster = new ClusterControllerContainerCluster(parent, "cluster-controllers", diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/configserver/ConfigserverCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/container/configserver/ConfigserverCluster.java index 205489ca0fc..2eff081f42d 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/container/configserver/ConfigserverCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/container/configserver/ConfigserverCluster.java @@ -78,8 +78,6 @@ public class ConfigserverCluster extends AbstractConfigProducer if (options.zookeeperClientPort().isPresent()) { builder.clientPort(options.zookeeperClientPort().get()); } - boolean hosted = options.hostedVespa().orElse(false); - builder.useRestrictedServerCnxnFactory( ! hosted); } @Override diff --git a/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java index f6cdf63232d..fc79a3f4bbf 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/content/cluster/ContentCluster.java @@ -311,7 +311,7 @@ public class ContentCluster extends AbstractConfigProducer implements Collection<HostResource> hosts = nodesSpecification.isDedicated() ? getControllerHosts(nodesSpecification, admin, clusterName, context) : drawControllerHosts(nodesSpecification.count(), rootGroup, containers); - clusterControllers = createClusterControllers(new ClusterControllerCluster(contentCluster, "standalone", context.getDeployState()), + clusterControllers = createClusterControllers(new ClusterControllerCluster(contentCluster, "standalone"), hosts, clusterName, true, diff --git a/config-model/src/test/java/com/yahoo/vespa/model/admin/ClusterControllerTestCase.java b/config-model/src/test/java/com/yahoo/vespa/model/admin/ClusterControllerTestCase.java index 35cbec015de..3817288d44b 100644 --- a/config-model/src/test/java/com/yahoo/vespa/model/admin/ClusterControllerTestCase.java +++ b/config-model/src/test/java/com/yahoo/vespa/model/admin/ClusterControllerTestCase.java @@ -212,7 +212,6 @@ public class ClusterControllerTestCase extends DomBuilderTest { assertThat(config.myid(), is(id)); Collection<Integer> serverIds = Collections2.transform(config.server(), ZookeeperServerConfig.Server::id); assertTrue(serverIds.contains(id)); - assertTrue(config.useRestrictedServerCnxnFactory()); } @Test diff --git a/config-model/src/test/java/com/yahoo/vespa/model/container/configserver/ConfigserverClusterTest.java b/config-model/src/test/java/com/yahoo/vespa/model/container/configserver/ConfigserverClusterTest.java index d82859e4df2..b4d889a4598 100644 --- a/config-model/src/test/java/com/yahoo/vespa/model/container/configserver/ConfigserverClusterTest.java +++ b/config-model/src/test/java/com/yahoo/vespa/model/container/configserver/ConfigserverClusterTest.java @@ -59,7 +59,6 @@ public class ConfigserverClusterTest { assertZookeeperServerProperty(config.server(), ZookeeperServerConfig.Server::hostname, "cfg1", "localhost", "cfg3"); assertZookeeperServerProperty(config.server(), ZookeeperServerConfig.Server::id, 4, 2, 3); assertEquals(2, config.myid()); - assertFalse(config.useRestrictedServerCnxnFactory()); } @Test @@ -70,7 +69,6 @@ public class ConfigserverClusterTest { assertZookeeperServerProperty(config.server(), ZookeeperServerConfig.Server::hostname, "cfg1", "localhost", "cfg3"); assertZookeeperServerProperty(config.server(), ZookeeperServerConfig.Server::id, 4, 2, 3); assertEquals(2, config.myid()); - assertTrue(config.useRestrictedServerCnxnFactory()); } @Test(expected = IllegalArgumentException.class) @@ -124,13 +122,12 @@ public class ConfigserverClusterTest { @SuppressWarnings("varargs") private static <T> void assertZookeeperServerProperty( - List<ZookeeperServerConfig.Server> zkServers, Function<ZookeeperServerConfig.Server, T> properyMapper, T... expectedProperties) { - List<T> actualPropertyValues = zkServers.stream().map(properyMapper).collect(Collectors.toList()); + List<ZookeeperServerConfig.Server> zkServers, Function<ZookeeperServerConfig.Server, T> propertyMapper, T... expectedProperties) { + List<T> actualPropertyValues = zkServers.stream().map(propertyMapper).collect(Collectors.toList()); List<T> expectedPropertyValues = Arrays.asList(expectedProperties); assertEquals(expectedPropertyValues, actualPropertyValues); } - private static TestOptions createTestOptions(List<String> configServerHostnames, List<Integer> configServerZkIds) { return createTestOptions(configServerHostnames, configServerZkIds, true); |