X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d5cf915bd09762c921e587f376420993f216a239..3116532779db93360dfda0e89394b11ba3c424be:/src/bindings/java/JavaContext.cpp diff --git a/src/bindings/java/JavaContext.cpp b/src/bindings/java/JavaContext.cpp index cbe65b1e34..9f4441e6db 100644 --- a/src/bindings/java/JavaContext.cpp +++ b/src/bindings/java/JavaContext.cpp @@ -12,10 +12,12 @@ #include #include #include +#include #include "JavaContext.hpp" #include "jxbt_utilities.h" #include "xbt/dynar.h" #include "../../simix/smx_private.h" + extern JavaVM *__java_vm; XBT_LOG_NEW_DEFAULT_CATEGORY(jmsg, "MSG for Java(TM)"); @@ -29,18 +31,15 @@ simgrid::simix::ContextFactory* java_factory() return new JavaContextFactory(); } -JavaContextFactory::JavaContextFactory() - : ContextFactory("JavaContextFactory") +JavaContextFactory::JavaContextFactory(): ContextFactory("JavaContextFactory") { } -JavaContextFactory::~JavaContextFactory() -{ -} +JavaContextFactory::~JavaContextFactory()=default; JavaContext* JavaContextFactory::self() { - return (JavaContext*) xbt_os_thread_get_extra_data(); + return static_cast(xbt_os_thread_get_extra_data()); } JavaContext* JavaContextFactory::create_context( @@ -74,14 +73,19 @@ JavaContext::JavaContext(std::function code, this->begin = xbt_os_sem_init(0); this->end = xbt_os_sem_init(0); - TRY { + try { this->thread = xbt_os_thread_create( nullptr, JavaContext::wrapper, this, nullptr); } - CATCH_ANONYMOUS { - RETHROWF("Failed to create context #%d. You may want to switch to Java coroutines to increase your limits (error: %s)." - "See the Install section of simgrid-java documentation (in doc/install.html) for more on coroutines.", - thread_amount); + catch (xbt_ex& ex) { + char* str = bprintf( + "Failed to create context #%d. You may want to switch to Java coroutines to increase your limits (error: %s)." + "See the Install section of simgrid-java documentation (in doc/install.html) for more on coroutines.", + thread_amount, ex.what()); + xbt_ex new_exception(XBT_THROW_POINT, str); + new_exception.category = ex.category; + new_exception.value = ex.value; + std::throw_with_nested(std::move(new_exception)); } } else { this->thread = nullptr; @@ -101,13 +105,13 @@ JavaContext::~JavaContext() void* JavaContext::wrapper(void *data) { - JavaContext* context = (JavaContext*)data; + JavaContext* context = static_cast(data); xbt_os_thread_set_extra_data(context); //Attach the thread to the JVM JNIEnv *env; XBT_ATTRIB_UNUSED jint error = - __java_vm->AttachCurrentThread((void **) &env, nullptr); + __java_vm->AttachCurrentThread((void **)&env, nullptr); xbt_assert((error == JNI_OK), "The thread could not be attached to the JVM"); context->jenv = get_current_thread_env(); //Wait for the first scheduling round to happen. @@ -132,7 +136,7 @@ void JavaContext::stop() // jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", bprintf("Process %s killed :) (file smx_context_java.c)", MSG_process_get_name( (msg_process_t)context) )); jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", bprintf("Process %s killed :) (file JavaContext.cpp)", - simcall_process_get_name(this->process()) )); + this->process()->name.c_str() )); XBT_DEBUG("Trigger a cancel error at the C level"); THROWF(cancel_error, 0, "process cancelled"); } else {