diff options
Diffstat (limited to 'shaping/include')
| -rw-r--r-- | shaping/include/shaper.h | 15 | ||||
| -rw-r--r-- | shaping/include/shaper_global_stat.h | 23 |
2 files changed, 38 insertions, 0 deletions
diff --git a/shaping/include/shaper.h b/shaping/include/shaper.h index 0a0ea11..a521ece 100644 --- a/shaping/include/shaper.h +++ b/shaping/include/shaper.h @@ -28,6 +28,13 @@ extern "C" { #define SHAPING_STAT_REFRESH_INTERVAL_SEC 2 #define SHAPING_STAT_REFRESH_MAX_PER_POLLING 5 +#define NANO_SECONDS_PER_MICRO_SEC 1000 +#define MICRO_SECONDS_PER_SEC 1000000 +#define NANO_SECONDS_PER_SEC 1000000000 + +#define NANO_SECONDS_PER_MILLI_SEC 1000000 +#define MILLI_SECONDS_PER_SEC 1000 + #define SHAPING_GLOBAL_CONF_FILE "./conf/shaping.conf" struct shaping_system_conf { @@ -155,6 +162,14 @@ struct shaper_flow_instance { int priority; }; +struct shaping_async_cb_arg { + struct shaping_thread_ctx *ctx; + struct shaping_profile_hash_node *pf_hash_node; + int priority; + unsigned char direction; + long long start_time_us; +}; + struct shaper;//instance of shaping, thread unsafe struct shaping_flow* shaping_flow_new(struct shaping_thread_ctx *ctx); diff --git a/shaping/include/shaper_global_stat.h b/shaping/include/shaper_global_stat.h index ebfa834..78ef41f 100644 --- a/shaping/include/shaper_global_stat.h +++ b/shaping/include/shaper_global_stat.h @@ -20,6 +20,12 @@ enum shaping_global_stat_column_index { ASYNC_INVOKE_IDX, ASYNC_CALLBACK_IDX, + ASYNC_TCONSUME_INVOKE_IDX, + ASYNC_TCONSUME_CALLBACK_IDX, + ASYNC_HINCRBY_INVOKE_IDX, + ASYNC_HINCRBY_CALLBACK_IDX, + ASYNC_HMGET_INVOKE_IDX, + ASYNC_HMGET_CALLBACK_IDX, ASYNC_TCONSUME_FAILED, ASYNC_HINCRBY_FAILED, ASYNC_HMGET_FAILED, @@ -63,6 +69,12 @@ struct shaping_global_stat_data { long long session_log_send; long long async_invoke; long long async_callback; + long long async_tconsume_invoke; + long long async_tconsume_callback; + long long async_hincrby_invoke; + long long async_hincrby_callback; + long long async_hmget_invoke; + long long async_hmget_callback; long long async_tconsume_failed; long long async_hincrby_failed; long long async_hmget_failed; @@ -73,6 +85,7 @@ struct shaping_global_stat_data { struct shaping_global_stat { struct fieldstat_instance *instance; int column_ids[GLOBAL_STAT_COLUNM_IDX_MAX]; + int swarmkv_latency_summary_id; struct shaping_global_stat_data local_stat_data; int output_interval_s; }; @@ -80,6 +93,8 @@ struct shaping_global_stat { struct shaping_global_stat* shaper_global_stat_init(); void shaper_global_stat_destroy(struct shaping_global_stat *stat); +void shaper_global_stat_swarmkv_latency_update(struct shaping_global_stat *stat, long long latency_us); + void shaper_global_stat_curr_session_inc(struct shaping_global_stat *stat); void shaper_global_stat_curr_session_dec(struct shaping_global_stat *stat); void shaper_global_stat_queueing_inc(struct shaping_global_stat *stat, int pkt_len); @@ -96,6 +111,14 @@ void shaper_global_stat_session_log_send_num_inc(struct shaping_global_stat *sta void shaper_global_stat_async_invoke_inc(struct shaping_global_stat *stat); void shaper_global_stat_async_callback_inc(struct shaping_global_stat *stat); + +void sheper_global_stat_tconsume_invoke_inc(struct shaping_global_stat *stat); +void shaper_global_stat_tconsume_callback_inc(struct shaping_global_stat *stat); +void shaper_global_stat_hincrby_invoke_inc(struct shaping_global_stat *stat); +void shaper_global_stat_hincrby_callback_inc(struct shaping_global_stat *stat); +void shaper_global_stat_hmget_invoke_inc(struct shaping_global_stat *stat); +void shaper_global_stat_hmget_callback_inc(struct shaping_global_stat *stat); + void shaper_global_stat_async_tconsume_failed_inc(struct shaping_global_stat *stat); void shaper_global_stat_async_hincrby_failed_inc(struct shaping_global_stat *stat); void shaper_global_stat_async_hmget_failed_inc(struct shaping_global_stat *stat); |