MINOR: h3: implement DATA parsing
Add a new function h3_data_to_htx. This function is used to parse a H3
DATA frame and copy it in the mux stream HTX buffer. This is required to
support HTTP POST data.
Note that partial transfers if the HTX buffer is fulled is not properly
handle. This causes large DATA transfer to fail at the moment.
diff --git a/src/h3.c b/src/h3.c
index 8832229..48bb8cf 100644
--- a/src/h3.c
+++ b/src/h3.c
@@ -189,6 +189,38 @@
return 0;
}
+/* Copy from buffer <buf> a H3 DATA frame of length <len> in QUIC stream <qcs>
+ * HTX buffer. <fin> must be set if this is the last data to transfer from this
+ * stream.
+ *
+ * Returns 0 on success else non-zero
+ */
+static int h3_data_to_htx(struct qcs *qcs, struct buffer *buf, uint64_t len,
+ char fin)
+{
+ struct buffer *appbuf;
+ struct htx *htx = NULL;
+ size_t htx_sent;
+ int htx_space;
+
+ appbuf = qc_get_buf(qcs, &qcs->rx.app_buf);
+ BUG_ON(!appbuf);
+ htx = htx_from_buf(appbuf);
+
+ htx_space = htx_free_data_space(htx);
+ BUG_ON(!htx_space || htx_space < len);
+
+ htx_sent = htx_add_data(htx, ist2(b_head(buf), len));
+ /* TODO handle full appbuf */
+ BUG_ON(htx_sent < len);
+
+ if (fin)
+ htx->flags |= HTX_FL_EOM;
+ htx_to_buf(htx, appbuf);
+
+ return 0;
+}
+
/* Decode <qcs> remotely initiated bidi-stream. <fin> must be set to indicate
* that we received the last data of the stream.
* Returns <0 on error else 0.
@@ -226,6 +258,7 @@
switch (ftype) {
case H3_FT_DATA:
+ h3_data_to_htx(qcs, rxbuf, flen, last_stream_frame);
break;
case H3_FT_HEADERS:
h3_headers_to_htx(qcs, rxbuf, flen, last_stream_frame);