aboutsummaryrefslogtreecommitdiff
path: root/src/os/unix/ngx_process_cycle.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2004-03-30 20:31:58 +0000
committerIgor Sysoev <igor@sysoev.ru>2004-03-30 20:31:58 +0000
commita741f8d0216d95a7ee0fbb8a24947de8842900c0 (patch)
tree39b3665a5cb0f7780a139eeea918316342fd92af /src/os/unix/ngx_process_cycle.c
parent6707ba90729c615ffa5bf5ea81b8d32c3d8bd6e4 (diff)
downloadnginx-a741f8d0216d95a7ee0fbb8a24947de8842900c0.tar.gz
nginx-a741f8d0216d95a7ee0fbb8a24947de8842900c0.zip
nginx-0.0.3-2004-03-31-00:31:58 import
Diffstat (limited to 'src/os/unix/ngx_process_cycle.c')
-rw-r--r--src/os/unix/ngx_process_cycle.c26
1 files changed, 10 insertions, 16 deletions
diff --git a/src/os/unix/ngx_process_cycle.c b/src/os/unix/ngx_process_cycle.c
index e4d95ada9..cc3d8a4c4 100644
--- a/src/os/unix/ngx_process_cycle.c
+++ b/src/os/unix/ngx_process_cycle.c
@@ -68,9 +68,14 @@ void ngx_master_process_cycle(ngx_cycle_t *cycle, ngx_master_ctx_t *ctx)
for ( ;; ) {
ngx_log_debug0(NGX_LOG_DEBUG_EVENT, cycle->log, 0, "new cycle");
+ ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx,
+ ngx_core_module);
+
if (ngx_process == NGX_PROCESS_MASTER) {
- ngx_spawn_process(cycle, ngx_worker_process_cycle, NULL,
- "worker process", NGX_PROCESS_RESPAWN);
+ for (i = 0; i < (ngx_uint_t) ccf->worker_processes; i++) {
+ ngx_spawn_process(cycle, ngx_worker_process_cycle, NULL,
+ "worker process", NGX_PROCESS_RESPAWN);
+ }
/*
* we have to limit the maximum life time of the worker processes
@@ -103,8 +108,6 @@ void ngx_master_process_cycle(ngx_cycle_t *cycle, ngx_master_ctx_t *ctx)
}
}
- ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx,
- ngx_core_module);
/* a cycle with the same configuration because a new one is invalid */
@@ -253,16 +256,8 @@ void ngx_master_process_cycle(ngx_cycle_t *cycle, ngx_master_ctx_t *ctx)
if (ngx_reopen) {
if (ngx_process == NGX_PROCESS_MASTER) {
- if (ccf->worker_reopen != 0) {
- signo = ngx_signal_value(NGX_REOPEN_SIGNAL);
- ngx_reopen = 0;
-
- } else if (ngx_noaccept) {
- ngx_reopen = 0;
-
- } else {
- signo = ngx_signal_value(NGX_SHUTDOWN_SIGNAL);
- }
+ signo = ngx_signal_value(NGX_REOPEN_SIGNAL);
+ ngx_reopen = 0;
} else { /* NGX_PROCESS_SINGLE */
ngx_reopen = 0;
@@ -270,8 +265,7 @@ void ngx_master_process_cycle(ngx_cycle_t *cycle, ngx_master_ctx_t *ctx)
ngx_log_error(NGX_LOG_INFO, cycle->log, 0,
"reopening logs");
- ngx_reopen_files(cycle,
- ccf->worker_reopen != 0 ? ccf->user : (uid_t) -1);
+ ngx_reopen_files(cycle, ccf->user);
}
}