diff options
author | Valentin Bartenev <vbart@nginx.com> | 2015-08-11 16:28:55 +0300 |
---|---|---|
committer | Valentin Bartenev <vbart@nginx.com> | 2015-08-11 16:28:55 +0300 |
commit | 50ff8b3c3a3eba0984ce55c63ab8ac07dcb65265 (patch) | |
tree | e0dabf7a35438fe72eb650c259f90044289e7085 /src/os/win32/ngx_process_cycle.c | |
parent | 9500e19919b5410b8bc17dbd3d705eef8cf5b1d8 (diff) | |
download | nginx-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.c | 22 |
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); } } |