mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-09-24 23:31:40 +02:00
Code Issues Projects Releases Wiki Activity

MINOR: mux-h2: allocate the array of shared rx bufs in the h2c

Browse Source 
In preparation for having a shared list of rx bufs, we're now allocating
the array of shared rx bufs in the h2c. The pool is created at the max
size between the front and back max streams for now, and the array is not
used yet.
This commit is contained in:
Willy Tarreau 2024-10-01 11:00:49 +02:00
parent 721ea5b06c
commit a891534bfd
1 changed files with 29 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/mux_h2.c
View File

@ -72,6 +72,7 @@ struct h2c {
/* states for the mux direction */
struct buffer mbuf[H2C_MBUF_CNT]; /* mux buffers (ring) */
struct bl_elem *shared_rx_bufs; /* shared rx bufs */
int32_t miw; /* mux initial window size for all new streams */
int32_t mws; /* mux window size. Can be negative. */
int32_t mfs; /* mux's max frame size */
@ -445,6 +446,9 @@ DECLARE_STATIC_POOL(pool_head_h2c, "h2c", sizeof(struct h2c));
/* the h2s stream pool */
DECLARE_STATIC_POOL(pool_head_h2s, "h2s", sizeof(struct h2s));
/* the shared rx_bufs pool */
struct pool_head *pool_head_h2_rx_bufs __read_mostly = NULL;
/* The default connection window size is 65535, it may only be enlarged using
* a WINDOW_UPDATE message. Since the window must never be larger than 2G-1,
* we'll pretend we already received the difference between the two to send
@ -1091,6 +1095,7 @@ static int h2_init(struct connection *conn, struct proxy *prx, struct session *s
h2c->proxy = prx;
h2c->task = NULL;
h2c->wait_event.tasklet = NULL;
h2c->shared_rx_bufs = NULL;
h2c->idle_start = now_ms;
if (tick_isset(h2c->timeout)) {
t = task_new_here();
@ -1119,6 +1124,10 @@ static int h2_init(struct connection *conn, struct proxy *prx, struct session *s
}
}
h2c->shared_rx_bufs = pool_alloc(pool_head_h2_rx_bufs);
if (!h2c->shared_rx_bufs)
goto fail;
h2c->ddht = hpack_dht_alloc();
if (!h2c->ddht)
goto fail;
@ -1255,6 +1264,7 @@ static void h2_release(struct h2c *h2c)
HA_ATOMIC_DEC(&h2c->px_counters->open_conns);
pool_free(pool_head_h2_rx_bufs, h2c->shared_rx_bufs);
pool_free(pool_head_h2c, h2c);
if (conn) {
@ -8022,6 +8032,8 @@ INITCALL1(STG_REGISTER, cfg_register_keywords, &cfg_kws);
*/
static int init_h2()
{
uint max_bufs;
pool_head_hpack_tbl = create_pool("hpack_tbl",
h2_settings_header_table_size,
MEM_F_SHARED|MEM_F_EXACT);
@ -8029,6 +8041,23 @@ static int init_h2()
ha_alert("failed to allocate hpack_tbl memory pool\n");
return (ERR_ALERT | ERR_FATAL);
}
max_bufs = h2_fe_settings_max_concurrent_streams ?
h2_fe_settings_max_concurrent_streams :
h2_settings_max_concurrent_streams;
max_bufs = MAX(max_bufs,
h2_be_settings_max_concurrent_streams ?
h2_be_settings_max_concurrent_streams :
h2_settings_max_concurrent_streams);
pool_head_h2_rx_bufs = create_pool("h2_rx_bufs",
(max_bufs + 1) * sizeof(struct bl_elem),
MEM_F_SHARED|MEM_F_EXACT);
if (!pool_head_h2_rx_bufs) {
ha_alert("failed to allocate h2_rx_bufs memory pool\n");
return (ERR_ALERT | ERR_FATAL);
}
return ERR_NONE;
}