#include "jvm.h"

/*

with javap -s -p <class>
you can get method signatures

This plugin is the core for all of the JVM-based ones

some function (for performance reason) use static vars. They are thread safe in gcc.

*/

extern struct uwsgi_server uwsgi;
struct uwsgi_plugin jvm_plugin;
struct uwsgi_jvm ujvm;


int uwsgi_jvm_register_request_handler(uint8_t modifier2,int (*setup)(void), int (*func)(struct wsgi_request *)) {
	if (ujvm.request_handlers[modifier2] || ujvm.request_handlers_setup[modifier2]) {
		uwsgi_log("JVM request_handler for modifier2 %u already registered !!!\n", modifier2);
		return -1;
	}
	ujvm.request_handlers_setup[modifier2] = setup;
	ujvm.request_handlers[modifier2] = func;
	return 0;
}

JNIEXPORT jint JNICALL uwsgi_jvm_api_worker_id(JNIEnv *env, jclass c) {
	return uwsgi.mywid;
}

JNIEXPORT void JNICALL uwsgi_jvm_api_register_signal(JNIEnv *env, jclass c, jint signum, jstring target, jobject handler) {
	// no need to release it
	char *t = uwsgi_jvm_str2c(target);
	if (uwsgi_register_signal(signum, t, uwsgi_jvm_ref(handler), jvm_plugin.modifier1)) {
		uwsgi_jvm_throw("unable to register signal handler");
	}
}

JNIEXPORT void JNICALL uwsgi_jvm_api_register_rpc(JNIEnv *env, jclass c, jstring name, jobject func) {
	// no need to release it
	char *n = uwsgi_jvm_str2c(name);
	if (uwsgi_register_rpc(n, &jvm_plugin, 0, uwsgi_jvm_ref(func))) {
		uwsgi_jvm_throw("unable to register rpc function");
	}
}

JNIEXPORT void JNICALL uwsgi_jvm_api_lock_zero(JNIEnv *env, jclass c) {
	uwsgi_lock(uwsgi.user_lock[0]);
}

JNIEXPORT void JNICALL uwsgi_jvm_api_unlock_zero(JNIEnv *env, jclass c) {
        uwsgi_unlock(uwsgi.user_lock[0]);
}

JNIEXPORT void JNICALL uwsgi_jvm_api_lock(JNIEnv *env, jclass c, jint locknum) {
	if (locknum < 0 || locknum > uwsgi.locks) {
		uwsgi_jvm_throw("invalid lock number");
		return;
	}
        uwsgi_lock(uwsgi.user_lock[locknum]);
}

JNIEXPORT void JNICALL uwsgi_jvm_api_unlock(JNIEnv *env, jclass c, jint locknum) {
	if (locknum < 0 || locknum > uwsgi.locks) {
		uwsgi_jvm_throw("invalid lock number");
		return;
	}
        uwsgi_unlock(uwsgi.user_lock[locknum]);
}

JNIEXPORT jobject JNICALL uwsgi_jvm_api_cache_get(JNIEnv *env, jclass c, jstring jkey) {
	if (!uwsgi.caches) {
		uwsgi_jvm_throw("cache not available");
		return NULL;
	}

	size_t keylen = uwsgi_jvm_strlen(jkey);
	char *key = uwsgi_jvm_str2c(jkey);
	uint64_t vallen = 0;
	char *value = uwsgi_cache_magic_get(key, keylen, &vallen, NULL, NULL);
	uwsgi_jvm_release_chars(jkey, key);
	if (value) {
		jobject o = uwsgi_jvm_bytearray(value, vallen);
		free(value);
		return o;
	}
	return NULL;
}

JNIEXPORT jobject JNICALL uwsgi_jvm_api_cache_get_name(JNIEnv *env, jclass c, jstring jkey, jstring jcache) {
        if (!uwsgi.caches) {
                uwsgi_jvm_throw("cache not available");
                return NULL;
        }

        size_t keylen = uwsgi_jvm_strlen(jkey);
        char *key = uwsgi_jvm_str2c(jkey);
        char *cache = uwsgi_jvm_str2c(jcache);
        uint64_t vallen = 0;
        char *value = uwsgi_cache_magic_get(key, keylen, &vallen, NULL, cache);
        uwsgi_jvm_release_chars(jkey, key);
        uwsgi_jvm_release_chars(jcache, cache);
        if (value) {
                jobject o = uwsgi_jvm_bytearray(value, vallen);
                free(value);
                return o;
        }
        return NULL;
}


JNIEXPORT void JNICALL uwsgi_jvm_api_alarm(JNIEnv *env, jclass c, jstring alarm, jstring msg) {

	char *c_alarm = uwsgi_jvm_str2c(alarm);
	size_t c_msg_len = uwsgi_jvm_strlen(msg);
	char *c_msg = uwsgi_jvm_str2c(msg);
        uwsgi_alarm_trigger(c_alarm, c_msg, c_msg_len);
	uwsgi_jvm_release_chars(msg, c_msg);
	uwsgi_jvm_release_chars(alarm, c_alarm);

}

JNIEXPORT jobject JNICALL uwsgi_jvm_api_rpc(JNIEnv *env, jclass c, jobject j_args) {

	char *argv[256];
        uint16_t argvs[256];
	jobject argvj[256];
	uint64_t size = 0;

	size_t args = uwsgi_jvm_array_len(j_args);
	if (args < 2) return NULL;

	jobject server = uwsgi_jvm_array_get(j_args, 0);
	jobject func = uwsgi_jvm_array_get(j_args, 1);
	
	size_t i;
	for(i=0;i<(args-2);i++) {
		jobject j_arg = uwsgi_jvm_array_get(j_args, i + 2);	
		argvs[i] = uwsgi_jvm_strlen(j_arg);
		argv[i] = uwsgi_jvm_str2c(j_arg);
		// need this value to unref later
		argvj[i] = j_arg;
	}

	char *c_server = uwsgi_jvm_str2c(server);
	char *c_func = uwsgi_jvm_str2c(func);
	char *response = uwsgi_do_rpc(c_server, c_func, args-2, argv, argvs, &size);
	uwsgi_jvm_release_chars(func, c_func);
	uwsgi_jvm_release_chars(server, c_server);
	uwsgi_jvm_local_unref(server);
	uwsgi_jvm_local_unref(func);
	for(i=0;i<(args-2);i++) {
		uwsgi_jvm_release_chars(argvj[i], argv[i]);
		uwsgi_jvm_local_unref(argvj[i]);
	}
	
	if (response) {
		jobject o = uwsgi_jvm_str(response, size);
		free(response);
		return o;
	}
	
	return NULL;

}


static JNINativeMethod uwsgi_jvm_api_methods[] = {
	{"register_signal", "(ILjava/lang/String;Luwsgi$SignalHandler;)V", (void *) &uwsgi_jvm_api_register_signal},
	{"register_rpc", "(Ljava/lang/String;Luwsgi$RpcFunction;)V", (void *) &uwsgi_jvm_api_register_rpc},
	{"worker_id", "()I", (void *) &uwsgi_jvm_api_worker_id},
	{"lock", "()V", (void *) &uwsgi_jvm_api_lock_zero},
	{"unlock", "()V", (void *) &uwsgi_jvm_api_unlock_zero},
	{"lock", "(I)V", (void *) &uwsgi_jvm_api_lock},
	{"unlock", "(I)V", (void *) &uwsgi_jvm_api_unlock},
	{"cache_get", "(Ljava/lang/String;)[B", (void *) &uwsgi_jvm_api_cache_get},
	{"cache_get", "(Ljava/lang/String;Ljava/lang/String;)[B", (void *) &uwsgi_jvm_api_cache_get_name},
	{"alarm", "(Ljava/lang/String;Ljava/lang/String;)V", (void *) &uwsgi_jvm_api_alarm},
	{"rpc", "([Ljava/lang/String;)Ljava/lang/String;", (void *) &uwsgi_jvm_api_rpc},
};

JNIEXPORT jint JNICALL uwsgi_jvm_request_body_read(JNIEnv *env, jobject o) {
	struct wsgi_request *wsgi_req = current_wsgi_req();
	ssize_t rlen = 0;
        char *chunk = uwsgi_request_body_read(wsgi_req, 1, &rlen);
	if (!chunk) {
		uwsgi_jvm_throw_io("error reading request body");	
		return -1;
	}
	if (chunk == uwsgi.empty) {
		return -1;
	}
	uint8_t byte = chunk[0];
	return (jint) byte;
}

JNIEXPORT jint JNICALL uwsgi_jvm_request_body_read_bytearray(JNIEnv *env, jobject o, jobject b) {
	struct wsgi_request *wsgi_req = current_wsgi_req();
	ssize_t rlen = 0;
	size_t len = uwsgi_jvm_array_len(b);
	char *chunk = uwsgi_request_body_read(wsgi_req, len, &rlen);
        if (!chunk) {
                uwsgi_jvm_throw_io("error reading request body");
                return -1;
        }
        if (chunk == uwsgi.empty) {
                return -1;
        }
	char *buf = (char *) (*ujvm_env)->GetByteArrayElements(ujvm_env, b, JNI_FALSE);
        if (!buf) return -1;
	memcpy(buf, chunk, rlen);
	 (*ujvm_env)->ReleaseByteArrayElements(ujvm_env, b, (jbyte *) buf, 0);
        return rlen;
}

JNIEXPORT jint JNICALL uwsgi_jvm_request_body_readline_bytearray(JNIEnv *env, jobject o, jobject b) {
        struct wsgi_request *wsgi_req = current_wsgi_req();
        ssize_t rlen = 0;
        size_t len = uwsgi_jvm_array_len(b);
        char *chunk = uwsgi_request_body_readline(wsgi_req, len, &rlen);
        if (!chunk) {
                uwsgi_jvm_throw_io("error reading request body");
                return -1;
        }
        if (chunk == uwsgi.empty) {
                return -1;
        }
        char *buf = (char *) (*ujvm_env)->GetByteArrayElements(ujvm_env, b, JNI_FALSE);
        if (!buf) return -1;
        memcpy(buf, chunk, rlen);
         (*ujvm_env)->ReleaseByteArrayElements(ujvm_env, b, (jbyte *) buf, 0);
        return rlen;
}


JNIEXPORT jint JNICALL uwsgi_jvm_request_body_available(JNIEnv *env, jobject o) {
	struct wsgi_request *wsgi_req = current_wsgi_req();
	return (jint) (wsgi_req->post_cl - wsgi_req->post_pos);
}

JNIEXPORT void JNICALL uwsgi_jvm_request_body_seek(JNIEnv *env, jobject o, jint pos) {
        struct wsgi_request *wsgi_req = current_wsgi_req();
	uwsgi_request_body_seek(wsgi_req, pos);
}

static JNINativeMethod uwsgi_jvm_request_body_methods[] = {
	{"read", "()I", (void *) &uwsgi_jvm_request_body_read},
	{"read", "([B)I", (void *) &uwsgi_jvm_request_body_read_bytearray},
	{"readLine", "([B)I", (void *) &uwsgi_jvm_request_body_readline_bytearray},
	{"available", "()I", (void *) &uwsgi_jvm_request_body_available},
	{"seek", "(I)V", (void *) &uwsgi_jvm_request_body_seek},
};

static struct uwsgi_option uwsgi_jvm_options[] = {
        {"jvm-main-class", required_argument, 0, "load the specified class and call its main() function", uwsgi_opt_add_string_list, &ujvm.main_classes, 0},
        {"jvm-opt", required_argument, 0, "add the specified jvm option", uwsgi_opt_add_string_list, &ujvm.opts, 0},
        {"jvm-class", required_argument, 0, "load the specified class", uwsgi_opt_add_string_list, &ujvm.classes, 0},
        {"jvm-classpath", required_argument, 0, "add the specified directory to the classpath", uwsgi_opt_add_string_list, &ujvm.classpath, 0},
        {0, 0, 0, 0},
};

jobject uwsgi_jvm_entryset(jobject o) {
	jclass c = uwsgi_jvm_class_from_object(o);
        if (!c) return NULL;
        jmethodID mid = uwsgi_jvm_get_method_id(c, "entrySet", "()Ljava/util/Set;");
        uwsgi_jvm_local_unref(c);
        if (!mid) return NULL;
        return uwsgi_jvm_call_object(o, mid);
}

jobject uwsgi_jvm_to_string(jobject o) {
	jclass c = uwsgi_jvm_class_from_object(o);
        if (!c) return NULL;
        jmethodID mid = uwsgi_jvm_get_method_id_quiet(c, "toString", "()Ljava/lang/String;");
        uwsgi_jvm_local_unref(c);
        if (!mid) return NULL;
        return uwsgi_jvm_call_object(o, mid);
}

int uwsgi_jvm_object_to_response_body(struct wsgi_request *wsgi_req, jobject body) {

	// check for string
	if (uwsgi_jvm_object_is_instance(body, ujvm.str_class)) {
                char *c_body = uwsgi_jvm_str2c(body);
                size_t c_body_len = uwsgi_jvm_strlen(body);
                uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                uwsgi_jvm_release_chars(body, c_body);
		return 0;
        }

	// check for string array
	if (uwsgi_jvm_object_is_instance(body, ujvm.str_array_class)) {
		size_t items = uwsgi_jvm_array_len(body);
		size_t i;
		for(i=0;i<items;i++) {
			jobject chunk = uwsgi_jvm_array_get(body, i);
                        if (!chunk) return 0;
                        if (!uwsgi_jvm_object_is_instance(chunk, ujvm.str_class)) {
                                uwsgi_log("body array item must be java/lang/String !!!\n");
                                uwsgi_jvm_local_unref(chunk);
				return 0;
                        }
                        char *c_body = uwsgi_jvm_str2c(chunk);
                        size_t c_body_len = uwsgi_jvm_strlen(chunk);
                        int ret = uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                        uwsgi_jvm_release_chars(chunk, c_body);
                        uwsgi_jvm_local_unref(chunk);
                        if (ret) return 0;
		}
	}

	// check for bytearray
	if (uwsgi_jvm_object_is_instance(body, ujvm.bytearray_class)) {
		char *c_body = uwsgi_jvm_bytearray2c(body);
                size_t c_body_len = uwsgi_jvm_array_len(body);
                uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                uwsgi_jvm_release_bytearray(body, c_body);
                return 0;
	}

	// check for iterable
        jobject chunks = uwsgi_jvm_auto_iterator(body);
        if (chunks) {
                while(uwsgi_jvm_iterator_hasNext(chunks)) {
                        jobject chunk = uwsgi_jvm_iterator_next(chunks);
                        if (!chunk) goto done;
			int ret = -1;
                        if (uwsgi_jvm_object_is_instance(chunk, ujvm.str_class)) {
                        	char *c_body = uwsgi_jvm_str2c(chunk);
                        	size_t c_body_len = uwsgi_jvm_strlen(chunk);
                        	ret = uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                        	uwsgi_jvm_release_chars(chunk, c_body);
                        	uwsgi_jvm_local_unref(chunk);
				if (ret) goto done;
				continue;
			}

			if (uwsgi_jvm_object_is_instance(chunk, ujvm.bytearray_class)) {
                        	char *c_body = uwsgi_jvm_bytearray2c(chunk);
                        	size_t c_body_len = uwsgi_jvm_array_len(chunk);
                        	ret = uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                        	uwsgi_jvm_release_bytearray(chunk, c_body);
                        	uwsgi_jvm_local_unref(chunk);
				if (ret) goto done;
				continue;
			}

			jobject str_o = uwsgi_jvm_to_string(chunk);
			if (str_o) {
				char *c_body = uwsgi_jvm_str2c(str_o);
                                size_t c_body_len = uwsgi_jvm_strlen(str_o);
                                ret = uwsgi_response_write_body_do(wsgi_req, c_body, c_body_len);
                                uwsgi_jvm_release_chars(str_o, c_body);
				uwsgi_jvm_local_unref(str_o);
				uwsgi_jvm_local_unref(chunk);
                                if (ret) goto done;
				continue;
			}

			uwsgi_log("body iterable item must be java/lang/String or array of bytes!!!\n");
                        uwsgi_jvm_local_unref(chunk);
                        goto done;
                }
done:
                uwsgi_jvm_local_unref(chunks);
		return 0;
        }

        if (uwsgi_jvm_object_is_instance(body, ujvm.file_class)) {
                jobject j_filename = uwsgi_jvm_filename(body);
                if (!j_filename) return 0;
                char *c_filename = uwsgi_jvm_str2c(j_filename);
                int fd = open(c_filename, O_RDONLY);
                if (fd < 0) {
                        uwsgi_error("java/io/File.open()");
                        goto done2;
                }
                uwsgi_response_sendfile_do(wsgi_req, fd, 0, 0);
done2:
                uwsgi_jvm_release_chars(j_filename, c_filename);
                uwsgi_jvm_local_unref(j_filename);
		return 0;
        }

        if (uwsgi_jvm_object_is_instance(body, ujvm.input_stream_class)) {
                uwsgi_jvm_consume_input_stream(wsgi_req, 8192, body);
		return 0;
        }

	return -1;
}

int uwsgi_jvm_iterator_to_response_headers(struct wsgi_request *wsgi_req, jobject headers) {
        int error = 0;
        while(uwsgi_jvm_iterator_hasNext(headers)) {
                jobject hh = NULL, h_key = NULL, h_value = NULL;

                hh = uwsgi_jvm_iterator_next(headers);

                if (!hh) { error = 1 ; goto clear;}
                h_key = uwsgi_jvm_getKey(hh);
                if (!h_key) { error = 1 ; goto clear;}
                h_value = uwsgi_jvm_getValue(hh);
                if (!h_value) { error = 1 ; goto clear;}


                if (!uwsgi_jvm_object_is_instance(h_key, ujvm.str_class)) {
                        uwsgi_log("headers key must be java/lang/String !!!\n");
                        error = 1 ; goto clear;
                }

                // check for string
                if (uwsgi_jvm_object_is_instance(h_value, ujvm.str_class)) {
                        char *c_h_key = uwsgi_jvm_str2c(h_key);
                        uint16_t c_h_keylen = uwsgi_jvm_strlen(h_key);
                        char *c_h_value = uwsgi_jvm_str2c(h_value);
                        uint16_t c_h_vallen = uwsgi_jvm_strlen(h_value);
                        int ret = uwsgi_response_add_header(wsgi_req, c_h_key, c_h_keylen, c_h_value, c_h_vallen);
                        uwsgi_jvm_release_chars(h_key, c_h_key);
                        uwsgi_jvm_release_chars(h_value, c_h_value);
                        if (ret) error = 1;
                        goto clear;
                }

		// check for string array
		if (uwsgi_jvm_object_is_instance(h_value, ujvm.str_array_class)) {
			size_t items = uwsgi_jvm_array_len(h_value);
			size_t i;
			for(i=0;i<items;i++) {
				jobject hh_value = uwsgi_jvm_array_get(h_value, i);
                                if (!uwsgi_jvm_object_is_instance(hh_value, ujvm.str_class)) {
                                        uwsgi_log("headers value must be java/lang/String !!!\n");
                                        uwsgi_jvm_local_unref(hh_value);
                                        error = 1 ; goto clear;
                                }
                                char *c_h_key = uwsgi_jvm_str2c(h_key);
                                uint16_t c_h_keylen = uwsgi_jvm_strlen(h_key);
                                char *c_h_value = uwsgi_jvm_str2c(hh_value);
                                uint16_t c_h_vallen = uwsgi_jvm_strlen(hh_value);
                                int ret = uwsgi_response_add_header(wsgi_req, c_h_key, c_h_keylen, c_h_value, c_h_vallen);
                                uwsgi_jvm_release_chars(h_key, c_h_key);
                                uwsgi_jvm_release_chars(hh_value, c_h_value);
                                uwsgi_jvm_local_unref(hh_value);
                                if (ret) { error = 1 ; goto clear;}
			}
			goto clear;
		}
		
                // check for iterable
                jobject values = uwsgi_jvm_auto_iterator(h_value);
                if (values) {
                        while(uwsgi_jvm_iterator_hasNext(values)) {
                                jobject hh_value = uwsgi_jvm_iterator_next(values);
                                if (!uwsgi_jvm_object_is_instance(hh_value, ujvm.str_class)) {
                                        uwsgi_log("headers value must be java/lang/String !!!\n");
                                        uwsgi_jvm_local_unref(hh_value);
                                        uwsgi_jvm_local_unref(values);
                                        error = 1 ; goto clear;
                                }
                                char *c_h_key = uwsgi_jvm_str2c(h_key);
                                uint16_t c_h_keylen = uwsgi_jvm_strlen(h_key);
                                char *c_h_value = uwsgi_jvm_str2c(hh_value);
                                uint16_t c_h_vallen = uwsgi_jvm_strlen(hh_value);
                                int ret = uwsgi_response_add_header(wsgi_req, c_h_key, c_h_keylen, c_h_value, c_h_vallen);
                                uwsgi_jvm_release_chars(h_key, c_h_key);
                                uwsgi_jvm_release_chars(hh_value, c_h_value);
                                uwsgi_jvm_local_unref(hh_value);
                                if (ret) { uwsgi_jvm_local_unref(values); error = 1 ; goto clear;}
                        }
                        uwsgi_jvm_local_unref(values);
                        goto clear;
                }
                uwsgi_log("unsupported header value !!! (must be java/lang/String or [java/lang/String)\n");
                error = 1;
clear:
                if (h_value)
                uwsgi_jvm_local_unref(h_value);
                if (h_key)
                uwsgi_jvm_local_unref(h_key);
                if (hh)
                uwsgi_jvm_local_unref(hh);
                if (error) return -1;;
        }
        return 0;
}


// returns 0 if ok, -1 on exception
int uwsgi_jvm_exception(void) {
	if ((*ujvm_env)->ExceptionCheck(ujvm_env)) {
        	(*ujvm_env)->ExceptionDescribe(ujvm_env);
        	(*ujvm_env)->ExceptionClear(ujvm_env);
		return -1;
	}
	return 0;
}

void uwsgi_jvm_clear_exception() {
	if ((*ujvm_env)->ExceptionCheck(ujvm_env)) {
		(*ujvm_env)->ExceptionClear(ujvm_env);
	}
}

int uwsgi_jvm_object_is_instance(jobject o, jclass c) {
	if ((*ujvm_env)->IsInstanceOf(ujvm_env, o, c)) {
		return 1;
	}
	return 0;
}

// load/find/get a class
jclass uwsgi_jvm_class(char *name) {

	jclass my_class = (*ujvm_env)->FindClass(ujvm_env, name);

	if (uwsgi_jvm_exception()) {
		return NULL;
	}

	return my_class;
}

// get the class of an object
jclass uwsgi_jvm_class_from_object(jobject o) {
	return (*ujvm_env)->GetObjectClass(ujvm_env, o);	
}


// return a java string of the object class name
jobject uwsgi_jvm_object_class_name(jobject o) {
	jclass c = uwsgi_jvm_class_from_object(o);
	jmethodID mid = uwsgi_jvm_get_method_id(c, "getClass", "()Ljava/lang/Class;");
	uwsgi_jvm_local_unref(c);
	if (!mid) return NULL;

	jobject oc = uwsgi_jvm_call_object(o, mid);
	if (!oc) return NULL;

	jclass c2 = uwsgi_jvm_class_from_object(oc);
        if (!c2) return NULL;	

	mid = uwsgi_jvm_get_method_id(c2, "getName", "()Ljava/lang/String;");
	uwsgi_jvm_local_unref(c2);
        if (!mid) return NULL;

	return uwsgi_jvm_call_object(oc, mid);
}

long uwsgi_jvm_int2c(jobject o) {
	static jmethodID mid = 0;
	if (!mid) {
		mid = uwsgi_jvm_get_method_id(ujvm.int_class, "intValue", "()I");
		if (!mid) return -1 ;
	}
	long value = (*ujvm_env)->CallIntMethod(ujvm_env, o, mid);
	if (uwsgi_jvm_exception()) {
		return -1;
	}
	return value;
}

long uwsgi_jvm_long2c(jobject o) {
        static jmethodID mid = 0;
        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.long_class, "longValue", "()J");
                if (!mid) return -1;
        }
        long value = (*ujvm_env)->CallLongMethod(ujvm_env, o, mid);
        if (uwsgi_jvm_exception()) {
                return -1;
        }
        return value;
}


long uwsgi_jvm_number2c(jobject o) {
	if (uwsgi_jvm_object_is_instance(o, ujvm.int_class)) {
		return uwsgi_jvm_int2c(o);
	}

	if (uwsgi_jvm_object_is_instance(o, ujvm.long_class)) {
                return uwsgi_jvm_long2c(o);
        }

	return -1;
}

size_t uwsgi_jvm_array_len(jobject o) {
	jsize len = (*ujvm_env)->GetArrayLength(ujvm_env, o);
	if (uwsgi_jvm_exception()) {
		return 0;
	}
	return len;
}

jobject uwsgi_jvm_array_get(jobject o, long index) {
	jobject ret = (*ujvm_env)->GetObjectArrayElement(ujvm_env, o, index);
	if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return ret;
}

jobject uwsgi_jvm_bytearray(char *buf, size_t len) {
	jobject byte_buffer = (*ujvm_env)->NewByteArray(ujvm_env, len);
        if (!byte_buffer) return NULL;

	char *dbuf = (char *) (*ujvm_env)->GetByteArrayElements(ujvm_env, byte_buffer, JNI_FALSE);
	memcpy(dbuf, buf, len);
	(*ujvm_env)->ReleaseByteArrayElements(ujvm_env, byte_buffer, (jbyte *) dbuf, 0);
	return byte_buffer;
}

int uwsgi_jvm_consume_input_stream(struct wsgi_request *wsgi_req, size_t chunk, jobject o) {
	int ret = 0;
	jclass c = uwsgi_jvm_class_from_object(o);
	jmethodID mid_read = uwsgi_jvm_get_method_id(c, "read", "([B)I");
	if (!mid_read) {
		uwsgi_jvm_local_unref(c);
		return -1;
	}
	jmethodID mid_close = uwsgi_jvm_get_method_id(c, "close", "()V");
        if (!mid_close) {
                uwsgi_jvm_local_unref(c);
                return -1;
        }
	uwsgi_jvm_local_unref(c);

	// allocate the byte buffer
	jobject byte_buffer = (*ujvm_env)->NewByteArray(ujvm_env, chunk);
	if (!byte_buffer) return -1;

	// ok start reading from the input stream
	for(;;) {
		long len = (*ujvm_env)->CallIntMethod(ujvm_env, o, mid_read, byte_buffer);
		if ((*ujvm_env)->ExceptionCheck(ujvm_env)) {
			(*ujvm_env)->ExceptionClear(ujvm_env);
			break;
		}
		if (len <= 0) {
			break;
		}
		// get the body of the array
		char *buf = (char *) (*ujvm_env)->GetByteArrayElements(ujvm_env, byte_buffer, JNI_FALSE);
		if (!buf) { ret = -1; break; }
		//send
		if (uwsgi_response_write_body_do(wsgi_req, buf, len)) {
			(*ujvm_env)->ReleaseByteArrayElements(ujvm_env, byte_buffer, (jbyte *) buf, 0);
			ret = -1; break;
		}
		// release
		(*ujvm_env)->ReleaseByteArrayElements(ujvm_env, byte_buffer, (jbyte *) buf, 0);
	}

	uwsgi_jvm_local_unref(byte_buffer);
	// close the inputstream
	if (uwsgi_jvm_call(o, mid_close)) {
		return -1;
	}
	return ret;
}

// returns the method id, given the method name and its signature
jmethodID uwsgi_jvm_get_method_id(jclass cls, char *name, char *signature) {
	jmethodID mid = (*ujvm_env)->GetMethodID(ujvm_env, cls, name, signature);
	if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return mid;
}

// returns the method id, given the method name and its signature
jmethodID uwsgi_jvm_get_method_id_quiet(jclass cls, char *name, char *signature) {
        jmethodID mid = (*ujvm_env)->GetMethodID(ujvm_env, cls, name, signature);
	if ((*ujvm_env)->ExceptionCheck(ujvm_env)) {
                (*ujvm_env)->ExceptionClear(ujvm_env);
                return NULL;
        }
        return mid;
}

jmethodID uwsgi_jvm_get_static_method_id_quiet(jclass cls, char *name, char *signature) {
        jmethodID mid = (*ujvm_env)->GetStaticMethodID(ujvm_env, cls, name, signature);
        if ((*ujvm_env)->ExceptionCheck(ujvm_env)) {
                (*ujvm_env)->ExceptionClear(ujvm_env);
                return NULL;
        }
        return mid;
}

// returns the static method id, given the method name and its signature
jmethodID uwsgi_jvm_get_static_method_id(jclass cls, char *name, char *signature) {
	jmethodID mid = (*ujvm_env)->GetStaticMethodID(ujvm_env, cls, name, signature);
	if (uwsgi_jvm_exception()) {
		return NULL;
	}
	return mid;
}

jobject uwsgi_jvm_ref(jobject obj) {
	return (*ujvm_env)->NewGlobalRef(ujvm_env, obj);
}

void uwsgi_jvm_unref(jobject obj) {
	(*ujvm_env)->DeleteGlobalRef(ujvm_env, obj);
}

void uwsgi_jvm_local_unref(jobject obj) {
        (*ujvm_env)->DeleteLocalRef(ujvm_env, obj);
}

jobject uwsgi_jvm_list() {
        // optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.list_class, "<init>", "()V");
                if (!mid) return NULL;
        }

        jobject ll = (*ujvm_env)->NewObject(ujvm_env, ujvm.list_class, mid);
        if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return ll;
}


jobject uwsgi_jvm_hashmap() {
	// optimization
	static jmethodID mid = 0;

	if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.hashmap_class, "<init>", "()V");
		if (!mid) return NULL;
        }

	jobject hm = (*ujvm_env)->NewObject(ujvm_env, ujvm.hashmap_class, mid);
	if (uwsgi_jvm_exception()) {
		return NULL;
	}
	return hm;
}

int uwsgi_jvm_hashmap_put(jobject hm, jobject key, jobject value) {
	// optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.hashmap_class, "put", "(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;");
                if (!mid) return -1;
        }

	return uwsgi_jvm_call(hm, mid, key, value);
}

int uwsgi_jvm_list_add(jobject ll, jobject value) {
        // optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.list_class, "add", "(Ljava/lang/Object;)Z");
                if (!mid) return -1;
        }

        return uwsgi_jvm_call(ll, mid, value);
}

jobject uwsgi_jvm_hashmap_get(jobject hm, jobject key) {
        // optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.hashmap_class, "get", "(Ljava/lang/Object;)Ljava/lang/Object;");
                if (!mid) return NULL;
        }

        return uwsgi_jvm_call_object(hm, mid, key);
}

int uwsgi_jvm_hashmap_has(jobject hm, jobject key) {
        // optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.hashmap_class, "containsKey", "(Ljava/lang/Object;)Z");
                if (!mid) return 0;
        }

	if (uwsgi_jvm_call_bool(hm, mid, key)) {
		return 1;
	}
	return 0;
}

jobject uwsgi_jvm_iterator(jobject set) {
	// optimization
        static jmethodID mid = 0;
	if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.set_class, "iterator", "()Ljava/util/Iterator;");
                if (!mid) return 0;
        }
	return uwsgi_jvm_call_object(set, mid);
}

jobject uwsgi_jvm_auto_iterator(jobject o) {
	jclass c = uwsgi_jvm_class_from_object(o);
	if (!c) return NULL;
        jmethodID mid = uwsgi_jvm_get_method_id_quiet(c, "iterator", "()Ljava/util/Iterator;");
	uwsgi_jvm_local_unref(c);
        if (!mid) return NULL;
        return uwsgi_jvm_call_object(o, mid);
}

// returns a java string of the filaname
jobject uwsgi_jvm_filename(jobject o) {
	// optimization
        static jmethodID mid = 0;
        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.file_class, "getPath", "()Ljava/lang/String;");
                if (!mid) return 0;
        }
	return uwsgi_jvm_call_object(o, mid);
}

jobject uwsgi_jvm_getKey(jobject item) {
	jclass c = uwsgi_jvm_class_from_object(item);
	if (!c) return NULL;
	jmethodID mid = uwsgi_jvm_get_method_id(c, "getKey", "()Ljava/lang/Object;");
	uwsgi_jvm_local_unref(c);
	if (!mid) return NULL;
	return uwsgi_jvm_call_object(item, mid);
}

jobject uwsgi_jvm_getValue(jobject item) {
        jclass c = uwsgi_jvm_class_from_object(item);
        if (!c) return NULL;
        jmethodID mid = uwsgi_jvm_get_method_id(c, "getValue", "()Ljava/lang/Object;");
	uwsgi_jvm_local_unref(c);
        if (!mid) return NULL;
        return uwsgi_jvm_call_object(item, mid);
}

int uwsgi_jvm_iterator_hasNext(jobject iterator) {
	// optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.iterator_class, "hasNext", "()Z");
                if (!mid) return 0;
        }

        if (uwsgi_jvm_call_bool(iterator, mid)) {
		return 1;
	}
	return 0;
}

jobject uwsgi_jvm_iterator_next(jobject iterator) {
        // optimization
        static jmethodID mid = 0;

        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.iterator_class, "next", "()Ljava/lang/Object;");
                if (!mid) return NULL;
        }

        return uwsgi_jvm_call_object(iterator, mid);
}

jobject uwsgi_jvm_request_body_input_stream() {
	static jmethodID mid = 0;
        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.request_body_class, "<init>", "()V");
                if (!mid) return NULL;
        }
        jobject o = (*ujvm_env)->NewObject(ujvm_env, ujvm.request_body_class, mid);
        if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return o;
}

jobject uwsgi_jvm_num(long num) {
	static jmethodID mid = 0;
	if (!mid) {
		mid = uwsgi_jvm_get_method_id(ujvm.int_class, "<init>", "(I)V");
		if (!mid) return NULL;
	}
	jobject o = (*ujvm_env)->NewObject(ujvm_env, ujvm.int_class, mid, num);
	if (uwsgi_jvm_exception()) {
                return NULL;
        }
	return o;
}

jobject uwsgi_jvm_bool(long b) {
        static jmethodID mid = 0;
        if (!mid) {
                mid = uwsgi_jvm_get_method_id(ujvm.int_class, "<init>", "(I)V");
                if (!mid) return NULL;
        }
        jobject o = (*ujvm_env)->NewObject(ujvm_env, ujvm.bool_class, mid, b);
        if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return o;
}

jobject uwsgi_jvm_str(char *str, size_t len) {
	jobject new_str;
	if (len > 0) {
		char *tmp = uwsgi_concat2n(str, len, "", 0);
		new_str = (*ujvm_env)->NewStringUTF(ujvm_env, tmp);	
		free(tmp);
	}
	else {
		new_str = (*ujvm_env)->NewStringUTF(ujvm_env, str);
	}
	
	return new_str;
}

int uwsgi_jvm_call_static(jclass c, jmethodID mid, ...) {
	va_list args;
	va_start(args, mid);
	(*ujvm_env)->CallStaticVoidMethodV(ujvm_env, c, mid, args);
	va_end(args);
        return uwsgi_jvm_exception();
}

int uwsgi_jvm_call(jobject o, jmethodID mid, ...) {
	va_list args;
	va_start(args, mid);
        (*ujvm_env)->CallVoidMethodV(ujvm_env, o, mid, args);
	va_end(args);
        return uwsgi_jvm_exception();
}

jobject uwsgi_jvm_call_object_static(jclass c, jmethodID mid, ...) {
        va_list args;
        va_start(args, mid);
        jobject ret = (*ujvm_env)->CallStaticObjectMethodV(ujvm_env, c, mid, args);
        va_end(args);
        if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return ret;
}


jobject uwsgi_jvm_call_object(jobject o, jmethodID mid, ...) {
	va_list args;
	va_start(args, mid);
        jobject ret = (*ujvm_env)->CallObjectMethodV(ujvm_env, o, mid, args);
	va_end(args);
        if (uwsgi_jvm_exception()) {
                return NULL;
        }
        return ret;
}

int uwsgi_jvm_call_bool(jobject o, jmethodID mid, ...) {
        va_list args;
        va_start(args, mid);
        int ret = (*ujvm_env)->CallBooleanMethodV(ujvm_env, o, mid, args);
        va_end(args);
        if (uwsgi_jvm_exception()) {
                return 0;
        }
        return ret;
}


jobject uwsgi_jvm_call_objectA(jobject o, jmethodID mid, jvalue *args) {
	jobject ret = (*ujvm_env)->CallObjectMethodA(ujvm_env, o, mid, args);
	if (uwsgi_jvm_exception()) {
		return NULL;
	}	
	return ret;
}

void uwsgi_jvm_throw(char *message) {
	(*ujvm_env)->ThrowNew(ujvm_env, ujvm.runtime_exception, message);
}

void uwsgi_jvm_throw_io(char *message) {
        (*ujvm_env)->ThrowNew(ujvm_env, ujvm.io_exception, message);
}

static int uwsgi_jvm_init(void) {

	return 0;
}

static void uwsgi_jvm_create(void) {


        ujvm.vm_args.version = JNI_VERSION_1_2;
        JNI_GetDefaultJavaVMInitArgs(&ujvm.vm_args);

	JavaVMOption *options;

	struct uwsgi_string_list *usl = ujvm.opts;
	int opt_count = 1;
	while(usl) {
		opt_count++;
		usl = usl->next;
	}

	options = uwsgi_calloc(sizeof(JavaVMOption) * opt_count);

        options[0].optionString = "-Djava.class.path=.";

        char *old_cp = NULL ;
        struct uwsgi_string_list *cp = ujvm.classpath;
        while(cp) {
                if (old_cp) {
                        options[0].optionString = uwsgi_concat3(old_cp, ":", cp->value);
                        free(old_cp);
                }
                else {
                        options[0].optionString = uwsgi_concat3(options[0].optionString, ":", cp->value);
                }
                old_cp = options[0].optionString ;
                cp = cp->next;
        }

	usl = ujvm.opts;
	opt_count = 1;
	while(usl) {
		options[opt_count].optionString = usl->value;
		opt_count++;
		usl = usl->next;
	}
	
        ujvm.vm_args.options  = options;
        ujvm.vm_args.nOptions = opt_count;

	JNIEnv  *env;
	if (pthread_key_create(&ujvm.env, NULL)) {
        	uwsgi_error("pthread_key_create()");
                exit(1);
        }

	if (JNI_CreateJavaVM(&ujvm.vm, (void **) &env, &ujvm.vm_args)) {
		uwsgi_log("unable to initialize the JVM\n");
		exit(1);
	}

	pthread_setspecific(ujvm.env, env);

	char *java_version = NULL;
	jvmtiEnv *jvmti;
	if ((*ujvm.vm)->GetEnv(ujvm.vm, (void **)&jvmti, JVMTI_VERSION) == JNI_OK) {
		(*jvmti)->GetSystemProperty(jvmti, "java.vm.version", &java_version);
	}

	if (uwsgi.mywid > 0) {
		if (java_version) {
			uwsgi_log("JVM %s initialized at %p (worker: %d pid: %d)\n", java_version, ujvm_env, uwsgi.mywid, (int) uwsgi.mypid);
		}
		else {
			uwsgi_log("JVM initialized at %p (worker: %d pid: %d)\n", ujvm_env, uwsgi.mywid, (int) uwsgi.mypid);
		}
	}

	ujvm.str_class = uwsgi_jvm_class("java/lang/String");
	if (!ujvm.str_class) exit(1);

	ujvm.str_array_class = uwsgi_jvm_class("[Ljava/lang/String;");
	if (!ujvm.str_array_class) exit(1);

	ujvm.int_class = uwsgi_jvm_class("java/lang/Integer");
	if (!ujvm.int_class) exit(1);

	ujvm.bool_class = uwsgi_jvm_class("java/lang/Boolean");
	if (!ujvm.bool_class) exit(1);

	ujvm.long_class = uwsgi_jvm_class("java/lang/Long");
	if (!ujvm.long_class) exit(1);

	ujvm.byte_class = uwsgi_jvm_class("java/lang/Byte");
	if (!ujvm.byte_class) exit(1);

	ujvm.bytearray_class = uwsgi_jvm_class("[B");
	if (!ujvm.bytearray_class) exit(1);

	ujvm.file_class = uwsgi_jvm_class("java/io/File");
	if (!ujvm.file_class) exit(1);

	ujvm.input_stream_class = uwsgi_jvm_class("java/io/InputStream");
	if (!ujvm.input_stream_class) exit(1);

	ujvm.hashmap_class = uwsgi_jvm_class("java/util/HashMap");
	if (!ujvm.hashmap_class) exit(1);

	ujvm.list_class = uwsgi_jvm_class("java/util/ArrayList");
	if (!ujvm.list_class) exit(1);

	ujvm.set_class = uwsgi_jvm_class("java/util/Set");
	if (!ujvm.set_class) exit(1);

	ujvm.iterator_class = uwsgi_jvm_class("java/util/Iterator");
	if (!ujvm.iterator_class) exit(1);

	ujvm.runtime_exception = uwsgi_jvm_class("java/lang/RuntimeException");
	if (!ujvm.runtime_exception) exit(1);

	ujvm.io_exception = uwsgi_jvm_class("java/io/IOException");
	if (!ujvm.io_exception) exit(1);

	jclass uwsgi_class = uwsgi_jvm_class("uwsgi");
	if (!uwsgi_class) {
		exit(1);
	}

	/*
		start filling uwsgi.opt
	*/
	jfieldID opt_fid = (*ujvm_env)->GetStaticFieldID(ujvm_env, uwsgi_class, "opt", "Ljava/util/HashMap;");
	if (uwsgi_jvm_exception()) {
                exit(1);
        }
	jobject opt_hm = uwsgi_jvm_hashmap();	
	int j;
	for (j = 0; j < uwsgi.exported_opts_cnt; j++) {
		jstring j_opt_key = uwsgi_jvm_str(uwsgi.exported_opts[j]->key, 0);
		if (uwsgi_jvm_hashmap_has(opt_hm, (jobject) j_opt_key)) {
			jobject j_opt_value = uwsgi_jvm_hashmap_get(opt_hm, (jobject) j_opt_key);
			if (uwsgi_jvm_object_is_instance(j_opt_value, ujvm.list_class)) {
				if (uwsgi.exported_opts[j]->value == NULL) {
                                        uwsgi_jvm_list_add(j_opt_value, uwsgi_jvm_bool(JNI_TRUE));
                                }
                                else {
                                        uwsgi_jvm_list_add(j_opt_value, uwsgi_jvm_str(uwsgi.exported_opts[j]->value, 0));
                                }	
			}
			else {
				jobject ll = uwsgi_jvm_list();
				uwsgi_jvm_list_add(ll, j_opt_value);
				if (uwsgi.exported_opts[j]->value == NULL) {
					uwsgi_jvm_list_add(ll, uwsgi_jvm_bool(JNI_TRUE));
				}
				else {
					uwsgi_jvm_list_add(ll, uwsgi_jvm_str(uwsgi.exported_opts[j]->value, 0));
				}
				uwsgi_jvm_hashmap_put(opt_hm, j_opt_key, ll);
			}
		}
		else {
			if (uwsgi.exported_opts[j]->value == NULL) {
				uwsgi_jvm_hashmap_put(opt_hm, j_opt_key, uwsgi_jvm_bool(JNI_TRUE));
			}
			else {
				uwsgi_jvm_hashmap_put(opt_hm, j_opt_key, uwsgi_jvm_str(uwsgi.exported_opts[j]->value, 0));
			}
		}
	}
	(*ujvm_env)->SetStaticObjectField(ujvm_env, uwsgi_class, opt_fid, opt_hm);
	

	(*ujvm_env)->RegisterNatives(ujvm_env, uwsgi_class, uwsgi_jvm_api_methods, sizeof(uwsgi_jvm_api_methods)/sizeof(uwsgi_jvm_api_methods[0]));
	if (uwsgi_jvm_exception()) {
		exit(1);
	}

	jclass uwsgi_signal_handler_class = uwsgi_jvm_class("uwsgi$SignalHandler");
	if (!uwsgi_signal_handler_class) exit(1);
	ujvm.api_signal_handler_mid = uwsgi_jvm_get_method_id(uwsgi_signal_handler_class, "function", "(I)V");
	if (!ujvm.api_signal_handler_mid) exit(1);

	jclass uwsgi_rpc_function_class = uwsgi_jvm_class("uwsgi$RpcFunction");
	if (!uwsgi_rpc_function_class) exit(1);
	ujvm.api_rpc_function_mid = uwsgi_jvm_get_method_id(uwsgi_rpc_function_class, "function", "([Ljava/lang/String;)Ljava/lang/String;");
	if (!ujvm.api_rpc_function_mid) exit(1);

	ujvm.request_body_class = uwsgi_jvm_class("uwsgi$RequestBody");
	if (!ujvm.request_body_class) exit(1);

	(*ujvm_env)->RegisterNatives(ujvm_env, ujvm.request_body_class, uwsgi_jvm_request_body_methods, sizeof(uwsgi_jvm_request_body_methods)/sizeof(uwsgi_jvm_request_body_methods[0]));
	if (uwsgi_jvm_exception()) {
		exit(1);
	}

	usl = ujvm.main_classes;
	while(usl) {
		jclass c = uwsgi_jvm_class(usl->value);
		if (!c) {
			exit(1);
		}
		jmethodID mid = uwsgi_jvm_get_static_method_id_quiet(c, "main", "([Ljava/lang/String;)V");
		if (mid) {
			jobject j_args = (*ujvm_env)->NewObjectArray(ujvm_env, 0, ujvm.str_class, NULL);
			if (uwsgi_jvm_call_static(c, mid, j_args)) {
                        	exit(1);
			}
			uwsgi_jvm_local_unref(j_args);
		}
		else {
			mid = uwsgi_jvm_get_static_method_id(c, "main", "()V");
			if (!mid) {
				uwsgi_log("unable to find main() method in class \"%s\"\n", usl->value);
				exit(1);
			}
			if (uwsgi_jvm_call_static(c, mid)) {
				exit(1);
			}
		}
		usl = usl->next;
	}

	usl = ujvm.classes;
	while(usl) {
		uwsgi_jvm_class(usl->value);
		usl = usl->next;
	}

	// load request_handlers setup functions
	int i;
	for(i=0;i<UMAX8;i++) {
		if (ujvm.request_handlers_setup[i]) {
			ujvm.request_handlers_setup[i]();
		}
	}

}

// get the raw body of a java string
char *uwsgi_jvm_str2c(jobject o) {
	return (char *) (*ujvm_env)->GetStringUTFChars(ujvm_env, o, JNI_FALSE);
}

// get c from bytearray
char *uwsgi_jvm_bytearray2c(jobject o) {
	return (char *) (*ujvm_env)->GetByteArrayElements(ujvm_env, o, JNI_FALSE);
}

// return the size of a java string (UTF8)
size_t uwsgi_jvm_strlen(jobject obj) {
	return (*ujvm_env)->GetStringUTFLength(ujvm_env, obj);
}

static int uwsgi_jvm_signal_handler(uint8_t signum, void *handler) {
	long l_signum = signum;
	return uwsgi_jvm_call(handler, ujvm.api_signal_handler_mid, (void *) l_signum);
}

// route request to the specific JVM plugin (identified by modifier2)
static int uwsgi_jvm_request(struct wsgi_request *wsgi_req) {
	uint8_t modifier2 = wsgi_req->uh->modifier2;
	if (!ujvm.request_handlers[modifier2]) {
		uwsgi_log("unable to find JVM request handler %u\n", modifier2);
		return -1;
	}

	/* Standard JVM request */
        if (!wsgi_req->uh->pktsize) {
                uwsgi_log("Empty JVM request. skip.\n");
                return -1;
        }

        if (uwsgi_parse_vars(wsgi_req)) {
                return -1;
        }

	return ujvm.request_handlers[modifier2](wsgi_req);
}

void uwsgi_jvm_release_chars(jobject o, char *str) {
	(*ujvm_env)->ReleaseStringUTFChars(ujvm_env, o, str);
}

void uwsgi_jvm_release_bytearray(jobject o, char *str) {
	(*ujvm_env)->ReleaseByteArrayElements(ujvm_env, o, (jbyte *)str, 0);
}

static uint64_t uwsgi_jvm_rpc(void *func, uint8_t argc, char **argv, uint16_t argvs[], char **buffer) {
	jvalue args[1];
	jobject str_array = (*ujvm_env)->NewObjectArray(ujvm_env, argc, ujvm.str_class, NULL);
	if (!str_array) return 0;
	uint8_t i;
	for(i=0;i<argc;i++) {
		jobject j_arg = uwsgi_jvm_str(argv[i], argvs[i]);
		(*ujvm_env)->SetObjectArrayElement(ujvm_env, str_array, i, j_arg);
		uwsgi_jvm_local_unref(j_arg);
	}
	args[0].l = str_array;
	jobject ret = uwsgi_jvm_call_objectA(func, ujvm.api_rpc_function_mid, args);
	uwsgi_jvm_local_unref(str_array);
	if (ret == NULL) {
		return 0;
	}
	size_t rlen = uwsgi_jvm_strlen(ret);
	if (rlen > 0) {
		*buffer = uwsgi_malloc(rlen);
		char *b = uwsgi_jvm_str2c(ret);
		memcpy(*buffer, b, rlen);
		uwsgi_jvm_release_chars(ret, b);
		uwsgi_jvm_local_unref(ret);
		return rlen;
	}
	uwsgi_jvm_local_unref(ret);
	return 0;
}

static void uwsgi_jvm_init_thread(int coreid) {
	JNIEnv *env;
	(*ujvm.vm)->AttachCurrentThread(ujvm.vm, (void **) &env, NULL);
	pthread_setspecific(ujvm.env, env);
}

static void uwsgi_jvm_after_request(struct wsgi_request *wsgi_req) {
	log_request(wsgi_req);
}

struct uwsgi_plugin jvm_plugin = {
	.name = "jvm",
	.modifier1 = 8,

	.request = uwsgi_jvm_request,
	.after_request = uwsgi_jvm_after_request,

	.init = uwsgi_jvm_init,
	.options = uwsgi_jvm_options,

	.post_fork = uwsgi_jvm_create,

	.signal_handler = uwsgi_jvm_signal_handler,
	.rpc = uwsgi_jvm_rpc,

	.init_thread = uwsgi_jvm_init_thread,
};