diff options
author | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-10-19 12:41:11 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@yahoo-inc.com> | 2016-10-19 12:41:11 +0200 |
commit | d314a9abd0da5bf5097ba65ed994469bfe49ef70 (patch) | |
tree | 64080b6f3e5ed4b95353504378e704ee4eafdc76 /zkfacade | |
parent | 01ed3f622e59b63608f2cd844796e4acbcd6ddf0 (diff) |
Make it possible to turn zk acces control on from the env
Diffstat (limited to 'zkfacade')
-rw-r--r-- | zkfacade/src/main/java/com/yahoo/vespa/zookeeper/RestrictedServerCnxnFactory.java | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/zkfacade/src/main/java/com/yahoo/vespa/zookeeper/RestrictedServerCnxnFactory.java b/zkfacade/src/main/java/com/yahoo/vespa/zookeeper/RestrictedServerCnxnFactory.java index b52f755bdc4..a51d15fec79 100644 --- a/zkfacade/src/main/java/com/yahoo/vespa/zookeeper/RestrictedServerCnxnFactory.java +++ b/zkfacade/src/main/java/com/yahoo/vespa/zookeeper/RestrictedServerCnxnFactory.java @@ -39,9 +39,13 @@ public class RestrictedServerCnxnFactory extends NIOServerCnxnFactory { if ( ! remoteHost.equals("localhost") && ! zooKeeperClients.contains(remoteHost)) { String errorMessage = "Rejecting connection to ZooKeeper from " + remoteHost + ": This cluster only allow connection from hosts in: " + zooKeeperClients; - // log.info(errorMessage); - // throw new IllegalArgumentException(errorMessage); - log.fine("Would reject if activated: " + errorMessage); + if ("true".equals(System.getenv("vespa_zkfacade__restrict"))) { + log.info(errorMessage); + throw new IllegalArgumentException(errorMessage); + } + else { + log.fine("Would reject if activated: " + errorMessage); + } } log.fine("Allowing connection to ZooKeeper from " + remoteHost + ", as it is in " + zookeeperClients); return super.createConnection(socket, selection); |