0,
NULL },
-#if (NGX_OLD_THREADS)
-
- { ngx_string("worker_threads"),
- NGX_MAIN_CONF|NGX_DIRECT_CONF|NGX_CONF_TAKE1,
- ngx_conf_set_num_slot,
- 0,
- offsetof(ngx_core_conf_t, worker_threads),
- NULL },
-
- { ngx_string("thread_stack_size"),
- NGX_MAIN_CONF|NGX_DIRECT_CONF|NGX_CONF_TAKE1,
- ngx_conf_set_size_slot,
- 0,
- offsetof(ngx_core_conf_t, thread_stack_size),
- NULL },
-
-#endif
-
ngx_null_command
};
ccf->user = (ngx_uid_t) NGX_CONF_UNSET_UINT;
ccf->group = (ngx_gid_t) NGX_CONF_UNSET_UINT;
-#if (NGX_OLD_THREADS)
- ccf->worker_threads = NGX_CONF_UNSET;
- ccf->thread_stack_size = NGX_CONF_UNSET_SIZE;
-#endif
-
if (ngx_array_init(&ccf->env, cycle->pool, 1, sizeof(ngx_str_t))
!= NGX_OK)
{
"using last mask for remaining worker processes");
}
-#endif
-
-#if (NGX_OLD_THREADS)
-
- ngx_conf_init_value(ccf->worker_threads, 0);
- ngx_threads_n = ccf->worker_threads;
- ngx_conf_init_size_value(ccf->thread_stack_size, 2 * 1024 * 1024);
-
#endif
ngx_array_t env;
char **environment;
-
-#if (NGX_OLD_THREADS)
- ngx_int_t worker_threads;
- size_t thread_stack_size;
-#endif
-
} ngx_core_conf_t;
#include <nginx.h>
-static void ngx_process_init(ngx_cycle_t *cycle);
static void ngx_console_init(ngx_cycle_t *cycle);
static int __stdcall ngx_console_handler(u_long type);
static ngx_int_t ngx_create_signal_events(ngx_cycle_t *cycle);
ngx_uint_t live;
HANDLE events[MAXIMUM_WAIT_OBJECTS];
- ngx_process_init(cycle);
-
ngx_sprintf((u_char *) ngx_master_process_event_name,
"ngx_master_%s%Z", ngx_unique);
}
-static void
-ngx_process_init(ngx_cycle_t *cycle)
-{
- ngx_core_conf_t *ccf;
-
- ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx_core_module);
-
- if (ngx_init_threads(ngx_threads_n, ccf->thread_stack_size, cycle)
- != NGX_OK)
- {
- /* fatal */
- exit(2);
- }
-}
-
-
static void
ngx_console_init(ngx_cycle_t *cycle)
{
{
ngx_tid_t tid;
- ngx_process_init(cycle);
-
ngx_console_init(cycle);
if (ngx_create_signal_events(cycle) != NGX_OK) {
#include <ngx_core.h>
-ngx_int_t ngx_threads_n;
-
-
-static size_t stack_size;
-
-
ngx_err_t
ngx_create_thread(ngx_tid_t *tid,
ngx_thread_value_t (__stdcall *func)(void *arg), void *arg, ngx_log_t *log)
u_long id;
ngx_err_t err;
- *tid = CreateThread(NULL, stack_size, func, arg, 0, &id);
+ *tid = CreateThread(NULL, 0, func, arg, 0, &id);
if (*tid != NULL) {
ngx_log_error(NGX_LOG_NOTICE, log, 0,
ngx_log_error(NGX_LOG_ALERT, log, err, "CreateThread() failed");
return err;
}
-
-
-ngx_int_t
-ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle)
-{
- stack_size = size;
-
- return NGX_OK;
-}
ngx_err_t ngx_create_thread(ngx_tid_t *tid,
ngx_thread_value_t (__stdcall *func)(void *arg), void *arg, ngx_log_t *log);
-ngx_int_t ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle);
#define ngx_log_tid GetCurrentThreadId()
#define NGX_TID_T_FMT "%ud"
-extern ngx_int_t ngx_threads_n;
-
-
#endif /* _NGX_THREAD_H_INCLUDED_ */