1 files changed, 148 insertions, 0 deletions
diff --git a/src/java/nxt_jni_HeadersEnumeration.c b/src/java/nxt_jni_HeadersEnumeration.c
new file mode 100644
index 00000000..aaea710d
--- /dev/null
+++ b/src/java/nxt_jni_HeadersEnumeration.c
@@ -0,0 +1,148 @@
+
+/*
+ * Copyright (C) NGINX, Inc.
+ */
+
+#include <nxt_auto_config.h>
+
+#include <nxt_unit.h>
+#include <nxt_unit_request.h>
+#include <jni.h>
+#include <stdio.h>
+
+#include "nxt_jni.h"
+#include "nxt_jni_URLClassLoader.h"
+#include "nxt_jni_HeadersEnumeration.h"
+
+
+static jclass     nxt_java_HeadersEnumeration_class;
+static jmethodID  nxt_java_HeadersEnumeration_ctor;
+
+
+static jlong JNICALL nxt_java_HeadersEnumeration_nextElementPos(JNIEnv *env,
+    jclass cls, jlong headers_ptr, jlong size, jlong ipos, jlong pos);
+
+static jstring JNICALL nxt_java_HeadersEnumeration_nextElement(JNIEnv *env,
+    jclass cls, jlong headers_ptr, jlong size, jlong ipos, jlong pos);
+
+
+int
+nxt_java_initHeadersEnumeration(JNIEnv *env, jobject cl)
+{
+    int     res;
+    jclass  cls;
+
+    cls = nxt_java_loadClass(env, cl, "nginx.unit.HeadersEnumeration");
+    if (cls == NULL) {
+        return NXT_UNIT_ERROR;
+    }
+
+    nxt_java_HeadersEnumeration_class = (*env)->NewGlobalRef(env, cls);
+    (*env)->DeleteLocalRef(env, cls);
+    cls = nxt_java_HeadersEnumeration_class;
+
+    nxt_java_HeadersEnumeration_ctor = (*env)->GetMethodID(env, cls,
+        "<init>", "(JJJ)V");
+    if (nxt_java_HeadersEnumeration_ctor == NULL) {
+        (*env)->DeleteGlobalRef(env, cls);
+        return NXT_UNIT_ERROR;
+    }
+
+    JNINativeMethod methods[] = {
+        { (char *) "nextElementPos",
+          (char *) "(JJJJ)J",
+          nxt_java_HeadersEnumeration_nextElementPos },
+
+        { (char *) "nextElement",
+          (char *) "(JJJJ)Ljava/lang/String;",
+          nxt_java_HeadersEnumeration_nextElement },
+    };
+
+    res = (*env)->RegisterNatives(env, nxt_java_HeadersEnumeration_class,
+                                  methods,
+                                  sizeof(methods) / sizeof(methods[0]));
+
+    nxt_unit_debug(NULL, "registered HeadersEnumeration methods: %d", res);
+
+    if (res != 0) {
+        (*env)->DeleteGlobalRef(env, cls);
+        return NXT_UNIT_ERROR;
+    }
+
+    return NXT_UNIT_OK;
+}
+
+
+jobject
+nxt_java_newHeadersEnumeration(JNIEnv *env, nxt_unit_field_t *f,
+    uint32_t fields_count, uint32_t pos)
+{
+    return (*env)->NewObject(env,
+        nxt_java_HeadersEnumeration_class,
+        nxt_java_HeadersEnumeration_ctor, nxt_ptr2jlong(f),
+        (jlong) fields_count, (jlong) pos);
+}
+
+
+static jlong JNICALL
+nxt_java_HeadersEnumeration_nextElementPos(JNIEnv *env, jclass cls,
+    jlong headers_ptr, jlong size, jlong ipos, jlong pos)
+{
+    nxt_unit_field_t  *f, *init_field;
+
+    f = nxt_jlong2ptr(headers_ptr);
+
+    init_field = f + ipos;
+
+    if (pos >= size) {
+        return size;
+    }
+
+    f += pos;
+
+    if (f->hash != init_field->hash
+        || f->name_length != init_field->name_length)
+    {
+        return size;
+    }
+
+    if (!nxt_java_strcaseeq(nxt_unit_sptr_get(&f->name),
+                            nxt_unit_sptr_get(&init_field->name),
+                            init_field->name_length))
+    {
+        return size;
+    }
+
+    return pos;
+}
+
+
+static jstring JNICALL
+nxt_java_HeadersEnumeration_nextElement(JNIEnv *env, jclass cls,
+    jlong headers_ptr, jlong size, jlong ipos, jlong pos)
+{
+    nxt_unit_field_t  *f, *init_field;
+
+    f = nxt_jlong2ptr(headers_ptr);
+
+    init_field = f + ipos;
+
+    if (pos >= size) {
+        nxt_java_throw_IOException(env, "pos >= size");
+
+        return NULL;
+    }
+
+    f += pos;
+
+    if (f->hash != init_field->hash
+        || f->name_length != init_field->name_length)
+    {
+        nxt_java_throw_IOException(env, "f->hash != hash");
+
+        return NULL;
+    }
+
+    return nxt_java_newString(env, nxt_unit_sptr_get(&f->value),
+                              f->value_length);
+}