clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-07 06:06:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

implemented read() method for jvm input stream

Browse Source
This commit is contained in:
Unbit
2013-03-06 14:26:52 +01:00
parent 5902749f9d
commit 37010c04ca
2 changed files with 34 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/jvm/jvm.h
+3
View File
@@ -25,7 +25,9 @@ struct uwsgi_jvm {
jclass hashmap_class;
jclass set_class;
jclass iterator_class;
jclass runtime_exception;
jclass io_exception;
jmethodID api_signal_handler_mid;
jmethodID api_rpc_function_mid;
@@ -47,6 +49,7 @@ int uwsgi_jvm_exception(void);
char *uwsgi_jvm_str2c(jobject);
void uwsgi_jvm_throw(char *);
void uwsgi_jvm_throw_io(char *);
jobject uwsgi_jvm_call_objectA(jobject o, jmethodID mid, jvalue *);
void uwsgi_jvm_release_chars(jobject, char *);
plugins/jvm/jvm_plugin.c
+31
View File
@@ -52,6 +52,25 @@ static JNINativeMethod uwsgi_jvm_api_methods[] = {
{"worker_id", "()I", (void *) &uwsgi_jvm_api_worker_id},
};
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;
}
static JNINativeMethod uwsgi_jvm_request_body_methods[] = {
{"read", "()I", (void *) &uwsgi_jvm_request_body_read},
};
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},
@@ -485,6 +504,10 @@ 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;
@@ -592,6 +615,9 @@ static void uwsgi_jvm_create(void) {
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);
@@ -614,6 +640,11 @@ static void uwsgi_jvm_create(void) {
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);