mirror of
https://github.com/nginx/nginx.git
synced 2025-06-12 05:11:37 +08:00
nginx-0.0.1-2004-01-15-11:12:45 import
This commit is contained in:
Igor Sysoev
parent
0911f77083
commit
b5b0ab9195
231
src/os/unix/ngx_posix_cycle.c
Normal file
231
src/os/unix/ngx_posix_cycle.c
Normal file
@ -0,0 +1,231 @@
|
||||
|
||||
|
||||
void ngx_posix_master_cycle(ngx_cycle_t *cycle)
|
||||
{
|
||||
static ngx_int_t sent;
|
||||
static ngx_msec_t delay = 125;
|
||||
|
||||
if (ngx_process == NGX_PROCESS_MASTER) {
|
||||
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,
|
||||
"sigprocmask() failed");
|
||||
continue;
|
||||
}
|
||||
|
||||
/*
|
||||
* there is very big chance that the pending signals
|
||||
* would be delivered right on the sigprocmask() return
|
||||
*/
|
||||
|
||||
if (!ngx_signal) {
|
||||
|
||||
if (delay < 15000) {
|
||||
delay *= 2;
|
||||
}
|
||||
|
||||
ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"msleep %d", delay);
|
||||
|
||||
ngx_msleep(delay);
|
||||
|
||||
ngx_gettimeofday(&tv);
|
||||
ngx_time_update(tv.tv_sec);
|
||||
|
||||
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"wake up");
|
||||
}
|
||||
|
||||
if (sigprocmask(SIG_BLOCK, &set, NULL) == -1) {
|
||||
ngx_log_error(NGX_LOG_ALERT, cycle->log, ngx_errno,
|
||||
"sigprocmask() failed");
|
||||
}
|
||||
|
||||
ngx_signal = 0;
|
||||
|
||||
} else {
|
||||
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"sigsuspend");
|
||||
|
||||
sigsuspend(&wset);
|
||||
|
||||
ngx_gettimeofday(&tv);
|
||||
ngx_time_update(tv.tv_sec);
|
||||
|
||||
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"wake up");
|
||||
}
|
||||
|
||||
} else { /* NGX_PROCESS_SINGLE */
|
||||
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"worker cycle");
|
||||
|
||||
ngx_process_events(cycle->log);
|
||||
}
|
||||
|
||||
if (ngx_reap) {
|
||||
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
|
||||
"reap childs");
|
||||
|
||||
live = 0;
|
||||
for (i = 0; i < ngx_last_process; i++) {
|
||||
|
||||
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;
|
||||
}
|
||||
|
||||
if (i != --ngx_last_process) {
|
||||
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;
|
||||
}
|
||||
}
|
||||
|
||||
if (!live) {
|
||||
if (ngx_terminate || ngx_quit) {
|
||||
|
||||
if (ngx_inherited && getppid() > 1) {
|
||||
name = ctx->pid.name.data;
|
||||
|
||||
} else {
|
||||
name = ctx->name;
|
||||
}
|
||||
|
||||
if (ngx_delete_file(name) == NGX_FILE_ERROR) {
|
||||
ngx_log_error(NGX_LOG_ALERT, cycle->log,
|
||||
ngx_errno,
|
||||
ngx_delete_file_n
|
||||
" \"%s\" failed", name);
|
||||
}
|
||||
|
||||
ngx_log_error(NGX_LOG_INFO, cycle->log, 0, "exit");
|
||||
exit(0);
|
||||
|
||||
} else {
|
||||
sent = 0;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (ngx_terminate) {
|
||||
if (delay > 10000) {
|
||||
signo = SIGKILL;
|
||||
} else {
|
||||
signo = ngx_signal_value(NGX_TERMINATE_SIGNAL);
|
||||
}
|
||||
|
||||
} else if (ngx_quit) {
|
||||
signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL);
|
||||
|
||||
} else {
|
||||
|
||||
if (ngx_noaccept) {
|
||||
signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL);
|
||||
}
|
||||
|
||||
if (ngx_change_binary) {
|
||||
ngx_change_binary = 0;
|
||||
ngx_log_error(NGX_LOG_INFO, cycle->log, 0, "changing binary");
|
||||
ngx_new_binary = ngx_exec_new_binary(cycle, ctx->argv);
|
||||
}
|
||||
|
||||
if (ngx_reconfigure) {
|
||||
signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL);
|
||||
ngx_log_error(NGX_LOG_INFO, cycle->log, 0, "reconfiguring");
|
||||
}
|
||||
|
||||
if (ngx_reopen) {
|
||||
/* STUB */
|
||||
signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL);
|
||||
|
||||
ngx_log_error(NGX_LOG_INFO, cycle->log, 0, "reopening logs");
|
||||
ngx_reopen_files(cycle);
|
||||
}
|
||||
}
|
||||
|
||||
if (signo) {
|
||||
for (i = 0; i < ngx_last_process; i++) {
|
||||
|
||||
if (!ngx_processes[i].detached) {
|
||||
ngx_processes[i].signal = signo;
|
||||
|
||||
ngx_log_debug2(NGX_LOG_DEBUG_EVENT,
|
||||
cycle->log, 0,
|
||||
"signal " PID_T_FMT " %d",
|
||||
ngx_processes[i].pid, signo);
|
||||
}
|
||||
}
|
||||
|
||||
delay = 125;
|
||||
signo = 0;
|
||||
}
|
||||
|
||||
for (i = 0; i < ngx_last_process; i++) {
|
||||
|
||||
if (ngx_processes[i].signal == 0) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (ccf->kqueue_signal != 1) {
|
||||
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;
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user