summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorroot <[email protected]>2024-06-05 09:23:35 +0000
committerroot <[email protected]>2024-06-05 09:23:35 +0000
commitda691ef02580893d6539f39e7543443f427ef2a6 (patch)
treeea321ee2ec356db1ae52cdb562b90a45dfbf17a5
parentddd6873dab598216449de3aec2bf55c40cb6b619 (diff)
fix swarmkv caller_thread_num
-rw-r--r--shaping/src/shaper_swarmkv.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/shaping/src/shaper_swarmkv.cpp b/shaping/src/shaper_swarmkv.cpp
index 069cf33..d7fcd77 100644
--- a/shaping/src/shaper_swarmkv.cpp
+++ b/shaping/src/shaper_swarmkv.cpp
@@ -129,7 +129,7 @@ struct swarmkv* shaper_swarmkv_init(int caller_thread_num)
swarmkv_options_set_health_check_announce_port(swarmkv_opts, conf.swarmkv_health_check_announce_port);
swarmkv_options_set_log_path(swarmkv_opts, "log");
swarmkv_options_set_log_level(swarmkv_opts, conf.swarmkv_log_level);
- swarmkv_options_set_caller_thread_number(swarmkv_opts, caller_thread_num);
+ swarmkv_options_set_caller_thread_number(swarmkv_opts, caller_thread_num + 1);
swarmkv_options_set_worker_thread_number(swarmkv_opts, conf.swarmkv_worker_thread_num);
swarmkv_db = swarmkv_open(swarmkv_opts, conf.swarmkv_cluster_name, &err);