]> git.ipfire.org Git - thirdparty/haproxy.git/commitdiff
CLEANUP: mux-quic: remove unused fields for Rx
authorAmaury Denoyelle <adenoyelle@haproxy.com>
Fri, 13 May 2022 13:41:35 +0000 (15:41 +0200)
committerAmaury Denoyelle <adenoyelle@haproxy.com>
Fri, 13 May 2022 15:29:52 +0000 (17:29 +0200)
Rx has been simplified since the conversion of buffer to a ncbuf. The
old buffer can now be removed. The frms tree is also removed. It was
used previously to stored out-of-order received STREAM frames. Now the
MUX is able to buffer them directly into the ncbuf.

include/haproxy/mux_quic-t.h
src/mux_quic.c

index d096d1dca4d1b2e4d40838954ea3b4bac546a26f..ddd19d380551fca6d1c946aebf263bbbe343aeb7 100644 (file)
@@ -101,9 +101,7 @@ struct qcs {
        void *ctx;           /* app-ops context */
 
        struct {
-               struct eb_root frms; /* received frames ordered by their offsets */
                uint64_t offset; /* absolute current base offset of ncbuf */
-               struct buffer buf; /* receive buffer, always valid (buf_empty or real buffer) */
                struct ncbuf ncbuf; /* receive buffer - can handle out-of-order offset frames */
                struct buffer app_buf; /* receive buffer used by conn_stream layer */
                uint64_t msd; /* fctl bytes limit to enforce */
index 022b1dbf53ad646f058348e0b8eba637d0f99404..f5de5510588ed03f4a9011221f871712d93dea43 100644 (file)
@@ -153,11 +153,9 @@ struct qcs *qcs_new(struct qcc *qcc, uint64_t id, enum qcs_type type)
        qcs->tx.msd = quic_stream_is_local(qcc, id) ? qcc->rfctl.msd_bidi_r :
                                                      qcc->rfctl.msd_bidi_l;
 
-       qcs->rx.buf = BUF_NULL;
        qcs->rx.ncbuf = NCBUF_NULL;
        qcs->rx.app_buf = BUF_NULL;
        qcs->rx.offset = 0;
-       qcs->rx.frms = EB_ROOT_UNIQUE;
 
        /* TODO use uni limit for unidirectional streams */
        qcs->rx.msd = quic_stream_is_local(qcc, id) ? qcc->lfctl.msd_bidi_l :
@@ -202,7 +200,6 @@ static void qc_free_ncbuf(struct qcs *qcs, struct ncbuf *ncbuf)
  */
 void qcs_free(struct qcs *qcs)
 {
-       b_free(&qcs->rx.buf);
        qc_free_ncbuf(qcs, &qcs->rx.ncbuf);
        b_free(&qcs->tx.buf);