summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_worker_process.c
diff options
context:
space:
mode:
authorValentin Bartenev <vbart@nginx.com>2017-08-30 03:10:13 +0300
committerValentin Bartenev <vbart@nginx.com>2017-08-30 03:10:13 +0300
commitf528cb393a137b5e9c34adb311d9addb3c5e1d78 (patch)
treefae9c1949cd76c15d481ea560d1d068b3a42cad2 /src/nxt_worker_process.c
parente21dbf89e6d5569d1c9a93f41a21bcc240c64cf3 (diff)
downloadunit-f528cb393a137b5e9c34adb311d9addb3c5e1d78.tar.gz
unit-f528cb393a137b5e9c34adb311d9addb3c5e1d78.tar.bz2
Controller: waiting for router before start to accept connections.
Previously, reconfiguration might fail right after the daemon start if the router process wasn't ready yet.
Diffstat (limited to 'src/nxt_worker_process.c')
-rw-r--r--src/nxt_worker_process.c20
1 files changed, 1 insertions, 19 deletions
diff --git a/src/nxt_worker_process.c b/src/nxt_worker_process.c
index 0d7ae796..6804f8ab 100644
--- a/src/nxt_worker_process.c
+++ b/src/nxt_worker_process.c
@@ -12,8 +12,6 @@
static void nxt_worker_process_quit(nxt_task_t *task);
-static void nxt_worker_process_quit_handler(nxt_task_t *task,
- nxt_port_recv_msg_t *msg);
static void nxt_worker_process_signal_handler(nxt_task_t *task, void *obj,
void *data);
static void nxt_worker_process_sigterm_handler(nxt_task_t *task, void *obj,
@@ -22,22 +20,6 @@ static void nxt_worker_process_sigquit_handler(nxt_task_t *task, void *obj,
void *data);
-nxt_port_handler_t nxt_controller_process_port_handlers[] = {
- nxt_worker_process_quit_handler,
- nxt_port_new_port_handler,
- nxt_port_change_log_file_handler,
- nxt_port_mmap_handler,
- nxt_port_data_handler,
- nxt_port_remove_pid_handler,
- NULL, /* NXT_PORT_MSG_READY */
- NULL, /* NXT_PORT_MSG_START_WORKER */
- NULL, /* NXT_PORT_MSG_SOCKET */
- NULL, /* NXT_PORT_MSG_MODULES */
- nxt_port_rpc_handler,
- nxt_port_rpc_handler,
-};
-
-
nxt_port_handler_t nxt_worker_process_port_handlers[] = {
nxt_worker_process_quit_handler,
nxt_port_new_port_handler,
@@ -169,7 +151,7 @@ nxt_worker_process_signal_handler(nxt_task_t *task, void *obj, void *data)
}
-static void
+void
nxt_worker_process_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg)
{
nxt_worker_process_quit(task);