X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/728b3d40a4cc988c5007fb695c57964c517ba05f..eb6d30291e95f07e908b5c3534e66e73b8499be7:/src/bindings/java/jmsg_process.cpp diff --git a/src/bindings/java/jmsg_process.cpp b/src/bindings/java/jmsg_process.cpp index 3181faf080..2ed2a9234c 100644 --- a/src/bindings/java/jmsg_process.cpp +++ b/src/bindings/java/jmsg_process.cpp @@ -51,12 +51,6 @@ void jprocess_bind(jobject jprocess, msg_process_t process, JNIEnv * env) env->SetLongField(jprocess, jprocess_field_Process_bind, (intptr_t)process); } -jstring jprocess_get_name(jobject jprocess, JNIEnv * env) -{ - jstring jname = (jstring) env->GetObjectField(jprocess, jprocess_field_Process_name); - return (jstring) env->NewGlobalRef(jname); -} - JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_nativeInit(JNIEnv *env, jclass cls) { jclass jprocess_class_Process = env->FindClass("org/simgrid/msg/Process"); xbt_assert(jprocess_class_Process, "Native initialization of msg/Process failed. Please report that bug"); @@ -72,50 +66,18 @@ JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_nativeInit(JNIEnv *env, jcla "Native initialization of msg/Process failed. Please report that bug"); } -JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_create(JNIEnv * env, jobject jprocess_arg, jobject jhostname) +JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_create(JNIEnv* env, jobject jprocess_arg, jobject jhost) { - jobject jprocess; /* the global reference to the java process instance */ - jstring jname; /* the name of the java process instance */ - msg_process_t process; /* the native process to create */ - msg_host_t host; /* Where that process lives */ - - - /* get the name of the java process */ - jname = jprocess_get_name(jprocess_arg, env); - if (!jname) { - jxbt_throw_null(env, xbt_strdup("Process name cannot be nullptr")); - return; - } - const char* name = env->GetStringUTFChars(jname, 0); - - /* bind/retrieve the msg host */ - const char* hostname = env->GetStringUTFChars((jstring)jhostname, 0); - host = MSG_host_by_name(hostname); - if (!(host)) { /* not bound */ - jxbt_throw_host_not_found(env, hostname); - return; - } - env->ReleaseStringUTFChars((jstring)jhostname, hostname); - /* create a global java process instance */ - jprocess = jprocess_ref(jprocess_arg, env); - if (!jprocess) { - jxbt_throw_jni(env, "Can't get a global ref to the java process"); - return; - } + jobject jprocess = jprocess_ref(jprocess_arg, env); /* Actually build the MSG process */ - process = MSG_process_create_with_environment(name, [](int argc, char** argv) -> int { - smx_actor_t process = SIMIX_process_self(); - // This is the jprocess passed as environment. - // It would be simpler if we could use a closure. - jobject jprocess = (jobject) MSG_process_get_data(process); - simgrid::kernel::context::java_main_jprocess(jprocess); - return 0; - }, jprocess, - host, - /*argc, argv, properties*/ - 0, nullptr, nullptr); + jstring jname = (jstring)env->GetObjectField(jprocess, jprocess_field_Process_name); + const char* name = env->GetStringUTFChars(jname, 0); + msg_process_t process = MSG_process_create_from_stdfunc( + name, [jprocess]() -> void { simgrid::kernel::context::java_main_jprocess(jprocess); }, + /*data*/ nullptr, jhost_get_native(env, jhost), /* properties*/ nullptr); + env->ReleaseStringUTFChars(jname, name); /* bind the java process instance to the native process */ jprocess_bind(jprocess, process, env); @@ -127,10 +89,6 @@ JNIEXPORT void JNICALL Java_org_simgrid_msg_Process_create(JNIEnv * env, jobject /* sets the PID and the PPID of the process */ env->SetIntField(jprocess, jprocess_field_Process_pid,(jint) MSG_process_get_PID(process)); env->SetIntField(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,nullptr, (jstring)jhostname); - - env->SetObjectField(jprocess, jprocess_field_Process_host, jhost); } JNIEXPORT jint JNICALL Java_org_simgrid_msg_Process_killAll(JNIEnv * env, jclass cls, jint jresetPID)