@@ -1101,6 +1101,8 @@ proxy_session_dtor(struct rspamd_proxy_session *session) | |||
rspamd_mempool_delete(session->pool); | |||
} | |||
session->worker->nconns--; | |||
g_free(session); | |||
} | |||
@@ -2275,6 +2277,8 @@ proxy_accept_socket(EV_P_ ev_io *w, int revents) | |||
return; | |||
} | |||
worker->nconns++; | |||
session = g_malloc0(sizeof(*session)); | |||
REF_INIT_RETAIN(session, proxy_session_dtor); | |||
session->client_sock = nfd; |