aboutsummaryrefslogtreecommitdiffstats
path: root/zkfacade
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@yahoo-inc.com>2016-10-19 12:41:11 +0200
committerJon Bratseth <bratseth@yahoo-inc.com>2016-10-19 12:41:11 +0200
commitd314a9abd0da5bf5097ba65ed994469bfe49ef70 (patch)
tree64080b6f3e5ed4b95353504378e704ee4eafdc76 /zkfacade
parent01ed3f622e59b63608f2cd844796e4acbcd6ddf0 (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.java10
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);