Skip to content

Commit

Permalink
feat: update client rpc config (#793)
Browse files Browse the repository at this point in the history
  • Loading branch information
@hycdong
hycdong authored Jul 28, 2021
1 parent bc7e5fe commit fa5bfbb
Show file tree
Hide file tree
Showing 2 changed files with 36 additions and 29 deletions.
2 changes: 1 addition & 1 deletion rdsn
Submodule rdsn updated 30 files
+4 −0 include/dsn/cpp/rpc_stream.h
+2 −2 include/dsn/cpp/serialization_helper/thrift_helper.h
+1 −0 include/dsn/dist/replication/replication.codes.h
+4 −0 include/dsn/dist/replication/replication_ddl_client.h
+1 −0 include/dsn/tool-api/task.h
+1 −0 include/dsn/tool-api/task_spec.h
+10 −3 include/dsn/utility/binary_reader.h
+14 −0 src/client/replication_ddl_client.cpp
+25 −0 src/common/fs_manager.cpp
+2 −0 src/common/fs_manager.h
+16 −0 src/common/replica_admin.thrift
+16 −7 src/common/replication_common.cpp
+3 −2 src/common/replication_common.h
+24 −3 src/common/test/replication_common_test.cpp
+47 −5 src/meta/greedy_load_balancer.cpp
+6 −1 src/meta/greedy_load_balancer.h
+3 −1 src/replica/duplication/replica_duplicator_manager.cpp
+4 −0 src/replica/duplication/test/replica_duplicator_manager_test.cpp
+9 −0 src/replica/replica_2pc.cpp
+2 −3 src/replica/replica_check.cpp
+49 −1 src/replica/replica_stub.cpp
+3 −0 src/replica/replica_stub.h
+0 −4 src/replica/test/replica_disk_migrate_test.cpp
+47 −2 src/replica/test/replica_disk_test.cpp
+21 −1 src/replica/test/replica_disk_test_base.h
+27 −1 src/runtime/profiler.cpp
+1 −0 src/runtime/profiler_header.h
+1 −0 src/runtime/task/task_spec.cpp
+21 −6 src/utils/binary_reader.cpp
+73 −0 src/utils/test/binary_reader_test.cpp
63 changes: 35 additions & 28 deletions src/server/config.ini
View file
Original file line number Diff line number Diff line change
Expand Up @@ -525,116 +525,123 @@
;is_profile = true

[task.RPC_RRDB_RRDB_PUT]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
profiler::size.request.server = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_PUT_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_MULTI_PUT]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
profiler::size.request.server = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_MULTI_PUT_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_REMOVE]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_REMOVE_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_MULTI_REMOVE]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_MULTI_REMOVE_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_INCR]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_INCR_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_CHECK_AND_SET]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_CHECK_AND_SET_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_CHECK_AND_MUTATE]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_CHECK_AND_MUTATE_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_GET]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
profiler::size.response.server = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_GET_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_MULTI_GET]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
profiler::size.response.server = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_MULTI_GET_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_SORTKEY_COUNT]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_SORTKEY_COUNT_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_TTL]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true
rpc_request_dropped_before_execution_when_timeout = true

[task.RPC_RRDB_RRDB_TTL_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_GET_SCANNER]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_GET_SCANNER_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_SCAN]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_SCAN_ACK]
is_profile = true

[task.RPC_RRDB_RRDB_CLEAR_SCANNER]
rpc_request_throttling_mode = TM_DELAY
rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
;rpc_request_throttling_mode = TM_DELAY
;rpc_request_delays_milliseconds = 50, 50, 50, 50, 50, 100
is_profile = true

[task.RPC_RRDB_RRDB_CLEAR_SCANNER_ACK]
Expand Down

0 comments on commit fa5bfbb

Please sign in to comment.