#include "msg/msg.h"
#include "msg/private.h"
#include "simix/private.h"
-#include "xbt/xbt_context_java.h"
+#include "simix/smx_context_java.h"
#include "jmsg_process.h"
#include "jmsg_host.h"
static jobject native_to_java_process(m_process_t process)
{
- return ((xbt_ctx_java_t)
- (process->simdata->s_process->simdata->context))->jprocess;
+ return ((smx_ctx_java_t)
+ (process->simdata->s_process->context))->jprocess;
}
MSG_global_init(&argc, argv);
MSG_set_channel_number(10); /* FIXME: this should not be fixed statically */
+ SIMIX_context_select_factory("java");
for (index = 0; index < argc; index++)
free(argv[index]);
jobject jhost;
/* Run everything */
- if (MSG_OK != MSG_main())
+ if (MSG_OK != MSG_main()) {
+ CRITICAL0("We are here!");
jxbt_throw_native(env, xbt_strdup("MSG_main() failed"));
-
- DEBUG0
+ }
+ INFO0
("MSG_main finished. Bail out before cleanup since there is a bug in this part.");
DEBUG0("Clean java world");
jhost_unref(env, jhost);
}
- DEBUG0("Clean native world");
+ INFO0("Clean native world");
/* cleanup native stuff */
- if (MSG_OK != MSG_clean())
+ if (MSG_OK != MSG_clean()){
+ CRITICAL0("We are there!");
jxbt_throw_native(env, xbt_strdup("MSG_main() failed"));
-
+ }
+ INFO0("All good");
}
JNIEXPORT jint JNICALL
return;
}
- xbt_context_stop(0);
+ SIMIX_context_stop(SIMIX_process_self()->context);
}
JNIEXPORT void JNICALL
const char *name = (*env)->GetStringUTFChars(env, jname, 0);
TRY {
- xbt_context_select_factory(name);
+ SIMIX_context_select_factory(name);
} CATCH(e) {
errmsg = xbt_strdup(e.msg);
xbt_ex_free(e);