/unit/src/ |
H A D | nxt_http_websocket.c | 101 res = nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_client() 147 (void) nxt_port_socket_write(task, req_rpc_data->app_port, in nxt_http_websocket_error_handler()
|
H A D | nxt_main_process.c | 612 nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_main_start_process_handler() 653 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_main_process_created_handler() 663 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_READY_LAST, in nxt_main_process_created_handler() 765 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_READY_LAST, -1, in nxt_main_process_whoami_handler() 882 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_ACCESS_LOG, in nxt_main_process_sigusr1_handler() 1038 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, in nxt_main_process_sigchld_handler() 1173 nxt_port_socket_write(task, port, type, ls.socket, msg->port_msg.stream, in nxt_main_port_socket_handler() 1439 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, -1, in nxt_main_port_modules_handler() 1727 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_main_port_access_log_handler()
|
H A D | nxt_cert.c | 1037 ret = nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_READY_LAST, -1, 1054 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, -1, 1092 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_CERT_GET, -1, in nxt_cert_store_get() 1186 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_cert_store_get_handler() 1207 (void) nxt_port_socket_write(task, main_port, NXT_PORT_MSG_CERT_DELETE, in nxt_cert_store_delete()
|
H A D | nxt_script.c | 509 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_SCRIPT_GET, -1, in nxt_script_store_get() 602 (void) nxt_port_socket_write(task, port, type, file.fd, in nxt_script_store_get_handler() 623 (void) nxt_port_socket_write(task, main_port, in nxt_script_store_delete()
|
H A D | nxt_router_access_log.c | 258 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_open() 406 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_reopen_handler()
|
H A D | nxt_router.c | 387 nxt_port_socket_write(task, controller_port, NXT_PORT_MSG_PROCESS_READY, in nxt_router_greet_controller() 830 nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, -1, in nxt_router_conf_data_handler() 942 nxt_port_socket_write(task, reply_port, reply, -1, msg->port_msg.stream, in nxt_router_app_restart_handler() 1021 nxt_port_socket_write(task, port, type, -1, msg->port_msg.stream, 0, b); in nxt_router_status_handler() 2830 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_SOCKET, -1, in nxt_router_listen_socket_rpc_create() 4348 res = nxt_port_socket_write(task, app_port, NXT_PORT_MSG_REQ_BODY, in nxt_router_req_headers_ack_handler() 4461 nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, -1, 0, 0, in nxt_router_app_port_ready() 5046 nxt_port_socket_write(task, proto_port, NXT_PORT_MSG_QUIT, in nxt_router_free_app() 5311 (void) nxt_port_socket_write(task, port, in nxt_router_app_prepare_request() 5803 nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_router_get_mmap_handler() [all …]
|
H A D | nxt_process.c | 796 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_WHOAMI, in nxt_process_whoami() 844 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_PROCESS_CREATED, in nxt_process_whoami_ok() 891 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_PROCESS_CREATED, in nxt_process_send_created() 1066 ret = nxt_port_socket_write(task, process->parent_port, in nxt_process_send_ready()
|
H A D | nxt_port.c | 400 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_CHANGE_FILE, in nxt_port_change_log_file() 494 nxt_port_socket_write(task, port, NXT_PORT_MSG_REMOVE_PID, -1, in nxt_port_remove_notify_others()
|
H A D | nxt_application.c | 193 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_MODULES, -1, in nxt_discovery_start() 665 nxt_port_socket_write(task, port, NXT_PORT_MSG_RPC_ERROR, in nxt_proto_start_process_handler() 695 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, in nxt_proto_quit_children()
|
H A D | nxt_port.h | 341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() function
|
H A D | nxt_controller.c | 642 rc = nxt_port_socket_write(task, router_port, in nxt_controller_conf_send() 1598 rc = nxt_port_socket_write(task, router_port, NXT_PORT_MSG_STATUS, in nxt_controller_process_status() 2345 rc = nxt_port_socket_write(task, router_port, NXT_PORT_MSG_APP_RESTART, in nxt_controller_process_control() 2465 (void) nxt_port_socket_write(task, main_port, in nxt_controller_conf_store()
|
H A D | nxt_runtime.c | 511 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, -1, in nxt_runtime_stop_app_processes() 533 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_QUIT, -1, 0, in nxt_runtime_stop_all_processes()
|
H A D | nxt_port_memory.c | 879 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_SHM_ACK, in nxt_port_broadcast_shm_ack()
|