From: Amaury Denoyelle Date: Wed, 27 Apr 2022 14:44:49 +0000 (+0200) Subject: MINOR: mux-quic: adjust comment on emission function X-Git-Tag: v2.6-dev8~47 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=fe8f555f5c25dbc72129fb99422bf8ceee3e01b5;p=thirdparty%2Fhaproxy.git MINOR: mux-quic: adjust comment on emission function Comments were not properly edited since the splitting of functions for stream emission. Also "payload" argument has been renamed to "in" as it better reflects the function purpose. --- diff --git a/src/mux_quic.c b/src/mux_quic.c index bb7d3ca271..f8c96f5600 100644 --- a/src/mux_quic.c +++ b/src/mux_quic.c @@ -555,20 +555,13 @@ static void qc_release(struct qcc *qcc) TRACE_LEAVE(QMUX_EV_QCC_END); } -/* Prepare a STREAM frame for instance. First, transfer data from - * to buffer. The STREAM frame payload points to the - * buffer. The frame is then pushed to . If is set, and the - * buf is emptied after transfer, FIN bit is set on the STREAM frame. - * Transfer is automatically adjusted to not exceed the stream flow-control - * limit. must contains the current sum offsets for the connection. - * This is useful to not exceed the connection flow-control limit when using - * repeatdly this function on multiple streams before passing the data to the - * lower layer. +/* Transfer as much as possible data on from to . is + * the current flow-control limit on the connection which must not be exceeded. * - * Returns the total bytes of newly transferred data. It may be 0 if none. + * Returns the total bytes of transferred data. */ static int qcs_xfer_data(struct qcs *qcs, struct buffer *out, - struct buffer *payload, uint64_t max_data) + struct buffer *in, uint64_t max_data) { struct qcc *qcc = qcs->qcc; int left, to_xfer; @@ -596,7 +589,7 @@ static int qcs_xfer_data(struct qcs *qcs, struct buffer *out, BUG_ON_HOT(qcs->tx.offset < qcs->tx.sent_offset); left = qcs->tx.offset - qcs->tx.sent_offset; - to_xfer = QUIC_MIN(b_data(payload), b_room(out)); + to_xfer = QUIC_MIN(b_data(in), b_room(out)); BUG_ON_HOT(qcs->tx.offset > qcs->tx.msd); /* do not exceed flow control limit */ @@ -611,7 +604,7 @@ static int qcs_xfer_data(struct qcs *qcs, struct buffer *out, if (!left && !to_xfer) goto out; - total = b_force_xfer(out, payload, to_xfer); + total = b_force_xfer(out, in, to_xfer); out: { @@ -625,6 +618,12 @@ static int qcs_xfer_data(struct qcs *qcs, struct buffer *out, return total; } +/* Prepare a STREAM frame for instance using as payload. The frame + * is appended in . Set if this is supposed to be the last + * stream frame. + * + * Returns the length of the STREAM frame or a negative error code. + */ static int qcs_build_stream_frm(struct qcs *qcs, struct buffer *out, char fin, struct list *frm_list) {