diff options
author | Jon Bratseth <bratseth@gmail.com> | 2022-04-21 18:53:12 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2022-04-21 18:53:12 +0200 |
commit | 65dfeb73636dbf8455ed11dd2378f15eaffa8c3b (patch) | |
tree | 81c99d48363fef6795c47b5402e9ae615c476681 /node-repository | |
parent | cf9e699bef6999602b7801e0d01cc322d034c10b (diff) |
Remove flag: Always true
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndices.java | 6 | ||||
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java | 5 | ||||
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java | 9 | ||||
-rw-r--r-- | node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndicesTest.java (renamed from node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIncidesTest.java) | 34 | ||||
-rw-r--r-- | node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java | 4 |
5 files changed, 12 insertions, 46 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndices.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndices.java index e75804fb343..a5a098dbfd6 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndices.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndices.java @@ -17,10 +17,10 @@ class NodeIndices { private int last; private int probe; - /** Pass the list of current indices in the cluster, and whether to fill gaps or not. */ - NodeIndices(List<Integer> used, boolean compact) { + /** Pass the list of current indices in the cluster. */ + NodeIndices(List<Integer> used) { this.used = List.copyOf(used); - this.last = compact ? -1 : used.stream().max(naturalOrder()).orElse(-1); + this.last = -1; this.probe = last; } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java index e24d71f22f2..64a345790cc 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodeRepositoryProvisioner.java @@ -114,10 +114,7 @@ public class NodeRepositoryProvisioner implements Provisioner { resources = getNodeResources(cluster, requested.minResources().nodeResources(), application); nodeSpec = NodeSpec.from(requested.type()); } - var reuseIndexes = Flags.REUSE_NODE_INDEXES.bindTo(nodeRepository.flagSource()) - .with(FetchVector.Dimension.ZONE_ID, zone.systemLocalValue()) - .value(); - return asSortedHosts(preparer.prepare(application, cluster, nodeSpec, groups, reuseIndexes), resources); + return asSortedHosts(preparer.prepare(application, cluster, nodeSpec, groups), resources); } private NodeResources getNodeResources(ClusterSpec cluster, NodeResources nodeResources, ApplicationId applicationId) { diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java index a6f16d3d65e..dbc92b1dbdf 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java @@ -34,10 +34,9 @@ class Preparer { } /** Prepare all required resources for the given application and cluster */ - public List<Node> prepare(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes, int wantedGroups, - boolean reuseIndexes) { + public List<Node> prepare(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes, int wantedGroups) { try { - var nodes = prepareNodes(application, cluster, requestedNodes, wantedGroups, reuseIndexes); + var nodes = prepareNodes(application, cluster, requestedNodes, wantedGroups); prepareLoadBalancer(application, cluster, requestedNodes); return nodes; } @@ -57,13 +56,13 @@ class Preparer { // but it may not change the set of active nodes, as the active nodes must stay in sync with the // active config model which is changed on activate private List<Node> prepareNodes(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes, - int wantedGroups, boolean reuseIndexes) { + int wantedGroups) { NodesAndHosts<LockedNodeList> allNodesAndHosts = groupPreparer.createNodesAndHostUnlocked(); NodeList appNodes = allNodesAndHosts.nodes().owner(application); List<Node> surplusNodes = findNodesInRemovableGroups(appNodes, cluster, wantedGroups); List<Integer> usedIndices = appNodes.cluster(cluster.id()).mapToList(node -> node.allocation().get().membership().index()); - NodeIndices indices = new NodeIndices(usedIndices, reuseIndexes || ! cluster.type().isContent()); + NodeIndices indices = new NodeIndices(usedIndices); List<Node> acceptedNodes = new ArrayList<>(); for (int groupIndex = 0; groupIndex < wantedGroups; groupIndex++) { diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIncidesTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndicesTest.java index 4e35bd54435..a2f9fa80b42 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIncidesTest.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/NodeIndicesTest.java @@ -10,39 +10,11 @@ import static org.junit.Assert.assertEquals; /** * @author jonmv */ -public class NodeIncidesTest { +public class NodeIndicesTest { @Test - public void testNonCompactIndices() { - NodeIndices indices = new NodeIndices(List.of(1, 3, 4), false); - assertEquals(5, indices.probeNext()); - assertEquals(6, indices.probeNext()); - - indices.resetProbe(); - assertEquals(5, indices.probeNext()); - assertEquals(6, indices.probeNext()); - - indices.commitProbe(); - assertEquals(7, indices.probeNext()); - assertEquals(8, indices.probeNext()); - - indices.resetProbe(); - assertEquals(7, indices.next()); - assertEquals(8, indices.next()); - - assertEquals(9, indices.probeNext()); - try { - indices.next(); - } - catch (IllegalStateException e) { - assertEquals("Must commit ongoing probe before calling 'next'", e.getMessage()); - } - } - - - @Test - public void testCompactIndices() { - NodeIndices indices = new NodeIndices(List.of(1, 3, 4), true); + public void testNodeIndices() { + NodeIndices indices = new NodeIndices(List.of(1, 3, 4)); assertEquals(0, indices.probeNext()); assertEquals(2, indices.probeNext()); assertEquals(5, indices.probeNext()); diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java index 9f722507ba2..af94bba2e70 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/provisioning/ProvisioningTester.java @@ -689,9 +689,7 @@ public class ProvisioningTester { } private FlagSource defaultFlagSource() { - var flagSource = new InMemoryFlagSource(); - flagSource.withBooleanFlag(Flags.REUSE_NODE_INDEXES.id(), true); - return flagSource; + return new InMemoryFlagSource(); } public ProvisioningTester build() { |