summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2021-04-27 10:50:33 +0200
committerMartin Polden <mpolden@mpolden.no>2021-04-27 10:50:33 +0200
commit070b5e535ecab1f629afe70bb1dc93cac273469e (patch)
treebcfb92533d8ba00fe7937555c2fac91c20f55564 /node-repository
parentd1546c3f5505dca9f2dbc0d967773e28bb35f5ed (diff)
Less Docker
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java2
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailerTest.java31
2 files changed, 16 insertions, 17 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java
index 3f66f9cadc4..9ded28094d2 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailTester.java
@@ -114,7 +114,7 @@ public class NodeFailTester {
return tester;
}
- public static NodeFailTester withTwoApplicationsOnDocker(int numberOfHosts) {
+ public static NodeFailTester withTwoApplications(int numberOfHosts) {
NodeFailTester tester = new NodeFailTester();
int nodesPerHost = 3;
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailerTest.java
index 0c48c6dfd83..7eff8af8b8d 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailerTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeFailerTest.java
@@ -47,7 +47,7 @@ public class NodeFailerTest {
@Test
public void fail_nodes_with_severe_reports_if_allowed_to_be_down() {
- NodeFailTester tester = NodeFailTester.withTwoApplicationsOnDocker(6);
+ NodeFailTester tester = NodeFailTester.withTwoApplications(6);
String hostWithFailureReports = selectFirstParentHostWithNActiveNodesExcept(tester.nodeRepository, 2);
// Set failure report to the parent and all its children.
@@ -106,7 +106,7 @@ public class NodeFailerTest {
@Test
public void hw_fail_only_if_whole_host_is_suspended() {
- NodeFailTester tester = NodeFailTester.withTwoApplicationsOnDocker(6);
+ NodeFailTester tester = NodeFailTester.withTwoApplications(6);
String hostWithFailureReports = selectFirstParentHostWithNActiveNodesExcept(tester.nodeRepository, 2);
assertEquals(Node.State.active, tester.nodeRepository.nodes().node(hostWithFailureReports).get().state());
@@ -380,7 +380,7 @@ public class NodeFailerTest {
public void failing_ready_nodes() {
NodeFailTester tester = NodeFailTester.withTwoApplications();
- // Add ready docker node
+ // Add ready node
NodeResources newNodeResources = new NodeResources(3, 4, 5, 1);
tester.createReadyNodes(1, 16, newNodeResources);
@@ -394,20 +394,20 @@ public class NodeFailerTest {
NodeList ready = tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.tenant);
- // Two ready nodes and a ready docker node die, but only 2 of those are failed out
+ // Two ready hosts and a ready node die, but only 2 of those are failed out
tester.clock.advance(Duration.ofMinutes(180));
- Node dockerNode = ready.stream().filter(node -> node.resources().equals(newNodeResources)).findFirst().get();
+ Node failingNode = ready.stream().filter(node -> node.resources().equals(newNodeResources)).findFirst().get();
List<Node> otherNodes = ready.stream()
- .filter(node -> ! node.resources().equals(newNodeResources))
- .collect(Collectors.toList());
- tester.allNodesMakeAConfigRequestExcept(otherNodes.get(0), otherNodes.get(2), dockerNode);
+ .filter(node -> !node.resources().equals(newNodeResources))
+ .collect(Collectors.toList());
+ tester.allNodesMakeAConfigRequestExcept(otherNodes.get(0), otherNodes.get(2), failingNode);
tester.runMaintainers();
assertEquals( 3, tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.tenant).size());
assertEquals( 2, tester.nodeRepository.nodes().list(Node.State.failed).nodeType(NodeType.tenant).size());
// Another ready node dies and the node that died earlier, are allowed to fail
tester.clock.advance(Duration.ofDays(1));
- tester.allNodesMakeAConfigRequestExcept(otherNodes.get(0), otherNodes.get(2), dockerNode, otherNodes.get(3));
+ tester.allNodesMakeAConfigRequestExcept(otherNodes.get(0), otherNodes.get(2), failingNode, otherNodes.get(3));
tester.runMaintainers();
assertEquals( 1, tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.tenant).size());
assertEquals(otherNodes.get(1), tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.tenant).first().get());
@@ -415,7 +415,7 @@ public class NodeFailerTest {
}
@Test
- public void docker_host_not_failed_without_config_requests() {
+ public void host_not_failed_without_config_requests() {
NodeFailTester tester = NodeFailTester.withTwoApplications();
// For a day all nodes work so nothing happens
@@ -427,18 +427,17 @@ public class NodeFailerTest {
assertEquals( 0, tester.nodeRepository.nodes().list(Node.State.failed).nodeType(NodeType.host).size());
}
- // Two ready nodes and a ready docker node die, but only 2 of those are failed out
tester.clock.advance(Duration.ofMinutes(180));
- Node dockerHost = tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.host).iterator().next();
- tester.allNodesMakeAConfigRequestExcept(dockerHost);
+ Node host = tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.host).first().get();
+ tester.allNodesMakeAConfigRequestExcept(host);
tester.runMaintainers();
assertEquals( 3, tester.nodeRepository.nodes().list(Node.State.ready).nodeType(NodeType.host).size());
assertEquals( 0, tester.nodeRepository.nodes().list(Node.State.failed).nodeType(NodeType.host).size());
}
@Test
- public void failing_docker_hosts() {
- NodeFailTester tester = NodeFailTester.withTwoApplicationsOnDocker(7);
+ public void failing_hosts() {
+ NodeFailTester tester = NodeFailTester.withTwoApplications(7);
// For a day all nodes work so nothing happens
for (int minutes = 0, interval = 30; minutes < 24 * 60; minutes += interval) {
@@ -603,7 +602,7 @@ public class NodeFailerTest {
// Throttles based on a absolute number in small zone
{
// 50 regular tenant nodes, 10 hosts with each 3 tenant nodes, total 90 nodes
- NodeFailTester tester = NodeFailTester.withTwoApplicationsOnDocker(10);
+ NodeFailTester tester = NodeFailTester.withTwoApplications(10);
List<Node> readyNodes = tester.createReadyNodes(50, 30);
NodeList hosts = tester.nodeRepository.nodes().list().nodeType(NodeType.host);
List<Node> deadNodes = readyNodes.subList(0, 4);