Home
last modified time | relevance | path

Searched refs:nxt_port_socket_write (Results 1 – 13 of 13) sorted by relevance

/unit/src/
H A Dnxt_http_websocket.c101 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 Dnxt_main_process.c612 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 Dnxt_cert.c1037 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 Dnxt_script.c509 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 Dnxt_router_access_log.c258 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 Dnxt_router.c387 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 Dnxt_process.c796 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 Dnxt_port.c400 (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 Dnxt_application.c193 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 Dnxt_port.h341 nxt_port_socket_write(nxt_task_t *task, nxt_port_t *port, in nxt_port_socket_write() function
H A Dnxt_controller.c642 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 Dnxt_runtime.c511 (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 Dnxt_port_memory.c879 (void) nxt_port_socket_write(task, port, NXT_PORT_MSG_SHM_ACK, in nxt_port_broadcast_shm_ack()