diff options
Diffstat (limited to '')
-rw-r--r-- | src/nxt_main_process.c | 33 |
1 files changed, 14 insertions, 19 deletions
diff --git a/src/nxt_main_process.c b/src/nxt_main_process.c index 2e91628b..7f39cc1d 100644 --- a/src/nxt_main_process.c +++ b/src/nxt_main_process.c @@ -231,20 +231,15 @@ failed: } -static nxt_port_handler_t nxt_main_process_port_handlers[] = { - NULL, /* NXT_PORT_MSG_QUIT */ - NULL, /* NXT_PORT_MSG_NEW_PORT */ - NULL, /* NXT_PORT_MSG_CHANGE_FILE */ - NULL, /* NXT_PORT_MSG_MMAP */ - nxt_port_main_data_handler, - NULL, /* NXT_PORT_MSG_REMOVE_PID */ - nxt_port_ready_handler, - nxt_port_main_start_worker_handler, - nxt_main_port_socket_handler, - nxt_main_port_modules_handler, - nxt_main_port_conf_store_handler, - nxt_port_rpc_handler, - nxt_port_rpc_handler, +static nxt_port_handlers_t nxt_main_process_port_handlers = { + .data = nxt_port_main_data_handler, + .process_ready = nxt_port_process_ready_handler, + .start_worker = nxt_port_main_start_worker_handler, + .socket = nxt_main_port_socket_handler, + .modules = nxt_main_port_modules_handler, + .conf_store = nxt_main_port_conf_store_handler, + .rpc_ready = nxt_port_rpc_handler, + .rpc_error = nxt_port_rpc_handler, }; @@ -278,7 +273,7 @@ nxt_main_process_port_create(nxt_task_t *task, nxt_runtime_t *rt) * A main process port. A write port is not closed * since it should be inherited by worker processes. */ - nxt_port_enable(task, port, nxt_main_process_port_handlers); + nxt_port_enable(task, port, &nxt_main_process_port_handlers); process->ready = 1; @@ -363,7 +358,7 @@ nxt_main_start_controller_process(nxt_task_t *task, nxt_runtime_t *rt) init->start = nxt_controller_start; init->name = "controller"; init->user_cred = &rt->user_cred; - init->port_handlers = nxt_controller_process_port_handlers; + init->port_handlers = &nxt_controller_process_port_handlers; init->signals = nxt_worker_process_signals; init->type = NXT_PROCESS_CONTROLLER; init->data = &conf; @@ -393,7 +388,7 @@ nxt_main_start_discovery_process(nxt_task_t *task, nxt_runtime_t *rt) init->start = nxt_discovery_start; init->name = "discovery"; init->user_cred = &rt->user_cred; - init->port_handlers = nxt_discovery_process_port_handlers; + init->port_handlers = &nxt_discovery_process_port_handlers; init->signals = nxt_worker_process_signals; init->type = NXT_PROCESS_DISCOVERY; init->data = rt; @@ -417,7 +412,7 @@ nxt_main_start_router_process(nxt_task_t *task, nxt_runtime_t *rt) init->start = nxt_router_start; init->name = "router"; init->user_cred = &rt->user_cred; - init->port_handlers = nxt_router_process_port_handlers; + init->port_handlers = &nxt_router_process_port_handlers; init->signals = nxt_worker_process_signals; init->type = NXT_PROCESS_ROUTER; init->data = rt; @@ -479,7 +474,7 @@ nxt_main_start_worker_process(nxt_task_t *task, nxt_runtime_t *rt, init->start = nxt_app_start; init->name = (char *) title; - init->port_handlers = nxt_app_process_port_handlers; + init->port_handlers = &nxt_app_process_port_handlers; init->signals = nxt_worker_process_signals; init->type = NXT_PROCESS_WORKER; init->data = app_conf; |