diff options
| author | root <[email protected]> | 2024-06-05 09:23:35 +0000 |
|---|---|---|
| committer | root <[email protected]> | 2024-06-05 09:23:35 +0000 |
| commit | da691ef02580893d6539f39e7543443f427ef2a6 (patch) | |
| tree | ea321ee2ec356db1ae52cdb562b90a45dfbf17a5 | |
| parent | ddd6873dab598216449de3aec2bf55c40cb6b619 (diff) | |
fix swarmkv caller_thread_num
| -rw-r--r-- | shaping/src/shaper_swarmkv.cpp | 2 |
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); |
