Parcourir la source

ZOOKEEPER-326. standalone server ignores tickTime configuration. (chris darroch via mahadev)

git-svn-id: https://svn.apache.org/repos/asf/hadoop/zookeeper/trunk@747222 13f79535-47bb-0310-9956-ffa450edef68
Mahadev Konar il y a 16 ans
Parent
commit
f36e174ebe

+ 3 - 0
CHANGES.txt

@@ -13,6 +13,9 @@ IMPROVEMENTS:
   ZOOKEEPER-308. improve the atomic broadcast performance 3x. (breed via
   ZOOKEEPER-308. improve the atomic broadcast performance 3x. (breed via
 mahadev)
 mahadev)
 
 
+ ZOOKEEPER-326. standalone server ignores tickTime configuration. (chris
+darroch via mahadev)
+
 NEW FEATURES:
 NEW FEATURES:
 
 
 
 

+ 3 - 1
src/java/main/org/apache/zookeeper/server/ZooKeeperServerMain.java

@@ -26,6 +26,7 @@ import javax.management.JMException;
 import org.apache.log4j.Logger;
 import org.apache.log4j.Logger;
 import org.apache.zookeeper.jmx.ManagedUtil;
 import org.apache.zookeeper.jmx.ManagedUtil;
 import org.apache.zookeeper.server.persistence.FileTxnSnapLog;
 import org.apache.zookeeper.server.persistence.FileTxnSnapLog;
+import org.apache.zookeeper.server.quorum.QuorumPeerConfig;
 
 
 /**
 /**
  * This class starts and runs a standalone ZooKeeperServer.
  * This class starts and runs a standalone ZooKeeperServer.
@@ -47,7 +48,7 @@ public class ZooKeeperServerMain {
         }
         }
 
 
         try {
         try {
-            ServerConfig.parse(args);
+            QuorumPeerConfig.parse(args);
         } catch(Exception e) {
         } catch(Exception e) {
             LOG.fatal("Error in config", e);
             LOG.fatal("Error in config", e);
             LOG.info(USAGE);
             LOG.info(USAGE);
@@ -66,6 +67,7 @@ public class ZooKeeperServerMain {
                        File(ServerConfig.getDataLogDir()),
                        File(ServerConfig.getDataLogDir()),
                         new File(ServerConfig.getDataDir()));
                         new File(ServerConfig.getDataDir()));
                zks.setTxnLogFactory(ftxn);
                zks.setTxnLogFactory(ftxn);
+               zks.setTickTime(QuorumPeerConfig.getTickTime());
                return zks;
                return zks;
             }
             }
         });
         });