Skip to content

Commit 230cf31

Browse files
committed
MINOR: h3: add traces on full demux
1 parent 1c1618f commit 230cf31

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

src/h3.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1196,6 +1196,7 @@ static ssize_t h3_resp_headers_to_htx(struct qcs *qcs, const struct buffer *buf,
11961196
* to close the stream.
11971197
*/
11981198
if (!htx_is_empty(htx)) {
1199+
TRACE_STATE("demux full", H3_EV_RX_FRAME|H3_EV_RX_DATA, qcs->qcc->conn, qcs);
11991200
qcs->flags |= QC_SF_DEM_FULL;
12001201
len = 0;
12011202
goto out;
@@ -1598,6 +1599,7 @@ static ssize_t h3_data_to_htx(struct qcs *qcs, const struct buffer *buf,
15981599
retry:
15991600
htx_space = htx_free_data_space(htx);
16001601
if (!htx_space) {
1602+
TRACE_STATE("demux full", H3_EV_RX_FRAME|H3_EV_RX_DATA, qcs->qcc->conn, qcs);
16011603
qcs->flags |= QC_SF_DEM_FULL;
16021604
goto out;
16031605
}
@@ -1611,6 +1613,7 @@ static ssize_t h3_data_to_htx(struct qcs *qcs, const struct buffer *buf,
16111613
size_t contig = b_wrap(buf) - head;
16121614
htx_sent = htx_add_data(htx, ist2(b_head(buf), contig));
16131615
if (htx_sent < contig) {
1616+
TRACE_STATE("demux full", H3_EV_RX_FRAME|H3_EV_RX_DATA, qcs->qcc->conn, qcs);
16141617
qcs->flags |= QC_SF_DEM_FULL;
16151618
goto out;
16161619
}
@@ -1622,6 +1625,7 @@ static ssize_t h3_data_to_htx(struct qcs *qcs, const struct buffer *buf,
16221625

16231626
htx_sent += htx_add_data(htx, ist2(head, len));
16241627
if (htx_sent < len) {
1628+
TRACE_STATE("demux full", H3_EV_RX_FRAME|H3_EV_RX_DATA, qcs->qcc->conn, qcs);
16251629
qcs->flags |= QC_SF_DEM_FULL;
16261630
goto out;
16271631
}

0 commit comments

Comments
 (0)