MAJOR: mux_quic: open bwnd earlier on FIN sent

Author: a-denoyelle

src/mux_quic.c

@@ -696,11 +696,15 @@ static void qcm_ctrl_send(struct qc_stream_desc *stream, uint64_t data, uint64_t
 			            QMUX_EV_QCS_SEND, qcc->conn, qcs);
 		}
 		/* Release buffer if everything sent and buf is full or stream is waiting for room. */
-		if (!qcs_prep_bytes(qcs) &&
-		    (b_full(&qcs->tx.stream->buf->buf) || qcs->flags & QC_SF_BLK_MROOM)) {
-			qc_stream_buf_release(qcs->tx.stream);
-			qcs->flags &= ~QC_SF_BLK_MROOM;
-			qcs_notify_send(qcs);
+		if (!qcs_prep_bytes(qcs)) {
+			if (b_full(&qcs->tx.stream->buf->buf) || qcs->flags & QC_SF_BLK_MROOM) {
+				qc_stream_buf_release(qcs->tx.stream);
+				qcs->flags &= ~QC_SF_BLK_MROOM;
+				qcs_notify_send(qcs);
+			}
+			else if (qcs->flags & QC_SF_FIN_STREAM) {
+				qc_stream_buf_release(qcs->tx.stream);
+			}
 		}
 
 		/* Add measurement for send rate. This is done at the MUX layer
@@ -4471,6 +4475,7 @@ static size_t qcm_strm_snd_buf(struct stconn *sc, struct buffer *buf,
 	if (fin) {
 		TRACE_STATE("reached stream fin", QMUX_EV_STRM_SEND, qcs->qcc->conn, qcs);
 		qcs->flags |= QC_SF_FIN_STREAM;
+		qc_stream_buf_release(qcs->tx.stream);
 	}
 
 	if (ret || fin) {
@@ -4589,6 +4594,7 @@ static size_t qcm_strm_done_ff(struct stconn *sc)
 	if (sd->iobuf.flags & IOBUF_FL_EOI) {
 		TRACE_STATE("reached stream fin", QMUX_EV_STRM_SEND, qcs->qcc->conn, qcs);
 		qcs->flags |= QC_SF_FIN_STREAM;
+		qc_stream_buf_release(qcs->tx.stream);
 	}
 
 	if (!(qcs->flags & QC_SF_FIN_STREAM) && !sd->iobuf.data) {