|
|
|
|
@ -269,6 +269,8 @@ void etcp_conn_reset(struct ETCP_CONN* etcp) {
|
|
|
|
|
etcp->rtt_history_idx = 0; |
|
|
|
|
|
|
|
|
|
// Clear queues (keep queue structures)
|
|
|
|
|
clear_fragment_queue(etcp->input_queue, etcp); |
|
|
|
|
clear_fragment_queue(etcp->output_queue, etcp); |
|
|
|
|
clear_inflight_queue(etcp->input_send_q, etcp); |
|
|
|
|
clear_inflight_queue(etcp->input_wait_ack, etcp); |
|
|
|
|
clear_fragment_queue(etcp->recv_q, etcp); |
|
|
|
|
|