summaryrefslogtreecommitdiff
path: root/zookeeper-server
diff options
context:
space:
mode:
authordengliming <liming.d.pro@gmail.com>2021-06-13 15:30:41 +0800
committermaoling <maoling@apache.org>2021-06-13 15:30:41 +0800
commit32e40e8cee36ddba1973875ab6637912719271fa (patch)
tree73a93a036bc0c325604e0e79a94f176bfefd359e /zookeeper-server
parent5e787c5990091b2d1fc560eba88d3c25b04690a2 (diff)
downloadzookeeper-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.java29
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() {