X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/95f8d2439ede822d33a1d491f53f4e80fc662941..7b2435d30a045a0c8c292c0fd98a2a2379a40fb3:/src/jmsg_process.c diff --git a/src/jmsg_process.c b/src/jmsg_process.c index 2a02b7f8e5..cba0649cf9 100644 --- a/src/jmsg_process.c +++ b/src/jmsg_process.c @@ -5,15 +5,25 @@ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ - #include "jmsg_process.h" + #include "jmsg.h" +#include "jmsg_host.h" #include "jxbt_utilities.h" #include "smx_context_java.h" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(jmsg); +static jfieldID jprocess_field_Process_host; +static jfieldID jprocess_field_Process_pid; +static jfieldID jprocess_field_Process_ppid; + +jobject native_to_java_process(m_process_t process) +{ + return ((smx_ctx_java_t)MSG_process_get_smx_ctx(process))->jprocess; +} + jobject jprocess_new_global_ref(jobject jprocess, JNIEnv * env) { return (*env)->NewGlobalRef(env, jprocess); @@ -27,7 +37,7 @@ void jprocess_delete_global_ref(jobject jprocess, JNIEnv * env) jboolean jprocess_is_alive(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "isAlive", "()Z"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "isAlive", "()Z"); if (!id) return 0; @@ -38,7 +48,7 @@ jboolean jprocess_is_alive(jobject jprocess, JNIEnv * env) void jprocess_join(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "join", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "join", "()V"); if (!id) return; @@ -49,7 +59,7 @@ void jprocess_join(jobject jprocess, JNIEnv * env) void jprocess_exit(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "interrupt", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "interrupt", "()V"); if (!id) return; @@ -60,7 +70,7 @@ void jprocess_exit(jobject jprocess, JNIEnv * env) void jprocess_yield(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "switchProcess", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "switchProcess", "()V"); if (!id) return; @@ -71,7 +81,7 @@ void jprocess_yield(jobject jprocess, JNIEnv * env) void jprocess_lock_mutex(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "lockMutex", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "lockMutex", "()V"); if (!id) return; @@ -82,7 +92,7 @@ void jprocess_lock_mutex(jobject jprocess, JNIEnv * env) void jprocess_unlock_mutex(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "unlockMutex", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "unlockMutex", "()V"); if (!id) return; @@ -94,7 +104,7 @@ void jprocess_unlock_mutex(jobject jprocess, JNIEnv * env) void jprocess_signal_cond(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "signalCond", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "signalCond", "()V"); if (!id) return; @@ -105,7 +115,7 @@ void jprocess_signal_cond(jobject jprocess, JNIEnv * env) void jprocess_wait_cond(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "waitCond", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "waitCond", "()V"); if (!id) return; @@ -117,19 +127,19 @@ void jprocess_wait_cond(jobject jprocess, JNIEnv * env) void jprocess_start(jobject jprocess, JNIEnv * env) { jmethodID id = - jxbt_get_smethod(env, "simgrid/msg/Process", "start", "()V"); + jxbt_get_smethod(env, "org/simgrid/msg/Process", "start", "()V"); if (!id) return; - DEBUG2("jprocess_start(jproc=%p,env=%p)", jprocess, env); + XBT_DEBUG("jprocess_start(jproc=%p,env=%p)", jprocess, env); (*env)->CallVoidMethod(env, jprocess, id); - DEBUG0("jprocess started"); + XBT_DEBUG("jprocess started"); } m_process_t jprocess_to_native_process(jobject jprocess, JNIEnv * env) { - jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J"); + jfieldID id = jxbt_get_sfield(env, "org/simgrid/msg/Process", "bind", "J"); if (!id) return NULL; @@ -139,8 +149,7 @@ m_process_t jprocess_to_native_process(jobject jprocess, JNIEnv * env) void jprocess_bind(jobject jprocess, m_process_t process, JNIEnv * env) { - jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J"); - + jfieldID id = jxbt_get_sfield(env, "org/simgrid/msg/Process", "bind", "J"); if (!id) return; @@ -149,7 +158,7 @@ void jprocess_bind(jobject jprocess, m_process_t process, JNIEnv * env) jlong jprocess_get_id(jobject jprocess, JNIEnv * env) { - jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "id", "J"); + jfieldID id = jxbt_get_sfield(env, "org/simgrid/msg/Process", "id", "J"); if (!id) return 0; @@ -159,7 +168,7 @@ jlong jprocess_get_id(jobject jprocess, JNIEnv * env) jstring jprocess_get_name(jobject jprocess, JNIEnv * env) { - jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "name", + jfieldID id = jxbt_get_sfield(env, "org/simgrid/msg/Process", "name", "Ljava/lang/String;"); jobject jname; @@ -174,7 +183,7 @@ jstring jprocess_get_name(jobject jprocess, JNIEnv * env) jboolean jprocess_is_valid(jobject jprocess, JNIEnv * env) { - jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J"); + jfieldID id = jxbt_get_sfield(env, "org/simgrid/msg/Process", "bind", "J"); if (!id) return JNI_FALSE; @@ -189,10 +198,12 @@ void jprocess_schedule(smx_context_t context) env = get_current_thread_env(); - id = jxbt_get_smethod(env, "simgrid/msg/Process", "schedule", "()V"); + id = jxbt_get_smethod(env, "org/simgrid/msg/Process", "schedule", "()V"); - if (!id) + if (!id) { + XBT_CRITICAL("Cannot find java method org/simgrid/msg/Process/schedule()V"); return; + } (*env)->CallVoidMethod(env, ((smx_ctx_java_t) context)->jprocess, id); } @@ -207,10 +218,278 @@ void jprocess_unschedule(smx_context_t context) env = get_current_thread_env(); - id = jxbt_get_smethod(env, "simgrid/msg/Process", "unschedule", "()V"); + id = jxbt_get_smethod(env, "org/simgrid/msg/Process", "unschedule", "()V"); if (!id) return; (*env)->CallVoidMethod(env, ((smx_ctx_java_t) context)->jprocess, id); } +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_nativeInit(JNIEnv *env, jclass cls) { + jclass jprocess_class_Process = (*env)->FindClass(env, "org/simgrid/msg/Process"); + + jprocess_field_Process_pid = jxbt_get_sfield(env, "org/simgrid/msg/Process", "pid", "I"); + jprocess_field_Process_ppid = jxbt_get_sfield(env, "org/simgrid/msg/Process", "ppid", "I"); + jprocess_field_Process_host = jxbt_get_jfield(env, jprocess_class_Process, "host", "Lorg/simgrid/msg/Host;"); + + if (!jprocess_class_Process || !jprocess_field_Process_pid || + !jprocess_field_Process_ppid || !jprocess_field_Process_host) { + jxbt_throw_native(env,bprintf("Can't find some fields in Java class. You should report this bug.")); + } +} +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_create(JNIEnv * env, + jobject jprocess_arg, + jobject jhostname) +{ + + + jobject jprocess; /* the global reference to the java process instance */ + jstring jname; /* the name of the java process instance */ + const char *name; /* the C name of the process */ + const char *hostname; + m_process_t process; /* the native process to create */ + m_host_t host; /* Where that process lives */ + + hostname = (*env)->GetStringUTFChars(env, jhostname, 0); + + XBT_DEBUG("Java_org_simgrid_msg_MsgNative_processCreate(env=%p,jproc=%p,host=%s)", + env, jprocess_arg, hostname); + + + /* get the name of the java process */ + jname = jprocess_get_name(jprocess_arg, env); + if (!jname) { + jxbt_throw_null(env, + xbt_strdup("Internal error: Process name cannot be NULL")); + return; + } + + /* bind/retrieve the msg host */ + host = MSG_get_host_by_name(hostname); + + if (!(host)) { /* not binded */ + jxbt_throw_host_not_found(env, hostname); + return; + } + + /* create a global java process instance */ + jprocess = jprocess_new_global_ref(jprocess_arg, env); + if (!jprocess) { + jxbt_throw_jni(env, "Can't get a global ref to the java process"); + return; + } + + /* build the C name of the process */ + name = (*env)->GetStringUTFChars(env, jname, 0); + name = xbt_strdup(name); + + /* Actually build the MSG process */ + process = MSG_process_create_with_environment(name, + (xbt_main_func_t) jprocess, + /*data*/ NULL, + host, + /* kill_time */-1, + /*argc, argv, properties*/ + 0,NULL,NULL); + + MSG_process_set_data(process,&process); + + /* release our reference to the process name (variable name becomes invalid) */ + //FIXME : This line should be uncommented but with mac it doesn't work. BIG WARNING + //(*env)->ReleaseStringUTFChars(env, jname, name); + (*env)->ReleaseStringUTFChars(env, jhostname, hostname); + + /* bind the java process instance to the native process */ + jprocess_bind(jprocess, process, env); + + /* sets the PID and the PPID of the process */ + (*env)->SetIntField(env, jprocess, jprocess_field_Process_pid,(jint) MSG_process_get_PID(process)); + (*env)->SetIntField(env, jprocess, jprocess_field_Process_ppid, (jint) MSG_process_get_PPID(process)); + /* sets the Host of the process */ + jobject jhost = Java_org_simgrid_msg_Host_getByName(env,NULL,jhostname); + + (*env)->SetObjectField(env, jprocess, jprocess_field_Process_host, jhost); +} + +JNIEXPORT jint JNICALL +Java_org_simgrid_msg_Process_killAll(JNIEnv * env, jclass cls, + jint jresetPID) +{ + return (jint) MSG_process_killall((int) jresetPID); +} + +JNIEXPORT jobject JNICALL +Java_org_simgrid_msg_Process_fromPID(JNIEnv * env, jclass cls, + jint PID) +{ + m_process_t process = MSG_process_from_PID(PID); + + if (!process) { + jxbt_throw_process_not_found(env, bprintf("PID = %d",(int) PID)); + return NULL; + } + + jobject jprocess = native_to_java_process(process); + + if (!jprocess) { + jxbt_throw_jni(env, "SIMIX_process_get_jprocess() failed"); + return NULL; + } + + return jprocess; +} + +JNIEXPORT jobject JNICALL +Java_org_simgrid_msg_Process_currentProcess(JNIEnv * env, jclass cls) +{ + m_process_t process = MSG_process_self(); + jobject jprocess; + + if (!process) { + jxbt_throw_jni(env, xbt_strdup("MSG_process_self() failed")); + return NULL; + } + + jprocess = native_to_java_process(process); + + if (!jprocess) + jxbt_throw_jni(env, xbt_strdup("SIMIX_process_get_jprocess() failed")); + + return jprocess; +} + +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_pause(JNIEnv * env, + jobject jprocess) +{ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + + /* try to suspend the process */ + MSG_error_t rv = MSG_process_suspend(process); + + jxbt_check_res("MSG_process_suspend()", rv, MSG_OK, + bprintf("unexpected error , please report this bug")); + +} +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_restart(JNIEnv * env, + jobject jprocess) +{ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + + /* try to resume the process */ + MSG_error_t rv = MSG_process_resume(process); + + jxbt_check_res("MSG_process_resume()", rv, MSG_OK, + bprintf("unexpected error , please report this bug")); +} +JNIEXPORT jboolean JNICALL +Java_org_simgrid_msg_Process_isSuspended(JNIEnv * env, + jobject jprocess) +{ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return 0; + } + + /* true is the process is suspended, false otherwise */ + return (jboolean) MSG_process_is_suspended(process); +} + +JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_sleep + (JNIEnv *env, jclass cls, jlong jmillis, jint jnanos) { + + double time = jmillis / 1000 + jnanos / 1000; + + MSG_error_t rv = MSG_process_sleep(time); + jxbt_check_res("MSG_process_sleep()", rv, MSG_OK, + bprintf("unexpected error , please report this bug")); +} +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_waitFor(JNIEnv * env, jobject jprocess, + jdouble jseconds) +{ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + MSG_error_t rv = MSG_process_sleep((double)jseconds); + + jxbt_check_res("MSG_process_sleep()", rv, MSG_OK, + bprintf("unexpected error , please report this bug")); + +} + +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_exit(JNIEnv * env, + jobject jprocess) +{ + + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + + smx_ctx_java_stop(MSG_process_get_smx_ctx(process)); +} + +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_kill(JNIEnv * env, jclass cls, + jobject jprocess) +{ + /* get the native instances from the java ones */ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + + /* kill the native process (this wrapper is call by the destructor of the java + * process instance) + */ + MSG_process_kill(process); +} +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_migrate(JNIEnv * env, + jobject jprocess, jobject jhost) +{ + m_process_t process = jprocess_to_native_process(jprocess, env); + + if (!process) { + jxbt_throw_notbound(env, "process", jprocess); + return; + } + + m_host_t host = jhost_get_native(env, jhost); + + if (!host) { + jxbt_throw_notbound(env, "host", jhost); + return; + } + + /* try to change the host of the process */ + MSG_error_t rv = MSG_process_migrate(process, host); + jxbt_check_res("MSG_process_migrate()", rv, MSG_OK, + bprintf("unexpected error , please report this bug")); + /* change the host java side */ + (*env)->SetObjectField(env, jprocess, jprocess_field_Process_host, jhost); +}