/unit/src/ |
H A D | nxt_socket_msg.c | 14 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 D | nxt_port_socket.c | 176 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 D | nxt_errno.c | 38 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 D | nxt_port.c | 180 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 D | nxt_port_rpc.c | 318 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 D | nxt_main_process.c | 335 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 D | nxt_polarssl.c | 105 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 D | nxt_socket_msg.h | 130 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 D | nxt_pcre2.c | 60 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 D | nxt_port.h | 217 #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 D | nxt_log.c | 74 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 D | nxt_linux_sendfile.c | 193 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 D | nxt_pcre.c | 41 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 D | nxt_log_moderation.c | 76 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 D | nxt_app_log.c | 29 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 D | nxt_router.c | 802 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 D | nxt_python_asgi_http.c | 143 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 D | nxt_python_asgi_websocket.c | 57 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 D | nxt_python_asgi_lifespan.c | 306 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 D | nxt_jni_Context.c | 22 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 D | nxt_jni.h | 16 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 D | nxt_jni.c | 86 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 D | IncludeResponseWrapper.java | 112 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 D | nxt_cgo_lib.c | 85 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 D | nxt_cgo_lib.h | 29 void nxt_cgo_warn(const char *msg, uint32_t msg_len); 30 void nxt_cgo_alert(const char *msg, uint32_t msg_len);
|