nxt_controller.c (317:94010c8bd7bc) nxt_controller.c (320:d385755599d6)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 85 unchanged lines hidden (view full) ---

94
95
96static const nxt_event_conn_state_t nxt_controller_conn_read_state;
97static const nxt_event_conn_state_t nxt_controller_conn_body_read_state;
98static const nxt_event_conn_state_t nxt_controller_conn_write_state;
99static const nxt_event_conn_state_t nxt_controller_conn_close_state;
100
101
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 85 unchanged lines hidden (view full) ---

94
95
96static const nxt_event_conn_state_t nxt_controller_conn_read_state;
97static const nxt_event_conn_state_t nxt_controller_conn_body_read_state;
98static const nxt_event_conn_state_t nxt_controller_conn_write_state;
99static const nxt_event_conn_state_t nxt_controller_conn_close_state;
100
101
102nxt_port_handler_t nxt_controller_process_port_handlers[] = {
103 nxt_worker_process_quit_handler,
104 nxt_controller_process_new_port_handler,
105 nxt_port_change_log_file_handler,
106 nxt_port_mmap_handler,
107 nxt_port_data_handler,
108 nxt_port_remove_pid_handler,
109 NULL, /* NXT_PORT_MSG_READY */
110 NULL, /* NXT_PORT_MSG_START_WORKER */
111 NULL, /* NXT_PORT_MSG_SOCKET */
112 NULL, /* NXT_PORT_MSG_MODULES */
113 NULL, /* NXT_PORT_MSG_CONF_STORE */
114 nxt_port_rpc_handler,
115 nxt_port_rpc_handler,
102nxt_port_handlers_t nxt_controller_process_port_handlers = {
103 .quit = nxt_worker_process_quit_handler,
104 .new_port = nxt_controller_process_new_port_handler,
105 .change_file = nxt_port_change_log_file_handler,
106 .mmap = nxt_port_mmap_handler,
107 .data = nxt_port_data_handler,
108 .remove_pid = nxt_port_remove_pid_handler,
109 .rpc_ready = nxt_port_rpc_handler,
110 .rpc_error = nxt_port_rpc_handler,
116};
117
118
119nxt_int_t
120nxt_controller_start(nxt_task_t *task, void *data)
121{
122 nxt_mp_t *mp;
123 nxt_str_t *json;

--- 1109 unchanged lines hidden --- 		111};
112
113
114nxt_int_t
115nxt_controller_start(nxt_task_t *task, void *data)
116{
117 nxt_mp_t *mp;
118 nxt_str_t *json;

--- 1109 unchanged lines hidden ---