diff --git a/src/main/worker.c b/src/main/worker.c
index b2f2787..b996aee 100644
--- a/src/main/worker.c
+++ b/src/main/worker.c
@@ -80,7 +80,7 @@ static void worker_io_timeout_cb(liWaitQueue *wq, gpointer data) {
 			VR_DEBUG(vr, "connection io-timeout from %s after %.2f seconds", con->info.remote_addr_str->str, now - wqe->ts);
 		}
 		li_plugins_handle_close(con);
-		li_worker_con_put(con);
+		li_connection_reset(con);
 	}
 
 	li_waitqueue_update(wq);
@@ -434,7 +434,7 @@ void li_worker_stop(liWorker *context, liWorker *wrk) {
 		for (i = wrk->connections_active; i-- > 0;) {
 			liConnection *con = g_array_index(wrk->connections, liConnection*, i);
 			if (con->state == LI_CON_STATE_KEEP_ALIVE) {
-				li_worker_con_put(con);
+				li_connection_reset(con);
 			}
 		}
 
@@ -461,7 +461,7 @@ void li_worker_stopping(liWorker *context, liWorker *wrk) {
 		for (i = wrk->connections_active; i-- > 0;) {
 			liConnection *con = g_array_index(wrk->connections, liConnection*, i);
 			if (con->state == LI_CON_STATE_KEEP_ALIVE) {
-				li_worker_con_put(con);
+				li_connection_reset(con);
 			}
 		}
 
@@ -486,7 +486,7 @@ void li_worker_suspend(liWorker *context, liWorker *wrk) {
 		for (i = wrk->connections_active; i-- > 0;) {
 			liConnection *con = g_array_index(wrk->connections, liConnection*, i);
 			if (con->state == LI_CON_STATE_KEEP_ALIVE) {
-				li_worker_con_put(con);
+				li_connection_reset(con);
 			}
 		}