(process->simdata->s_process->context))->jprocess;
}
-
/*
* The MSG process connected functions implementation.
*/
}
/* try to suspend the process */
- if (MSG_OK != MSG_process_suspend(process))
- jxbt_throw_native(env, xbt_strdup("MSG_process_suspend() failed"));
+ 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
m_process_t process = jprocess_to_native_process(jprocess, env);
if (!process) {
- jxbt_throw_notbound(env, "process", jprocess);
+ jxbt_throw_notbound(env,"process", jprocess);
return;
}
/* try to resume the process */
- if (MSG_OK != MSG_process_resume(process))
- jxbt_throw_native(env, xbt_strdup("MSG_process_resume() failed"));
+ 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
host = MSG_process_get_host(process);
if (!host->data) {
- jxbt_throw_native(env, xbt_strdup("MSG_process_get_host() failed"));
+ jxbt_throw_jni(env, "MSG_process_get_host() failed");
return NULL;
}
Java_simgrid_msg_MsgNative_processWaitFor(JNIEnv * env, jclass cls,
jdouble seconds)
{
- if (MSG_OK != MSG_process_sleep((double) seconds))
- jxbt_throw_native(env,
- bprintf("MSG_process_change_host(%f) failed",
- (double) 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));
+
}
host = MSG_task_get_source(task);
if (!host->data) {
- jxbt_throw_native(env, xbt_strdup("MSG_task_get_source() failed"));
+ jxbt_throw_jni(env, "MSG_task_get_source() failed");
return NULL;
}
return;
}
- if (MSG_OK != MSG_task_cancel(ptask))
- jxbt_throw_native(env, xbt_strdup("MSG_task_cancel() failed"));
+ MSG_error_t rv = MSG_task_cancel(ptask);
+
+ jxbt_check_res("MSG_task_cancel()",rv,MSG_OK,
+ bprintf("unexpected error , please report this bug"));
}
JNIEXPORT jdouble JNICALL
return;
}
jtask = (jobject) task->data;
+
+ MSG_error_t rv = MSG_task_destroy(task);
+
+ jxbt_check_res("MSG_task_destroy()",rv,MSG_OK,
+ bprintf("unexpected error , please report this bug"));
- if (MSG_OK != MSG_task_destroy(task))
- jxbt_throw_native(env, xbt_strdup("MSG_task_destroy() failed"));
/* delete the global reference to the java task object */
jtask_delete_global_ref(jtask, env);
return;
}
- if (MSG_OK != MSG_task_execute(task))
- jxbt_throw_native(env, xbt_strdup("MSG_task_execute() failed"));
+ MSG_error_t rv = MSG_task_execute(task);
+
+ jxbt_check_res("MSG_task_execute()",rv,MSG_HOST_FAILURE|MSG_TASK_CANCELLED,
+ bprintf("while executing task %s", MSG_task_get_name(task)));
}
/***************************************************************************************
(*env)->ReleaseStringUTFChars(env, jalias, alias);
- /* throw the right exception corresponding to HostFailureException, TransferFailureException, TimeoutFailureException
- * Note: these exceptions must be created beforehand
- * then, you want to create some functions like jxbt_throw_notbound()
- * then, you must declare in the MsgNative stuff that these native functions can throw these exceptions
- */
- if (MSG_OK != rv)
- {
-
- if ( rv == MSG_TRANSFER_FAILURE )
- jxbt_throw_transfer_failure(env,MSG_task_get_name(task),alias);
-
- else if ( rv == MSG_HOST_FAILURE )
- jxbt_throw_host_failure(env,MSG_task_get_name(task),alias);
-
- else
- jxbt_throw_native(env, xbt_strdup("MSG_task_send_with_timeout() failed"));
-
- }
+ jxbt_check_res("MSG_task_send_with_timeout()",rv, MSG_HOST_FAILURE|MSG_TRANSFER_FAILURE|MSG_TIMEOUT,
+ bprintf("while sending task %s to mailbox %s", MSG_task_get_name(task),alias));
}
JNIEXPORT void JNICALL
(*env)->ReleaseStringUTFChars(env, jalias, alias);
- if (MSG_OK != rv)
- jxbt_throw_native(env, xbt_strdup("MSG_task_send_bounded() failed"));
+ jxbt_check_res("MSG_task_send_bounded()",rv, MSG_HOST_FAILURE|MSG_TRANSFER_FAILURE|MSG_TIMEOUT,
+ bprintf("while sending task %s to mailbox %s with max rate %f", MSG_task_get_name(task),alias,(double)jmaxRate));
+
}
JNIEXPORT jobject JNICALL
(*env)->ReleaseStringUTFChars(env, jalias, alias);
- if (MSG_OK != rv) {
- jxbt_throw_native(env, xbt_strdup("MSG_task_receive_ext() failed"));
- return NULL;
- }
+ jxbt_check_res("MSG_task_receive_ext()",rv, MSG_HOST_FAILURE|MSG_TRANSFER_FAILURE|MSG_TIMEOUT,
+ bprintf("while receiving from mailbox %s",alias));
return (jobject) task->data;
}