diff --git a/src/etcp.c b/src/etcp.c index 92c0a47a..4bab999e 100644 --- a/src/etcp.c +++ b/src/etcp.c @@ -375,7 +375,10 @@ void etcp_conn_reset(struct ETCP_CONN* etcp) { etcp->last_rr_link = NULL; // Return unconfirmed inflight data to normalizer input (до нормалайзера) - if (etcp->normalizer) etcp_return_inflight_to_normalizer(etcp); + if (etcp->normalizer) { + etcp->normalizer->input->callback_suspended = 1; + etcp_return_inflight_to_normalizer(etcp); + } // Clear queues (keep queue structures) clear_queue(etcp->input_queue);