Added missing checks if nxt_port_rpc_register_handler() failed.
This closes #97 issue on GitHub. Thanks to 洪志道 (Hong Zhi Dao).
This commit is contained in:
@@ -73,6 +73,10 @@ nxt_discovery_start(nxt_task_t *task, void *data)
|
|||||||
nxt_discovery_quit,
|
nxt_discovery_quit,
|
||||||
main_port->pid, NULL);
|
main_port->pid, NULL);
|
||||||
|
|
||||||
|
if (nxt_slow_path(stream == 0)) {
|
||||||
|
return NXT_ERROR;
|
||||||
|
}
|
||||||
|
|
||||||
ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_MODULES, -1,
|
ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_MODULES, -1,
|
||||||
stream, discovery_port->id, b);
|
stream, discovery_port->id, b);
|
||||||
|
|
||||||
|
|||||||
@@ -335,6 +335,10 @@ nxt_controller_conf_send(nxt_task_t *task, nxt_conf_value_t *conf,
|
|||||||
handler, handler,
|
handler, handler,
|
||||||
router_port->pid, data);
|
router_port->pid, data);
|
||||||
|
|
||||||
|
if (nxt_slow_path(stream == 0)) {
|
||||||
|
return NXT_ERROR;
|
||||||
|
}
|
||||||
|
|
||||||
rc = nxt_port_socket_write(task, router_port, NXT_PORT_MSG_DATA_LAST, -1,
|
rc = nxt_port_socket_write(task, router_port, NXT_PORT_MSG_DATA_LAST, -1,
|
||||||
stream, controller_port->id, b);
|
stream, controller_port->id, b);
|
||||||
|
|
||||||
|
|||||||
@@ -1741,7 +1741,7 @@ nxt_router_listen_socket_rpc_create(nxt_task_t *task,
|
|||||||
nxt_router_listen_socket_ready,
|
nxt_router_listen_socket_ready,
|
||||||
nxt_router_listen_socket_error,
|
nxt_router_listen_socket_error,
|
||||||
main_port->pid, rpc);
|
main_port->pid, rpc);
|
||||||
if (stream == 0) {
|
if (nxt_slow_path(stream == 0)) {
|
||||||
goto fail;
|
goto fail;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user