Mercurial > hg > nginx
annotate src/os/win32/ngx_process_cycle.c @ 9201:791ead216b03
Silenced complaints about socket leaks on forced termination.
When graceful shutdown was requested, and then nginx was forced to
do fast shutdown, it used to (incorrectly) complain about open sockets
left in connections which weren't yet closed when fast shutdown
was requested.
Fix is to avoid complaining about open sockets when fast shutdown was
requested after graceful one. Abnormal termination, if requested with
the WINCH signal, can still happen though.
| author | Maxim Dounin <mdounin@mdounin.ru> |
|---|---|
| date | Mon, 29 Jan 2024 10:29:39 +0300 |
| parents | b809f53d3f5b |
| children |
| rev | line source |
|---|---|
|
441
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
368
diff
changeset
|
1 |
|
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
368
diff
changeset
|
2 /* |
|
444
42d11f017717
nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright
Igor Sysoev <igor@sysoev.ru>
parents:
441
diff
changeset
|
3 * Copyright (C) Igor Sysoev |
| 4412 | 4 * Copyright (C) Nginx, Inc. |
|
441
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
368
diff
changeset
|
5 */ |
|
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
368
diff
changeset
|
6 |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
7 |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
8 #include <ngx_config.h> |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
9 #include <ngx_core.h> |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
10 #include <ngx_event.h> |
| 461 | 11 #include <nginx.h> |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
12 |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
13 |
| 2725 | 14 static void ngx_console_init(ngx_cycle_t *cycle); |
| 15 static int __stdcall ngx_console_handler(u_long type); | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
16 static ngx_int_t ngx_create_signal_events(ngx_cycle_t *cycle); |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
17 static ngx_int_t ngx_start_worker_processes(ngx_cycle_t *cycle, ngx_int_t type); |
| 2725 | 18 static void ngx_reopen_worker_processes(ngx_cycle_t *cycle); |
| 19 static void ngx_quit_worker_processes(ngx_cycle_t *cycle, ngx_uint_t old); | |
| 20 static void ngx_terminate_worker_processes(ngx_cycle_t *cycle); | |
| 21 static ngx_uint_t ngx_reap_worker(ngx_cycle_t *cycle, HANDLE h); | |
| 22 static void ngx_master_process_exit(ngx_cycle_t *cycle); | |
| 23 static void ngx_worker_process_cycle(ngx_cycle_t *cycle, char *mevn); | |
| 24 static void ngx_worker_process_exit(ngx_cycle_t *cycle); | |
| 25 static ngx_thread_value_t __stdcall ngx_worker_thread(void *data); | |
| 26 static ngx_thread_value_t __stdcall ngx_cache_manager_thread(void *data); | |
| 27 static void ngx_cache_manager_process_handler(void); | |
| 3022 | 28 static ngx_thread_value_t __stdcall ngx_cache_loader_thread(void *data); |
|
368
15c84a40e87d
nginx-0.0.7-2004-06-24-20:07:04 import
Igor Sysoev <igor@sysoev.ru>
parents:
326
diff
changeset
|
29 |
|
306
6b91bfbc4123
nginx-0.0.3-2004-04-05-00:32:09 import
Igor Sysoev <igor@sysoev.ru>
parents:
302
diff
changeset
|
30 |
| 2725 | 31 ngx_uint_t ngx_process; |
|
6151
b4cc553aafeb
Introduced worker number, ngx_worker.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6111
diff
changeset
|
32 ngx_uint_t ngx_worker; |
| 2725 | 33 ngx_pid_t ngx_pid; |
|
7162
8b84d60ef13d
Fixed "changing binary" when reaper is not init.
Ruslan Ermilov <ru@nginx.com>
parents:
6930
diff
changeset
|
34 ngx_pid_t ngx_parent; |
|
290
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
282
diff
changeset
|
35 |
| 2725 | 36 ngx_uint_t ngx_inherited; |
| 37 ngx_pid_t ngx_new_binary; | |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
38 |
| 2725 | 39 sig_atomic_t ngx_terminate; |
| 40 sig_atomic_t ngx_quit; | |
| 41 sig_atomic_t ngx_reopen; | |
| 42 sig_atomic_t ngx_reconfigure; | |
| 43 ngx_uint_t ngx_exiting; | |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
44 |
|
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
45 |
| 2725 | 46 HANDLE ngx_master_process_event; |
| 47 char ngx_master_process_event_name[NGX_PROCESS_SYNC_NAME]; | |
| 48 | |
| 49 static HANDLE ngx_stop_event; | |
| 50 static char ngx_stop_event_name[NGX_PROCESS_SYNC_NAME]; | |
| 51 static HANDLE ngx_quit_event; | |
| 52 static char ngx_quit_event_name[NGX_PROCESS_SYNC_NAME]; | |
| 53 static HANDLE ngx_reopen_event; | |
| 54 static char ngx_reopen_event_name[NGX_PROCESS_SYNC_NAME]; | |
| 55 static HANDLE ngx_reload_event; | |
| 56 static char ngx_reload_event_name[NGX_PROCESS_SYNC_NAME]; | |
| 57 | |
| 58 HANDLE ngx_cache_manager_mutex; | |
| 59 char ngx_cache_manager_mutex_name[NGX_PROCESS_SYNC_NAME]; | |
| 60 HANDLE ngx_cache_manager_event; | |
| 461 | 61 |
|
290
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
282
diff
changeset
|
62 |
| 509 | 63 void |
| 64 ngx_master_process_cycle(ngx_cycle_t *cycle) | |
|
278
0ba4821f4460
nginx-0.0.2-2004-03-04-10:04:55 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
65 { |
| 2725 | 66 u_long nev, ev, timeout; |
| 67 ngx_err_t err; | |
| 68 ngx_int_t n; | |
| 69 ngx_msec_t timer; | |
| 70 ngx_uint_t live; | |
| 71 HANDLE events[MAXIMUM_WAIT_OBJECTS]; | |
| 72 | |
| 73 ngx_sprintf((u_char *) ngx_master_process_event_name, | |
| 74 "ngx_master_%s%Z", ngx_unique); | |
| 75 | |
| 76 if (ngx_process == NGX_PROCESS_WORKER) { | |
| 77 ngx_worker_process_cycle(cycle, ngx_master_process_event_name); | |
| 78 return; | |
| 79 } | |
| 80 | |
| 81 ngx_log_debug0(NGX_LOG_DEBUG_CORE, cycle->log, 0, "master started"); | |
| 82 | |
| 83 ngx_console_init(cycle); | |
| 84 | |
| 85 SetEnvironmentVariable("ngx_unique", ngx_unique); | |
| 86 | |
| 87 ngx_master_process_event = CreateEvent(NULL, 1, 0, | |
| 88 ngx_master_process_event_name); | |
| 89 if (ngx_master_process_event == NULL) { | |
| 90 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 91 "CreateEvent(\"%s\") failed", | |
| 92 ngx_master_process_event_name); | |
| 93 exit(2); | |
| 94 } | |
| 95 | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
96 if (ngx_create_signal_events(cycle) != NGX_OK) { |
| 2725 | 97 exit(2); |
| 98 } | |
| 99 | |
| 100 ngx_sprintf((u_char *) ngx_cache_manager_mutex_name, | |
| 101 "ngx_cache_manager_mutex_%s%Z", ngx_unique); | |
| 102 | |
| 103 ngx_cache_manager_mutex = CreateMutex(NULL, 0, | |
| 104 ngx_cache_manager_mutex_name); | |
| 105 if (ngx_cache_manager_mutex == NULL) { | |
| 106 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 107 "CreateMutex(\"%s\") failed", ngx_cache_manager_mutex_name); | |
| 108 exit(2); | |
| 109 } | |
| 110 | |
| 111 | |
| 112 events[0] = ngx_stop_event; | |
| 113 events[1] = ngx_quit_event; | |
| 114 events[2] = ngx_reopen_event; | |
| 115 events[3] = ngx_reload_event; | |
| 116 | |
| 117 ngx_close_listening_sockets(cycle); | |
| 118 | |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
119 if (ngx_start_worker_processes(cycle, NGX_PROCESS_RESPAWN) == 0) { |
|
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
120 exit(2); |
|
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
121 } |
| 2725 | 122 |
| 123 timer = 0; | |
| 124 timeout = INFINITE; | |
| 125 | |
| 126 for ( ;; ) { | |
| 127 | |
| 128 nev = 4; | |
| 129 for (n = 0; n < ngx_last_process; n++) { | |
| 130 if (ngx_processes[n].handle) { | |
| 131 events[nev++] = ngx_processes[n].handle; | |
| 132 } | |
| 133 } | |
| 134 | |
| 135 if (timer) { | |
| 136 timeout = timer > ngx_current_msec ? timer - ngx_current_msec : 0; | |
| 137 } | |
| 138 | |
| 139 ev = WaitForMultipleObjects(nev, events, 0, timeout); | |
| 140 | |
| 141 err = ngx_errno; | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
142 ngx_time_update(); |
| 2725 | 143 |
| 144 ngx_log_debug1(NGX_LOG_DEBUG_CORE, cycle->log, 0, | |
| 145 "master WaitForMultipleObjects: %ul", ev); | |
| 146 | |
| 147 if (ev == WAIT_OBJECT_0) { | |
| 148 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting"); | |
|
324
0ab66f4b6c4d
nginx-0.0.3-2004-04-22-00:13:48 import
Igor Sysoev <igor@sysoev.ru>
parents:
318
diff
changeset
|
149 |
| 2725 | 150 if (ResetEvent(ngx_stop_event) == 0) { |
| 151 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
| 152 "ResetEvent(\"%s\") failed", ngx_stop_event_name); | |
| 153 } | |
| 154 | |
| 155 if (timer == 0) { | |
| 156 timer = ngx_current_msec + 5000; | |
| 157 } | |
| 158 | |
| 159 ngx_terminate = 1; | |
| 160 ngx_quit_worker_processes(cycle, 0); | |
| 161 | |
| 162 continue; | |
| 163 } | |
| 164 | |
| 165 if (ev == WAIT_OBJECT_0 + 1) { | |
| 166 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "shutting down"); | |
| 167 | |
| 168 if (ResetEvent(ngx_quit_event) == 0) { | |
| 169 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
| 170 "ResetEvent(\"%s\") failed", ngx_quit_event_name); | |
| 171 } | |
| 172 | |
| 173 ngx_quit = 1; | |
| 174 ngx_quit_worker_processes(cycle, 0); | |
| 175 | |
| 176 continue; | |
| 177 } | |
| 178 | |
| 179 if (ev == WAIT_OBJECT_0 + 2) { | |
| 180 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reopening logs"); | |
| 181 | |
| 182 if (ResetEvent(ngx_reopen_event) == 0) { | |
| 183 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
| 184 "ResetEvent(\"%s\") failed", | |
| 185 ngx_reopen_event_name); | |
| 186 } | |
| 187 | |
| 188 ngx_reopen_files(cycle, -1); | |
| 189 ngx_reopen_worker_processes(cycle); | |
| 190 | |
| 191 continue; | |
| 192 } | |
| 193 | |
| 194 if (ev == WAIT_OBJECT_0 + 3) { | |
| 195 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "reconfiguring"); | |
| 196 | |
| 197 if (ResetEvent(ngx_reload_event) == 0) { | |
| 198 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
| 199 "ResetEvent(\"%s\") failed", | |
| 200 ngx_reload_event_name); | |
| 201 } | |
| 202 | |
| 2823 | 203 cycle = ngx_init_cycle(cycle); |
| 204 if (cycle == NULL) { | |
| 205 cycle = (ngx_cycle_t *) ngx_cycle; | |
| 206 continue; | |
| 207 } | |
| 208 | |
| 209 ngx_cycle = cycle; | |
| 210 | |
| 2928 | 211 ngx_close_listening_sockets(cycle); |
| 212 | |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
213 if (ngx_start_worker_processes(cycle, NGX_PROCESS_JUST_RESPAWN)) { |
|
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
214 ngx_quit_worker_processes(cycle, 1); |
|
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
215 } |
| 2725 | 216 |
| 217 continue; | |
| 218 } | |
| 219 | |
| 220 if (ev > WAIT_OBJECT_0 + 3 && ev < WAIT_OBJECT_0 + nev) { | |
| 221 | |
| 222 ngx_log_debug0(NGX_LOG_DEBUG_CORE, cycle->log, 0, "reap worker"); | |
| 223 | |
| 224 live = ngx_reap_worker(cycle, events[ev]); | |
| 225 | |
| 226 if (!live && (ngx_terminate || ngx_quit)) { | |
| 227 ngx_master_process_exit(cycle); | |
| 228 } | |
| 229 | |
| 230 continue; | |
| 231 } | |
| 232 | |
| 233 if (ev == WAIT_TIMEOUT) { | |
| 234 ngx_terminate_worker_processes(cycle); | |
| 235 | |
| 236 ngx_master_process_exit(cycle); | |
| 237 } | |
| 238 | |
| 239 if (ev == WAIT_FAILED) { | |
| 240 ngx_log_error(NGX_LOG_ALERT, cycle->log, err, | |
| 241 "WaitForMultipleObjects() failed"); | |
| 242 | |
| 243 continue; | |
| 244 } | |
| 245 | |
| 246 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
| 247 "WaitForMultipleObjects() returned unexpected value %ul", ev); | |
| 248 } | |
|
318
56496082668b
nginx-0.0.3-2004-04-16-09:14:16 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
249 } |
|
56496082668b
nginx-0.0.3-2004-04-16-09:14:16 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
250 |
|
56496082668b
nginx-0.0.3-2004-04-16-09:14:16 import
Igor Sysoev <igor@sysoev.ru>
parents:
306
diff
changeset
|
251 |
| 2725 | 252 static void |
| 253 ngx_console_init(ngx_cycle_t *cycle) | |
| 254 { | |
| 255 ngx_core_conf_t *ccf; | |
| 256 | |
| 257 ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module); | |
| 258 | |
| 259 if (ccf->daemon) { | |
| 260 if (FreeConsole() == 0) { | |
| 261 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 262 "FreeConsole() failed"); | |
| 263 } | |
| 264 | |
| 265 return; | |
| 266 } | |
| 267 | |
| 268 if (SetConsoleCtrlHandler(ngx_console_handler, 1) == 0) { | |
| 269 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 270 "SetConsoleCtrlHandler() failed"); | |
| 271 } | |
| 272 } | |
| 273 | |
| 274 | |
| 275 static int __stdcall | |
| 276 ngx_console_handler(u_long type) | |
| 277 { | |
| 278 char *msg; | |
| 279 | |
| 280 switch (type) { | |
| 281 | |
| 282 case CTRL_C_EVENT: | |
| 283 msg = "Ctrl-C pressed, exiting"; | |
| 284 break; | |
| 285 | |
| 286 case CTRL_BREAK_EVENT: | |
| 287 msg = "Ctrl-Break pressed, exiting"; | |
| 288 break; | |
| 289 | |
| 290 case CTRL_CLOSE_EVENT: | |
| 291 msg = "console closing, exiting"; | |
| 292 break; | |
| 293 | |
| 294 case CTRL_LOGOFF_EVENT: | |
| 295 msg = "user logs off, exiting"; | |
| 296 break; | |
| 297 | |
| 298 default: | |
| 299 return 0; | |
| 300 } | |
| 301 | |
| 302 ngx_log_error(NGX_LOG_NOTICE, ngx_cycle->log, 0, msg); | |
| 303 | |
| 304 if (ngx_stop_event == NULL) { | |
| 305 return 1; | |
| 306 } | |
| 307 | |
| 308 if (SetEvent(ngx_stop_event) == 0) { | |
| 309 ngx_log_error(NGX_LOG_ALERT, ngx_cycle->log, 0, | |
| 310 "SetEvent(\"%s\") failed", ngx_stop_event_name); | |
| 2627 | 311 } |
| 312 | |
| 2725 | 313 return 1; |
| 314 } | |
| 315 | |
| 316 | |
| 317 static ngx_int_t | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
318 ngx_create_signal_events(ngx_cycle_t *cycle) |
| 2725 | 319 { |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
320 ngx_sprintf((u_char *) ngx_stop_event_name, |
|
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
321 "Global\\ngx_stop_%s%Z", ngx_unique); |
| 2725 | 322 |
| 323 ngx_stop_event = CreateEvent(NULL, 1, 0, ngx_stop_event_name); | |
| 324 if (ngx_stop_event == NULL) { | |
| 325 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 326 "CreateEvent(\"%s\") failed", ngx_stop_event_name); | |
| 327 return NGX_ERROR; | |
| 328 } | |
| 329 | |
| 330 | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
331 ngx_sprintf((u_char *) ngx_quit_event_name, |
|
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
332 "Global\\ngx_quit_%s%Z", ngx_unique); |
| 2725 | 333 |
| 334 ngx_quit_event = CreateEvent(NULL, 1, 0, ngx_quit_event_name); | |
| 335 if (ngx_quit_event == NULL) { | |
| 336 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 337 "CreateEvent(\"%s\") failed", ngx_quit_event_name); | |
| 338 return NGX_ERROR; | |
| 339 } | |
| 340 | |
| 341 | |
| 342 ngx_sprintf((u_char *) ngx_reopen_event_name, | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
343 "Global\\ngx_reopen_%s%Z", ngx_unique); |
| 2725 | 344 |
| 345 ngx_reopen_event = CreateEvent(NULL, 1, 0, ngx_reopen_event_name); | |
| 346 if (ngx_reopen_event == NULL) { | |
| 347 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 348 "CreateEvent(\"%s\") failed", ngx_reopen_event_name); | |
| 349 return NGX_ERROR; | |
| 350 } | |
| 351 | |
| 352 | |
| 353 ngx_sprintf((u_char *) ngx_reload_event_name, | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
354 "Global\\ngx_reload_%s%Z", ngx_unique); |
| 2725 | 355 |
| 356 ngx_reload_event = CreateEvent(NULL, 1, 0, ngx_reload_event_name); | |
| 357 if (ngx_reload_event == NULL) { | |
| 358 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 359 "CreateEvent(\"%s\") failed", ngx_reload_event_name); | |
| 360 return NGX_ERROR; | |
| 361 } | |
| 362 | |
| 363 return NGX_OK; | |
| 364 } | |
| 365 | |
| 366 | |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
367 static ngx_int_t |
| 2725 | 368 ngx_start_worker_processes(ngx_cycle_t *cycle, ngx_int_t type) |
| 369 { | |
| 370 ngx_int_t n; | |
| 371 ngx_core_conf_t *ccf; | |
| 372 | |
| 373 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "start worker processes"); | |
| 374 | |
| 375 ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module); | |
| 376 | |
| 377 for (n = 0; n < ccf->worker_processes; n++) { | |
| 378 if (ngx_spawn_process(cycle, "worker", type) == NGX_INVALID_PID) { | |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
379 break; |
| 2725 | 380 } |
| 381 } | |
|
2922
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
382 |
|
f0604d0b28a6
*) exit if no workers could not be started
Igor Sysoev <igor@sysoev.ru>
parents:
2921
diff
changeset
|
383 return n; |
| 2627 | 384 } |
| 385 | |
| 386 | |
| 2725 | 387 static void |
| 388 ngx_reopen_worker_processes(ngx_cycle_t *cycle) | |
| 389 { | |
| 390 ngx_int_t n; | |
| 391 | |
| 392 for (n = 0; n < ngx_last_process; n++) { | |
| 393 | |
| 394 if (ngx_processes[n].handle == NULL) { | |
| 395 continue; | |
| 396 } | |
| 397 | |
| 398 if (SetEvent(ngx_processes[n].reopen) == 0) { | |
| 399 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 400 "SetEvent(\"%s\") failed", | |
| 401 ngx_processes[n].reopen_event); | |
| 402 } | |
| 403 } | |
| 404 } | |
| 405 | |
| 406 | |
| 407 static void | |
| 408 ngx_quit_worker_processes(ngx_cycle_t *cycle, ngx_uint_t old) | |
| 2627 | 409 { |
| 2725 | 410 ngx_int_t n; |
| 411 | |
| 412 for (n = 0; n < ngx_last_process; n++) { | |
| 413 | |
| 414 ngx_log_debug5(NGX_LOG_DEBUG_CORE, cycle->log, 0, | |
| 2921 | 415 "process: %d %P %p e:%d j:%d", |
| 2725 | 416 n, |
| 417 ngx_processes[n].pid, | |
| 418 ngx_processes[n].handle, | |
| 419 ngx_processes[n].exiting, | |
|
3016
d82993af1da0
introduce NGX_PROCESS_JUST_SPAWN and change field name accordingly
Igor Sysoev <igor@sysoev.ru>
parents:
2928
diff
changeset
|
420 ngx_processes[n].just_spawn); |
| 2725 | 421 |
|
3016
d82993af1da0
introduce NGX_PROCESS_JUST_SPAWN and change field name accordingly
Igor Sysoev <igor@sysoev.ru>
parents:
2928
diff
changeset
|
422 if (old && ngx_processes[n].just_spawn) { |
|
d82993af1da0
introduce NGX_PROCESS_JUST_SPAWN and change field name accordingly
Igor Sysoev <igor@sysoev.ru>
parents:
2928
diff
changeset
|
423 ngx_processes[n].just_spawn = 0; |
| 2725 | 424 continue; |
| 425 } | |
| 426 | |
| 427 if (ngx_processes[n].handle == NULL) { | |
| 428 continue; | |
| 429 } | |
| 430 | |
| 431 if (SetEvent(ngx_processes[n].quit) == 0) { | |
| 432 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 433 "SetEvent(\"%s\") failed", | |
| 434 ngx_processes[n].quit_event); | |
| 435 } | |
| 436 | |
| 437 ngx_processes[n].exiting = 1; | |
| 438 } | |
| 439 } | |
| 440 | |
| 441 | |
| 442 static void | |
| 443 ngx_terminate_worker_processes(ngx_cycle_t *cycle) | |
| 444 { | |
| 445 ngx_int_t n; | |
| 446 | |
| 447 for (n = 0; n < ngx_last_process; n++) { | |
| 448 | |
| 449 if (ngx_processes[n].handle == NULL) { | |
| 450 continue; | |
| 451 } | |
| 452 | |
| 453 if (TerminateProcess(ngx_processes[n].handle, 0) == 0) { | |
| 454 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 455 "TerminateProcess(\"%p\") failed", | |
| 456 ngx_processes[n].handle); | |
| 457 } | |
| 458 | |
| 459 ngx_processes[n].exiting = 1; | |
| 2627 | 460 |
| 2725 | 461 ngx_close_handle(ngx_processes[n].reopen); |
| 462 ngx_close_handle(ngx_processes[n].quit); | |
| 463 ngx_close_handle(ngx_processes[n].term); | |
| 464 ngx_close_handle(ngx_processes[n].handle); | |
| 465 } | |
| 466 } | |
| 467 | |
| 468 | |
| 469 static ngx_uint_t | |
| 470 ngx_reap_worker(ngx_cycle_t *cycle, HANDLE h) | |
| 471 { | |
| 472 u_long code; | |
| 473 ngx_int_t n; | |
| 474 | |
| 475 for (n = 0; n < ngx_last_process; n++) { | |
| 476 | |
| 477 if (ngx_processes[n].handle != h) { | |
| 478 continue; | |
| 479 } | |
| 480 | |
| 481 if (GetExitCodeProcess(h, &code) == 0) { | |
|
2908
234a8248812c
log GetExitCodeProcess()'s errno
Igor Sysoev <igor@sysoev.ru>
parents:
2823
diff
changeset
|
482 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, |
| 2725 | 483 "GetExitCodeProcess(%P) failed", |
| 484 ngx_processes[n].pid); | |
| 485 } | |
| 486 | |
| 487 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, | |
|
6509
7640d6c213e1
Removed redundant "u" format specifier.
Ruslan Ermilov <ru@nginx.com>
parents:
6483
diff
changeset
|
488 "%s process %P exited with code %Xl", |
| 2725 | 489 ngx_processes[n].name, ngx_processes[n].pid, code); |
| 490 | |
| 491 ngx_close_handle(ngx_processes[n].reopen); | |
| 492 ngx_close_handle(ngx_processes[n].quit); | |
| 493 ngx_close_handle(ngx_processes[n].term); | |
| 494 ngx_close_handle(h); | |
| 2627 | 495 |
| 2725 | 496 ngx_processes[n].handle = NULL; |
| 497 ngx_processes[n].term = NULL; | |
| 498 ngx_processes[n].quit = NULL; | |
| 499 ngx_processes[n].reopen = NULL; | |
| 500 | |
| 501 if (!ngx_processes[n].exiting && !ngx_terminate && !ngx_quit) { | |
| 502 | |
| 503 if (ngx_spawn_process(cycle, ngx_processes[n].name, n) | |
| 504 == NGX_INVALID_PID) | |
| 505 { | |
| 506 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
|
4133
59b99f217c6d
Replaced "can not" with "cannot" and "could not" in a bunch of places.
Ruslan Ermilov <ru@nginx.com>
parents:
3751
diff
changeset
|
507 "could not respawn %s", ngx_processes[n].name); |
| 2725 | 508 |
| 509 if (n == ngx_last_process - 1) { | |
| 510 ngx_last_process--; | |
| 511 } | |
| 512 } | |
| 513 } | |
| 2627 | 514 |
| 2725 | 515 goto found; |
| 516 } | |
| 517 | |
| 518 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, "unknown process handle %p", h); | |
| 519 | |
| 520 found: | |
| 521 | |
| 522 for (n = 0; n < ngx_last_process; n++) { | |
| 523 | |
| 524 ngx_log_debug5(NGX_LOG_DEBUG_CORE, cycle->log, 0, | |
| 2921 | 525 "process: %d %P %p e:%d j:%d", |
| 2725 | 526 n, |
| 527 ngx_processes[n].pid, | |
| 528 ngx_processes[n].handle, | |
| 529 ngx_processes[n].exiting, | |
|
3016
d82993af1da0
introduce NGX_PROCESS_JUST_SPAWN and change field name accordingly
Igor Sysoev <igor@sysoev.ru>
parents:
2928
diff
changeset
|
530 ngx_processes[n].just_spawn); |
| 2725 | 531 |
| 532 if (ngx_processes[n].handle) { | |
| 533 return 1; | |
| 534 } | |
| 2627 | 535 } |
| 536 | |
| 537 return 0; | |
| 538 } | |
| 539 | |
| 540 | |
| 541 static void | |
| 2725 | 542 ngx_master_process_exit(ngx_cycle_t *cycle) |
| 543 { | |
| 544 ngx_uint_t i; | |
| 545 | |
| 546 ngx_delete_pidfile(cycle); | |
| 547 | |
| 548 ngx_close_handle(ngx_cache_manager_mutex); | |
| 549 ngx_close_handle(ngx_stop_event); | |
| 550 ngx_close_handle(ngx_quit_event); | |
| 551 ngx_close_handle(ngx_reopen_event); | |
| 552 ngx_close_handle(ngx_reload_event); | |
| 553 ngx_close_handle(ngx_master_process_event); | |
| 554 | |
| 555 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exit"); | |
| 556 | |
|
6379
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
557 for (i = 0; cycle->modules[i]; i++) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
558 if (cycle->modules[i]->exit_master) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
559 cycle->modules[i]->exit_master(cycle); |
| 2725 | 560 } |
| 561 } | |
| 562 | |
| 563 ngx_destroy_pool(cycle->pool); | |
| 564 | |
| 565 exit(0); | |
| 566 } | |
| 567 | |
| 568 | |
| 569 static void | |
| 570 ngx_worker_process_cycle(ngx_cycle_t *cycle, char *mevn) | |
| 2627 | 571 { |
| 2725 | 572 char wtevn[NGX_PROCESS_SYNC_NAME]; |
| 573 char wqevn[NGX_PROCESS_SYNC_NAME]; | |
| 574 char wroevn[NGX_PROCESS_SYNC_NAME]; | |
| 575 HANDLE mev, events[3]; | |
| 576 u_long nev, ev; | |
| 577 ngx_err_t err; | |
|
3352
5c43621c580a
a cache manager thread handle was overwritten by a cache loader thread handle,
Igor Sysoev <igor@sysoev.ru>
parents:
3035
diff
changeset
|
578 ngx_tid_t wtid, cmtid, cltid; |
| 2725 | 579 ngx_log_t *log; |
| 580 | |
| 581 log = cycle->log; | |
| 582 | |
| 583 ngx_log_debug0(NGX_LOG_DEBUG_CORE, log, 0, "worker started"); | |
| 584 | |
|
6482
2b7dacb381ed
Fixed ngx_pid_t formatting in ngx_sprintf() and logging.
Sergey Kandaurov <pluknet@nginx.com>
parents:
6379
diff
changeset
|
585 ngx_sprintf((u_char *) wtevn, "ngx_worker_term_%P%Z", ngx_pid); |
| 2725 | 586 events[0] = CreateEvent(NULL, 1, 0, wtevn); |
| 587 if (events[0] == NULL) { | |
| 588 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 589 "CreateEvent(\"%s\") failed", wtevn); | |
| 590 goto failed; | |
| 591 } | |
| 592 | |
|
6482
2b7dacb381ed
Fixed ngx_pid_t formatting in ngx_sprintf() and logging.
Sergey Kandaurov <pluknet@nginx.com>
parents:
6379
diff
changeset
|
593 ngx_sprintf((u_char *) wqevn, "ngx_worker_quit_%P%Z", ngx_pid); |
| 2725 | 594 events[1] = CreateEvent(NULL, 1, 0, wqevn); |
| 595 if (events[1] == NULL) { | |
| 596 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 597 "CreateEvent(\"%s\") failed", wqevn); | |
| 598 goto failed; | |
| 599 } | |
| 600 | |
|
6482
2b7dacb381ed
Fixed ngx_pid_t formatting in ngx_sprintf() and logging.
Sergey Kandaurov <pluknet@nginx.com>
parents:
6379
diff
changeset
|
601 ngx_sprintf((u_char *) wroevn, "ngx_worker_reopen_%P%Z", ngx_pid); |
| 2725 | 602 events[2] = CreateEvent(NULL, 1, 0, wroevn); |
| 603 if (events[2] == NULL) { | |
| 604 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 605 "CreateEvent(\"%s\") failed", wroevn); | |
| 606 goto failed; | |
| 607 } | |
| 608 | |
| 609 mev = OpenEvent(EVENT_MODIFY_STATE, 0, mevn); | |
| 610 if (mev == NULL) { | |
| 611 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 612 "OpenEvent(\"%s\") failed", mevn); | |
| 613 goto failed; | |
| 614 } | |
| 615 | |
| 616 if (SetEvent(mev) == 0) { | |
| 617 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 618 "SetEvent(\"%s\") failed", mevn); | |
| 619 goto failed; | |
| 620 } | |
| 621 | |
| 622 | |
| 623 ngx_sprintf((u_char *) ngx_cache_manager_mutex_name, | |
| 624 "ngx_cache_manager_mutex_%s%Z", ngx_unique); | |
| 625 | |
| 626 ngx_cache_manager_mutex = OpenMutex(SYNCHRONIZE, 0, | |
| 627 ngx_cache_manager_mutex_name); | |
| 628 if (ngx_cache_manager_mutex == NULL) { | |
| 629 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 630 "OpenMutex(\"%s\") failed", ngx_cache_manager_mutex_name); | |
| 631 goto failed; | |
| 632 } | |
| 633 | |
| 634 ngx_cache_manager_event = CreateEvent(NULL, 1, 0, NULL); | |
| 635 if (ngx_cache_manager_event == NULL) { | |
| 636 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 637 "CreateEvent(\"ngx_cache_manager_event\") failed"); | |
| 638 goto failed; | |
| 639 } | |
| 640 | |
| 641 | |
| 642 if (ngx_create_thread(&wtid, ngx_worker_thread, NULL, log) != 0) { | |
| 643 goto failed; | |
| 644 } | |
| 645 | |
| 646 if (ngx_create_thread(&cmtid, ngx_cache_manager_thread, NULL, log) != 0) { | |
| 647 goto failed; | |
| 648 } | |
| 649 | |
|
3352
5c43621c580a
a cache manager thread handle was overwritten by a cache loader thread handle,
Igor Sysoev <igor@sysoev.ru>
parents:
3035
diff
changeset
|
650 if (ngx_create_thread(&cltid, ngx_cache_loader_thread, NULL, log) != 0) { |
| 3022 | 651 goto failed; |
| 652 } | |
| 653 | |
| 2725 | 654 for ( ;; ) { |
| 655 ev = WaitForMultipleObjects(3, events, 0, INFINITE); | |
| 656 | |
| 657 err = ngx_errno; | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
658 ngx_time_update(); |
| 461 | 659 |
| 2725 | 660 ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, |
| 661 "worker WaitForMultipleObjects: %ul", ev); | |
| 662 | |
| 663 if (ev == WAIT_OBJECT_0) { | |
| 664 ngx_terminate = 1; | |
| 665 ngx_log_error(NGX_LOG_NOTICE, log, 0, "exiting"); | |
| 666 | |
| 667 if (ResetEvent(events[0]) == 0) { | |
| 668 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 669 "ResetEvent(\"%s\") failed", wtevn); | |
| 670 } | |
| 671 | |
| 672 break; | |
| 673 } | |
| 674 | |
| 675 if (ev == WAIT_OBJECT_0 + 1) { | |
| 676 ngx_quit = 1; | |
| 677 ngx_log_error(NGX_LOG_NOTICE, log, 0, "gracefully shutting down"); | |
| 678 break; | |
| 679 } | |
| 680 | |
| 681 if (ev == WAIT_OBJECT_0 + 2) { | |
| 682 ngx_reopen = 1; | |
| 683 ngx_log_error(NGX_LOG_NOTICE, log, 0, "reopening logs"); | |
| 684 | |
| 685 if (ResetEvent(events[2]) == 0) { | |
| 686 ngx_log_error(NGX_LOG_ALERT, log, 0, | |
| 687 "ResetEvent(\"%s\") failed", wroevn); | |
| 688 } | |
| 689 | |
| 690 continue; | |
| 691 } | |
| 692 | |
| 693 if (ev == WAIT_FAILED) { | |
| 694 ngx_log_error(NGX_LOG_ALERT, log, err, | |
| 695 "WaitForMultipleObjects() failed"); | |
| 696 | |
| 697 goto failed; | |
| 698 } | |
| 699 } | |
| 700 | |
| 701 /* wait threads */ | |
| 461 | 702 |
| 2725 | 703 if (SetEvent(ngx_cache_manager_event) == 0) { |
| 704 ngx_log_error(NGX_LOG_ALERT, log, ngx_errno, | |
| 705 "SetEvent(\"ngx_cache_manager_event\") failed"); | |
| 706 } | |
| 707 | |
| 708 events[1] = wtid; | |
| 709 events[2] = cmtid; | |
| 710 | |
| 711 nev = 3; | |
| 712 | |
| 713 for ( ;; ) { | |
| 714 ev = WaitForMultipleObjects(nev, events, 0, INFINITE); | |
| 715 | |
| 716 err = ngx_errno; | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
717 ngx_time_update(); |
| 2725 | 718 |
| 719 ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, | |
| 720 "worker exit WaitForMultipleObjects: %ul", ev); | |
| 721 | |
| 722 if (ev == WAIT_OBJECT_0) { | |
| 723 break; | |
| 724 } | |
| 725 | |
| 726 if (ev == WAIT_OBJECT_0 + 1) { | |
| 727 if (nev == 2) { | |
| 728 break; | |
| 729 } | |
| 730 | |
| 731 events[1] = events[2]; | |
| 732 nev = 2; | |
| 733 continue; | |
| 734 } | |
| 735 | |
| 736 if (ev == WAIT_OBJECT_0 + 2) { | |
| 737 nev = 2; | |
| 738 continue; | |
| 739 } | |
| 740 | |
| 741 if (ev == WAIT_FAILED) { | |
| 742 ngx_log_error(NGX_LOG_ALERT, log, err, | |
| 743 "WaitForMultipleObjects() failed"); | |
| 744 break; | |
| 745 } | |
| 461 | 746 } |
| 747 | |
| 2725 | 748 ngx_close_handle(ngx_cache_manager_event); |
| 749 ngx_close_handle(events[0]); | |
| 750 ngx_close_handle(events[1]); | |
| 751 ngx_close_handle(events[2]); | |
| 752 ngx_close_handle(mev); | |
| 753 | |
| 754 ngx_worker_process_exit(cycle); | |
| 755 | |
| 756 failed: | |
| 757 | |
| 758 exit(2); | |
| 759 } | |
| 760 | |
| 761 | |
| 762 static ngx_thread_value_t __stdcall | |
| 763 ngx_worker_thread(void *data) | |
| 764 { | |
|
6220
5e6142609e48
Core: idle connections now closed only once on exiting.
Valentin Bartenev <vbart@nginx.com>
parents:
6151
diff
changeset
|
765 ngx_int_t n; |
|
6651
7d4e33092e2a
Always seed PRNG with PID, seconds, and milliseconds.
Ruslan Ermilov <ru@nginx.com>
parents:
6649
diff
changeset
|
766 ngx_time_t *tp; |
|
6220
5e6142609e48
Core: idle connections now closed only once on exiting.
Valentin Bartenev <vbart@nginx.com>
parents:
6151
diff
changeset
|
767 ngx_cycle_t *cycle; |
| 2725 | 768 |
|
6651
7d4e33092e2a
Always seed PRNG with PID, seconds, and milliseconds.
Ruslan Ermilov <ru@nginx.com>
parents:
6649
diff
changeset
|
769 tp = ngx_timeofday(); |
|
7d4e33092e2a
Always seed PRNG with PID, seconds, and milliseconds.
Ruslan Ermilov <ru@nginx.com>
parents:
6649
diff
changeset
|
770 srand((ngx_pid << 16) ^ (unsigned) tp->sec ^ tp->msec); |
|
6649
09c918460cc6
Win32: added per-thread random seeding.
Ruslan Ermilov <ru@nginx.com>
parents:
6509
diff
changeset
|
771 |
| 2725 | 772 cycle = (ngx_cycle_t *) ngx_cycle; |
| 773 | |
|
6379
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
774 for (n = 0; cycle->modules[n]; n++) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
775 if (cycle->modules[n]->init_process) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
776 if (cycle->modules[n]->init_process(cycle) == NGX_ERROR) { |
| 2725 | 777 /* fatal */ |
| 778 exit(2); | |
| 779 } | |
| 780 } | |
| 781 } | |
| 782 | |
| 783 while (!ngx_quit) { | |
| 784 | |
| 785 if (ngx_exiting) { | |
|
6929
3069dd358ba2
Cancelable timers are now preserved if there are other timers.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6727
diff
changeset
|
786 if (ngx_event_no_timers_left() == NGX_OK) { |
| 2725 | 787 break; |
| 788 } | |
| 789 } | |
| 790 | |
| 791 ngx_log_debug0(NGX_LOG_DEBUG_CORE, cycle->log, 0, "worker cycle"); | |
| 792 | |
| 793 ngx_process_events_and_timers(cycle); | |
| 794 | |
| 795 if (ngx_terminate) { | |
| 796 return 0; | |
| 797 } | |
| 798 | |
| 799 if (ngx_quit) { | |
| 800 ngx_quit = 0; | |
| 801 | |
| 802 if (!ngx_exiting) { | |
|
6220
5e6142609e48
Core: idle connections now closed only once on exiting.
Valentin Bartenev <vbart@nginx.com>
parents:
6151
diff
changeset
|
803 ngx_exiting = 1; |
|
6930
97c99bb43737
Introduced worker_shutdown_timeout.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6929
diff
changeset
|
804 ngx_set_shutdown_timer(cycle); |
| 2725 | 805 ngx_close_listening_sockets(cycle); |
|
6220
5e6142609e48
Core: idle connections now closed only once on exiting.
Valentin Bartenev <vbart@nginx.com>
parents:
6151
diff
changeset
|
806 ngx_close_idle_connections(cycle); |
|
8103
b809f53d3f5b
Process events posted by ngx_close_idle_connections() immediately.
Roman Arutyunyan <arut@nginx.com>
parents:
7162
diff
changeset
|
807 ngx_event_process_posted(cycle, &ngx_posted_events); |
| 2725 | 808 } |
| 809 } | |
| 810 | |
| 811 if (ngx_reopen) { | |
| 812 ngx_reopen = 0; | |
| 813 ngx_reopen_files(cycle, -1); | |
| 814 } | |
| 815 } | |
| 816 | |
| 817 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting"); | |
| 818 | |
| 819 return 0; | |
| 820 } | |
| 821 | |
| 822 | |
| 823 static void | |
| 824 ngx_worker_process_exit(ngx_cycle_t *cycle) | |
| 825 { | |
| 826 ngx_uint_t i; | |
| 827 ngx_connection_t *c; | |
| 828 | |
| 829 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exit"); | |
| 830 | |
|
6379
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
831 for (i = 0; cycle->modules[i]; i++) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
832 if (cycle->modules[i]->exit_process) { |
|
cf5e822cf470
Dynamic modules: changed ngx_modules to cycle->modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
6220
diff
changeset
|
833 cycle->modules[i]->exit_process(cycle); |
| 2725 | 834 } |
| 835 } | |
| 836 | |
|
9201
791ead216b03
Silenced complaints about socket leaks on forced termination.
Maxim Dounin <mdounin@mdounin.ru>
parents:
8103
diff
changeset
|
837 if (ngx_exiting && !ngx_terminate) { |
| 2725 | 838 c = cycle->connections; |
| 839 for (i = 0; i < cycle->connection_n; i++) { | |
|
5360
3d2d3e1cf427
Win32: MinGW GCC compatibility.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4870
diff
changeset
|
840 if (c[i].fd != (ngx_socket_t) -1 |
| 2725 | 841 && c[i].read |
| 842 && !c[i].read->accept | |
| 843 && !c[i].read->channel | |
| 844 && !c[i].read->resolver) | |
| 845 { | |
| 846 ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, | |
|
5601
e45fa57ef725
Added connection serial number in logging of left open sockets.
Sergey Kandaurov <pluknet@nginx.com>
parents:
5452
diff
changeset
|
847 "*%uA open socket #%d left in connection %ui", |
|
e45fa57ef725
Added connection serial number in logging of left open sockets.
Sergey Kandaurov <pluknet@nginx.com>
parents:
5452
diff
changeset
|
848 c[i].number, c[i].fd, i); |
| 2725 | 849 } |
| 850 } | |
| 461 | 851 } |
| 852 | |
| 2725 | 853 ngx_destroy_pool(cycle->pool); |
| 854 | |
| 855 exit(0); | |
| 856 } | |
| 857 | |
| 858 | |
| 859 static ngx_thread_value_t __stdcall | |
| 860 ngx_cache_manager_thread(void *data) | |
| 861 { | |
| 862 u_long ev; | |
| 863 HANDLE events[2]; | |
| 864 ngx_err_t err; | |
| 865 ngx_cycle_t *cycle; | |
| 866 | |
| 867 cycle = (ngx_cycle_t *) ngx_cycle; | |
| 868 | |
| 869 events[0] = ngx_cache_manager_event; | |
| 870 events[1] = ngx_cache_manager_mutex; | |
| 871 | |
| 872 for ( ;; ) { | |
| 873 ev = WaitForMultipleObjects(2, events, 0, INFINITE); | |
| 874 | |
| 875 err = ngx_errno; | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
876 ngx_time_update(); |
| 2725 | 877 |
| 878 ngx_log_debug1(NGX_LOG_DEBUG_CORE, cycle->log, 0, | |
| 879 "cache manager WaitForMultipleObjects: %ul", ev); | |
| 880 | |
| 881 if (ev == WAIT_FAILED) { | |
| 882 ngx_log_error(NGX_LOG_ALERT, cycle->log, err, | |
| 883 "WaitForMultipleObjects() failed"); | |
| 884 } | |
| 885 | |
| 886 /* | |
| 887 * ev == WAIT_OBJECT_0 | |
| 888 * ev == WAIT_OBJECT_0 + 1 | |
| 889 * ev == WAIT_ABANDONED_0 + 1 | |
| 890 */ | |
| 891 | |
|
5633
b74f1106f920
Win32: fixed cpu hog by cache manager on exit (ticket #514).
Maxim Dounin <mdounin@mdounin.ru>
parents:
5601
diff
changeset
|
892 if (ngx_terminate || ngx_quit || ngx_exiting) { |
| 2725 | 893 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting"); |
| 894 return 0; | |
| 895 } | |
| 896 | |
| 3021 | 897 break; |
| 2725 | 898 } |
| 899 | |
| 900 for ( ;; ) { | |
| 901 | |
|
5633
b74f1106f920
Win32: fixed cpu hog by cache manager on exit (ticket #514).
Maxim Dounin <mdounin@mdounin.ru>
parents:
5601
diff
changeset
|
902 if (ngx_terminate || ngx_quit || ngx_exiting) { |
| 2725 | 903 ngx_log_error(NGX_LOG_NOTICE, cycle->log, 0, "exiting"); |
| 904 break; | |
| 905 } | |
| 906 | |
| 907 ngx_cache_manager_process_handler(); | |
| 908 } | |
| 909 | |
| 910 if (ReleaseMutex(ngx_cache_manager_mutex) == 0) { | |
| 911 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 912 "ReleaseMutex() failed"); | |
| 913 } | |
| 914 | |
| 915 return 0; | |
| 916 } | |
| 917 | |
| 918 | |
| 919 static void | |
| 920 ngx_cache_manager_process_handler(void) | |
| 921 { | |
| 922 u_long ev; | |
| 923 ngx_uint_t i; | |
|
6727
ca709bca4b77
Cache: cache manager limits.
Dmitry Volyntsev <xeioex@nginx.com>
parents:
6651
diff
changeset
|
924 ngx_msec_t next, n; |
| 2725 | 925 ngx_path_t **path; |
| 926 | |
|
6727
ca709bca4b77
Cache: cache manager limits.
Dmitry Volyntsev <xeioex@nginx.com>
parents:
6651
diff
changeset
|
927 next = 60 * 60 * 1000; |
| 2725 | 928 |
|
4870
8a9b7b4e9f2d
Correct plural form for "path" in the whole source base.
Andrey Belov <defan@nginx.com>
parents:
4412
diff
changeset
|
929 path = ngx_cycle->paths.elts; |
|
8a9b7b4e9f2d
Correct plural form for "path" in the whole source base.
Andrey Belov <defan@nginx.com>
parents:
4412
diff
changeset
|
930 for (i = 0; i < ngx_cycle->paths.nelts; i++) { |
| 2725 | 931 |
| 932 if (path[i]->manager) { | |
| 933 n = path[i]->manager(path[i]->data); | |
| 934 | |
| 935 next = (n <= next) ? n : next; | |
| 936 | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
937 ngx_time_update(); |
| 2725 | 938 } |
| 939 } | |
| 940 | |
| 941 if (next == 0) { | |
| 942 next = 1; | |
| 943 } | |
| 944 | |
|
6727
ca709bca4b77
Cache: cache manager limits.
Dmitry Volyntsev <xeioex@nginx.com>
parents:
6651
diff
changeset
|
945 ev = WaitForSingleObject(ngx_cache_manager_event, (u_long) next); |
| 2725 | 946 |
| 947 if (ev != WAIT_TIMEOUT) { | |
| 948 | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
949 ngx_time_update(); |
| 2725 | 950 |
| 951 ngx_log_debug1(NGX_LOG_DEBUG_CORE, ngx_cycle->log, 0, | |
| 952 "cache manager WaitForSingleObject: %ul", ev); | |
| 953 } | |
| 954 } | |
| 955 | |
| 956 | |
| 3022 | 957 static ngx_thread_value_t __stdcall |
| 958 ngx_cache_loader_thread(void *data) | |
| 959 { | |
| 960 ngx_uint_t i; | |
| 961 ngx_path_t **path; | |
| 962 ngx_cycle_t *cycle; | |
| 963 | |
| 964 ngx_msleep(60000); | |
| 965 | |
| 966 cycle = (ngx_cycle_t *) ngx_cycle; | |
| 967 | |
|
4870
8a9b7b4e9f2d
Correct plural form for "path" in the whole source base.
Andrey Belov <defan@nginx.com>
parents:
4412
diff
changeset
|
968 path = cycle->paths.elts; |
|
8a9b7b4e9f2d
Correct plural form for "path" in the whole source base.
Andrey Belov <defan@nginx.com>
parents:
4412
diff
changeset
|
969 for (i = 0; i < cycle->paths.nelts; i++) { |
| 3022 | 970 |
|
5633
b74f1106f920
Win32: fixed cpu hog by cache manager on exit (ticket #514).
Maxim Dounin <mdounin@mdounin.ru>
parents:
5601
diff
changeset
|
971 if (ngx_terminate || ngx_quit || ngx_exiting) { |
| 3022 | 972 break; |
| 973 } | |
| 974 | |
| 975 if (path[i]->loader) { | |
| 976 path[i]->loader(path[i]->data); | |
|
3475
ab353d7dc182
*) introduce ngx_time_sigsafe_update() to update the error log time only
Igor Sysoev <igor@sysoev.ru>
parents:
3474
diff
changeset
|
977 ngx_time_update(); |
| 3022 | 978 } |
| 979 } | |
| 980 | |
| 981 return 0; | |
| 982 } | |
| 983 | |
| 984 | |
| 2725 | 985 void |
| 986 ngx_single_process_cycle(ngx_cycle_t *cycle) | |
| 987 { | |
| 988 ngx_tid_t tid; | |
| 989 | |
| 990 ngx_console_init(cycle); | |
| 991 | |
|
3751
a4755d4fd91b
add "Global\" prefix for signal events
Igor Sysoev <igor@sysoev.ru>
parents:
3475
diff
changeset
|
992 if (ngx_create_signal_events(cycle) != NGX_OK) { |
| 461 | 993 exit(2); |
| 994 } | |
| 995 | |
| 2725 | 996 if (ngx_create_thread(&tid, ngx_worker_thread, NULL, cycle->log) != 0) { |
| 461 | 997 /* fatal */ |
| 998 exit(2); | |
| 999 } | |
| 1000 | |
| 2725 | 1001 /* STUB */ |
| 1002 WaitForSingleObject(ngx_stop_event, INFINITE); | |
| 461 | 1003 } |
| 1004 | |
| 1005 | |
| 2725 | 1006 ngx_int_t |
|
6483
3a50ccd94333
Fixed ngx_os_signal_process() prototype.
Ruslan Ermilov <ru@nginx.com>
parents:
6482
diff
changeset
|
1007 ngx_os_signal_process(ngx_cycle_t *cycle, char *sig, ngx_pid_t pid) |
| 461 | 1008 { |
|
2738
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1009 HANDLE ev; |
|
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1010 ngx_int_t rc; |
|
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1011 char evn[NGX_PROCESS_SYNC_NAME]; |
| 461 | 1012 |
|
6483
3a50ccd94333
Fixed ngx_os_signal_process() prototype.
Ruslan Ermilov <ru@nginx.com>
parents:
6482
diff
changeset
|
1013 ngx_sprintf((u_char *) evn, "Global\\ngx_%s_%P%Z", sig, pid); |
| 2725 | 1014 |
| 1015 ev = OpenEvent(EVENT_MODIFY_STATE, 0, evn); | |
| 1016 if (ev == NULL) { | |
| 1017 ngx_log_error(NGX_LOG_ERR, cycle->log, ngx_errno, | |
| 1018 "OpenEvent(\"%s\") failed", evn); | |
|
2738
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1019 return 1; |
| 2725 | 1020 } |
| 461 | 1021 |
| 2725 | 1022 if (SetEvent(ev) == 0) { |
| 1023 ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, | |
| 1024 "SetEvent(\"%s\") failed", evn); | |
|
2738
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1025 rc = 1; |
|
ae81441e23f4
implement "-s signal" option for Unix
Igor Sysoev <igor@sysoev.ru>
parents:
2725
diff
changeset
|
1026 |
| 2725 | 1027 } else { |
| 1028 rc = 0; | |
| 1029 } | |
| 1030 | |
| 1031 ngx_close_handle(ev); | |
| 1032 | |
| 1033 return rc; | |
| 1034 } | |
| 461 | 1035 |
| 1036 | |
| 2725 | 1037 void |
| 1038 ngx_close_handle(HANDLE h) | |
| 1039 { | |
| 1040 if (CloseHandle(h) == 0) { | |
| 1041 ngx_log_error(NGX_LOG_ALERT, ngx_cycle->log, ngx_errno, | |
| 1042 "CloseHandle(%p) failed", h); | |
| 461 | 1043 } |
| 1044 } |