diff options
Diffstat (limited to 'src/http_decoder_stat.cpp')
| -rw-r--r-- | src/http_decoder_stat.cpp | 130 |
1 files changed, 59 insertions, 71 deletions
diff --git a/src/http_decoder_stat.cpp b/src/http_decoder_stat.cpp index ffa01eb..dfd1a2e 100644 --- a/src/http_decoder_stat.cpp +++ b/src/http_decoder_stat.cpp @@ -3,56 +3,61 @@ #include <unistd.h> #include "http_decoder_inc.h" -static __thread struct http_decoder_stat _th_stat; - -int http_decoder_stat_init(struct http_decoder_context *ctx, int thread_num) +static const struct hd_stat_config_tuple g_httpd_stat_tuple[HTTPD_STAT_MAX] = { - ctx->fse = fieldstat_easy_new(thread_num, "http_decoder_statistics", NULL, 0); - if (NULL == ctx->fse) - { - fprintf(stderr, "fieldstat_easy_new failed."); - return -1; - } - - ctx->fs_incoming_bytes_id = - fieldstat_easy_register_counter(ctx->fse, "incoming_bytes"); - if (ctx->fs_incoming_bytes_id < 0) - { - fprintf(stderr, "fieldstat_easy_register_counter incoming_bytes failed."); - return -1; - } - - ctx->fs_incoming_trans_id = - fieldstat_easy_register_counter(ctx->fse, "incoming_trans"); - if (ctx->fs_incoming_trans_id < 0) - { - fprintf(stderr, "fieldstat_easy_register_counter incoming_trans failed."); - return -1; + {HTTPD_STAT_BYTES_C2S, "bytes_c2s"}, + {HTTPD_STAT_BYTES_S2C, "bytes_s2c"}, + {HTTPD_STAT_TCP_SEG_C2S, "tcp_seg_c2s"}, + {HTTPD_STAT_TCP_SEG_S2C, "tcp_seg_s2c"}, + {HTTPD_STAT_HEADERS_C2S, "headers_c2s"}, + {HTTPD_STAT_HEADERS_S2C, "headers_s2c"}, + {HTTPD_STAT_URL_BYTES, "url_bytes"}, + {HTTPD_STAT_SESSION_NEW, "session_new"}, + {HTTPD_STAT_SESSION_FREE, "session_free"}, + {HTTPD_STAT_SESSION_EXCEPTION, "sess_exception"}, + {HTTPD_STAT_TRANSACTION_NEW, "trans_new"}, + {HTTPD_STAT_TRANSACTION_FREE, "trans_free"}, + {HTTPD_STAT_ASYMMETRY_SESSION_C2S, "asymmetry_sess_c2s"}, + {HTTPD_STAT_ASYMMETRY_SESSION_S2C, "asymmetry_sess_s2c"}, + {HTTPD_STAT_ASYMMETRY_TRANSACTION_C2S, "asymmetry_trans_c2s"}, + {HTTPD_STAT_ASYMMETRY_TRANSACTION_S2C, "asymmetry_trans_s2c"}, + {HTTPD_STAT_PARSE_ERR, "parse_err"}, +}; + +void http_decoder_stat_free(struct http_decoder_stat *hd_stat) +{ + if(hd_stat->stats != NULL){ + free(hd_stat->stats); } - - ctx->fs_incoming_pkts_id = - fieldstat_easy_register_counter(ctx->fse, "incoming_pkts"); - if (ctx->fs_incoming_pkts_id < 0) - { - fprintf(stderr, "fieldstat_easy_register_counter incoming_pkts failed."); - return -1; + if(hd_stat->fse != NULL){ + fieldstat_easy_free(hd_stat->fse); } +} - ctx->fs_err_pkts_id = fieldstat_easy_register_counter(ctx->fse, "err_pkts"); - if (ctx->fs_err_pkts_id < 0) +int http_decoder_stat_init(struct http_decoder_stat *hd_stat, int thread_max, int stat_interval_pkts, int stat_interval_time) +{ + assert(sizeof(g_httpd_stat_tuple)/sizeof(struct hd_stat_config_tuple) == HTTPD_STAT_MAX); + hd_stat->fse = fieldstat_easy_new(thread_max, "http_decoder_statistics", NULL, 0); + if (NULL == hd_stat->fse) { - fprintf(stderr, "fieldstat_easy_register_counter err_pkts failed."); + fprintf(stderr, "fieldstat_easy_new failed."); return -1; } - int stat_output_interval = DEFAULT_STAT_OUTPUT_INTERVAL; - if (ctx->hd_cfg.stat_output_interval > 0) + for(int i = 0; i < HTTPD_STAT_MAX; i++) { - stat_output_interval = ctx->hd_cfg.stat_output_interval; + hd_stat->field_stat_id[i] = fieldstat_easy_register_counter(hd_stat->fse, g_httpd_stat_tuple[i].name); + if (hd_stat->field_stat_id[i] < 0) + { + fprintf(stderr, "fieldstat_easy_register_counter %s failed.", g_httpd_stat_tuple[i].name); + return -1; + } } - int ret = fieldstat_easy_enable_auto_output(ctx->fse, FILEDSTAT_OUTPUT_FILE, - stat_output_interval); + hd_stat->stats = (struct hd_statistics *)calloc(thread_max, sizeof(struct hd_statistics)); + hd_stat->stat_interval_pkts = stat_interval_pkts; + + int ret = fieldstat_easy_enable_auto_output(hd_stat->fse, FILEDSTAT_OUTPUT_FILE, stat_interval_time); if (ret < 0) { fprintf(stderr, "fieldstat_easy_enable_auto_output failed."); @@ -62,38 +67,21 @@ int http_decoder_stat_init(struct http_decoder_context *ctx, int thread_num) return 0; } -void http_decoder_stat_output(struct http_decoder_context *ctx, int thread_id) +void http_decoder_stat_update(struct http_decoder_stat *hd_stat, int thread_id, enum http_decoder_stat_type type, long long value) { - assert(ctx != NULL); - - int stat_interval_pkts = DEFAULT_STAT_INTERVAL_PKTS; - if (ctx->hd_cfg.stat_interval_pkts > 0) - { - stat_interval_pkts = ctx->hd_cfg.stat_interval_pkts; - } - - if (_th_stat.counter >= stat_interval_pkts) - { - fieldstat_easy_counter_incrby(ctx->fse, thread_id, - ctx->fs_incoming_bytes_id, NULL, 0, - _th_stat.incoming_bytes); - - fieldstat_easy_counter_incrby(ctx->fse, thread_id, - ctx->fs_incoming_pkts_id, NULL, 0, - _th_stat.incoming_pkts); - - fieldstat_easy_counter_incrby(ctx->fse, thread_id, - ctx->fs_incoming_trans_id, NULL, 0, - _th_stat.incoming_trans); - - fieldstat_easy_counter_incrby(ctx->fse, thread_id, - ctx->fs_err_pkts_id, NULL, 0, - _th_stat.err_pkts); - - _th_stat.counter = 0; - _th_stat.err_pkts = 0; - _th_stat.incoming_bytes = 0; - _th_stat.incoming_pkts = 0; - _th_stat.incoming_trans = 0; + assert(hd_stat); + assert(thread_id >= 0); + assert(type < HTTPD_STAT_MAX); + + hd_stat->stats[thread_id].counter[type] += value; + hd_stat->stats[thread_id].batch++; + + if(hd_stat->stats[thread_id].batch >= hd_stat->stat_interval_pkts){ + for(int i = 0; i < HTTPD_STAT_MAX; i++){ + //update all type, maybe decrease performance ? + fieldstat_easy_counter_incrby(hd_stat->fse, thread_id, hd_stat->field_stat_id[i], NULL, 0, hd_stat->stats[thread_id].counter[i]); + hd_stat->stats[thread_id].counter[i] = 0; + } + hd_stat->stats[thread_id].batch = 0; } } |