mirror of
https://git.haproxy.org/git/haproxy.git/
synced 2026-04-14 10:02:02 +02:00
9019a5db93
Now thanks to new macro EXTRA_COUNTERS_AGGR() we can iterate over all thread groups storages when returning the data for a given metric. This remains convenient and mostly transparent. The caller continues to pass the pointer to the metric in the first group, and offsets are calculated for all other groups and data summed. For now all groups except the first one contain only zeroes but reported values are nevertheless correct.
359 lines
15 KiB
C
359 lines
15 KiB
C
#include <haproxy/h3.h>
|
|
#include <haproxy/qpack-t.h>
|
|
#include <haproxy/stats.h>
|
|
|
|
enum {
|
|
/* h3 frame type counters */
|
|
H3_ST_DATA,
|
|
H3_ST_HEADERS,
|
|
H3_ST_CANCEL_PUSH,
|
|
H3_ST_PUSH_PROMISE,
|
|
H3_ST_MAX_PUSH_ID,
|
|
H3_ST_GOAWAY,
|
|
H3_ST_SETTINGS,
|
|
/* h3 error counters */
|
|
H3_ST_H3_NO_ERROR,
|
|
H3_ST_H3_GENERAL_PROTOCOL_ERROR,
|
|
H3_ST_H3_INTERNAL_ERROR,
|
|
H3_ST_H3_STREAM_CREATION_ERROR,
|
|
H3_ST_H3_CLOSED_CRITICAL_STREAM,
|
|
H3_ST_H3_FRAME_UNEXPECTED,
|
|
H3_ST_H3_FRAME_ERROR,
|
|
H3_ST_H3_EXCESSIVE_LOAD,
|
|
H3_ST_H3_ID_ERROR,
|
|
H3_ST_H3_SETTINGS_ERROR,
|
|
H3_ST_H3_MISSING_SETTINGS,
|
|
H3_ST_H3_REQUEST_REJECTED,
|
|
H3_ST_H3_REQUEST_CANCELLED,
|
|
H3_ST_H3_REQUEST_INCOMPLETE,
|
|
H3_ST_H3_MESSAGE_ERROR,
|
|
H3_ST_H3_CONNECT_ERROR,
|
|
H3_ST_H3_VERSION_FALLBACK,
|
|
/* QPACK error counters */
|
|
H3_ST_QPACK_DECOMPRESSION_FAILED,
|
|
H3_ST_QPACK_ENCODER_STREAM_ERROR,
|
|
H3_ST_QPACK_DECODER_STREAM_ERROR,
|
|
H3_STATS_COUNT /* must be the last */
|
|
};
|
|
|
|
static struct stat_col h3_stats[] = {
|
|
/* h3 frame type counters */
|
|
[H3_ST_DATA] = { .name = "h3_data",
|
|
.desc = "Total number of DATA frames received" },
|
|
[H3_ST_HEADERS] = { .name = "h3_headers",
|
|
.desc = "Total number of HEADERS frames received" },
|
|
[H3_ST_CANCEL_PUSH] = { .name = "h3_cancel_push",
|
|
.desc = "Total number of CANCEL_PUSH frames received" },
|
|
[H3_ST_PUSH_PROMISE] = { .name = "h3_push_promise",
|
|
.desc = "Total number of PUSH_PROMISE frames received" },
|
|
[H3_ST_MAX_PUSH_ID] = { .name = "h3_max_push_id",
|
|
.desc = "Total number of MAX_PUSH_ID frames received" },
|
|
[H3_ST_GOAWAY] = { .name = "h3_goaway",
|
|
.desc = "Total number of GOAWAY frames received" },
|
|
[H3_ST_SETTINGS] = { .name = "h3_settings",
|
|
.desc = "Total number of SETTINGS frames received" },
|
|
/* h3 error counters */
|
|
[H3_ST_H3_NO_ERROR] = { .name = "h3_no_error",
|
|
.desc = "Total number of H3_NO_ERROR errors received" },
|
|
[H3_ST_H3_GENERAL_PROTOCOL_ERROR] = { .name = "h3_general_protocol_error",
|
|
.desc = "Total number of H3_GENERAL_PROTOCOL_ERROR errors received" },
|
|
[H3_ST_H3_INTERNAL_ERROR] = { .name = "h3_internal_error",
|
|
.desc = "Total number of H3_INTERNAL_ERROR errors received" },
|
|
[H3_ST_H3_STREAM_CREATION_ERROR] = { .name = "h3_stream_creation_error",
|
|
.desc = "Total number of H3_STREAM_CREATION_ERROR errors received" },
|
|
[H3_ST_H3_CLOSED_CRITICAL_STREAM] = { .name = "h3_closed_critical_stream",
|
|
.desc = "Total number of H3_CLOSED_CRITICAL_STREAM errors received" },
|
|
[H3_ST_H3_FRAME_UNEXPECTED] = { .name = "h3_frame_unexpected",
|
|
.desc = "Total number of H3_FRAME_UNEXPECTED errors received" },
|
|
[H3_ST_H3_FRAME_ERROR] = { .name = "h3_frame_error",
|
|
.desc = "Total number of H3_FRAME_ERROR errors received" },
|
|
[H3_ST_H3_EXCESSIVE_LOAD] = { .name = "h3_excessive_load",
|
|
.desc = "Total number of H3_EXCESSIVE_LOAD errors received" },
|
|
[H3_ST_H3_ID_ERROR] = { .name = "h3_id_error",
|
|
.desc = "Total number of H3_ID_ERROR errors received" },
|
|
[H3_ST_H3_SETTINGS_ERROR] = { .name = "h3_settings_error",
|
|
.desc = "Total number of H3_SETTINGS_ERROR errors received" },
|
|
[H3_ST_H3_MISSING_SETTINGS] = { .name = "h3_missing_settings",
|
|
.desc = "Total number of H3_MISSING_SETTINGS errors received" },
|
|
[H3_ST_H3_REQUEST_REJECTED] = { .name = "h3_request_rejected",
|
|
.desc = "Total number of H3_REQUEST_REJECTED errors received" },
|
|
[H3_ST_H3_REQUEST_CANCELLED] = { .name = "h3_request_cancelled",
|
|
.desc = "Total number of H3_REQUEST_CANCELLED errors received" },
|
|
[H3_ST_H3_REQUEST_INCOMPLETE] = { .name = "h3_request_incomplete",
|
|
.desc = "Total number of H3_REQUEST_INCOMPLETE errors received" },
|
|
[H3_ST_H3_MESSAGE_ERROR] = { .name = "h3_message_error",
|
|
.desc = "Total number of H3_MESSAGE_ERROR errors received" },
|
|
[H3_ST_H3_CONNECT_ERROR] = { .name = "h3_connect_error",
|
|
.desc = "Total number of H3_CONNECT_ERROR errors received" },
|
|
[H3_ST_H3_VERSION_FALLBACK] = { .name = "h3_version_fallback",
|
|
.desc = "Total number of H3_VERSION_FALLBACK errors received" },
|
|
/* QPACK error counters */
|
|
[H3_ST_QPACK_DECOMPRESSION_FAILED] = { .name = "pack_decompression_failed",
|
|
.desc = "Total number of QPACK_DECOMPRESSION_FAILED errors received" },
|
|
[H3_ST_QPACK_ENCODER_STREAM_ERROR] = { .name = "qpack_encoder_stream_error",
|
|
.desc = "Total number of QPACK_ENCODER_STREAM_ERROR errors received" },
|
|
[H3_ST_QPACK_DECODER_STREAM_ERROR] = { .name = "qpack_decoder_stream_error",
|
|
.desc = "Total number of QPACK_DECODER_STREAM_ERROR errors received" },
|
|
};
|
|
|
|
static struct h3_counters {
|
|
/* h3 frame type counters */
|
|
long long h3_data; /* total number of DATA frames received */
|
|
long long h3_headers; /* total number of HEADERS frames received */
|
|
long long h3_cancel_push; /* total number of CANCEL_PUSH frames received */
|
|
long long h3_push_promise; /* total number of PUSH_PROMISE frames received */
|
|
long long h3_max_push_id; /* total number of MAX_PUSH_ID frames received */
|
|
long long h3_goaway; /* total number of GOAWAY frames received */
|
|
long long h3_settings; /* total number of SETTINGS frames received */
|
|
/* h3 error counters */
|
|
long long h3_no_error; /* total number of H3_NO_ERROR errors received */
|
|
long long h3_general_protocol_error; /* total number of H3_GENERAL_PROTOCOL_ERROR errors received */
|
|
long long h3_internal_error; /* total number of H3_INTERNAL_ERROR errors received */
|
|
long long h3_stream_creation_error; /* total number of H3_STREAM_CREATION_ERROR errors received */
|
|
long long h3_closed_critical_stream; /* total number of H3_CLOSED_CRITICAL_STREAM errors received */
|
|
long long h3_frame_unexpected; /* total number of H3_FRAME_UNEXPECTED errors received */
|
|
long long h3_frame_error; /* total number of H3_FRAME_ERROR errors received */
|
|
long long h3_excessive_load; /* total number of H3_EXCESSIVE_LOAD errors received */
|
|
long long h3_id_error; /* total number of H3_ID_ERROR errors received */
|
|
long long h3_settings_error; /* total number of H3_SETTINGS_ERROR errors received */
|
|
long long h3_missing_settings; /* total number of H3_MISSING_SETTINGS errors received */
|
|
long long h3_request_rejected; /* total number of H3_REQUEST_REJECTED errors received */
|
|
long long h3_request_cancelled; /* total number of H3_REQUEST_CANCELLED errors received */
|
|
long long h3_request_incomplete; /* total number of H3_REQUEST_INCOMPLETE errors received */
|
|
long long h3_message_error; /* total number of H3_MESSAGE_ERROR errors received */
|
|
long long h3_connect_error; /* total number of H3_CONNECT_ERROR errors received */
|
|
long long h3_version_fallback; /* total number of H3_VERSION_FALLBACK errors received */
|
|
/* QPACK error counters */
|
|
long long qpack_decompression_failed; /* total number of QPACK_DECOMPRESSION_FAILED errors received */
|
|
long long qpack_encoder_stream_error; /* total number of QPACK_ENCODER_STREAM_ERROR errors received */
|
|
long long qpack_decoder_stream_error; /* total number of QPACK_DECODER_STREAM_ERROR errors received */
|
|
} h3_counters;
|
|
|
|
static int h3_fill_stats(struct stats_module *mod, struct extra_counters *ctr,
|
|
struct field *stats, unsigned int *selected_field)
|
|
{
|
|
unsigned int current_field = (selected_field != NULL ? *selected_field : 0);
|
|
|
|
for (; current_field < H3_STATS_COUNT; current_field++) {
|
|
struct field metric = { 0 };
|
|
struct h3_counters *counters;
|
|
|
|
if (!ctr)
|
|
goto store_metric;
|
|
|
|
counters = EXTRA_COUNTERS_BASE(ctr, mod);
|
|
|
|
switch (current_field) {
|
|
/* h3 frame type counters */
|
|
case H3_ST_DATA:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_data));
|
|
break;
|
|
case H3_ST_HEADERS:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_headers));
|
|
break;
|
|
case H3_ST_CANCEL_PUSH:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_cancel_push));
|
|
break;
|
|
case H3_ST_PUSH_PROMISE:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_push_promise));
|
|
break;
|
|
case H3_ST_MAX_PUSH_ID:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_max_push_id));
|
|
break;
|
|
case H3_ST_GOAWAY:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_goaway));
|
|
break;
|
|
case H3_ST_SETTINGS:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_settings));
|
|
break;
|
|
|
|
/* h3 error counters */
|
|
case H3_ST_H3_NO_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_no_error));
|
|
break;
|
|
case H3_ST_H3_GENERAL_PROTOCOL_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_general_protocol_error));
|
|
break;
|
|
case H3_ST_H3_INTERNAL_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_internal_error));
|
|
break;
|
|
case H3_ST_H3_STREAM_CREATION_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_stream_creation_error));
|
|
break;
|
|
case H3_ST_H3_CLOSED_CRITICAL_STREAM:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_closed_critical_stream));
|
|
break;
|
|
case H3_ST_H3_FRAME_UNEXPECTED:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_frame_unexpected));
|
|
break;
|
|
case H3_ST_H3_FRAME_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_frame_error));
|
|
break;
|
|
case H3_ST_H3_EXCESSIVE_LOAD:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_excessive_load));
|
|
break;
|
|
case H3_ST_H3_ID_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_id_error));
|
|
break;
|
|
case H3_ST_H3_SETTINGS_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_settings_error));
|
|
break;
|
|
case H3_ST_H3_MISSING_SETTINGS:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_missing_settings));
|
|
break;
|
|
case H3_ST_H3_REQUEST_REJECTED:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_request_rejected));
|
|
break;
|
|
case H3_ST_H3_REQUEST_CANCELLED:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_request_cancelled));
|
|
break;
|
|
case H3_ST_H3_REQUEST_INCOMPLETE:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_request_incomplete));
|
|
break;
|
|
case H3_ST_H3_MESSAGE_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_message_error));
|
|
break;
|
|
case H3_ST_H3_CONNECT_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_connect_error));
|
|
break;
|
|
case H3_ST_H3_VERSION_FALLBACK:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->h3_version_fallback));
|
|
break;
|
|
|
|
/* QPACK error counters */
|
|
case H3_ST_QPACK_DECOMPRESSION_FAILED:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->qpack_decompression_failed));
|
|
break;
|
|
case H3_ST_QPACK_ENCODER_STREAM_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->qpack_encoder_stream_error));
|
|
break;
|
|
case H3_ST_QPACK_DECODER_STREAM_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, EXTRA_COUNTERS_AGGR(ctr, counters->qpack_decoder_stream_error));
|
|
break;
|
|
default:
|
|
/* not used for frontends. If a specific metric
|
|
* is requested, return an error. Otherwise continue.
|
|
*/
|
|
if (selected_field != NULL)
|
|
return 0;
|
|
continue;
|
|
}
|
|
store_metric:
|
|
stats[current_field] = metric;
|
|
if (selected_field != NULL)
|
|
break;
|
|
}
|
|
return 1;
|
|
}
|
|
|
|
struct stats_module h3_stats_module = {
|
|
.name = "h3",
|
|
.fill_stats = h3_fill_stats,
|
|
.stats = h3_stats,
|
|
.stats_count = H3_STATS_COUNT,
|
|
.counters = &h3_counters,
|
|
.counters_size = sizeof(h3_counters),
|
|
.domain_flags = MK_STATS_PROXY_DOMAIN(STATS_PX_CAP_FE|STATS_PX_CAP_BE),
|
|
.clearable = 1,
|
|
};
|
|
|
|
INITCALL1(STG_REGISTER, stats_register_module, &h3_stats_module);
|
|
|
|
void h3_inc_err_cnt(struct h3_counters *ctrs, int error_code)
|
|
{
|
|
switch (error_code) {
|
|
case H3_ERR_NO_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_no_error);
|
|
break;
|
|
case H3_ERR_GENERAL_PROTOCOL_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_general_protocol_error);
|
|
break;
|
|
case H3_ERR_INTERNAL_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_internal_error);
|
|
break;
|
|
case H3_ERR_STREAM_CREATION_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_stream_creation_error);
|
|
break;
|
|
case H3_ERR_CLOSED_CRITICAL_STREAM:
|
|
HA_ATOMIC_INC(&ctrs->h3_closed_critical_stream);
|
|
break;
|
|
case H3_ERR_FRAME_UNEXPECTED:
|
|
HA_ATOMIC_INC(&ctrs->h3_frame_unexpected);
|
|
break;
|
|
case H3_ERR_FRAME_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_frame_error);
|
|
break;
|
|
case H3_ERR_EXCESSIVE_LOAD:
|
|
HA_ATOMIC_INC(&ctrs->h3_excessive_load);
|
|
break;
|
|
case H3_ERR_ID_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_id_error);
|
|
break;
|
|
case H3_ERR_SETTINGS_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_settings_error);
|
|
break;
|
|
case H3_ERR_MISSING_SETTINGS:
|
|
HA_ATOMIC_INC(&ctrs->h3_missing_settings);
|
|
break;
|
|
case H3_ERR_REQUEST_REJECTED:
|
|
HA_ATOMIC_INC(&ctrs->h3_request_rejected);
|
|
break;
|
|
case H3_ERR_REQUEST_CANCELLED:
|
|
HA_ATOMIC_INC(&ctrs->h3_request_cancelled);
|
|
break;
|
|
case H3_ERR_REQUEST_INCOMPLETE:
|
|
HA_ATOMIC_INC(&ctrs->h3_request_incomplete);
|
|
break;
|
|
case H3_ERR_MESSAGE_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_message_error);
|
|
break;
|
|
case H3_ERR_CONNECT_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->h3_connect_error);
|
|
break;
|
|
case H3_ERR_VERSION_FALLBACK:
|
|
HA_ATOMIC_INC(&ctrs->h3_version_fallback);
|
|
break;
|
|
case QPACK_ERR_DECOMPRESSION_FAILED:
|
|
HA_ATOMIC_INC(&ctrs->qpack_decompression_failed);
|
|
break;
|
|
case QPACK_ERR_ENCODER_STREAM_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->qpack_encoder_stream_error);
|
|
break;
|
|
case QPACK_ERR_DECODER_STREAM_ERROR:
|
|
HA_ATOMIC_INC(&ctrs->qpack_decoder_stream_error);
|
|
break;
|
|
default:
|
|
break;
|
|
|
|
}
|
|
}
|
|
|
|
void h3_inc_frame_type_cnt(struct h3_counters *ctrs, int frm_type)
|
|
{
|
|
switch (frm_type) {
|
|
case H3_FT_DATA:
|
|
HA_ATOMIC_INC(&ctrs->h3_data);
|
|
break;
|
|
case H3_FT_HEADERS:
|
|
HA_ATOMIC_INC(&ctrs->h3_headers);
|
|
break;
|
|
case H3_FT_CANCEL_PUSH:
|
|
HA_ATOMIC_INC(&ctrs->h3_cancel_push);
|
|
break;
|
|
case H3_FT_PUSH_PROMISE:
|
|
HA_ATOMIC_INC(&ctrs->h3_push_promise);
|
|
break;
|
|
case H3_FT_MAX_PUSH_ID:
|
|
HA_ATOMIC_INC(&ctrs->h3_max_push_id);
|
|
break;
|
|
case H3_FT_GOAWAY:
|
|
HA_ATOMIC_INC(&ctrs->h3_goaway);
|
|
break;
|
|
case H3_FT_SETTINGS:
|
|
HA_ATOMIC_INC(&ctrs->h3_settings);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|