aboutsummaryrefslogtreecommitdiff
path: root/src/os/win32/ngx_process_cycle.c
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/os/win32/ngx_process_cycle.c
parent9500e19919b5410b8bc17dbd3d705eef8cf5b1d8 (diff)
downloadnginx-50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265.tar.gz
nginx-50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265.zip
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/os/win32/ngx_process_cycle.c')
-rw-r--r--src/os/win32/ngx_process_cycle.c22
1 files changed, 4 insertions, 18 deletions
diff --git a/src/os/win32/ngx_process_cycle.c b/src/os/win32/ngx_process_cycle.c
index 203bece3f..06ff8b50e 100644
--- a/src/os/win32/ngx_process_cycle.c
+++ b/src/os/win32/ngx_process_cycle.c
@@ -761,10 +761,8 @@ failed:
static ngx_thread_value_t __stdcall
ngx_worker_thread(void *data)
{
- ngx_int_t n;
- ngx_uint_t i;
- ngx_cycle_t *cycle;
- ngx_connection_t *c;
+ ngx_int_t n;
+ ngx_cycle_t *cycle;
cycle = (ngx_cycle_t *) ngx_cycle;
@@ -780,19 +778,6 @@ ngx_worker_thread(void *data)
while (!ngx_quit) {
if (ngx_exiting) {
-
- c = cycle->connections;
-
- for (i = 0; i < cycle->connection_n; i++) {
-
- /* THREAD: lock */
-
- if (c[i].fd != (ngx_socket_t) -1 && c[i].idle) {
- c[i].close = 1;
- c[i].read->handler(c[i].read);
- }
- }
-
ngx_event_cancel_timers();
if (ngx_event_timer_rbtree.root
@@ -814,8 +799,9 @@ ngx_worker_thread(void *data)
ngx_quit = 0;
if (!ngx_exiting) {
- ngx_close_listening_sockets(cycle);
ngx_exiting = 1;
+ ngx_close_listening_sockets(cycle);
+ ngx_close_idle_connections(cycle);
}
}