diff options
| author | liuchang <[email protected]> | 2023-11-07 10:37:22 +0000 |
|---|---|---|
| committer | liuchang <[email protected]> | 2023-11-07 10:37:22 +0000 |
| commit | 2bcbeb873b9d9fed90c010e8bea349c5579cd452 (patch) | |
| tree | 3e93392ee60ff84b33a09031dd55163091a33e68 /shaping/include | |
| parent | 7ce4f3abd8ae83c95bee215c272b354d1a6143e7 (diff) | |
1.reduce frequency of invoking hmget
2.add aqm control for swarmkv pending queue
Diffstat (limited to 'shaping/include')
| -rw-r--r-- | shaping/include/shaper.h | 2 | ||||
| -rw-r--r-- | shaping/include/shaper_swarmkv.h | 3 |
2 files changed, 4 insertions, 1 deletions
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 |