diff --git a/src/etcp.c b/src/etcp.c
index ac83132e..15ec8894 100644
--- a/src/etcp.c
+++ b/src/etcp.c
@@ -453,6 +453,11 @@ void etcp_conn_reset(struct ETCP_CONN* etcp) {
             }
     }
 
+    clear_queue(etcp->input_send_q);
+    clear_queue(etcp->input_wait_ack);
+    queue_resume_callback(etcp->input_send_q);
+    queue_resume_callback(etcp->input_wait_ack);
+
     DEBUG_TRACE(DEBUG_CATEGORY_ETCP, "end");
 }