Home
last modified time | relevance | path

Searched refs:msg (Results 26 – 50 of 63) sorted by relevance

123

/unit/src/
H A Dnxt_router.c803 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 Dnxt_unit.c958 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 Dnxt_regex.h25 u_char msg[ERR_BUF_SIZE]; member
27 const char *msg; member
H A Dnxt_port_rpc.h12 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 Dnxt_cert.h29 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 Dnxt_port_memory.h35 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 Dnxt_cyassl.c542 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 Dnxt_script.h30 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 Dnxt_gnutls.c686 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 Dnxt_script.c541 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 Dnxt_controller.c51 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 Dnxt_credential.c71 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 Dnxt_cert.c963 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 Dnxt_process.c51 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 Dnxt_port_memory.c712 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 Dnxt_application.c48 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 Dnxt_log_moderation.h14 const char *msg; member
/unit/src/java/nginx/unit/
H A DResponse.java371 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 DRequest.java1259 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 Dapp.java19 public void echoTextMessage(Session session, String msg) { in echoTextMessage() argument
22 session.getBasicRemote().sendText(msg, true); in echoTextMessage()
/unit/src/test/
H A Dnxt_clone_test.c394 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 DWsSession.java627 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 DWsRemoteEndpointImplBase.java543 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 Dnxt_jni_Request.c66 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 Dnxt_jni_Response.c107 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()

123