A number of engine connections is decreased on connection close.

src/nxt_conn.c

@@ -93,6 +93,15 @@ nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task)
 }
 
 
+void
+nxt_conn_free(nxt_task_t *task, nxt_conn_t *c)
+{
+    task->thread->engine->connections--;
+
+    nxt_mp_release(c->mem_pool, c);
+}
+
+
 void
 nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data)
 {

src/nxt_conn.h

@@ -224,6 +224,7 @@ struct nxt_conn_s {
 
 
 NXT_EXPORT nxt_conn_t *nxt_conn_create(nxt_mp_t *mp, nxt_task_t *task);
+NXT_EXPORT void nxt_conn_free(nxt_task_t *task, nxt_conn_t *c);
 void nxt_conn_io_shutdown(nxt_task_t *task, void *obj, void *data);
 NXT_EXPORT void nxt_conn_close(nxt_event_engine_t *engine, nxt_conn_t *c);
 

src/nxt_controller.c

@@ -721,9 +721,7 @@ nxt_controller_conn_free(nxt_task_t *task, void *obj, void *data)
 
     nxt_sockaddr_cache_free(task->thread->engine, c);
 
-    nxt_mp_destroy(c->mem_pool);
+    nxt_conn_free(task, c);
-
-    //nxt_free(c);
 }
 
 

src/nxt_router.c

@@ -3662,7 +3662,7 @@ nxt_router_conn_free(nxt_task_t *task, void *obj, void *data)
     nxt_mp_cleanup(c->mem_pool, nxt_router_conn_mp_cleanup,
                    &engine->task, joint, NULL);
 
-    nxt_mp_release(c->mem_pool, c);
+    nxt_conn_free(task, c);
 }