iv-org-mirror/litespeed-quic
1
0
Fork 0
mirror of https://gitea.invidious.io/iv-org/litespeed-quic.git synced 2024-08-15 00:53:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

mini conn: consider amplification when deciding to return TICK_SEND

Browse source
This commit is contained in:
Dmitri Tikhonov 2020-06-04 10:27:30 -04:00
parent ad48a114a2
commit c3c2342f79
1 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/liblsquic/lsquic_mini_conn_ietf.c
View file

@ -1345,9 +1345,11 @@ imico_handle_losses_and_have_unsent (struct ietf_mini_conn *conn,
{ {
TAILQ_HEAD(, lsquic_packet_out) lost_packets = TAILQ_HEAD(, lsquic_packet_out) lost_packets =
TAILQ_HEAD_INITIALIZER(lost_packets); TAILQ_HEAD_INITIALIZER(lost_packets);
const struct lsquic_conn *const lconn = &conn->imc_conn;
lsquic_packet_out_t *packet_out, *next; lsquic_packet_out_t *packet_out, *next;
lsquic_time_t retx_to = 0; lsquic_time_t retx_to = 0;
unsigned n_to_send = 0; unsigned n_to_send = 0;
size_t packet_size;
for (packet_out = TAILQ_FIRST(&conn->imc_packets_out); packet_out; for (packet_out = TAILQ_FIRST(&conn->imc_packets_out); packet_out;
packet_out = next) packet_out = next)
@ -1365,8 +1367,11 @@ imico_handle_losses_and_have_unsent (struct ietf_mini_conn *conn,
TAILQ_INSERT_TAIL(&lost_packets, packet_out, po_next); TAILQ_INSERT_TAIL(&lost_packets, packet_out, po_next);
} }
} }
else else if (packet_size = lsquic_packet_out_total_sz(lconn, packet_out),
imico_can_send(conn, packet_size))
++n_to_send; ++n_to_send;
else
break;
} }
conn->imc_hsk_count += !TAILQ_EMPTY(&lost_packets); conn->imc_hsk_count += !TAILQ_EMPTY(&lost_packets);
@ -1376,7 +1381,11 @@ imico_handle_losses_and_have_unsent (struct ietf_mini_conn *conn,
TAILQ_REMOVE(&lost_packets, packet_out, po_next); TAILQ_REMOVE(&lost_packets, packet_out, po_next);
if ((packet_out->po_frame_types & IQUIC_FRAME_RETX_MASK) if ((packet_out->po_frame_types & IQUIC_FRAME_RETX_MASK)
&& 0 == imico_repackage_packet(conn, packet_out)) && 0 == imico_repackage_packet(conn, packet_out))
++n_to_send; {
packet_size = lsquic_packet_out_total_sz(lconn, packet_out);
if (imico_can_send(conn, packet_size))
++n_to_send;
}
else else
imico_destroy_packet(conn, packet_out); imico_destroy_packet(conn, packet_out);
} }