diff options
| author | 刘畅 <[email protected]> | 2023-10-11 06:56:36 +0000 |
|---|---|---|
| committer | 刘畅 <[email protected]> | 2023-10-11 06:56:36 +0000 |
| commit | a9b563f964ac68d03b0c4b936767709ddfc46274 (patch) | |
| tree | 5b9e84e19ea03d674c17e2872a35de6141c2ac33 | |
| parent | 329a44aef63ed3247812481a112b8fac0facbde0 (diff) | |
| parent | c865cbd205f4f96db45350a813a3a53042ce6443 (diff) | |
Merge branch 'add_swarmkv_worker_thread_num_config' into 'rel'v1.3.1
add config for swarmkv worker thread num
See merge request tango/shaping-engine!43
| -rw-r--r-- | shaping/src/shaper_swarmkv.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/shaping/src/shaper_swarmkv.cpp b/shaping/src/shaper_swarmkv.cpp index 05ccecc..3f6df0c 100644 --- a/shaping/src/shaper_swarmkv.cpp +++ b/shaping/src/shaper_swarmkv.cpp @@ -18,6 +18,7 @@ struct shaper_swarmkv_conf short swarmkv_health_check_port; short swarmkv_health_check_announce_port; short swarmkv_log_level; + int swarmkv_worker_thread_num; }; static int shaper_swarmkv_config_load(struct shaper_swarmkv_conf *conf) @@ -82,6 +83,8 @@ static int shaper_swarmkv_config_load(struct shaper_swarmkv_conf *conf) return ret; } + MESA_load_profile_int_def(SHAPING_GLOBAL_CONF_FILE, "SWARMKV", "SWARMKV_WORKER_THREAD_NUM", &conf->swarmkv_worker_thread_num, 1); + MESA_load_profile_short_def(SHAPING_GLOBAL_CONF_FILE, "SWARMKV", "SWARMKV_LOG_LEVEL", &conf->swarmkv_log_level, 4); return 0; @@ -121,7 +124,7 @@ struct swarmkv* shaper_swarmkv_init(int caller_thread_num) 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_worker_thread_number(swarmkv_opts, 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); if (err) { |