diff --git a/src/etcp.c b/src/etcp.c
index 9760aec1..e2f92418 100644
--- a/src/etcp.c
+++ b/src/etcp.c
@@ -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);