/unit/auto/ |
H A D | sockets | 154 struct msghdr msg; 156 printf(\"%d\", (int) sizeof(msg.msg_control));
|
/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);
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 2994 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 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()
|
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
|
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 …]
|
/unit/src/java/nginx/unit/websocket/ |
H A D | WsFrameBase.java | 566 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 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 …]
|
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 …]
|
/unit/src/java/ |
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()
|
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_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_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()
|
/unit/src/ |
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_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_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_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_conf_validation.c | 2216 err.msg, err.offset); in nxt_conf_vldt_match_pattern() 2220 err.msg); in nxt_conf_vldt_match_pattern()
|
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_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_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 (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_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()
|