diff options
author | Harald Musum <musum@yahooinc.com> | 2022-08-22 10:58:34 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-08-22 10:58:34 +0200 |
commit | da873a1f429b262ca82f7d288b93a7bc31e72fec (patch) | |
tree | ab01085c2ca471058aef86c5c2200a922390084b /clustercontroller-core | |
parent | 785e08522e517698c63521457ef64cebf5b6e5ee (diff) |
Dynamically choose port to use, avoid collisions with other users of port
Diffstat (limited to 'clustercontroller-core')
-rw-r--r-- | clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/RpcServerTest.java | 8 |
1 files changed, 5 insertions, 3 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 6a7c75c629e..789c86bd6cf 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 @@ -22,7 +22,6 @@ import com.yahoo.vespa.clustercontroller.core.rpc.RpcServer; import com.yahoo.vespa.clustercontroller.core.testutils.LogFormatter; import com.yahoo.vespa.clustercontroller.core.testutils.WaitCondition; import org.junit.jupiter.api.Test; - import java.util.ArrayList; import java.util.List; import java.util.Set; @@ -31,7 +30,10 @@ import java.util.logging.Level; import java.util.logging.Logger; import java.util.stream.Collectors; -import static org.junit.jupiter.api.Assertions.*; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertFalse; +import static org.junit.jupiter.api.Assertions.assertNotEquals; +import static org.junit.jupiter.api.Assertions.assertTrue; /** * @author humbe @@ -55,7 +57,7 @@ public class RpcServerTest extends FleetControllerTest { Slobrok slobrok = new Slobrok(); String[] slobrokConnectionSpecs = getSlobrokConnectionSpecs(slobrok); RpcServer server = new RpcServer(timer, new Object(), "mycluster", 0, new BackOff()); - server.setSlobrokConnectionSpecs(slobrokConnectionSpecs, 18347); + server.setSlobrokConnectionSpecs(slobrokConnectionSpecs, 0); int portUsed = server.getPort(); server.setSlobrokConnectionSpecs(slobrokConnectionSpecs, portUsed); server.disconnect(); |