diff options
author | Harald Musum <musum@yahooinc.com> | 2022-08-11 14:54:43 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-08-11 14:54:43 +0200 |
commit | 6fa6a0847973d4d4cc84fa40f48f796dcac3a995 (patch) | |
tree | 7b92757e323bb3fe159b8e8ef5ed865364434ec4 | |
parent | 37137acd5bebf5e6cdbcae6f26393f34997b4614 (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.java | 48 |
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()); } } |