diff options
author | Martin Polden <mpolden@mpolden.no> | 2020-12-04 09:07:54 +0100 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2020-12-04 09:07:54 +0100 |
commit | 63ac5a6ea30524fca40ee00835dd830da03d608f (patch) | |
tree | b6dd002679af52a1dbe7e6205aa20c1c919cf0bb /zookeeper-server | |
parent | 6182826218bce697bea240cbd25ddad5ee22b59c (diff) |
Include client port in server statement
Diffstat (limited to 'zookeeper-server')
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()); |