# HG changeset patch # User Igor Sysoev # Date 1074104382 0 # Node ID 2ba3477070ac007287a99bd79af7415342e094db # Parent b0c1e21e68dba657313466d8217da299d05a6dad nginx-0.0.1-2004-01-14-21:19:42 import diff -r b0c1e21e68db -r 2ba3477070ac src/core/nginx.c --- a/src/core/nginx.c Tue Jan 13 21:33:59 2004 +0000 +++ b/src/core/nginx.c Wed Jan 14 18:19:42 2004 +0000 @@ -241,7 +241,7 @@ char *name; sigset_t set, wset; struct timeval tv; - ngx_uint_t i, live, mark; + ngx_uint_t i, live, sent; ngx_msec_t delay; delay = 125; @@ -265,7 +265,7 @@ ngx_signal = 0; ngx_new_binary = 0; signo = 0; - mark = 1; + sent = 0; for ( ;; ) { ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "new cycle"); @@ -273,7 +273,6 @@ if (ngx_process == NGX_PROCESS_MASTER) { ngx_spawn_process(cycle, ngx_worker_process_cycle, NULL, "worker process", NGX_PROCESS_RESPAWN); - mark = 1; } else { ngx_init_temp_number(); @@ -297,9 +296,9 @@ for ( ;; ) { if (ngx_process == NGX_PROCESS_MASTER) { - if (signo) { - ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0, - "signal cycle: %d, %d", signo, mark); + if (sent) { + ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, + "sent signal cycle"); if (sigprocmask(SIG_UNBLOCK, &set, NULL) == -1) { ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, @@ -364,14 +363,37 @@ live = 0; for (i = 0; i < ngx_last_process; i++) { - if (ngx_processes[i].exiting - && !ngx_processes[i].exited) - { - live = 1; - continue; - } + ngx_log_debug6(NGX_LOG_DEBUG_EVENT, cycle->log, 0, + "child: " PID_T_FMT + " s:%d e:%d t:%d d:%d r:%d", + ngx_processes[i].pid, + ngx_processes[i].signal, + ngx_processes[i].exiting, + ngx_processes[i].exited, + ngx_processes[i].detached, + ngx_processes[i].respawn); if (ngx_processes[i].exited) { + + if (ngx_processes[i].respawn + && !ngx_processes[i].exiting + && !ngx_terminate + && !ngx_quit) + { + if (ngx_spawn_process(cycle, + ngx_processes[i].proc, + ngx_processes[i].data, + ngx_processes[i].name, i) + == NGX_ERROR) + { + ngx_log_error(NGX_LOG_ALERT, cycle->log, 0, + "can not respawn %s", + ngx_processes[i].name); + } + + continue; + } + if (ngx_processes[i].pid == ngx_new_binary) { ngx_new_binary = 0; } @@ -380,6 +402,14 @@ ngx_processes[i--] = ngx_processes[ngx_last_process]; } + + } else if (!ngx_processes[i].detached + && (ngx_terminate || ngx_quit)) + { + live = 1; + + } else if (ngx_processes[i].exiting) { + live = 1; } } @@ -404,8 +434,7 @@ exit(0); } else { - signo = 0; - mark = 0; + sent = 0; } } } @@ -415,31 +444,14 @@ signo = SIGKILL; } else { signo = ngx_signal_value(NGX_TERMINATE_SIGNAL); - if (mark == 0) { - mark = 1; - } } - ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, - "mark: %d", mark); } else if (ngx_quit) { signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL); - if (mark == 0) { - mark = 1; - } } else { - if (ngx_reap) { - ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, - "respawn processes"); - ngx_respawn_processes(cycle); - } - if (ngx_noaccept) { - if (mark == 0) { - mark = 1; - } signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL); } @@ -451,17 +463,13 @@ } if (ngx_reconfigure) { - mark = 1; signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL); ngx_log_error(NGX_LOG_INFO, cycle->log, 0, "reconfiguring"); } if (ngx_reopen) { - ngx_reopen = 0; - /* STUB */ - mark = 1; signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL); ngx_log_error(NGX_LOG_INFO, cycle->log, 0, @@ -471,26 +479,49 @@ } if (signo) { - if (mark == 1) { - for (i = 0; i < ngx_last_process; i++) { - ngx_log_debug1(NGX_LOG_DEBUG_EVENT, - cycle->log, 0, - "proc " PID_T_FMT, - ngx_processes[i].pid); + for (i = 0; i < ngx_last_process; i++) { + + if (!ngx_processes[i].detached) { + ngx_processes[i].signal = signo; - if (!ngx_processes[i].detached) { - ngx_processes[i].signal = 1; - ngx_log_debug1(NGX_LOG_DEBUG_EVENT, - cycle->log, 0, - "mark " PID_T_FMT, - ngx_processes[i].pid); - } + ngx_log_debug2(NGX_LOG_DEBUG_EVENT, + cycle->log, 0, + "signal " PID_T_FMT " %d", + ngx_processes[i].pid, signo); } - mark = -1; - delay = 125; + } + delay = 125; + signo = 0; + } + + for (i = 0; i < ngx_last_process; i++) { + + if (ngx_processes[i].signal == 0) { + continue; } - ngx_signal_processes(cycle, signo); + sent = 1; + + ngx_log_debug2(NGX_LOG_DEBUG_CORE, cycle->log, 0, + "kill (" PID_T_FMT ", %d)" , + ngx_processes[i].pid, + ngx_processes[i].signal); + + if (kill(ngx_processes[i].pid, ngx_processes[i].signal) + == -1) + { + ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, + "kill(%d, %d) failed", + ngx_processes[i].pid, + ngx_processes[i].signal); + continue; + } + + if (ngx_processes[i].signal + != ngx_signal_value(NGX_REOPEN_SIGNAL)) + { + ngx_processes[i].exiting = 1; + } } if (ngx_reap) { @@ -499,6 +530,7 @@ /* STUB */ if (ngx_reopen) { + ngx_reopen = 0; break; } diff -r b0c1e21e68db -r 2ba3477070ac src/core/ngx_cycle.c --- a/src/core/ngx_cycle.c Tue Jan 13 21:33:59 2004 +0000 +++ b/src/core/ngx_cycle.c Wed Jan 14 18:19:42 2004 +0000 @@ -138,8 +138,6 @@ NGX_FILE_RDWR, NGX_FILE_CREATE_OR_OPEN|NGX_FILE_APPEND); -ngx_log_debug(log, "OPEN: %d:%s" _ file[i].fd _ file[i].name.data); - if (file[i].fd == NGX_INVALID_FILE) { ngx_log_error(NGX_LOG_EMERG, log, ngx_errno, ngx_open_file_n " \"%s\" failed", @@ -156,6 +154,14 @@ failed = 1; break; } +#else + if (fcntl(file[i].fd, F_SETFD, FD_CLOEXEC) == -1) { + ngx_log_error(NGX_LOG_EMERG, log, ngx_errno, + "fcntl(FD_CLOEXEC) \"%s\" failed", + file[i].name.data); + failed = 1; + break; + } #endif } @@ -631,6 +637,20 @@ continue; } +#else + if (fcntl(fd, F_SETFD, FD_CLOEXEC) == -1) { + ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno, + "fcntl(FD_CLOEXEC) \"%s\" failed", + file[i].name.data); + + if (ngx_close_file(fd) == NGX_FILE_ERROR) { + ngx_log_error(NGX_LOG_EMERG, cycle->log, ngx_errno, + ngx_close_file_n " \"%s\" failed", + file[i].name.data); + } + + continue; + } #endif if (ngx_close_file(file[i].fd) == NGX_FILE_ERROR) { diff -r b0c1e21e68db -r 2ba3477070ac src/core/ngx_log.c --- a/src/core/ngx_log.c Tue Jan 13 21:33:59 2004 +0000 +++ b/src/core/ngx_log.c Wed Jan 14 18:19:42 2004 +0000 @@ -276,8 +276,8 @@ ngx_test_null(log, ngx_pcalloc(cycle->pool, sizeof(ngx_log_t)), NULL); ngx_test_null(log->file, ngx_conf_open_file(cycle, name), NULL); -#if 0 - /* STUB */ log->log_level = NGX_LOG_DEBUG; +#if 1 + /* STUB */ log->log_level = NGX_LOG_DEBUG | NGX_LOG_DEBUG_CORE | NGX_LOG_DEBUG_ALLOC | NGX_LOG_DEBUG_EVENT | NGX_LOG_DEBUG_HTTP; #endif return log; diff -r b0c1e21e68db -r 2ba3477070ac src/event/ngx_event.c --- a/src/event/ngx_event.c Tue Jan 13 21:33:59 2004 +0000 +++ b/src/event/ngx_event.c Wed Jan 14 18:19:42 2004 +0000 @@ -374,7 +374,7 @@ value = cf->args->elts; - if (cf->cycle->old_cycle) { + if (cf->cycle->old_cycle->conf_ctx) { old_ecf = ngx_event_get_conf(cf->cycle->old_cycle->conf_ctx, ngx_event_core_module); } else { diff -r b0c1e21e68db -r 2ba3477070ac src/os/unix/ngx_process.c --- a/src/os/unix/ngx_process.c Tue Jan 13 21:33:59 2004 +0000 +++ b/src/os/unix/ngx_process.c Wed Jan 14 18:19:42 2004 +0000 @@ -106,13 +106,15 @@ } -void ngx_signal_processes(ngx_cycle_t *cycle, ngx_int_t signo) +#if 0 + +void ngx_signal_processes(ngx_cycle_t *cycle) { ngx_uint_t i; for (i = 0; i < ngx_last_process; i++) { - if (!ngx_processes[i].signal) { + if (ngx_processes[i].signal0 == 0) { continue; } @@ -127,28 +129,29 @@ ngx_log_debug2(NGX_LOG_DEBUG_CORE, cycle->log, 0, "kill (" PID_T_FMT ", %d)" , - ngx_processes[i].pid, signo); + ngx_processes[i].pid, ngx_processes[i].signal0); - if (kill(ngx_processes[i].pid, signo) == -1) { + if (kill(ngx_processes[i].pid, ngx_processes[i].signal0) == -1) { ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno, - "kill(%d, %d) failed", ngx_processes[i].pid, signo); + "kill(%d, %d) failed", + ngx_processes[i].pid, ngx_processes[i].signal0); continue; } - if (signo != ngx_signal_value(NGX_REOPEN_SIGNAL)) { + if (ngx_processes[i].signal0 != ngx_signal_value(NGX_REOPEN_SIGNAL)) { ngx_processes[i].exiting = 1; } } } +#endif + void ngx_respawn_processes(ngx_cycle_t *cycle) { ngx_uint_t i; for (i = 0; i < ngx_last_process; i++) { - ngx_log_debug1(NGX_LOG_DEBUG_CORE, cycle->log, 0, - "proc table " PID_T_FMT, ngx_processes[i].pid); if (ngx_processes[i].exiting || !ngx_processes[i].exited) { continue; diff -r b0c1e21e68db -r 2ba3477070ac src/os/unix/ngx_process.h --- a/src/os/unix/ngx_process.h Tue Jan 13 21:33:59 2004 +0000 +++ b/src/os/unix/ngx_process.h Wed Jan 14 18:19:42 2004 +0000 @@ -8,6 +8,7 @@ typedef struct { ngx_pid_t pid; + int signal; int status; ngx_spawn_proc_pt proc; @@ -16,7 +17,6 @@ unsigned respawn:1; unsigned detached:1; - unsigned signal:1; unsigned exiting:1; unsigned exited:1; } ngx_process_t; @@ -47,7 +47,6 @@ ngx_spawn_proc_pt proc, void *data, char *name, ngx_int_t respawn); ngx_pid_t ngx_exec(ngx_cycle_t *cycle, ngx_exec_ctx_t *ctx); -void ngx_signal_processes(ngx_cycle_t *cycle, ngx_int_t signo); void ngx_respawn_processes(ngx_cycle_t *cycle); void ngx_process_get_status(void);