Initial version.

1 files changed, 213 insertions, 0 deletions

diff --git a/src/nxt_worker_process.c b/src/nxt_worker_process.c
new file mode 100644
index 00000000..6f64b8f9
--- /dev/null
+++ b/src/nxt_worker_process.c
@@ -0,0 +1,213 @@
+
+/*
+ * Copyright (C) Igor Sysoev
+ * Copyright (C) NGINX, Inc.
+ */
+
+#include <nxt_main.h>
+#include <nxt_cycle.h>
+#include <nxt_process_chan.h>
+#include <nxt_master_process.h>
+
+
+static void nxt_worker_process_quit(nxt_thread_t *thr);
+static void nxt_worker_process_quit_handler(nxt_thread_t *thr,
+    nxt_chan_recv_msg_t *msg);
+static void nxt_worker_process_signal_handler(nxt_thread_t *thr, void *obj,
+    void *data);
+static void nxt_worker_process_sigterm_handler(nxt_thread_t *thr, void *obj,
+    void *data);
+static void nxt_worker_process_sigquit_handler(nxt_thread_t *thr, void *obj,
+    void *data);
+
+
+static nxt_process_chan_handler_t  nxt_worker_process_chan_handlers[] = {
+    nxt_worker_process_quit_handler,
+    nxt_process_chan_new_handler,
+    nxt_process_chan_change_log_file_handler,
+    nxt_process_chan_data_handler,
+};
+
+
+static const nxt_event_sig_t  nxt_worker_process_signals[] = {
+    nxt_event_signal(SIGHUP,  nxt_worker_process_signal_handler),
+    nxt_event_signal(SIGINT,  nxt_worker_process_sigterm_handler),
+    nxt_event_signal(SIGQUIT, nxt_worker_process_sigterm_handler),
+    nxt_event_signal(SIGTERM, nxt_worker_process_sigquit_handler),
+    nxt_event_signal(SIGCHLD, nxt_worker_process_signal_handler),
+    nxt_event_signal(SIGUSR1, nxt_worker_process_signal_handler),
+    nxt_event_signal(SIGUSR1, nxt_worker_process_signal_handler),
+    nxt_event_signal_end,
+};
+
+
+void
+nxt_worker_process_start(void *data)
+{
+    nxt_int_t                  n;
+    nxt_cycle_t                *cycle;
+    nxt_thread_t               *thr;
+    nxt_process_chan_t         *proc;
+    const nxt_event_set_ops_t  *event_set;
+
+    cycle = data;
+
+    nxt_thread_init_data(nxt_thread_cycle_data);
+    nxt_thread_cycle_set(cycle);
+
+    thr = nxt_thread();
+
+    nxt_log_error(NXT_LOG_INFO, thr->log, "worker process");
+
+    nxt_process_title("nginman: worker process");
+
+    cycle->type = NXT_PROCESS_WORKER;
+
+    nxt_random_init(&nxt_random_data);
+
+    if (getuid() == 0) {
+        /* Super-user. */
+
+        n = nxt_user_cred_set(&cycle->user_cred);
+        if (n != NXT_OK) {
+            goto fail;
+        }
+    }
+
+    /* Update inherited master process event engine and signals processing. */
+    thr->engine->signals->sigev = nxt_worker_process_signals;
+
+    event_set = nxt_service_get(cycle->services, "engine", cycle->engine);
+    if (event_set == NULL) {
+        goto fail;
+    }
+
+    if (nxt_event_engine_change(thr, event_set, cycle->batch) != NXT_OK) {
+        goto fail;
+    }
+
+#if 0
+    if (nxt_cycle_listen_sockets_enable(thr, cycle) != NXT_OK) {
+        goto fail;
+    }
+#endif
+
+    proc = cycle->processes->elts;
+
+    /* A master process chan. */
+    nxt_chan_read_close(proc[0].chan);
+    nxt_chan_write_enable(thr, proc[0].chan);
+
+    /* A worker process chan. */
+    nxt_process_chan_create(thr, &proc[cycle->current_process],
+                            nxt_worker_process_chan_handlers);
+
+#if (NXT_THREADS)
+    {
+        nxt_int_t  ret;
+
+        ret = nxt_cycle_thread_pool_create(thr, cycle, cycle->auxiliary_threads,
+                                           60000 * 1000000LL);
+
+        if (nxt_slow_path(ret != NXT_OK)) {
+            goto fail;
+        }
+    }
+
+    nxt_app_start(cycle);
+#endif
+
+    return;
+
+fail:
+
+    exit(1);
+    nxt_unreachable();
+}
+
+
+static void
+nxt_worker_process_quit(nxt_thread_t *thr)
+{
+    nxt_uint_t               n;
+    nxt_cycle_t              *cycle;
+    nxt_queue_t              *listen;
+    nxt_queue_link_t         *link, *next;
+    nxt_listen_socket_t      *ls;
+    nxt_event_conn_listen_t  *cls;
+
+    cycle = nxt_thread_cycle();
+
+    nxt_log_debug(thr->log, "close listen connections");
+
+    listen = &thr->engine->listen_connections;
+
+    for (link = nxt_queue_first(listen);
+         link != nxt_queue_tail(listen);
+         link = next)
+    {
+        next = nxt_queue_next(link);
+        cls = nxt_queue_link_data(link, nxt_event_conn_listen_t, link);
+        nxt_queue_remove(link);
+
+        nxt_event_fd_close(thr->engine, &cls->socket);
+    }
+
+    if (cycle->listen_sockets != NULL) {
+
+        ls = cycle->listen_sockets->elts;
+        n = cycle->listen_sockets->nelts;
+
+        while (n != 0) {
+            nxt_socket_close(ls->socket);
+            ls->socket = -1;
+
+            ls++;
+            n--;
+        }
+
+        cycle->listen_sockets->nelts = 0;
+    }
+
+    nxt_cycle_quit(thr, cycle);
+}
+
+
+static void
+nxt_worker_process_signal_handler(nxt_thread_t *thr, void *obj, void *data)
+{
+    nxt_log_error(NXT_LOG_INFO, thr->log,
+                  "signal signo:%d (%s) recevied, ignored",
+                  (int) (uintptr_t) obj, data);
+}
+
+
+static void
+nxt_worker_process_quit_handler(nxt_thread_t *thr, nxt_chan_recv_msg_t *msg)
+{
+    nxt_worker_process_quit(thr);
+}
+
+
+static void
+nxt_worker_process_sigterm_handler(nxt_thread_t *thr, void *obj, void *data)
+{
+    nxt_log_debug(thr->log, "sigterm handler signo:%d (%s)",
+                  (int) (uintptr_t) obj, data);
+
+    /* A fast exit. */
+
+    nxt_cycle_quit(thr, NULL);
+}
+
+
+static void
+nxt_worker_process_sigquit_handler(nxt_thread_t *thr, void *obj, void *data)
+{
+    nxt_log_debug(thr->log, "sigquit handler signo:%d (%s)",
+                  (int) (uintptr_t) obj, data);
+
+    /* A graceful exit. */
+
+    nxt_worker_process_quit(thr);
+}