mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-09-25 07:41:36 +02:00
Code Issues Projects Releases Wiki Activity

MINOR: mux_h2: add stat for total count of connections/streams

Browse Source 
Add counters for total number of http2 connections/stream since haproxy
startup. Contrary to open_conn/stream, they are never reset to zero.
This commit is contained in:
Amaury Denoyelle 2020-11-03 15:04:45 +01:00 committed by Willy Tarreau
parent 2ac34d97a6
commit e7b891f7d3
1 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/mux_h2.c
View File

@ -393,6 +393,8 @@ enum {
H2_ST_OPEN_CONN, H2_ST_OPEN_CONN,
H2_ST_OPEN_STREAM, H2_ST_OPEN_STREAM,
H2_ST_TOTAL_CONN,
H2_ST_TOTAL_STREAM,
H2_STATS_COUNT /* must be the last member of the enum */ H2_STATS_COUNT /* must be the last member of the enum */
}; };
@ -422,6 +424,10 @@ static struct name_desc h2_stats[] = {
.desc = "Count of currently open connections" }, .desc = "Count of currently open connections" },
[H2_ST_OPEN_STREAM] = { .name = "h2_backend_open_streams", [H2_ST_OPEN_STREAM] = { .name = "h2_backend_open_streams",
.desc = "Count of currently open streams" }, .desc = "Count of currently open streams" },
[H2_ST_TOTAL_CONN] = { .name = "h2_open_connections",
.desc = "Total number of connections" },
[H2_ST_TOTAL_STREAM] = { .name = "h2_backend_open_streams",
.desc = "Total number of streams" },
}; };
static struct h2_counters { static struct h2_counters {
@ -438,6 +444,8 @@ static struct h2_counters {
long long open_conns; /* count of currently open connections */ long long open_conns; /* count of currently open connections */
long long open_streams; /* count of currently open streams */ long long open_streams; /* count of currently open streams */
long long total_conns; /* total number of connections */
long long total_streams; /* total number of streams */
} h2_counters; } h2_counters;
static void h2_fill_stats(void *data, struct field *stats) static void h2_fill_stats(void *data, struct field *stats)
@ -457,6 +465,8 @@ static void h2_fill_stats(void *data, struct field *stats)
stats[H2_ST_OPEN_CONN] = mkf_u64(FN_GAUGE, counters->open_conns); stats[H2_ST_OPEN_CONN] = mkf_u64(FN_GAUGE, counters->open_conns);
stats[H2_ST_OPEN_STREAM] = mkf_u64(FN_GAUGE, counters->open_streams); stats[H2_ST_OPEN_STREAM] = mkf_u64(FN_GAUGE, counters->open_streams);
stats[H2_ST_TOTAL_CONN] = mkf_u64(FN_COUNTER, counters->total_conns);
stats[H2_ST_TOTAL_STREAM] = mkf_u64(FN_COUNTER, counters->total_streams);
} }
static struct stats_module h2_stats_module = { static struct stats_module h2_stats_module = {
@ -989,6 +999,7 @@ static int h2_init(struct connection *conn, struct proxy *prx, struct session *s
} }
HA_ATOMIC_ADD(&h2c->px_counters->open_conns, 1); HA_ATOMIC_ADD(&h2c->px_counters->open_conns, 1);
HA_ATOMIC_ADD(&h2c->px_counters->total_conns, 1);
/* prepare to read something */ /* prepare to read something */
h2c_restart_reading(h2c, 1); h2c_restart_reading(h2c, 1);
@ -1448,6 +1459,7 @@ static struct h2s *h2s_new(struct h2c *h2c, int id)
h2c->stream_cnt++; h2c->stream_cnt++;
HA_ATOMIC_ADD(&h2c->px_counters->open_streams, 1); HA_ATOMIC_ADD(&h2c->px_counters->open_streams, 1);
HA_ATOMIC_ADD(&h2c->px_counters->total_streams, 1);
TRACE_LEAVE(H2_EV_H2S_NEW, h2c->conn, h2s); TRACE_LEAVE(H2_EV_H2S_NEW, h2c->conn, h2s);
return h2s; return h2s;