Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 63) sorted by path

123

/unit/auto/
H A Dsockets154 struct msghdr msg;
156 printf(\"%d\", (int) sizeof(msg.msg_control));
/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);
/unit/src/java/nginx/unit/
H A DContext.java2994 public void log(Exception exception, String msg)
2996 log(msg, exception);
3000 public void log(String msg)
3002 msg = "Context." + msg;
3003 log(0, msg, msg.length());
3012 private static native void log(long ctx_ptr, String msg, int msg_len);
3015 public static void trace(String msg)
3017 msg = "Context." + msg;
3018 trace(0, msg, msg.length());
3021 private static native void trace(long ctx_ptr, String msg, int msg_len);
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()
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
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 …]
/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java566 protected void sendMessageBinary(ByteBuffer msg, boolean last) throws WsIOException { in sendMessageBinary() argument
569 if (maxMessageSize > -1 && msg.remaining() > maxMessageSize) { in sendMessageBinary()
572 Long.valueOf(msg.remaining()), in sendMessageBinary()
578 ((MessageHandler.Partial<ByteBuffer>) binaryMsgHandler).onMessage(msg, last); in sendMessageBinary()
581 ((MessageHandler.Whole<ByteBuffer>) binaryMsgHandler).onMessage(msg); in sendMessageBinary()
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 …]
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 …]
/unit/src/java/
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()
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_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_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()
/unit/src/
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_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_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_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_conf_validation.c2216 err.msg, err.offset); in nxt_conf_vldt_match_pattern()
2220 err.msg); in nxt_conf_vldt_match_pattern()
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_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_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 (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_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()

123