| /unit/src/ |
| 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
2632 nxt_port_msg_t msg; in nxt_unit_mmap_buf_send() member
3620 nxt_port_msg_t msg; in nxt_unit_send_oosm() local
3903 nxt_port_msg_t msg; in nxt_unit_send_mmap() local
4091 nxt_port_msg_t msg; in nxt_unit_awake_ctx() local
4316 nxt_port_msg_t msg; in nxt_unit_get_mmap() member
4388 nxt_port_msg_t msg; in nxt_unit_send_shm_ack() local
5873 nxt_port_msg_t msg; in nxt_unit_get_port() member
5908 nxt_port_msg_t msg; in nxt_unit_port_send() local
[all …]
|
| H A D | nxt_router_access_log.c | 250 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready()
268 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error()
329 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler()
413 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready()
437 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_router.c | 650 nxt_router_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_new_port_handler()
736 nxt_router_conf_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_conf_data_handler()
926 nxt_router_status_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_status_handler()
1019 nxt_router_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_remove_pid_handler()
2786 nxt_router_tls_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_tls_rpc_handler()
4029 nxt_port_recv_msg_t *msg, nxt_request_rpc_data_t *req_rpc_data) in nxt_router_req_headers_ack_handler()
4213 nxt_router_app_port_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_ready()
4332 nxt_router_app_port_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_app_port_error()
5047 } msg; in nxt_router_app_prepare_request() local
5507 nxt_router_oosm_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_oosm_handler()
[all …]
|
| H A D | nxt_main_process.c | 320 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
328 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
354 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
540 nxt_main_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_created_handler()
603 nxt_main_process_whoami_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_whoami_handler()
1014 nxt_main_port_socket_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_socket_handler()
1265 nxt_main_port_modules_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_modules_handler()
1441 nxt_main_port_conf_store_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_conf_store_handler()
1557 nxt_main_port_access_log_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_access_log_handler()
|
| H A D | nxt_openssl.c | 1632 u_char msg[NXT_MAX_ERROR_STR]; local
1740 u_char msg[NXT_MAX_ERROR_STR]; local
|
| H A D | nxt_errno.c | 38 char *msg; in nxt_strerror_start() local
142 nxt_str_t *msg; in nxt_runtime_strerror() local
|
| H A D | nxt_controller.c | 386 nxt_port_recv_msg_t *msg) in nxt_controller_process_new_port_handler()
444 nxt_port_recv_msg_t *msg) in nxt_controller_router_ready_handler()
462 nxt_controller_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_controller_remove_pid_handler()
512 nxt_controller_conf_init_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_conf_init_handler()
1558 nxt_controller_status_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_status_handler()
1805 nxt_controller_process_cert_save(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_process_cert_save()
1883 nxt_controller_conf_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_conf_handler()
2041 nxt_controller_app_restart_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_controller_app_restart_handler()
|
| H A D | nxt_application.c | 499 nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_discovery_quit()
595 nxt_proto_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_start_process_handler()
672 nxt_proto_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_quit_handler()
703 nxt_proto_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_proto_process_created_handler()
|
| 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 | 218 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->cmsg_pid) argument
219 #define nxt_recv_msg_cmsg_pid_ref(msg) (&(msg)->cmsg_pid) argument
221 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid) argument
222 #define nxt_recv_msg_cmsg_pid_ref(msg) (NULL) argument
|
| H A D | nxt_process.c | 556 nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_ok()
601 nxt_process_whoami_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_whoami_error()
651 nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, void *data) in nxt_process_created_ok()
691 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error()
865 const char *msg; in nxt_process_daemon() 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_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_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_log_moderation.h | 14 const char *msg; member
|
| H A D | nxt_gnutls.c | 686 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_conn_log_error() local
734 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_log_error() local
|
| H A D | nxt_cert.c | 1124 nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_get_handler()
1214 nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_cert_store_delete_handler()
|
| H A D | nxt_socket_msg.h | 130 struct msghdr msg; in nxt_socket_msg_oob_get_fds() local
161 struct msghdr msg; in nxt_socket_msg_oob_get() local
|
| H A D | nxt_socket_msg.c | 14 struct msghdr msg; in nxt_sendmsg() local
41 struct msghdr msg; in nxt_recvmsg() local
|
| /unit/src/python/ |
| H A D | nxt_python_asgi.c | 1335 PyObject *msg; in nxt_py_asgi_new_msg() 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 | 1190 VALUE err, ary, eclass, msg; in nxt_ruby_exception_log() local
|
| /unit/src/java/ |
| H A D | nxt_jni_Request.c | 698 nxt_java_Request_log(JNIEnv *env, jclass cls, jlong req_info_ptr, jstring msg, in nxt_java_Request_log()
718 nxt_java_Request_trace(JNIEnv *env, jclass cls, jlong req_info_ptr, jstring msg, in nxt_java_Request_trace()
|
| /unit/src/java/nginx/unit/websocket/ |
| H A D | WsRemoteEndpointImplBase.java | 543 String msg = obj.toString(); in sendObject() local
548 ByteBuffer msg = ByteBuffer.wrap((byte[]) obj); in sendObject() local
554 String msg = ((Encoder.Text) encoder).encode(obj); in sendObject() local
561 ByteBuffer msg = ((Encoder.Binary) encoder).encode(obj); in sendObject() local
598 String msg = obj.toString(); in sendObjectByCompletion() local
603 ByteBuffer msg = ByteBuffer.wrap((byte[]) obj); in sendObjectByCompletion() local
610 String msg = ((Encoder.Text) encoder).encode(obj); in sendObjectByCompletion() local
618 ByteBuffer msg = ((Encoder.Binary) encoder).encode(obj); in sendObjectByCompletion() local
|
| /unit/go/ |
| H A D | nxt_cgo_lib.c | 85 nxt_cgo_warn(const char *msg, uint32_t msg_len) in nxt_cgo_warn()
92 nxt_cgo_alert(const char *msg, uint32_t msg_len) in nxt_cgo_alert()
|