Home
last modified time | relevance | path

Searched defs:msg (Results 1 – 25 of 48) sorted by relevance

12

/unit/src/
H A Dnxt_port.c173 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 Dnxt_regex.h25 u_char msg[ERR_BUF_SIZE]; member
27 const char *msg; member
H A Dnxt_socket_msg.c14 struct msghdr msg; in nxt_sendmsg() local
41 struct msghdr msg; in nxt_recvmsg() local
H A Dnxt_port_socket.c167 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 Dnxt_errno.c38 char *msg; in nxt_strerror_start() local
142 nxt_str_t *msg; in nxt_runtime_strerror() local
H A Dnxt_router_access_log.c247 nxt_router_access_log_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_ready()
265 nxt_router_access_log_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_error()
326 nxt_router_access_log_reopen_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_router_access_log_reopen_handler()
410 nxt_router_access_log_reopen_ready(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_router_access_log_reopen_ready()
434 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 Dnxt_main_process.c332 nxt_main_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_data_handler()
340 nxt_main_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_new_port_handler()
366 nxt_main_start_process_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_start_process_handler()
552 nxt_main_process_created_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_created_handler()
615 nxt_main_process_whoami_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_process_whoami_handler()
1026 nxt_main_port_socket_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_socket_handler()
1275 nxt_main_port_modules_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_modules_handler()
1451 nxt_main_port_conf_store_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_main_port_conf_store_handler()
1567 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 Dnxt_log_moderation.c76 nxt_bool_t msg; in nxt_log_moderate_timer_handler() local
H A Dnxt_socket_msg.h130 struct msghdr msg; in nxt_socket_msg_oob_get_fds() local
161 struct msghdr msg; in nxt_socket_msg_oob_get() local
H A Dnxt_signal_handlers.c40 nxt_signal_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg) in nxt_signal_quit_handler()
H A Dnxt_process.c556 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 Dnxt_log.c74 u_char msg[NXT_MAX_ERROR_STR]; in nxt_log_handler() local
H A Dnxt_port_rpc.c307 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 Dnxt_app_log.c29 u_char msg[NXT_MAX_ERROR_STR]; in nxt_log_time_handler() local
H A Dnxt_polarssl.c105 u_char *p, *end, msg[NXT_MAX_ERROR_STR]; in nxt_polarssl_log_error() local
H A Dnxt_log_moderation.h14 const char *msg; member
/unit/src/java/
H A Dnxt_jni.c86 nxt_java_throw_NoSuchElementException(JNIEnv *env, const char *msg) in nxt_java_throw_NoSuchElementException()
93 nxt_java_throw_IOException(JNIEnv *env, const char *msg) in nxt_java_throw_IOException()
100 nxt_java_throw_IllegalStateException(JNIEnv *env, const char *msg) in nxt_java_throw_IllegalStateException()
H A Dnxt_jni_Context.c126 nxt_java_Context_log(JNIEnv *env, jclass cls, jlong ctx_ptr, jstring msg, in nxt_java_Context_log()
146 nxt_java_Context_trace(JNIEnv *env, jclass cls, jlong ctx_ptr, jstring msg, in nxt_java_Context_trace()
/unit/go/
H A Dnxt_cgo_lib.c85 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()
/unit/src/python/
H A Dnxt_python_asgi_http.c115 PyObject *msg, *future; in nxt_py_asgi_http_receive() local
167 PyObject *msg, *body; in nxt_py_asgi_http_read_msg() local
470 PyObject *msg, *future; in nxt_py_asgi_http_emit_disconnect() local
497 PyObject *msg) in nxt_py_asgi_http_set_result()
527 PyObject *msg, *future; in nxt_py_asgi_http_data_handler() local
H A Dnxt_python_asgi_websocket.c139 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
H A Dnxt_python_asgi_lifespan.c306 PyObject *msg, *future, *res; in nxt_py_asgi_lifespan_target_shutdown() local
363 PyObject *msg, *future; in nxt_py_asgi_lifespan_receive() local
407 PyObject *type, *msg; in nxt_py_asgi_lifespan_send() local
/unit/test/java/websockets_mirror/
H A Dapp.java19 public void echoTextMessage(Session session, String msg) { in echoTextMessage()
/unit/src/java/nginx/unit/websocket/
H A DWsRemoteEndpointImplBase.java543 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/src/java/nginx/unit/
H A DResponse.java371 public void sendError(int sc, String msg) throws IOException in sendError()
816 private void log(String msg) in log()
822 public static native void log(long req_info_ptr, byte[] msg); in log()
825 private void trace(String msg) in trace()
831 public static native void trace(long req_info_ptr, byte[] msg); in trace()

12