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

MINOR: h3: parse headers to htx

Browse Source
This commit is contained in:
Amaury Denoyelle 2021-08-24 15:30:12 +02:00
parent fd7cdc3e70
commit b49fa1aa6d
1 changed files with 59 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
src/h3.c
View File

@ -19,6 +19,8 @@
#include <haproxy/buf.h> #include <haproxy/buf.h>
#include <haproxy/dynbuf.h> #include <haproxy/dynbuf.h>
#include <haproxy/h3.h> #include <haproxy/h3.h>
#include <haproxy/http.h>
#include <haproxy/htx.h>
#include <haproxy/istbuf.h> #include <haproxy/istbuf.h>
#include <haproxy/mux_quic.h> #include <haproxy/mux_quic.h>
#include <haproxy/pool.h> #include <haproxy/pool.h>
@ -121,7 +123,10 @@ static int h3_decode_qcs(struct qcs *qcs, void *ctx)
{ {
struct buffer *rxbuf = &qcs->rx.buf; struct buffer *rxbuf = &qcs->rx.buf;
struct h3 *h3 = ctx; struct h3 *h3 = ctx;
struct htx *htx;
struct htx_sl *sl;
struct http_hdr list[global.tune.max_http_hdr]; struct http_hdr list[global.tune.max_http_hdr];
unsigned int flags = HTX_SL_F_NONE;
int hdr_idx; int hdr_idx;
h3_debug_printf(stderr, "%s: STREAM ID: %llu\n", __func__, qcs->by_id.key); h3_debug_printf(stderr, "%s: STREAM ID: %llu\n", __func__, qcs->by_id.key);
@ -153,11 +158,65 @@ static int h3_decode_qcs(struct qcs *qcs, void *ctx)
const unsigned char *buf = (const unsigned char *)b_head(rxbuf); const unsigned char *buf = (const unsigned char *)b_head(rxbuf);
size_t len = b_data(rxbuf); size_t len = b_data(rxbuf);
struct buffer *tmp = get_trash_chunk(); struct buffer *tmp = get_trash_chunk();
struct ist meth = IST_NULL, path = IST_NULL;
struct ist scheme = IST_NULL, authority = IST_NULL;
if (qpack_decode_fs(buf, len, tmp, list) < 0) { if (qpack_decode_fs(buf, len, tmp, list) < 0) {
h3->err = QPACK_DECOMPRESSION_FAILED; h3->err = QPACK_DECOMPRESSION_FAILED;
return -1; return -1;
} }
struct buffer htx_buf = BUF_NULL;
b_alloc(&htx_buf);
htx = htx_from_buf(&htx_buf);
/* first treat pseudo-header to build the start line */
hdr_idx = 0;
while (1) {
if (isteq(list[hdr_idx].n, ist("")))
break;
if (istmatch(list[hdr_idx].n, ist(":"))) {
/* pseudo-header */
if (isteq(list[hdr_idx].n, ist(":method")))
meth = list[hdr_idx].v;
else if (isteq(list[hdr_idx].n, ist(":path")))
path = list[hdr_idx].v;
else if (isteq(list[hdr_idx].n, ist(":scheme")))
scheme = list[hdr_idx].v;
else if (isteq(list[hdr_idx].n, ist(":authority")))
authority = list[hdr_idx].v;
}
++hdr_idx;
}
flags |= HTX_SL_F_VER_11;
sl = htx_add_stline(htx, HTX_BLK_REQ_SL, flags, meth, path, ist("HTTP/3.0"));
sl->flags |= HTX_SL_F_BODYLESS;
sl->info.req.meth = find_http_meth(meth.ptr, meth.len);
BUG_ON(sl->info.req.meth == HTTP_METH_OTHER);
if (isttest(authority))
htx_add_header(htx, ist("host"), authority);
/* now treat standard headers */
hdr_idx = 0;
while (1) {
if (isteq(list[hdr_idx].n, ist("")))
break;
if (!istmatch(list[hdr_idx].n, ist(":")))
htx_add_header(htx, list[hdr_idx].n, list[hdr_idx].v);
++hdr_idx;
}
htx_add_endof(htx, HTX_BLK_EOH);
htx_to_buf(htx, &htx_buf);
b_free(&htx_buf);
break; break;
} }
case H3_FT_PUSH_PROMISE: case H3_FT_PUSH_PROMISE: