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

MINOR: mux-quic: add traces on frame parsing functions

Browse Source 
Add traces for parsing functions for MAX_DATA and MAX_STREAM_DATA.
This commit is contained in:
Amaury Denoyelle 2022-07-06 15:44:16 +02:00
parent c1a6dfd477
commit 392e94e985
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mux_quic.c
View File

@ -704,14 +704,19 @@ int qcc_recv(struct qcc *qcc, uint64_t id, uint64_t len, uint64_t offset,
*/ */
int qcc_recv_max_data(struct qcc *qcc, uint64_t max) int qcc_recv_max_data(struct qcc *qcc, uint64_t max)
{ {
TRACE_ENTER(QMUX_EV_QCC_RECV, qcc->conn);
if (qcc->rfctl.md < max) { if (qcc->rfctl.md < max) {
qcc->rfctl.md = max; qcc->rfctl.md = max;
TRACE_DEVEL("increase remote max-data", QMUX_EV_QCC_RECV, qcc->conn);
if (qcc->flags & QC_CF_BLK_MFCTL) { if (qcc->flags & QC_CF_BLK_MFCTL) {
qcc->flags &= ~QC_CF_BLK_MFCTL; qcc->flags &= ~QC_CF_BLK_MFCTL;
tasklet_wakeup(qcc->wait_event.tasklet); tasklet_wakeup(qcc->wait_event.tasklet);
} }
} }
TRACE_LEAVE(QMUX_EV_QCC_RECV, qcc->conn);
return 0; return 0;
} }
@ -725,11 +730,14 @@ int qcc_recv_max_stream_data(struct qcc *qcc, uint64_t id, uint64_t max)
struct qcs *qcs; struct qcs *qcs;
struct eb64_node *node; struct eb64_node *node;
TRACE_ENTER(QMUX_EV_QCC_RECV, qcc->conn);
node = eb64_lookup(&qcc->streams_by_id, id); node = eb64_lookup(&qcc->streams_by_id, id);
if (node) { if (node) {
qcs = eb64_entry(node, struct qcs, by_id); qcs = eb64_entry(node, struct qcs, by_id);
if (max > qcs->tx.msd) { if (max > qcs->tx.msd) {
qcs->tx.msd = max; qcs->tx.msd = max;
TRACE_DEVEL("increase remote max-stream-data", QMUX_EV_QCC_RECV|QMUX_EV_QCS_RECV, qcc->conn, qcs);
if (qcs->flags & QC_SF_BLK_SFCTL) { if (qcs->flags & QC_SF_BLK_SFCTL) {
qcs->flags &= ~QC_SF_BLK_SFCTL; qcs->flags &= ~QC_SF_BLK_SFCTL;
@ -738,6 +746,7 @@ int qcc_recv_max_stream_data(struct qcc *qcc, uint64_t id, uint64_t max)
} }
} }
TRACE_LEAVE(QMUX_EV_QCC_RECV, qcc->conn);
return 0; return 0;
} }