add "Global\" prefix for signal events
Igor Sysoev
11 years ago
| 12 | 12 | static void ngx_process_init(ngx_cycle_t *cycle); |
| 13 | 13 | static void ngx_console_init(ngx_cycle_t *cycle); |
| 14 | 14 | static int __stdcall ngx_console_handler(u_long type); |
| 15 | static ngx_int_t ngx_create_events(ngx_cycle_t *cycle); | |
| 15 | static ngx_int_t ngx_create_signal_events(ngx_cycle_t *cycle); | |
| 16 | 16 | static ngx_int_t ngx_start_worker_processes(ngx_cycle_t *cycle, ngx_int_t type); |
| 17 | 17 | static void ngx_reopen_worker_processes(ngx_cycle_t *cycle); |
| 18 | 18 | static void ngx_quit_worker_processes(ngx_cycle_t *cycle, ngx_uint_t old); |
| 93 | 93 | exit(2); |
| 94 | 94 | } |
| 95 | 95 | |
| 96 | if (ngx_create_events(cycle) != NGX_OK) { | |
| 96 | if (ngx_create_signal_events(cycle) != NGX_OK) { | |
| 97 | 97 | exit(2); |
| 98 | 98 | } |
| 99 | 99 | |
| 340 | 340 | |
| 341 | 341 | |
| 342 | 342 | static ngx_int_t |
| 343 | ngx_create_events(ngx_cycle_t *cycle) | |
| 344 | { | |
| 345 | ngx_sprintf((u_char *) ngx_stop_event_name, "ngx_stop_%s%Z", ngx_unique); | |
| 343 | ngx_create_signal_events(ngx_cycle_t *cycle) | |
| 344 | { | |
| 345 | ngx_sprintf((u_char *) ngx_stop_event_name, | |
| 346 | "Global\\ngx_stop_%s%Z", ngx_unique); | |
| 346 | 347 | |
| 347 | 348 | ngx_stop_event = CreateEvent(NULL, 1, 0, ngx_stop_event_name); |
| 348 | 349 | if (ngx_stop_event == NULL) { |
| 352 | 353 | } |
| 353 | 354 | |
| 354 | 355 | |
| 355 | ngx_sprintf((u_char *) ngx_quit_event_name, "ngx_quit_%s%Z", ngx_unique); | |
| 356 | ngx_sprintf((u_char *) ngx_quit_event_name, | |
| 357 | "Global\\ngx_quit_%s%Z", ngx_unique); | |
| 356 | 358 | |
| 357 | 359 | ngx_quit_event = CreateEvent(NULL, 1, 0, ngx_quit_event_name); |
| 358 | 360 | if (ngx_quit_event == NULL) { |
| 363 | 365 | |
| 364 | 366 | |
| 365 | 367 | ngx_sprintf((u_char *) ngx_reopen_event_name, |
| 366 | "ngx_reopen_%s%Z", ngx_unique); | |
| 368 | "Global\\ngx_reopen_%s%Z", ngx_unique); | |
| 367 | 369 | |
| 368 | 370 | ngx_reopen_event = CreateEvent(NULL, 1, 0, ngx_reopen_event_name); |
| 369 | 371 | if (ngx_reopen_event == NULL) { |
| 374 | 376 | |
| 375 | 377 | |
| 376 | 378 | ngx_sprintf((u_char *) ngx_reload_event_name, |
| 377 | "ngx_reload_%s%Z", ngx_unique); | |
| 379 | "Global\\ngx_reload_%s%Z", ngx_unique); | |
| 378 | 380 | |
| 379 | 381 | ngx_reload_event = CreateEvent(NULL, 1, 0, ngx_reload_event_name); |
| 380 | 382 | if (ngx_reload_event == NULL) { |
| 1034 | 1036 | |
| 1035 | 1037 | ngx_console_init(cycle); |
| 1036 | 1038 | |
| 1037 | if (ngx_create_events(cycle) != NGX_OK) { | |
| 1039 | if (ngx_create_signal_events(cycle) != NGX_OK) { | |
| 1038 | 1040 | exit(2); |
| 1039 | 1041 | } |
| 1040 | 1042 | |
| 1055 | 1057 | ngx_int_t rc; |
| 1056 | 1058 | char evn[NGX_PROCESS_SYNC_NAME]; |
| 1057 | 1059 | |
| 1058 | ngx_sprintf((u_char *) evn, "ngx_%s_%ul%Z", sig, pid); | |
| 1060 | ngx_sprintf((u_char *) evn, "Global\\ngx_%s_%ul%Z", sig, pid); | |
| 1059 | 1061 | |
| 1060 | 1062 | ev = OpenEvent(EVENT_MODIFY_STATE, 0, evn); |
| 1061 | 1063 | if (ev == NULL) { |