X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/4a59f17b3e539abe1a63c83a1645a28321d8de2e..12fdd5a6725a42b1c3baf51e9927462ae5b6db44:/src/jmsg.c diff --git a/src/jmsg.c b/src/jmsg.c index e876df3729..9f7490584f 100644 --- a/src/jmsg.c +++ b/src/jmsg.c @@ -9,7 +9,7 @@ #include #include #include - +#include #include "smx_context_java.h" @@ -46,464 +46,8 @@ JNIEnv *get_current_thread_env(void) JNIEnv *env; (*__java_vm)->AttachCurrentThread(__java_vm, (void **) &env, NULL); - return env; } - -/* - * The MSG process connected functions implementation. - */ - -JNIEXPORT void JNICALL -Java_org_simgrid_msg_MsgNative_processCreate(JNIEnv * env, jclass cls, - 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,cls=%p,jproc=%p,host=%s)", - env, cls, 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); - -} - -JNIEXPORT void JNICALL -Java_org_simgrid_msg_MsgNative_processSuspend(JNIEnv * env, jclass cls, - 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_simulatedSleep(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_MsgNative_processResume(JNIEnv * env, jclass cls, - 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_MsgNative_processIsSuspended(JNIEnv * env, jclass cls, - 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_MsgNative_processKill(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 jobject JNICALL -Java_org_simgrid_msg_MsgNative_processGetHost(JNIEnv * env, jclass cls, - jobject jprocess) -{ - /* get the native instances from the java ones */ - m_process_t process = jprocess_to_native_process(jprocess, env); - m_host_t host; - - if (!process) { - jxbt_throw_notbound(env, "process", jprocess); - return NULL; - } - - host = MSG_process_get_host(process); - jobject res = (jobject)MSG_host_get_data(host); - - if (!res) { - XBT_INFO("Binding error for host %s ",MSG_host_get_name(host)); - jxbt_throw_jni(env, bprintf("Binding error for host %s ",MSG_host_get_name(host))); - return NULL; - } - - /* return the global reference to the java host instance */ - return res; - -} - -JNIEXPORT jobject JNICALL -Java_org_simgrid_msg_MsgNative_processFromPID(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; - } - - if (!native_to_java_process(process)) { - jxbt_throw_jni(env, "SIMIX_process_get_jprocess() failed"); - return NULL; - } - - return (jobject) (native_to_java_process(process)); -} - - -JNIEXPORT jint JNICALL -Java_org_simgrid_msg_MsgNative_processGetPID(JNIEnv * env, jclass cls, - jobject jprocess) -{ - m_process_t process = jprocess_to_native_process(jprocess, env); - - if (!process) { - jxbt_throw_notbound(env, "process", jprocess); - return 0; - } - - return (jint) MSG_process_get_PID(process); -} - - -JNIEXPORT jint JNICALL -Java_org_simgrid_msg_MsgNative_processGetPPID(JNIEnv * env, jclass cls, - jobject jprocess) -{ - m_process_t process = jprocess_to_native_process(jprocess, env); - - if (!process) { - jxbt_throw_notbound(env, "process", jprocess); - return 0; - } - - return (jint) MSG_process_get_PPID(process); -} - -JNIEXPORT jobject JNICALL -Java_org_simgrid_msg_MsgNative_processSelf(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_MsgNative_processMigrate(JNIEnv * env, jclass cls, - 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")); - -} - -JNIEXPORT void JNICALL -Java_org_simgrid_msg_MsgNative_processWaitFor(JNIEnv * env, jclass cls, - jdouble seconds) -{ - MSG_error_t rv = MSG_process_sleep((double) seconds); - - jxbt_check_res("MSG_process_sleep()", rv, MSG_HOST_FAILURE, - bprintf("while process was waiting for %f seconds", - (double) seconds)); - -} - - -/*************************************************************************************** - * The MSG host connected functions implementation. * - ***************************************************************************************/ - -JNIEXPORT jobject JNICALL -Java_org_simgrid_msg_MsgNative_hostGetByName(JNIEnv * env, jclass cls, - jstring jname) -{ - m_host_t host; /* native host */ - jobject jhost; /* global reference to the java host instance returned */ - - /* get the C string from the java string */ - const char *name = (*env)->GetStringUTFChars(env, jname, 0); - XBT_DEBUG("Looking for host '%s'",name); - /* get the host by name (the hosts are created during the grid resolution) */ - host = MSG_get_host_by_name(name); - XBT_DEBUG("MSG gave %p as native host", host); - - if (!host) { /* invalid name */ - jxbt_throw_host_not_found(env, name); - (*env)->ReleaseStringUTFChars(env, jname, name); - return NULL; - } - (*env)->ReleaseStringUTFChars(env, jname, name); - - if (!MSG_host_get_data(host)) { /* native host not associated yet with java host */ - - /* Instantiate a new java host */ - jhost = jhost_new_instance(env); - - if (!jhost) { - jxbt_throw_jni(env, "java host instantiation failed"); - return NULL; - } - - /* get a global reference to the newly created host */ - jhost = jhost_ref(env, jhost); - - if (!jhost) { - jxbt_throw_jni(env, "new global ref allocation failed"); - return NULL; - } - - /* bind the java host and the native host */ - jhost_bind(jhost, host, env); - - /* the native host data field is set with the global reference to the - * java host returned by this function - */ - MSG_host_set_data(host, (void *) jhost); - } - - /* return the global reference to the java host instance */ - return (jobject) MSG_host_get_data(host); -} - -JNIEXPORT jstring JNICALL -Java_org_simgrid_msg_MsgNative_hostGetName(JNIEnv * env, jclass cls, - jobject jhost) -{ - m_host_t host = jhost_get_native(env, jhost); - const char* name; - - if (!host) { - jxbt_throw_notbound(env, "host", jhost); - return NULL; - } - - name = MSG_host_get_name(host); - if (!name) - xbt_die("This host has no name..."); - - return (*env)->NewStringUTF(env, name); -} - -JNIEXPORT jint JNICALL -Java_org_simgrid_msg_MsgNative_hostGetNumber(JNIEnv * env, jclass cls) -{ - xbt_dynar_t hosts = MSG_hosts_as_dynar(); - int nb_host = xbt_dynar_length(hosts); - xbt_dynar_free(&hosts); - return (jint) nb_host; -} - -JNIEXPORT jobject JNICALL -Java_org_simgrid_msg_MsgNative_hostSelf(JNIEnv * env, jclass cls) -{ - jobject jhost; - - m_host_t host = MSG_host_self(); - - if (!MSG_host_get_data(host)) { - /* the native host not yet associated with the java host instance */ - - /* instanciate a new java host instance */ - jhost = jhost_new_instance(env); - - if (!jhost) { - jxbt_throw_jni(env, "java host instantiation failed"); - return NULL; - } - - /* get a global reference to the newly created host */ - jhost = jhost_ref(env, jhost); - - if (!jhost) { - jxbt_throw_jni(env, "global ref allocation failed"); - return NULL; - } - - /* Bind & store it */ - jhost_bind(jhost, host, env); - MSG_host_set_data(host, (void *) jhost); - } else { - jhost = (jobject) MSG_host_get_data(host); - } - - return jhost; -} - -JNIEXPORT jdouble JNICALL -Java_org_simgrid_msg_MsgNative_hostGetSpeed(JNIEnv * env, jclass cls, - jobject jhost) -{ - m_host_t host = jhost_get_native(env, jhost); - - if (!host) { - jxbt_throw_notbound(env, "host", jhost); - return -1; - } - - return (jdouble) MSG_get_host_speed(host); -} - -JNIEXPORT jint JNICALL -Java_org_simgrid_msg_MsgNative_hostGetLoad(JNIEnv * env, jclass cls, - jobject jhost) -{ - m_host_t host = jhost_get_native(env, jhost); - - if (!host) { - jxbt_throw_notbound(env, "host", jhost); - return -1; - } - - return (jint) MSG_get_host_msgload(host); -} - - -JNIEXPORT jboolean JNICALL -Java_org_simgrid_msg_MsgNative_hostIsAvail(JNIEnv * env, jclass cls, - jobject jhost) -{ - m_host_t host = jhost_get_native(env, jhost); - - if (!host) { - jxbt_throw_notbound(env, "host", jhost); - return 0; - } - - return (jboolean) MSG_host_is_avail(host); -} - /*************************************************************************************** * Unsortable functions * ***************************************************************************************/ @@ -525,6 +69,8 @@ Java_org_simgrid_msg_Msg_init(JNIEnv * env, jclass cls, jobjectArray jargs) smx_factory_initializer_to_use = SIMIX_ctx_java_factory_init; + setlocale(LC_NUMERIC,"C"); + if (jargs) argc = (int) (*env)->GetArrayLength(env, jargs); @@ -589,13 +135,6 @@ JNIEXPORT void JNICALL bprintf ("unexpected error : MSG_clean() failed .. please report this bug ")); } - -JNIEXPORT jint JNICALL -Java_org_simgrid_msg_MsgNative_processKillAll(JNIEnv * env, jclass cls, - jint jresetPID) -{ - return (jint) MSG_process_killall((int) jresetPID); -} JNIEXPORT void JNICALL Java_org_simgrid_msg_Msg_createEnvironment(JNIEnv * env, jclass cls, @@ -610,21 +149,6 @@ Java_org_simgrid_msg_Msg_createEnvironment(JNIEnv * env, jclass cls, (*env)->ReleaseStringUTFChars(env, jplatformFile, platformFile); } -JNIEXPORT void JNICALL -Java_org_simgrid_msg_MsgNative_processExit(JNIEnv * env, jclass cls, - 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_Msg_info(JNIEnv * env, jclass cls, jstring js) { @@ -633,49 +157,6 @@ Java_org_simgrid_msg_Msg_info(JNIEnv * env, jclass cls, jstring js) (*env)->ReleaseStringUTFChars(env, js, s); } -JNIEXPORT jobjectArray JNICALL -Java_org_simgrid_msg_MsgNative_allHosts(JNIEnv * env, jclass cls_arg) -{ - int index; - jobjectArray jtable; - jobject jhost; - jstring jname; - m_host_t host; - - xbt_dynar_t table = MSG_hosts_as_dynar(); - int count = xbt_dynar_length(table); - - jclass cls = jxbt_get_class(env, "org/simgrid/msg/Host"); - - if (!cls) { - return NULL; - } - - jtable = (*env)->NewObjectArray(env, (jsize) count, cls, NULL); - - if (!jtable) { - jxbt_throw_jni(env, "Hosts table allocation failed"); - return NULL; - } - - for (index = 0; index < count; index++) { - host = xbt_dynar_get_as(table,index,m_host_t); - jhost = (jobject) (MSG_host_get_data(host)); - - if (!jhost) { - jname = (*env)->NewStringUTF(env, MSG_host_get_name(host)); - - jhost = - Java_org_simgrid_msg_MsgNative_hostGetByName(env, cls_arg, jname); - /* FIXME: leak of jname ? */ - } - - (*env)->SetObjectArrayElement(env, jtable, index, jhost); - } - xbt_dynar_free(&table); - return jtable; -} - JNIEXPORT void JNICALL Java_org_simgrid_msg_Msg_deployApplication(JNIEnv * env, jclass cls, jstring jdeploymentFile)