summaryrefslogtreecommitdiffstats
path: root/zookeeper-server
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2020-12-04 09:07:54 +0100
committerMartin Polden <mpolden@mpolden.no>2020-12-04 09:07:54 +0100
commit63ac5a6ea30524fca40ee00835dd830da03d608f (patch)
treeb6dd002679af52a1dbe7e6205aa20c1c919cf0bb /zookeeper-server
parent6182826218bce697bea240cbd25ddad5ee22b59c (diff)
Include client port in server statement
Diffstat (limited to 'zookeeper-server')
-rw-r--r--zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java2
-rw-r--r--zookeeper-server/zookeeper-server-3.5.6/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java2
2 files changed, 2 insertions, 2 deletions
diff --git a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
index a5dd0978fe8..9cf528434ef 100644
--- a/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
+++ b/zookeeper-server/zookeeper-server-3.5.6/src/main/java/com/yahoo/vespa/zookeeper/Reconfigurer.java
@@ -107,7 +107,7 @@ public class Reconfigurer extends AbstractComponent {
// See https://zookeeper.apache.org/doc/r3.5.8/zookeeperReconfig.html#sc_reconfig_clientport for format
return config.server().stream()
.map(server -> server.id() + "=" + server.hostname() + ":" + server.quorumPort() + ":" +
- server.electionPort())
+ server.electionPort() + ";" + config.clientPort())
.collect(Collectors.toList());
}
diff --git a/zookeeper-server/zookeeper-server-3.5.6/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java b/zookeeper-server/zookeeper-server-3.5.6/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java
index db6c0aec4d9..232d1aed94d 100644
--- a/zookeeper-server/zookeeper-server-3.5.6/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java
+++ b/zookeeper-server/zookeeper-server-3.5.6/src/test/java/com/yahoo/vespa/zookeeper/ReconfigurerTest.java
@@ -47,7 +47,7 @@ public class ReconfigurerTest {
ZookeeperServerConfig nextConfig = createConfig(5, true);
reconfigurer.startOrReconfigure(nextConfig);
assertEquals("node0:2181,node1:2181,node2:2181", reconfigurer.connectionSpec);
- assertEquals("3=node3:2182:2183,4=node4:2182:2183", reconfigurer.joiningServers);
+ assertEquals("3=node3:2182:2183;2181,4=node4:2182:2183;2181", reconfigurer.joiningServers);
assertNull("No servers are leaving", reconfigurer.leavingServers);
assertEquals(1, reconfigurer.reconfigurations);
assertSame(nextConfig, reconfigurer.activeConfig());