/unit/src/ |
H A D | nxt_router.c | 803 msg->fd[0] = -1; in nxt_router_conf_data_handler() 2856 s = msg->fd[0]; in nxt_router_listen_socket_ready() 2914 in = nxt_buf_chk_make_plain(tmcf->mem_pool, msg->buf, msg->size); in nxt_router_listen_socket_error() 4074 b = (msg->size == 0) ? NULL : msg->buf; in nxt_router_response_ready_handler() 4241 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_req_headers_ack_handler() 5247 } msg; in nxt_router_app_prepare_request() local 5296 msg.pm.nf = 0; in nxt_router_app_prepare_request() 5297 msg.pm.mf = 0; in nxt_router_app_prepare_request() 5306 res = nxt_app_queue_send(port->queue, &msg, sizeof(msg), in nxt_router_app_prepare_request() 5780 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_router_get_mmap_handler() [all …]
|
H A D | nxt_unit.c | 958 msg.nf = 0; in nxt_unit_ready() 959 msg.mf = 0; in nxt_unit_ready() 1611 &msg, sizeof(msg), NULL); in nxt_unit_send_req_headers_ack() 2721 memcpy(buf->start - sizeof(m.msg), &m.msg, sizeof(m.msg)); in nxt_unit_mmap_buf_send() 3310 msg.nf = 0; in nxt_unit_request_done() 3314 &msg, sizeof(msg), NULL); in nxt_unit_request_done() 4111 &msg, sizeof(msg), NULL); in nxt_unit_awake_ctx() 6599 p = msg; in nxt_unit_log() 6615 n = write(log_fd, msg, p - msg); in nxt_unit_log() 6643 p = msg; in nxt_unit_req_log() [all …]
|
H A D | nxt_regex.h | 25 u_char msg[ERR_BUF_SIZE]; member 27 const char *msg; member
|
H A D | nxt_port_rpc.h | 12 nxt_port_recv_msg_t *msg, void *data); 27 void nxt_port_rpc_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
|
H A D | nxt_cert.h | 29 void nxt_cert_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); 30 void nxt_cert_store_delete_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg);
|
H A D | nxt_port_memory.h | 35 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb, void *mmsg_buf); 38 nxt_port_mmap_read(nxt_task_t *task, nxt_port_recv_msg_t *msg);
|
H A D | nxt_cyassl.c | 542 u_char msg[NXT_MAX_ERROR_STR]; in nxt_cyassl_conn_error() local 550 end = msg + sizeof(msg); in nxt_cyassl_conn_error() 553 p = nxt_vsprintf(msg, end, fmt, args); in nxt_cyassl_conn_error() 562 nxt_log_error(level, c->socket.log, "%*s", p - msg, msg); in nxt_cyassl_conn_error() 590 u_char msg[NXT_MAX_ERROR_STR]; in nxt_cyassl_log_error() local 594 end = msg + sizeof(msg); in nxt_cyassl_log_error() 597 p = nxt_vsprintf(msg, end, fmt, args); in nxt_cyassl_log_error() 602 nxt_log_error(level, log, "%*s", p - msg, msg); in nxt_cyassl_log_error()
|
H A D | nxt_script.h | 30 void nxt_script_store_get_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg); 32 nxt_port_recv_msg_t *msg);
|
H A D | nxt_gnutls.c | 686 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_conn_log_error() local 693 p = nxt_vsprintf(msg, msg + sizeof(msg), fmt, args); in nxt_gnutls_conn_log_error() 697 p - msg, msg, err, gnutls_strerror(err)); in nxt_gnutls_conn_log_error() 734 u_char *p, msg[NXT_MAX_ERROR_STR]; in nxt_gnutls_log_error() local 737 p = nxt_vsprintf(msg, msg + sizeof(msg), fmt, args); in nxt_gnutls_log_error() 741 p - msg, msg, err, gnutls_strerror(err)); in nxt_gnutls_log_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() argument 551 port = nxt_runtime_port_find(task->thread->runtime, msg->port_msg.pid, in nxt_script_store_get_handler() 552 msg->port_msg.reply_port); in nxt_script_store_get_handler() 556 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_script_store_get_handler() 564 msg->port_msg.pid); in nxt_script_store_get_handler() 580 name.start = msg->buf->mem.pos; in nxt_script_store_get_handler() 603 msg->port_msg.stream, 0, NULL); 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() argument 646 if (nxt_slow_path(nxt_recv_msg_cmsg_pid(msg) != ctl_port->pid)) { in nxt_script_store_delete_handler() 648 nxt_recv_msg_cmsg_pid(msg)); in nxt_script_store_delete_handler() [all …]
|
H A D | nxt_controller.c | 51 nxt_port_recv_msg_t *msg); 54 nxt_port_recv_msg_t *msg); 56 nxt_port_recv_msg_t *msg); 59 nxt_port_recv_msg_t *msg, void *data); 410 nxt_port_recv_msg_t *msg) in nxt_controller_process_new_port_handler() argument 468 nxt_port_recv_msg_t *msg) in nxt_controller_router_ready_handler() argument 1883 if (msg == NULL || msg->port_msg.type == _NXT_PORT_MSG_RPC_ERROR) { in nxt_controller_process_cert_save() 1897 nxt_fd_close(msg->fd[0]); in nxt_controller_process_cert_save() 2149 if (msg == NULL || msg->port_msg.type == _NXT_PORT_MSG_RPC_ERROR) { in nxt_controller_process_script_save() 2163 nxt_fd_close(msg->fd[0]); in nxt_controller_process_script_save() [all …]
|
H A D | nxt_credential.c | 71 u_char msg[NXT_MAX_ERROR_STR]; in nxt_credential_get() local 73 p = msg; in nxt_credential_get() 74 end = msg + NXT_MAX_ERROR_STR; in nxt_credential_get() 84 nxt_debug(task, "user \"%s\" has gids:%*s", uc->user, p - msg, msg); in nxt_credential_get()
|
H A D | nxt_cert.c | 963 msg->port_msg.reply_port); 1038 msg->port_msg.stream, 0, b); 1055 msg->port_msg.stream, 0, NULL); 1135 msg->port_msg.reply_port); in nxt_cert_store_get_handler() 1139 msg->port_msg.pid, msg->port_msg.reply_port); in nxt_cert_store_get_handler() 1147 msg->port_msg.pid); in nxt_cert_store_get_handler() 1163 name.start = msg->buf->mem.pos; in nxt_cert_store_get_handler() 1187 msg->port_msg.stream, 0, NULL); in nxt_cert_store_get_handler() 1230 if (nxt_slow_path(nxt_recv_msg_cmsg_pid(msg) != ctl_port->pid)) { in nxt_cert_store_delete_handler() 1232 nxt_recv_msg_cmsg_pid(msg)); in nxt_cert_store_delete_handler() [all …]
|
H A D | nxt_process.c | 51 static void nxt_process_whoami_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, 59 static void nxt_process_created_ok(nxt_task_t *task, nxt_port_recv_msg_t *msg, 62 nxt_port_recv_msg_t *msg, void *data); 822 buf = msg->buf; in nxt_process_whoami_ok() 947 nxt_process_created_error(nxt_task_t *task, nxt_port_recv_msg_t *msg, in nxt_process_created_error() argument 1121 const char *msg; in nxt_process_daemon() local 1136 msg = "fork() failed %E"; in nxt_process_daemon() 1174 msg = "open(\"/dev/null\") failed %E"; in nxt_process_daemon() 1179 msg = "dup2(\"/dev/null\", STDIN) failed %E"; in nxt_process_daemon() 1184 msg = "dup2(\"/dev/null\", STDOUT) failed %E"; in nxt_process_daemon() [all …]
|
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() argument 727 bmem = msg->buf; in nxt_port_mmap_write() 760 msg->port_msg.mmap = 1; 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() argument 770 pb = &msg->buf; in nxt_port_mmap_read() 771 msg->size = 0; in nxt_port_mmap_read() 773 for (b = msg->buf; b != NULL; b = b->next) { in nxt_port_mmap_read() 781 msg->port_msg.pid); in nxt_port_mmap_read() 783 *pb = nxt_port_mmap_get_incoming_buf(task, msg->port, in nxt_port_mmap_read() 784 msg->port_msg.pid, mmap_msg); in nxt_port_mmap_read() [all …]
|
H A D | nxt_application.c | 48 static void nxt_discovery_quit(nxt_task_t *task, nxt_port_recv_msg_t *msg, 57 nxt_port_recv_msg_t *msg); 60 nxt_port_recv_msg_t *msg); 501 nxt_signal_quit_handler(task, msg); in nxt_discovery_quit() 644 process->stream = msg->port_msg.stream; in nxt_proto_start_process_handler() 661 port = nxt_runtime_port_find(rt, msg->port_msg.pid, in nxt_proto_start_process_handler() 662 msg->port_msg.reply_port); in nxt_proto_start_process_handler() 666 -1, msg->port_msg.stream, 0, NULL); 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() argument 708 isolated_pid = nxt_recv_msg_cmsg_pid(msg); in nxt_proto_process_created_handler() [all …]
|
H A D | nxt_log_moderation.h | 14 const char *msg; member
|
/unit/src/java/nginx/unit/ |
H A D | Response.java | 371 public void sendError(int sc, String msg) throws IOException in sendError() argument 373 trace("sendError: " + sc + ", " + msg); in sendError() 388 request.setAttribute_(RequestDispatcher.ERROR_MESSAGE, msg); in sendError() 816 private void log(String msg) in log() argument 818 msg = "Response." + msg; in log() 819 log(req_info_ptr, msg.getBytes(UTF_8)); in log() 822 public static native void log(long req_info_ptr, byte[] msg); in log() argument 825 private void trace(String msg) in trace() argument 827 msg = "Response." + msg; in trace() 828 trace(req_info_ptr, msg.getBytes(UTF_8)); in trace() [all …]
|
H A D | Request.java | 1259 private void log(String msg) in log() argument 1261 msg = "Request." + msg; in log() 1262 log(req_info_ptr, msg, msg.length()); in log() 1265 public static native void log(long req_info_ptr, String msg, int msg_len); in log() argument 1268 private void trace(String msg) in trace() argument 1270 msg = "Request." + msg; in trace() 1271 trace(req_info_ptr, msg, msg.length()); in trace() 1274 public static native void trace(long req_info_ptr, String msg, int msg_len); in trace() argument
|
/unit/test/java/websockets_mirror/ |
H A D | app.java | 19 public void echoTextMessage(Session session, String msg) { in echoTextMessage() argument 22 session.getBasicRemote().sendText(msg, true); in echoTextMessage()
|
/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 396 p = msg; in nxt_clone_test_log_handler() 397 end = msg + NXT_MAX_ERROR_STR; in nxt_clone_test_log_handler() 413 nxt_log_error(NXT_LOG_ERR, &nxt_main_log, "unexpected log: %s", msg); in nxt_clone_test_log_handler() 417 if (!nxt_str_eq(&tc->errmsg, msg, (nxt_uint_t) (p - msg - 1))) { in nxt_clone_test_log_handler() 420 msg, &tc->errmsg); in nxt_clone_test_log_handler()
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsSession.java | 627 ByteBuffer msg = ByteBuffer.allocate(125); in sendCloseMessage() local 632 msg.putShort((short) CloseCodes.PROTOCOL_ERROR.getCode()); in sendCloseMessage() 634 msg.putShort((short) closeCode.getCode()); in sendCloseMessage() 639 appendCloseReasonWithTruncation(msg, reason); in sendCloseMessage() 641 msg.flip(); in sendCloseMessage() 678 msg.put(reasonBytes); in appendCloseReasonWithTruncation() 685 msg.put(bytesNext); in appendCloseReasonWithTruncation() 690 msg.put(ELLIPSIS_BYTES); in appendCloseReasonWithTruncation() 1045 String msg = sm.getString("wsSession.timeout", getId()); in checkExpiration() local 1047 log.debug(msg); in checkExpiration() [all …]
|
H A D | WsRemoteEndpointImplBase.java | 543 String msg = obj.toString(); in sendObject() local 544 sendString(msg); in sendObject() 548 ByteBuffer msg = ByteBuffer.wrap((byte[]) obj); in sendObject() local 549 sendBytes(msg); in sendObject() 555 sendString(msg); in sendObject() 562 sendBytes(msg); in sendObject() 598 String msg = obj.toString(); in sendObjectByCompletion() local 599 sendStringByCompletion(msg, completion); in sendObjectByCompletion() 604 sendBytesByCompletion(msg, completion); in sendObjectByCompletion() 611 sendStringByCompletion(msg, completion); in sendObjectByCompletion() [all …]
|
/unit/src/java/ |
H A D | nxt_jni_Request.c | 66 jlong req_info_ptr, jstring msg, jint msg_len); 68 jlong req_info_ptr, jstring msg, jint msg_len); 698 nxt_java_Request_log(JNIEnv *env, jclass cls, jlong req_info_ptr, jstring msg, in nxt_java_Request_log() argument 706 msg_str = (*env)->GetStringUTFChars(env, msg, NULL); in nxt_java_Request_log() 713 (*env)->ReleaseStringUTFChars(env, msg, msg_str); 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() argument 727 msg_str = (*env)->GetStringUTFChars(env, msg, NULL); in nxt_java_Request_trace() 734 (*env)->ReleaseStringUTFChars(env, msg, msg_str); in nxt_java_Request_trace()
|
H A D | nxt_jni_Response.c | 107 jlong req_info_ptr, jarray msg); 110 jlong req_info_ptr, jarray msg); 1063 nxt_java_Response_log(JNIEnv *env, jclass cls, jlong req_info_ptr, jarray msg) in nxt_java_Response_log() argument 1070 msg_len = (*env)->GetArrayLength(env, msg); in nxt_java_Response_log() 1072 msg_str = (*env)->GetPrimitiveArrayCritical(env, msg, NULL); in nxt_java_Response_log() 1080 (*env)->ReleasePrimitiveArrayCritical(env, msg, msg_str, 0); in nxt_java_Response_log() 1085 nxt_java_Response_trace(JNIEnv *env, jclass cls, jlong req_info_ptr, jarray msg) in nxt_java_Response_trace() argument 1093 msg_len = (*env)->GetArrayLength(env, msg); in nxt_java_Response_trace() 1095 msg_str = (*env)->GetPrimitiveArrayCritical(env, msg, NULL); in nxt_java_Response_trace() 1103 (*env)->ReleasePrimitiveArrayCritical(env, msg, msg_str, 0); in nxt_java_Response_trace()
|