diff options
author | dengliming <liming.d.pro@gmail.com> | 2021-06-13 15:30:41 +0800 |
---|---|---|
committer | maoling <maoling@apache.org> | 2021-06-13 15:30:41 +0800 |
commit | 32e40e8cee36ddba1973875ab6637912719271fa (patch) | |
tree | 73a93a036bc0c325604e0e79a94f176bfefd359e /zookeeper-server | |
parent | 5e787c5990091b2d1fc560eba88d3c25b04690a2 (diff) | |
download | zookeeper-32e40e8cee36ddba1973875ab6637912719271fa.tar.gz |
ZOOKEEPER-3821: Improve getSnapCount and getGlobalOutstandingLimit
Author: dengliming <liming.d.pro@gmail.com>
Reviewers: Enrico Olivelli <eolivelli@apache.org>, Andor Molnar <anmolnar@apache.org>, maoling <maoling@apache.org>
Closes #1352 from dengliming/ZOOKEEPER-3821
Diffstat (limited to 'zookeeper-server')
-rw-r--r-- | zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java | 29 |
1 files changed, 9 insertions, 20 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java index 6a424178f..aeeebb9ec 100644 --- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java +++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ZooKeeperServer.java @@ -194,6 +194,8 @@ public class ZooKeeperServer implements SessionExpirer, ServerStats.Provider { protected String initialConfig; protected boolean reconfigEnabled; private final RequestPathMetricsCollector requestPathMetricsCollector; + private static final int DEFAULT_SNAP_COUNT = 100000; + private static final int DEFAULT_GLOBAL_OUTSTANDING_LIMIT = 1000; private boolean localSessionEnabled = false; protected enum State { @@ -1183,30 +1185,17 @@ public class ZooKeeperServer implements SessionExpirer, ServerStats.Provider { } public static int getSnapCount() { - String sc = System.getProperty(SNAP_COUNT); - try { - int snapCount = Integer.parseInt(sc); - - // snapCount must be 2 or more. See org.apache.zookeeper.server.SyncRequestProcessor - if (snapCount < 2) { - LOG.warn("SnapCount should be 2 or more. Now, snapCount is reset to 2"); - snapCount = 2; - } - return snapCount; - } catch (Exception e) { - return 100000; + int snapCount = Integer.getInteger(SNAP_COUNT, DEFAULT_SNAP_COUNT); + // snapCount must be 2 or more. See org.apache.zookeeper.server.SyncRequestProcessor + if (snapCount < 2) { + LOG.warn("SnapCount should be 2 or more. Now, snapCount is reset to 2"); + snapCount = 2; } + return snapCount; } public int getGlobalOutstandingLimit() { - String sc = System.getProperty(GLOBAL_OUTSTANDING_LIMIT); - int limit; - try { - limit = Integer.parseInt(sc); - } catch (Exception e) { - limit = 1000; - } - return limit; + return Integer.getInteger(GLOBAL_OUTSTANDING_LIMIT, DEFAULT_GLOBAL_OUTSTANDING_LIMIT); } public static long getSnapSizeInBytes() { |