Mercurial > hg > nginx
diff src/core/nginx.c @ 227:2ba3477070ac
nginx-0.0.1-2004-01-14-21:19:42 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Wed, 14 Jan 2004 18:19:42 +0000 |
parents | b0c1e21e68db |
children | 92db0aa1e83f |
line wrap: on
line diff
--- 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; }