summaryrefslogtreecommitdiffhomepage
path: root/src/core
diff options
context:
space:
mode:
authorValentin Bartenev <vbart@nginx.com>2015-08-11 16:28:55 +0300
committerValentin Bartenev <vbart@nginx.com>2015-08-11 16:28:55 +0300
commit50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265 (patch)
treee0dabf7a35438fe72eb650c259f90044289e7085 /src/core
parent9500e19919b5410b8bc17dbd3d705eef8cf5b1d8 (diff)
downloadnginx-50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265.tar.gz
nginx-50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265.tar.bz2
Core: idle connections now closed only once on exiting.
Iterating through all connections takes a lot of CPU time, especially with large number of worker connections configured. As a result nginx processes used to consume CPU time during graceful shutdown. To mitigate this we now only do a full scan for idle connections when shutdown signal is received. Transitions of connections to idle ones are now expected to be avoided if the ngx_exiting flag is set. The upstream keepalive module was modified to follow this.
Diffstat (limited to 'src/core')
-rw-r--r--src/core/ngx_connection.c20
-rw-r--r--src/core/ngx_connection.h1
2 files changed, 21 insertions, 0 deletions
diff --git a/src/core/ngx_connection.c b/src/core/ngx_connection.c
index 00c5a08e6..9f2675b88 100644
--- a/src/core/ngx_connection.c
+++ b/src/core/ngx_connection.c
@@ -1163,6 +1163,26 @@ ngx_drain_connections(void)
}
+void
+ngx_close_idle_connections(ngx_cycle_t *cycle)
+{
+ ngx_uint_t i;
+ ngx_connection_t *c;
+
+ c = cycle->connections;
+
+ for (i = 0; i < cycle->connection_n; i++) {
+
+ /* THREAD: lock */
+
+ if (c[i].fd != -1 && c[i].idle) {
+ c[i].close = 1;
+ c[i].read->handler(c[i].read);
+ }
+ }
+}
+
+
ngx_int_t
ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s,
ngx_uint_t port)
diff --git a/src/core/ngx_connection.h b/src/core/ngx_connection.h
index a49aa9579..c3aca7f47 100644
--- a/src/core/ngx_connection.h
+++ b/src/core/ngx_connection.h
@@ -215,6 +215,7 @@ ngx_int_t ngx_open_listening_sockets(ngx_cycle_t *cycle);
void ngx_configure_listening_sockets(ngx_cycle_t *cycle);
void ngx_close_listening_sockets(ngx_cycle_t *cycle);
void ngx_close_connection(ngx_connection_t *c);
+void ngx_close_idle_connections(ngx_cycle_t *cycle);
ngx_int_t ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s,
ngx_uint_t port);
ngx_int_t ngx_connection_error(ngx_connection_t *c, ngx_err_t err, char *text);