diff options
author | Harald Musum <musum@verizonmedia.com> | 2019-12-02 09:40:24 +0100 |
---|---|---|
committer | Harald Musum <musum@verizonmedia.com> | 2019-12-02 09:40:24 +0100 |
commit | 015c9451ecaa2fa96b663f68df11229b1780494e (patch) | |
tree | 9f107f9b0feb67ec16f432fb5a350b6028cf5104 /zookeeper-server | |
parent | e346de03f3ff1b37e9b7ce94399492fdebcd5ac6 (diff) |
Minor cleanup, no functional changes
Diffstat (limited to 'zookeeper-server')
-rw-r--r-- | zookeeper-server/zookeeper-server-3.5/src/main/java/com/yahoo/vespa/zookeeper/VespaZooKeeperServerImpl.java | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/zookeeper-server/zookeeper-server-3.5/src/main/java/com/yahoo/vespa/zookeeper/VespaZooKeeperServerImpl.java b/zookeeper-server/zookeeper-server-3.5/src/main/java/com/yahoo/vespa/zookeeper/VespaZooKeeperServerImpl.java index b87e3c9738c..a1ab14b834c 100644 --- a/zookeeper-server/zookeeper-server-3.5/src/main/java/com/yahoo/vespa/zookeeper/VespaZooKeeperServerImpl.java +++ b/zookeeper-server/zookeeper-server-3.5/src/main/java/com/yahoo/vespa/zookeeper/VespaZooKeeperServerImpl.java @@ -109,7 +109,6 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna sb.append("serverCnxnFactory=org.apache.zookeeper.server.NettyServerCnxnFactory").append("\n"); ensureThisServerIsRepresented(config.myid(), config.server()); config.server().forEach(server -> addServerToCfg(sb, server)); - // TODO: Refactor TLS config generation in the tow methods below, lots of common code SSLContext sslContext = new SslContextBuilder().build(); sb.append(new TlsQuorumConfig(sslContext, jksKeyStoreFilePath).createConfig(config, transportSecurityOptions)); sb.append(new TlsClientServerConfig(sslContext, jksKeyStoreFilePath).createConfig(config, transportSecurityOptions)); @@ -207,6 +206,8 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna String jksKeyStoreFilePath(); + SSLContext sslContext(); + default String createCommonKeyStoreTrustStoreOptions(Optional<TransportSecurityOptions> transportSecurityOptions) { StringBuilder sb = new StringBuilder(); transportSecurityOptions.ifPresent(options -> { @@ -220,11 +221,8 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna return sb.toString(); } - SSLContext sslContext(); - default String createCommonConfig() { StringBuilder sb = new StringBuilder(); - // Common config sb.append(configFieldPrefix()).append(".hostnameVerification=false\n"); sb.append(configFieldPrefix()).append(".clientAuth=NEED\n"); sb.append(configFieldPrefix()).append(".ciphersuites=").append(String.join(",", allowedCiphers(sslContext()))).append("\n"); @@ -252,7 +250,6 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna validateOptions(transportSecurityOptions, tlsSetting); StringBuilder sb = new StringBuilder(createCommonConfig()); - boolean portUnification; switch (tlsSetting) { case "OFF": @@ -267,7 +264,6 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna throw new IllegalArgumentException("Unknown value of config setting tlsForClientServerCommunication: " + tlsSetting); } sb.append("client.portUnification=").append(portUnification).append("\n"); - sb.append(createCommonKeyStoreTrustStoreOptions(transportSecurityOptions)); return sb.toString(); @@ -305,7 +301,6 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna validateOptions(transportSecurityOptions, tlsSetting); StringBuilder sb = new StringBuilder(createCommonConfig()); - boolean sslQuorum; boolean portUnification; switch (tlsSetting) { @@ -329,7 +324,6 @@ public class VespaZooKeeperServerImpl extends AbstractComponent implements Runna } sb.append("sslQuorum=").append(sslQuorum).append("\n"); sb.append("portUnification=").append(portUnification).append("\n"); - sb.append(createCommonKeyStoreTrustStoreOptions(transportSecurityOptions)); return sb.toString(); |