From b5e545be6de4346fc82bf0ed65bdae5fac34e91e Mon Sep 17 00:00:00 2001 From: jeka Date: Sun, 8 Mar 2026 13:29:29 +0300 Subject: [PATCH] 1 --- src/etcp.c | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/etcp.c b/src/etcp.c index f7e30478..8f88c42f 100644 --- a/src/etcp.c +++ b/src/etcp.c @@ -289,6 +289,12 @@ void etcp_conn_reset(struct ETCP_CONN* etcp) { pn_reset(etcp->normalizer); } + queue_resume_callback(etcp->input_queue); + queue_resume_callback(etcp->output_queue); + queue_resume_callback(etcp->input_send_q); + queue_resume_callback(etcp->input_wait_ack); + queue_resume_callback(etcp->recv_q); + DEBUG_TRACE(DEBUG_CATEGORY_ETCP, "end"); }