X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/25fa04f8ceaf4b43a87d0df425073ec22f7b1d9e..0b7177aaa933483692b39ba8ed330f531f204fac:/src/jmsg_process.c diff --git a/src/jmsg_process.c b/src/jmsg_process.c index 85c476f279..1fa964ce93 100644 --- a/src/jmsg_process.c +++ b/src/jmsg_process.c @@ -11,9 +11,19 @@ #include "jmsg_host.h" #include "jxbt_utilities.h" #include "smx_context_java.h" +#include "smx_context_cojava.h" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(jmsg); +JNIEXPORT void JNICALL +Java_org_simgrid_msg_Process_exit(JNIEnv *env, jobject jprocess) { + if (smx_factory_initializer_to_use == SIMIX_ctx_cojava_factory_init) { + m_process_t process = jprocess_to_native_process(jprocess, env); + smx_context_t context = MSG_process_get_smx_ctx(process); + smx_ctx_cojava_stop(context); + } +} + jobject native_to_java_process(m_process_t process) { return ((smx_ctx_java_t)MSG_process_get_smx_ctx(process))->jprocess; @@ -43,7 +53,7 @@ m_process_t jprocess_to_native_process(jobject jprocess, JNIEnv * env) void jprocess_bind(jobject jprocess, m_process_t process, JNIEnv * env) { - (*env)->SetLongField(env, jprocess, jprocess_field_Process_bind, (jlong) (long) (process)); + (*env)->SetLongField(env, jprocess, jprocess_field_Process_bind, (jlong)(process)); } jlong jprocess_get_id(jobject jprocess, JNIEnv * env) @@ -137,10 +147,9 @@ Java_org_simgrid_msg_Process_create(JNIEnv * env, (xbt_main_func_t) jprocess, /*data*/ jprocess, host, - (double)jkill, /* kill time */ /*argc, argv, properties*/ 0,NULL,NULL); - + MSG_process_set_kill_time(process, (double)jkill); MSG_process_set_data(process,&process); /* bind the java process instance to the native process */ jprocess_bind(jprocess, process, env); @@ -275,13 +284,7 @@ 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_error_t rv; TRY { rv = MSG_process_sleep((double)jseconds); } @@ -332,3 +335,6 @@ Java_org_simgrid_msg_Process_migrate(JNIEnv * env, /* change the host java side */ (*env)->SetObjectField(env, jprocess, jprocess_field_Process_host, jhost); } + + +