You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by sm...@apache.org on 2022/01/28 04:00:05 UTC
[incubator-pegasus] branch master updated: feat: add throttle config of read/write request (#831)
This is an automated email from the ASF dual-hosted git repository.
smityz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
The following commit(s) were added to refs/heads/master by this push:
new 59dc6bd feat: add throttle config of read/write request (#831)
59dc6bd is described below
commit 59dc6bd46805e18f405c3a03ebba5a8a591ce029
Author: Smilencer <52...@qq.com>
AuthorDate: Fri Jan 28 12:00:00 2022 +0800
feat: add throttle config of read/write request (#831)
---
src/server/config.ini | 14 ++++++++++++++
src/server/config.min.ini | 9 +++++++++
2 files changed, 23 insertions(+)
diff --git a/src/server/config.ini b/src/server/config.ini
index f21d419..b823a3f 100644
--- a/src/server/config.ini
+++ b/src/server/config.ini
@@ -544,6 +544,7 @@
is_profile = true
profiler::size.request.server = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_PUT_ACK]
is_profile = true
@@ -554,6 +555,7 @@
is_profile = true
profiler::size.request.server = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_MULTI_PUT_ACK]
is_profile = true
@@ -563,6 +565,7 @@
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_REMOVE_ACK]
is_profile = true
@@ -572,6 +575,7 @@
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_MULTI_REMOVE_ACK]
is_profile = true
@@ -580,6 +584,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_INCR_ACK]
is_profile = true
@@ -588,6 +593,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_CHECK_AND_SET_ACK]
is_profile = true
@@ -596,6 +602,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_CHECK_AND_MUTATE_ACK]
is_profile = true
@@ -606,6 +613,7 @@
is_profile = true
profiler::size.response.server = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_GET_ACK]
is_profile = true
@@ -616,6 +624,7 @@
is_profile = true
profiler::size.response.server = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_MULTI_GET_ACK]
is_profile = true
@@ -624,6 +633,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_SORTKEY_COUNT_ACK]
is_profile = true
@@ -633,6 +643,7 @@
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
;rpc_request_dropped_before_execution_when_timeout = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_TTL_ACK]
is_profile = true
@@ -641,6 +652,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_GET_SCANNER_ACK]
is_profile = true
@@ -649,6 +661,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_SCAN_ACK]
is_profile = true
@@ -657,6 +670,7 @@
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_CLEAR_SCANNER_ACK]
is_profile = true
diff --git a/src/server/config.min.ini b/src/server/config.min.ini
index ff74e65..3e7556b 100644
--- a/src/server/config.min.ini
+++ b/src/server/config.min.ini
@@ -179,6 +179,7 @@
[task.RPC_RRDB_RRDB_PUT]
is_profile = true
profiler::size.request.server = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_PUT_ACK]
is_profile = true
@@ -186,36 +187,42 @@
[task.RPC_RRDB_RRDB_MULTI_PUT]
is_profile = true
profiler::size.request.server = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_MULTI_PUT_ACK]
is_profile = true
[task.RPC_RRDB_RRDB_REMOVE]
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_REMOVE_ACK]
is_profile = true
[task.RPC_RRDB_RRDB_MULTI_REMOVE]
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_MULTI_REMOVE_ACK]
is_profile = true
[task.RPC_RRDB_RRDB_INCR]
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_INCR_ACK]
is_profile = true
[task.RPC_RRDB_RRDB_CHECK_AND_SET]
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_CHECK_AND_SET_ACK]
is_profile = true
[task.RPC_RRDB_RRDB_CHECK_AND_MUTATE]
is_profile = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_CHECK_AND_MUTATE_ACK]
is_profile = true
@@ -223,6 +230,7 @@
[task.RPC_RRDB_RRDB_GET]
is_profile = true
profiler::size.response.server = true
+ rpc_request_throttling_mode = TM_REJECT
[task.RPC_RRDB_RRDB_GET_ACK]
is_profile = true
@@ -230,3 +238,4 @@
[task.RPC_RRDB_RRDB_MULTI_GET]
is_profile = true
profiler::size.response.server = true
+ rpc_request_throttling_mode = TM_REJECT
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org