WIP: quic: quic_tx modifs TO BE CHECKED

Author: haproxyFred

src/quic_tx.c

@@ -503,7 +503,8 @@ enum quic_tx_err qc_send_mux(struct quic_conn *qc, struct list *frms,
 		struct quic_cc *cc = &qc->path->cc;
 
 		ns_pkts = cc->algo->pacing_delay_ns(cc);
-		max_dgram = global.tune.quic_frontend_max_tx_burst * 1000000 / (ns_pkts + 1) + 1;
+		//max_dgram = global.tune.quic_frontend_max_tx_burst * 1000000 / (ns_pkts + 1) + 1;
+		max_dgram = qc->path->send_quantum / qc->path->mtu;
 	}
 
 	TRACE_STATE("preparing data (from MUX)", QUIC_EV_CONN_TXPKT, qc);
@@ -513,9 +514,9 @@ enum quic_tx_err qc_send_mux(struct quic_conn *qc, struct list *frms,
 		ret = QUIC_TX_ERR_FATAL;
 	}
 	else if (pacer) {
-		if (max_dgram && max_dgram == sent && !LIST_ISEMPTY(frms))
+		if (max_dgram && max_dgram <= sent && !LIST_ISEMPTY(frms))
 			ret = QUIC_TX_ERR_AGAIN;
-		quic_pacing_sent_done(pacer, sent, ns_pkts);
+		quic_pacing_sent_done(pacer, sent > 2 ? sent - 1 : sent, ns_pkts);
 	}
 
 	TRACE_LEAVE(QUIC_EV_CONN_TXPKT, qc);
@@ -881,7 +882,7 @@ int qc_send(struct quic_conn *qc, int old_data, struct list *send_list,
 		}
 
 		ret += prep_pkts;
-		if (max_dgrams && ret == max_dgrams && !LIST_ISEMPTY(send_list)) {
+		if (max_dgrams && ret >= max_dgrams) {// && !LIST_ISEMPTY(send_list)) {
 			TRACE_DEVEL("stopping for artificial pacing", QUIC_EV_CONN_TXPKT, qc);
 			break;
 		}