mirror of
https://git.haproxy.org/git/haproxy.git/
synced 2025-10-31 08:30:59 +01:00
e094412337
Rename enum values used for HTTP/3 and QPACK RFC defined codes. First uses a prefix H3_ERR_* which serves as identifier between them. Also separate QPACK values in a new dedicated enum qpack_err. This is deemed cleaner.
352 lines
14 KiB
C
352 lines
14 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(void *data, struct field *stats, unsigned int *selected_field)
|
|
{
|
|
struct h3_counters *counters = data;
|
|
unsigned int current_field = (selected_field != NULL ? *selected_field : 0);
|
|
|
|
for (; current_field < H3_STATS_COUNT; current_field++) {
|
|
struct field metric = { 0 };
|
|
|
|
switch (current_field) {
|
|
/* h3 frame type counters */
|
|
case H3_ST_DATA:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_data);
|
|
break;
|
|
case H3_ST_HEADERS:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_headers);
|
|
break;
|
|
case H3_ST_CANCEL_PUSH:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_cancel_push);
|
|
break;
|
|
case H3_ST_PUSH_PROMISE:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_push_promise);
|
|
break;
|
|
case H3_ST_MAX_PUSH_ID:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_max_push_id);
|
|
break;
|
|
case H3_ST_GOAWAY:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_goaway);
|
|
break;
|
|
case H3_ST_SETTINGS:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_settings);
|
|
break;
|
|
|
|
/* h3 error counters */
|
|
case H3_ST_H3_NO_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_no_error);
|
|
break;
|
|
case H3_ST_H3_GENERAL_PROTOCOL_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_general_protocol_error);
|
|
break;
|
|
case H3_ST_H3_INTERNAL_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_internal_error);
|
|
break;
|
|
case H3_ST_H3_STREAM_CREATION_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_stream_creation_error);
|
|
break;
|
|
case H3_ST_H3_CLOSED_CRITICAL_STREAM:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_closed_critical_stream);
|
|
break;
|
|
case H3_ST_H3_FRAME_UNEXPECTED:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_frame_unexpected);
|
|
break;
|
|
case H3_ST_H3_FRAME_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_frame_error);
|
|
break;
|
|
case H3_ST_H3_EXCESSIVE_LOAD:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_excessive_load);
|
|
break;
|
|
case H3_ST_H3_ID_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_id_error);
|
|
break;
|
|
case H3_ST_H3_SETTINGS_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_settings_error);
|
|
break;
|
|
case H3_ST_H3_MISSING_SETTINGS:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_missing_settings);
|
|
break;
|
|
case H3_ST_H3_REQUEST_REJECTED:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_request_rejected);
|
|
break;
|
|
case H3_ST_H3_REQUEST_CANCELLED:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_request_cancelled);
|
|
break;
|
|
case H3_ST_H3_REQUEST_INCOMPLETE:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_request_incomplete);
|
|
break;
|
|
case H3_ST_H3_MESSAGE_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_message_error);
|
|
break;
|
|
case H3_ST_H3_CONNECT_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_connect_error);
|
|
break;
|
|
case H3_ST_H3_VERSION_FALLBACK:
|
|
metric = mkf_u64(FN_COUNTER, counters->h3_version_fallback);
|
|
break;
|
|
|
|
/* QPACK error counters */
|
|
case H3_ST_QPACK_DECOMPRESSION_FAILED:
|
|
metric = mkf_u64(FN_COUNTER, counters->qpack_decompression_failed);
|
|
break;
|
|
case H3_ST_QPACK_ENCODER_STREAM_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, counters->qpack_encoder_stream_error);
|
|
break;
|
|
case H3_ST_QPACK_DECODER_STREAM_ERROR:
|
|
metric = mkf_u64(FN_COUNTER, 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;
|
|
}
|
|
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),
|
|
.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;
|
|
}
|
|
}
|