aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-08-11 14:54:43 +0200
committerHarald Musum <musum@yahooinc.com>2022-08-11 14:54:43 +0200
commit6fa6a0847973d4d4cc84fa40f48f796dcac3a995 (patch)
tree7b92757e323bb3fe159b8e8ef5ed865364434ec4
parent37137acd5bebf5e6cdbcae6f26393f34997b4614 (diff)
Always breaks out of loop in first iteration, so just remove loop
-rw-r--r--clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java48
1 files changed, 22 insertions, 26 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java
index 31730c88276..677772e5c4e 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java
@@ -589,35 +589,31 @@ public class RpcServerTest extends FleetControllerTest {
Target connection = supervisor.connect(new Spec("localhost", rpcPort));
assertTrue(connection.isValid());
- // Possibly do request multiple times if we haven't lost slobrok contact first times yet.
- for (int j = 0; j <= nodeCount; ++j) {
- Request req = new Request("getNodeList");
- connection.invokeSync(req, timeoutS);
- assertEquals(ErrorCode.NONE, req.errorCode(), req.errorMessage());
- assertTrue(req.checkReturnTypes("SS"), req.toString());
- String[] slobrok = req.returnValues().get(0).asStringArray().clone();
- String[] rpc = req.returnValues().get(1).asStringArray().clone();
-
- assertEquals(2 * nodeCount, slobrok.length);
- assertEquals(2 * nodeCount, rpc.length);
-
- // Verify that we can connect to all addresses returned.
- for (int i = 0; i < 2 * nodeCount; ++i) {
- if (slobrok[i].equals("storage/cluster.mycluster/distributor/0")) {
- if (i < nodeCount && !"".equals(rpc[i])) {
- continue;
- }
- assertEquals("", rpc[i], slobrok[i]);
+ Request req = new Request("getNodeList");
+ connection.invokeSync(req, timeoutS);
+ assertEquals(ErrorCode.NONE, req.errorCode(), req.errorMessage());
+ assertTrue(req.checkReturnTypes("SS"), req.toString());
+ String[] slobrok = req.returnValues().get(0).asStringArray().clone();
+ String[] rpc = req.returnValues().get(1).asStringArray().clone();
+
+ assertEquals(2 * nodeCount, slobrok.length);
+ assertEquals(2 * nodeCount, rpc.length);
+
+ // Verify that we can connect to all addresses returned.
+ for (int i = 0; i < 2 * nodeCount; ++i) {
+ if (slobrok[i].equals("storage/cluster.mycluster/distributor/0")) {
+ if (i < nodeCount && !"".equals(rpc[i])) {
continue;
}
- assertNotEquals("", rpc[i]);
- Request req2 = new Request("getnodestate2");
- req2.parameters().add(new StringValue("unknown"));
- Target connection2 = supervisor.connect(new Spec(rpc[i]));
- connection2.invokeSync(req2, timeoutS);
- assertEquals(ErrorCode.NONE, req.errorCode(), req2.toString());
+ assertEquals("", rpc[i], slobrok[i]);
+ continue;
}
- break;
+ assertNotEquals("", rpc[i]);
+ Request req2 = new Request("getnodestate2");
+ req2.parameters().add(new StringValue("unknown"));
+ Target connection2 = supervisor.connect(new Spec(rpc[i]));
+ connection2.invokeSync(req2, timeoutS);
+ assertEquals(ErrorCode.NONE, req.errorCode(), req2.toString());
}
}