Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 60) sorted by relevance

123

/unit/src/
H A Dnxt_socket_msg.c14 struct msghdr msg; in nxt_sendmsg() local
16 msg.msg_name = NULL; in nxt_sendmsg()
17 msg.msg_namelen = 0; in nxt_sendmsg()
18 msg.msg_iov = iob; in nxt_sendmsg()
19 msg.msg_iovlen = niob; in nxt_sendmsg()
21 msg.msg_flags = 0; in nxt_sendmsg()
41 struct msghdr msg; in nxt_recvmsg() local
43 msg.msg_name = NULL; in nxt_recvmsg()
44 msg.msg_namelen = 0; in nxt_recvmsg()
45 msg.msg_iov = iob; in nxt_recvmsg()
[all …]
H A Dnxt_port_socket.c176 msg.buf = b; in nxt_port_socket_write2()
177 msg.share = 0; in nxt_port_socket_write2()
316 msg = nxt_port_msg_alloc(msg); in nxt_port_msg_chk_insert()
344 *msg = *m; in nxt_port_msg_alloc()
348 return msg; in nxt_port_msg_alloc()
528 msg = nxt_port_msg_insert_tail(port, msg); in nxt_port_write_handler()
587 return msg; in nxt_port_msg_first()
685 msg = nxt_port_msg_alloc(msg); in nxt_port_msg_insert_tail()
698 return msg; in nxt_port_msg_insert_tail()
1228 if (!msg->port_msg.mmap && msg->buf == b) { in nxt_port_read_msg_process()
[all …]
H A Dnxt_errno.c38 char *msg; in nxt_strerror_start() local
54 msg = strerror((int) nxt_sys_nerr); in nxt_strerror_start()
71 if (msg == NULL) { in nxt_strerror_start()
76 length = nxt_strlen(msg); in nxt_strerror_start()
89 if (nxt_memcmp(msg, "Error ", 6) == 0 in nxt_strerror_start()
113 msg = strerror((int) err); in nxt_strerror_start()
114 length = nxt_strlen(msg); in nxt_strerror_start()
119 p = nxt_cpymem(p, msg, length); in nxt_strerror_start()
142 nxt_str_t *msg; in nxt_runtime_strerror() local
147 msg = &nxt_sys_errlist[n]; in nxt_runtime_strerror()
[all …]
H A Dnxt_port.c180 msg->port->socket.fd, msg->port_msg.type, in nxt_port_handler()
181 msg->fd[0], msg->fd[1]); in nxt_port_handler()
184 handlers[msg->port_msg.type](task, msg); in nxt_port_handler()
190 msg->port->socket.fd, msg->port_msg.type); in nxt_port_handler()
247 msg->id = new_port->id; in nxt_port_send_port()
283 msg->fd[0] = -1; in nxt_port_new_port_handler()
305 msg->u.new_port = port; in nxt_port_new_port_handler()
333 if (msg->fd[0] != -1) { in nxt_port_process_ready_handler()
417 b = msg->buf; in nxt_port_change_log_file_handler()
443 b = msg->buf; in nxt_port_data_handler()
[all …]
H A Dnxt_port_rpc.c318 port = msg->port; in nxt_port_rpc_handler()
389 nxt_memzero(&msg, sizeof(msg)); in nxt_port_rpc_remove_peer()
392 msg.fd[0] = -1; in nxt_port_rpc_remove_peer()
393 msg.fd[1] = -1; in nxt_port_rpc_remove_peer()
394 msg.buf = &buf; in nxt_port_rpc_remove_peer()
395 msg.port = port; in nxt_port_rpc_remove_peer()
504 msg.fd[0] = -1; in nxt_port_rpc_close()
505 msg.fd[1] = -1; in nxt_port_rpc_close()
507 msg.port = port; in nxt_port_rpc_close()
516 msg.size = 0; in nxt_port_rpc_close()
[all …]
H A Dnxt_main_process.c335 nxt_buf_mem_used_size(&msg->buf->mem), msg->buf->mem.pos); in nxt_main_data_handler()
360 msg->fd[1] = -1; in nxt_main_new_port_handler()
412 b = nxt_buf_chk_make_plain(process->mem_pool, msg->buf, msg->size); in nxt_main_start_process_handler()
523 msg->fd[0] = -1; in nxt_main_start_process_handler()
524 msg->fd[1] = -1; in nxt_main_start_process_handler()
544 msg->fd[0] = -1; in nxt_main_start_process_handler()
547 msg->fd[1] = -1; in nxt_main_start_process_handler()
658 msg->fd[0] = -1; in nxt_main_process_whoami_handler()
1050 b = msg->buf; in nxt_main_port_socket_handler()
1310 b = msg->buf; in nxt_main_port_modules_handler()
[all …]
H A Dnxt_polarssl.c105 u_char *p, *end, msg[NXT_MAX_ERROR_STR]; in nxt_polarssl_log_error() local
107 end = msg + NXT_MAX_ERROR_STR; in nxt_polarssl_log_error()
110 p = nxt_vsprintf(msg, end, fmt, args); in nxt_polarssl_log_error()
115 error_strerror(err, (char *) msg, p - msg); in nxt_polarssl_log_error()
117 nxt_log_error(level, log, "%*s)", p - msg, msg); in nxt_polarssl_log_error()
H A Dnxt_socket_msg.h130 struct msghdr msg; in nxt_socket_msg_oob_get_fds() local
133 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get_fds()
134 msg.msg_controllen = oob->size; in nxt_socket_msg_oob_get_fds()
136 for (cmsg = CMSG_FIRSTHDR(&msg); in nxt_socket_msg_oob_get_fds()
138 cmsg = CMSG_NXTHDR(&msg, cmsg)) in nxt_socket_msg_oob_get_fds()
161 struct msghdr msg; in nxt_socket_msg_oob_get() local
172 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get()
173 msg.msg_controllen = oob->size; in nxt_socket_msg_oob_get()
175 for (cmsg = CMSG_FIRSTHDR(&msg); in nxt_socket_msg_oob_get()
177 cmsg = CMSG_NXTHDR(&msg, cmsg)) in nxt_socket_msg_oob_get()
H A Dnxt_pcre2.c60 ret = pcre2_get_error_message(errcode, (PCRE2_UCHAR *) err->msg, in nxt_regex_compile()
63 (void) nxt_sprintf(err->msg, err->msg + ERR_BUF_SIZE, in nxt_regex_compile()
74 ret = pcre2_get_error_message(errcode, (PCRE2_UCHAR *) err->msg, in nxt_regex_compile()
77 (void) nxt_sprintf(err->msg, err->msg + ERR_BUF_SIZE, in nxt_regex_compile()
91 nxt_memcpy(err->msg, alloc_error, sizeof(alloc_error)); in nxt_regex_compile()
H A Dnxt_port.h217 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->cmsg_pid) argument
218 #define nxt_recv_msg_cmsg_pid_ref(msg) (&(msg)->cmsg_pid) argument
220 #define nxt_recv_msg_cmsg_pid(msg) ((msg)->port_msg.pid) argument
221 #define nxt_recv_msg_cmsg_pid_ref(msg) (NULL) argument
347 void nxt_port_quit_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
348 void nxt_port_new_port_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
351 nxt_port_recv_msg_t *msg);
352 void nxt_port_mmap_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
353 void nxt_port_data_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
354 void nxt_port_remove_pid_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
[all …]
H A Dnxt_log.c74 u_char msg[NXT_MAX_ERROR_STR]; in nxt_log_handler() local
76 p = msg; in nxt_log_handler()
77 end = msg + NXT_MAX_ERROR_STR; in nxt_log_handler()
106 (void) nxt_write_console(nxt_stderr, msg, p - msg); in nxt_log_handler()
H A Dnxt_linux_sendfile.c193 struct msghdr msg; in nxt_linux_sendmsg() local
195 msg.msg_name = NULL; in nxt_linux_sendmsg()
196 msg.msg_namelen = 0; in nxt_linux_sendmsg()
197 msg.msg_iov = sb->iobuf; in nxt_linux_sendmsg()
198 msg.msg_iovlen = niov; in nxt_linux_sendmsg()
199 msg.msg_control = NULL; in nxt_linux_sendmsg()
200 msg.msg_controllen = 0; in nxt_linux_sendmsg()
201 msg.msg_flags = 0; in nxt_linux_sendmsg()
203 n = sendmsg(c->socket.fd, &msg, flags); in nxt_linux_sendmsg()
H A Dnxt_pcre.c41 err->msg = "memory allocation failed"; in nxt_regex_compile()
60 re->code = pcre_compile(pattern, 0, &err->msg, &erroffset, NULL); in nxt_regex_compile()
63 re->extra = pcre_study(re->code, PCRE_STUDY_JIT_COMPILE, &err->msg); in nxt_regex_compile()
64 if (nxt_slow_path(re->extra == NULL && err->msg != NULL)) { in nxt_regex_compile()
65 nxt_log_warn(thr->log, "pcre_study(%V) failed: %s", source, err->msg); in nxt_regex_compile()
H A Dnxt_log_moderation.c76 nxt_bool_t msg; in nxt_log_moderate_timer_handler() local
89 msg = (mod->pid == nxt_pid); in nxt_log_moderate_timer_handler()
93 if (msg) { in nxt_log_moderate_timer_handler()
95 mod->msg, n - mod->limit); in nxt_log_moderate_timer_handler()
H A Dnxt_app_log.c29 u_char msg[NXT_MAX_ERROR_STR]; in nxt_log_time_handler() local
33 end = msg + NXT_MAX_ERROR_STR; in nxt_log_time_handler()
38 p = nxt_thread_time_string(thr, time_cache, msg); in nxt_log_time_handler()
85 (void) nxt_write_console(nxt_stderr, msg, p - msg); in nxt_log_time_handler()
H A Dnxt_router.c802 msg->fd[0] = -1; in nxt_router_conf_data_handler()
2610 s = msg->fd[0]; in nxt_router_listen_socket_ready()
2668 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error()
4169 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler()
4336 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler()
5342 } msg; in nxt_router_app_prepare_request() local
5391 msg.pm.nf = 0; in nxt_router_app_prepare_request()
5392 msg.pm.mf = 0; in nxt_router_app_prepare_request()
5402 res = nxt_app_queue_send(port->queue, &msg, sizeof(msg), in nxt_router_app_prepare_request()
5869 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler()
[all …]
/unit/src/python/
H A Dnxt_python_asgi_http.c143 Py_DECREF(msg); in nxt_py_asgi_http_receive()
149 if (msg != Py_None) { in nxt_py_asgi_http_receive()
156 Py_DECREF(msg); in nxt_py_asgi_http_receive()
237 return msg; in nxt_py_asgi_http_read_msg()
246 Py_DECREF(msg); in nxt_py_asgi_http_read_msg()
481 if (msg == Py_None) { in nxt_py_asgi_http_emit_disconnect()
482 Py_DECREF(msg); in nxt_py_asgi_http_emit_disconnect()
491 Py_DECREF(msg); in nxt_py_asgi_http_emit_disconnect()
497 PyObject *msg) in nxt_py_asgi_http_set_result() argument
544 Py_DECREF(msg); in nxt_py_asgi_http_data_handler()
[all …]
H A Dnxt_python_asgi_websocket.c57 PyObject *msg);
563 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_websocket_handler()
644 Py_DECREF(msg); in nxt_py_asgi_websocket_receive_done()
901 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_websocket_pop_msg()
909 Py_DECREF(msg); in nxt_py_asgi_websocket_pop_msg()
918 return msg; in nxt_py_asgi_websocket_pop_msg()
994 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_websocket_close_handler()
1009 PyObject *msg, *code; in nxt_py_asgi_websocket_disconnect_msg() local
1021 Py_DECREF(msg); in nxt_py_asgi_websocket_disconnect_msg()
1029 Py_DECREF(msg); in nxt_py_asgi_websocket_disconnect_msg()
[all …]
H A Dnxt_python_asgi_lifespan.c306 PyObject *msg, *future, *res; in nxt_py_asgi_lifespan_target_shutdown() local
323 if (nxt_fast_path(msg != NULL)) { in nxt_py_asgi_lifespan_target_shutdown()
325 msg, NULL); in nxt_py_asgi_lifespan_target_shutdown()
327 Py_DECREF(msg); in nxt_py_asgi_lifespan_target_shutdown()
363 PyObject *msg, *future; in nxt_py_asgi_lifespan_receive() local
384 msg = nxt_py_asgi_new_msg(NULL, nxt_py_lifespan_startup_str); in nxt_py_asgi_lifespan_receive()
407 PyObject *type, *msg; in nxt_py_asgi_lifespan_send() local
445 msg = PyDict_GetItem(dict, nxt_py_message_str); in nxt_py_asgi_lifespan_send()
446 return nxt_py_asgi_lifespan_send_startup(lifespan, 1, msg); in nxt_py_asgi_lifespan_send()
458 msg = PyDict_GetItem(dict, nxt_py_message_str); in nxt_py_asgi_lifespan_send()
[all …]
/unit/src/java/
H A Dnxt_jni_Context.c22 jlong ctx_ptr, jstring msg, jint msg_len);
24 jlong ctx_ptr, jstring msg, jint msg_len);
126 nxt_java_Context_log(JNIEnv *env, jclass cls, jlong ctx_ptr, jstring msg, in nxt_java_Context_log() argument
134 msg_str = (*env)->GetStringUTFChars(env, msg, NULL); in nxt_java_Context_log()
141 (*env)->ReleaseStringUTFChars(env, msg, msg_str); in nxt_java_Context_log()
146 nxt_java_Context_trace(JNIEnv *env, jclass cls, jlong ctx_ptr, jstring msg, in nxt_java_Context_trace() argument
155 msg_str = (*env)->GetStringUTFChars(env, msg, NULL); in nxt_java_Context_trace()
162 (*env)->ReleaseStringUTFChars(env, msg, msg_str); in nxt_java_Context_trace()
H A Dnxt_jni.h16 void nxt_java_throw_NoSuchElementException(JNIEnv *env, const char *msg);
18 void nxt_java_throw_IOException(JNIEnv *env, const char *msg);
20 void nxt_java_throw_IllegalStateException(JNIEnv *env, const char *msg);
H A Dnxt_jni.c86 nxt_java_throw_NoSuchElementException(JNIEnv *env, const char *msg) in nxt_java_throw_NoSuchElementException() argument
88 (*env)->ThrowNew(env, nxt_java_NoSuchElementException_class, msg); in nxt_java_throw_NoSuchElementException()
93 nxt_java_throw_IOException(JNIEnv *env, const char *msg) in nxt_java_throw_IOException() argument
95 (*env)->ThrowNew(env, nxt_java_IOException_class, msg); in nxt_java_throw_IOException()
100 nxt_java_throw_IllegalStateException(JNIEnv *env, const char *msg) in nxt_java_throw_IllegalStateException() argument
102 (*env)->ThrowNew(env, nxt_java_IllegalStateException_class, msg); in nxt_java_throw_IllegalStateException()
/unit/src/java/nginx/unit/
H A DIncludeResponseWrapper.java112 private void trace(String msg) in trace() argument
114 msg = "IncludeResponse." + msg; in trace()
115 Response.trace(0, msg.getBytes(UTF_8)); in trace()
/unit/go/
H A Dnxt_cgo_lib.c85 nxt_cgo_warn(const char *msg, uint32_t msg_len) in nxt_cgo_warn() argument
87 nxt_unit_warn(NULL, "%.*s", (int) msg_len, (char *) msg); in nxt_cgo_warn()
92 nxt_cgo_alert(const char *msg, uint32_t msg_len) in nxt_cgo_alert() argument
94 nxt_unit_alert(NULL, "%.*s", (int) msg_len, (char *) msg); in nxt_cgo_alert()
H A Dnxt_cgo_lib.h29 void nxt_cgo_warn(const char *msg, uint32_t msg_len);
30 void nxt_cgo_alert(const char *msg, uint32_t msg_len);

123