postgres/typesense
1
0
Fork 0
mirror of https://github.com/typesense/typesense.git synced 2025-05-21 06:02:26 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

Bump raft max byte count per rpc for snapshot install.

Browse Source
This commit is contained in:
kishorenc 2020-12-25 19:11:27 +05:30
parent bc1d88f1eb
commit 1a8d5a0912
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/raft_server.cpp
View File

@ -13,6 +13,9 @@ namespace braft {
DECLARE_int32(raft_do_snapshot_min_index_gap);
DECLARE_int32(raft_max_parallel_append_entries_rpc_num);
DECLARE_bool(raft_enable_append_entries_cache);
DECLARE_int32(raft_max_append_entries_cache_size);
DECLARE_int32(raft_max_byte_count_per_rpc);
}
void ReplicationClosure::Run() {
@ -43,9 +46,13 @@ int ReplicationState::start(const butil::EndPoint & peering_endpoint, const int
// do snapshot only when the gap between applied index and last snapshot index is >= this number
braft::FLAGS_raft_do_snapshot_min_index_gap = 1;
// parallelizes reads and writes
braft::FLAGS_raft_max_parallel_append_entries_rpc_num = 8;
braft::FLAGS_raft_enable_append_entries_cache = true;
// flags for controlling parallelism of append entries
braft::FLAGS_raft_max_parallel_append_entries_rpc_num = 1;
braft::FLAGS_raft_enable_append_entries_cache = false;
braft::FLAGS_raft_max_append_entries_cache_size = 8;
// flag controls snapshot download size of each RPC
braft::FLAGS_raft_max_byte_count_per_rpc = 4 * 1024 * 1024; // 4 MB
node_options.election_timeout_ms = election_timeout_ms;
node_options.fsm = this;