/unit/src/ |
H A D | nxt_polarssl.c | 105 u_char *p, *end, msg[NXT_MAX_ERROR_STR]; in nxt_polarssl_log_error() local
|
H A D | nxt_port.c | 173 nxt_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_handler() 195 nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_quit_handler() 233 nxt_port_msg_new_port_t *msg; in nxt_port_send_port() local 260 nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_new_port_handler() 310 nxt_port_process_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_process_ready_handler() 345 nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_handler() 408 nxt_port_change_log_file_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_change_log_file_handler() 438 nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_data_handler() 502 nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_remove_pid_handler() 518 nxt_port_remove_pid(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_port_remove_pid() [all …]
|
H A D | nxt_port.h | 227 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->cmsg_pid) argument 228 #define nxt_recv_msg_cmsg_pid_ref(msg) (&(msg)->cmsg_pid) argument 230 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid) argument 231 #define nxt_recv_msg_cmsg_pid_ref(msg) (NULL) argument
|
H A D | nxt_port_memory.c | 712 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb, void *mmsg_buf) in nxt_port_mmap_write() 765 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_mmap_read()
|
H A D | nxt_port_rpc.c | 307 nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_port_rpc_handler() 376 nxt_port_recv_msg_t msg; in nxt_port_rpc_remove_peer() local 496 nxt_port_recv_msg_t msg; in nxt_port_rpc_close() local
|
H A D | nxt_port_socket.c | 167 nxt_port_send_msg_t msg; in nxt_port_socket_write2() local 304 nxt_port_send_msg_t *msg) in nxt_port_msg_chk_insert() 337 nxt_port_send_msg_t *msg; in nxt_port_msg_alloc() local 378 nxt_port_send_msg_t *msg; in nxt_port_write_handler() local 572 nxt_port_send_msg_t *msg; in nxt_port_msg_first() local 592 nxt_port_msg_close_fd(nxt_port_send_msg_t *msg) in nxt_port_msg_close_fd() 738 nxt_port_recv_msg_t msg; in nxt_port_read_handler() local 821 nxt_port_recv_msg_t msg, *smsg; in nxt_port_queue_read_handler() local 1077 nxt_port_recv_msg_t *msg) in nxt_port_frag_start() 1172 nxt_port_recv_msg_t *msg) in nxt_port_read_msg_process() [all …]
|
H A D | nxt_process.c | 812 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok() 857 nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_error() 907 nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_created_ok() 947 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error() 1121 const char *msg; in nxt_process_daemon() local
|
H A D | nxt_regex.h | 25 u_char msg[ERR_BUF_SIZE]; member 27 const char *msg; member
|
H A D | nxt_router.c | 672 nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_new_port_handler() 758 nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_conf_data_handler() 948 nxt_router_status_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_status_handler() 1041 nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_remove_pid_handler() 2949 nxt_router_tls_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_tls_rpc_handler() 4229 nxt_port_recv_msg_t *msg, nxt_request_rpc_data_t *req_rpc_data) in nxt_router_req_headers_ack_handler() 4413 nxt_router_app_port_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_ready() 4532 nxt_router_app_port_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_error() 5247 } msg; in nxt_router_app_prepare_request() local 5708 nxt_router_oosm_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_oosm_handler() [all …]
|
H A D | nxt_router_access_log.c | 275 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready() 293 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error() 354 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler() 438 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready() 462 nxt_router_access_log_reopen_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_error()
|
H A D | nxt_script.c | 541 nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_get_handler() 630 nxt_script_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_script_store_delete_handler()
|
H A D | nxt_signal_handlers.c | 40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler()
|
H A D | nxt_socket_msg.c | 14 struct msghdr msg; in nxt_sendmsg() local 41 struct msghdr msg; in nxt_recvmsg() local
|
H A D | nxt_socket_msg.h | 144 struct msghdr msg; in nxt_socket_msg_oob_get_fds() local 175 struct msghdr msg; in nxt_socket_msg_oob_get() local
|
H A D | nxt_unit.c | 946 nxt_port_msg_t msg; in nxt_unit_ready() local 1594 nxt_port_msg_t msg; in nxt_unit_send_req_headers_ack() local 2633 nxt_port_msg_t msg; in nxt_unit_mmap_buf_send() member 3621 nxt_port_msg_t msg; in nxt_unit_send_oosm() local 3904 nxt_port_msg_t msg; in nxt_unit_send_mmap() local 4092 nxt_port_msg_t msg; in nxt_unit_awake_ctx() local 4317 nxt_port_msg_t msg; in nxt_unit_get_mmap() member 4389 nxt_port_msg_t msg; in nxt_unit_send_shm_ack() local 5874 nxt_port_msg_t msg; in nxt_unit_get_port() member 5909 nxt_port_msg_t msg; in nxt_unit_port_send() local [all …]
|
/unit/src/python/ |
H A D | nxt_python_asgi.c | 1403 PyObject *msg; in nxt_py_asgi_new_msg() local
|
H A D | nxt_python_asgi_http.c | 115 PyObject *msg, *future; in nxt_py_asgi_http_receive() local 167 PyObject *msg, *body; in nxt_py_asgi_http_read_msg() local 477 PyObject *msg, *future; in nxt_py_asgi_http_emit_disconnect() local 504 PyObject *msg) in nxt_py_asgi_http_set_result() 534 PyObject *msg, *future; in nxt_py_asgi_http_data_handler() local
|
H A D | nxt_python_asgi_lifespan.c | 348 PyObject *msg, *future, *res; in nxt_py_asgi_lifespan_target_shutdown() local 405 PyObject *msg, *future; in nxt_py_asgi_lifespan_receive() local 449 PyObject *type, *msg; in nxt_py_asgi_lifespan_send() local
|
H A D | nxt_python_asgi_websocket.c | 139 PyObject *future, *msg; in nxt_py_asgi_websocket_receive() local 494 PyObject *msg, *exc; in nxt_py_asgi_websocket_handler() local 628 nxt_py_asgi_websocket_receive_done(nxt_py_asgi_websocket_t *ws, PyObject *msg) in nxt_py_asgi_websocket_receive_done() 737 PyObject *msg, *data, *type, *data_key; in nxt_py_asgi_websocket_pop_msg() local 976 PyObject *msg, *exc; in nxt_py_asgi_websocket_close_handler() local 1009 PyObject *msg, *code; in nxt_py_asgi_websocket_disconnect_msg() local
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 1261 VALUE err, ary, eclass, msg; in nxt_ruby_exception_log() local
|
/unit/src/test/ |
H A D | nxt_clone_test.c | 394 u_char msg[NXT_MAX_ERROR_STR]; in nxt_clone_test_log_handler() local
|
/unit/test/java/websockets_mirror/ |
H A D | app.java | 19 public void echoTextMessage(Session session, String msg) { in echoTextMessage()
|