From 2bcbeb873b9d9fed90c010e8bea349c5579cd452 Mon Sep 17 00:00:00 2001 From: liuchang Date: Tue, 7 Nov 2023 10:37:22 +0000 Subject: 1.reduce frequency of invoking hmget 2.add aqm control for swarmkv pending queue --- shaping/include/shaper.h | 2 ++ shaping/include/shaper_swarmkv.h | 3 ++- 2 files changed, 4 insertions(+), 1 deletion(-) (limited to 'shaping/include') diff --git a/shaping/include/shaper.h b/shaping/include/shaper.h index da32ef8..aacd15e 100644 --- a/shaping/include/shaper.h +++ b/shaping/include/shaper.h @@ -50,6 +50,8 @@ struct shaping_thread_ctx { struct shaping_global_stat *global_stat; struct shaping_marsio_info *marsio_info; struct swarmkv *swarmkv_db;//handle of swarmkv + int swarmkv_aqm_prob; + time_t swarmkv_aqm_update_time; struct shaping_maat_info *maat_info; struct session_table *session_table; struct timeouts *expires; diff --git a/shaping/include/shaper_swarmkv.h b/shaping/include/shaper_swarmkv.h index e533802..963fff0 100644 --- a/shaping/include/shaper_swarmkv.h +++ b/shaping/include/shaper_swarmkv.h @@ -2,4 +2,5 @@ struct swarmkv* shaper_swarmkv_init(int caller_thread_num); void shaper_swarmkv_destroy(struct swarmkv* swarmkv_db); -void swarmkv_reload_log_level(); \ No newline at end of file +void swarmkv_reload_log_level(); +int shaper_swarmkv_pending_queue_aqm_drop(struct shaping_thread_ctx *ctx); \ No newline at end of file -- cgit v1.2.3