X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1847d1441271d076b3de449c8853031ea208ce8f..4d02714ee138a3bd9b02e0064b7a2aa26407e9e8:/src/bindings/java/jmsg_vm.cpp diff --git a/src/bindings/java/jmsg_vm.cpp b/src/bindings/java/jmsg_vm.cpp index 76b0dcec4b..b917e08303 100644 --- a/src/bindings/java/jmsg_vm.cpp +++ b/src/bindings/java/jmsg_vm.cpp @@ -1,20 +1,20 @@ /* Functions related to the Virtual Machines. */ -/* Copyright (c) 2012-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2012-2019. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ #include "jmsg_vm.h" #include "jmsg_host.h" -#include "jxbt_utilities.h" +#include "jxbt_utilities.hpp" +#include "simgrid/Exception.hpp" +#include "simgrid/plugins/live_migration.h" +#include "src/kernel/context/Context.hpp" #include "src/plugins/vm/VirtualMachineImpl.hpp" -#include "xbt/ex.hpp" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(java); -SG_BEGIN_DECL() - extern int JAVA_HOST_LEVEL; static jfieldID jvm_field_bind; @@ -72,8 +72,8 @@ JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_create(JNIEnv* env, jobject jVm, msg_host_t host = jhost_get_native(env, jHost); const char* name = env->GetStringUTFChars(jname, 0); - msg_vm_t vm = MSG_vm_create(host, name, static_cast(coreAmount), static_cast(jramsize), - static_cast(jmig_netspeed), static_cast(jdp_intensity)); + msg_vm_t vm = MSG_vm_create_migratable(host, name, static_cast(coreAmount), static_cast(jramsize), + static_cast(jmig_netspeed), static_cast(jdp_intensity)); env->ReleaseStringUTFChars(jname, name); jvm_bind(env, jVm, vm); @@ -91,7 +91,7 @@ JNIEXPORT jobjectArray JNICALL Java_org_simgrid_msg_VM_all(JNIEnv* env, jclass c msg_host_t h; xbt_dynar_foreach (hosts, it, h) { simgrid::s4u::VirtualMachine* vm = dynamic_cast(h); - if (vm != nullptr && vm->getState() != SURF_VM_STATE_DESTROYED) { + if (vm != nullptr && vm->get_state() != simgrid::s4u::VirtualMachine::state::DESTROYED) { jobject jvm = static_cast(vm->extension(JAVA_HOST_LEVEL)); vms.push_back(jvm); } @@ -133,9 +133,16 @@ JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_start(JNIEnv *env, jobject jvm) JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_shutdown(JNIEnv *env, jobject jvm) { msg_vm_t vm = jvm_get_native(env,jvm); - if (vm) { + if (vm) MSG_vm_shutdown(vm); - auto vmList = &simgrid::vm::VirtualMachineImpl::allVms_; +} + +JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_destroy(JNIEnv* env, jobject jvm) +{ + msg_vm_t vm = jvm_get_native(env, jvm); + if (vm) { + MSG_vm_destroy(vm); + auto* vmList = &simgrid::vm::VirtualMachineImpl::allVms_; vmList->erase(std::remove(vmList->begin(), vmList->end(), vm), vmList->end()); } } @@ -144,12 +151,9 @@ JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_nativeMigration(JNIEnv* env, jobj { msg_vm_t vm = jvm_get_native(env,jvm); msg_host_t host = jhost_get_native(env, jhost); - try { - MSG_vm_migrate(vm,host); - } - catch(xbt_ex& e){ - XBT_VERB("CATCH EXCEPTION MIGRATION %s",e.what()); - jxbt_throw_host_failure(env, (char*)"during migration"); + if (not simgrid::ForcefulKillException::try_n_catch([&vm, &host]() { MSG_vm_migrate(vm, host); })) { + XBT_VERB("Caught exception during migration"); + jxbt_throw_host_failure(env, "during migration"); } } @@ -186,4 +190,3 @@ JNIEXPORT jobject JNICALL Java_org_simgrid_msg_VM_getVMByName(JNIEnv* env, jclas return static_cast(host->extension(JAVA_HOST_LEVEL)); } -SG_END_DECL()