oops - forgot to try again on bind exception

Project: http://git-wip-us.apache.org/repos/asf/curator/repo
Commit: http://git-wip-us.apache.org/repos/asf/curator/commit/f8f13c25
Tree: http://git-wip-us.apache.org/repos/asf/curator/tree/f8f13c25
Diff: http://git-wip-us.apache.org/repos/asf/curator/diff/f8f13c25

Branch: refs/heads/CURATOR-261
Commit: f8f13c25d65e96efa6a0718515e8e035d72de7e9
Parents: 0603e95
Author: randgalt <[email protected]>
Authored: Thu Sep 10 21:20:14 2015 -0500
Committer: randgalt <[email protected]>
Committed: Thu Sep 10 21:20:14 2015 -0500

----------------------------------------------------------------------
 .../main/java/org/apache/curator/test/TestingZooKeeperMain.java   | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/curator/blob/f8f13c25/curator-test/src/main/java/org/apache/curator/test/TestingZooKeeperMain.java
----------------------------------------------------------------------
diff --git 
a/curator-test/src/main/java/org/apache/curator/test/TestingZooKeeperMain.java 
b/curator-test/src/main/java/org/apache/curator/test/TestingZooKeeperMain.java
index 82bcd9b..795e5d0 100644
--- 
a/curator-test/src/main/java/org/apache/curator/test/TestingZooKeeperMain.java
+++ 
b/curator-test/src/main/java/org/apache/curator/test/TestingZooKeeperMain.java
@@ -224,6 +224,9 @@ public class TestingZooKeeperMain implements 
ZooKeeperMainFace
             {
                 log.info("Could not server. Waiting and trying one more 
time.", e);
                 timing.sleepABit();
+                cnxnFactory = ServerCnxnFactory.createFactory();
+                cnxnFactory.configure(config.getClientPortAddress(),
+                    config.getMaxClientCnxns());
             }
             cnxnFactory.startup(zkServer);
             containerManager = new ContainerManager(zkServer.getZKDatabase(), 
zkServer.getFirstProcessor(), 
Integer.getInteger("znode.container.checkIntervalMs", 
(int)TimeUnit.MINUTES.toMillis(1L)).intValue(), 
Integer.getInteger("znode.container.maxPerMinute", 10000).intValue());

Reply via email to