Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
12d1fe113ac109f58eddd2ee87ba485ee813b52c
[simgrid.git] / src / bindings / java / jmsg_vm.cpp
1 /* Functions related to the Virtual Machines.                               */
2
3 /* Copyright (c) 2012-2017. The SimGrid Team. All rights reserved.          */
4
5 /* This program is free software; you can redistribute it and/or modify it
6  * under the terms of the license (GNU LGPL) which comes with this package. */
7
8 #include "jmsg_vm.h"
9 #include "jmsg_host.h"
10 #include "jxbt_utilities.h"
11 #include "xbt/ex.hpp"
12
13 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(jmsg);
14
15 SG_BEGIN_DECL()
16
17 static jfieldID jvm_field_bind;
18
19 void jvm_bind(JNIEnv *env, jobject jvm, msg_vm_t vm)
20 {
21   env->SetLongField(jvm, jvm_field_bind, (intptr_t)vm);
22 }
23
24 msg_vm_t jvm_get_native(JNIEnv *env, jobject jvm)
25 {
26   return (msg_vm_t)(intptr_t)env->GetLongField(jvm, jvm_field_bind);
27 }
28
29 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_nativeInit(JNIEnv *env, jclass cls)
30 {
31   jclass jprocess_class_VM = env->FindClass("org/simgrid/msg/VM");
32   jvm_field_bind = jxbt_get_jfield(env, jprocess_class_VM, "bind", "J");
33   xbt_assert(jvm_field_bind, "Native initialization of msg/VM failed. Please report that bug");
34 }
35
36 JNIEXPORT jint JNICALL Java_org_simgrid_msg_VM_isCreated(JNIEnv * env, jobject jvm)
37 {
38   msg_vm_t vm = jvm_get_native(env,jvm);
39   return (jint) MSG_vm_is_created(vm);
40 }
41
42 JNIEXPORT jint JNICALL Java_org_simgrid_msg_VM_isRunning(JNIEnv * env, jobject jvm)
43 {
44   msg_vm_t vm = jvm_get_native(env,jvm);
45   return (jint) MSG_vm_is_running(vm);
46 }
47
48 JNIEXPORT jint JNICALL Java_org_simgrid_msg_VM_isMigrating(JNIEnv * env, jobject jvm)
49 {
50   msg_vm_t vm = jvm_get_native(env,jvm);
51   return (jint) MSG_vm_is_migrating(vm);
52 }
53
54 JNIEXPORT jint JNICALL Java_org_simgrid_msg_VM_isSuspended(JNIEnv * env, jobject jvm)
55 {
56   msg_vm_t vm = jvm_get_native(env,jvm);
57   return (jint) MSG_vm_is_suspended(vm);
58 }
59
60 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_setBound(JNIEnv *env, jobject jvm, jdouble bound)
61 {
62   msg_vm_t vm = jvm_get_native(env,jvm);
63   MSG_vm_set_bound(vm, bound);
64 }
65
66 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_create(JNIEnv* env, jobject jvm, jobject jhost, jstring jname,
67                                                       jint jramsize, jint jmig_netspeed, jint jdp_intensity)
68 {
69   msg_host_t host = jhost_get_native(env, jhost);
70
71   const char* name = env->GetStringUTFChars(jname, 0);
72   name = xbt_strdup(name);
73
74   msg_vm_t vm = MSG_vm_create(host, name, static_cast<int>(jramsize), static_cast<int>(jmig_netspeed),
75                               static_cast<int>(jdp_intensity));
76
77   jvm_bind(env, jvm, vm);
78 }
79
80 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_nativeFinalize(JNIEnv *env, jobject jvm)
81 {
82   msg_vm_t vm = jvm_get_native(env,jvm);
83   MSG_vm_destroy(vm);
84 }
85
86 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_start(JNIEnv *env, jobject jvm)
87 {
88   msg_vm_t vm = jvm_get_native(env,jvm);
89   MSG_vm_start(vm);
90 }
91
92 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_shutdown(JNIEnv *env, jobject jvm)
93 {
94   msg_vm_t vm = jvm_get_native(env,jvm);
95   MSG_vm_shutdown(vm);
96 }
97
98 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_internalmig(JNIEnv *env, jobject jvm, jobject jhost)
99 {
100   msg_vm_t vm = jvm_get_native(env,jvm);
101   msg_host_t host = jhost_get_native(env, jhost);
102   try {
103     MSG_vm_migrate(vm,host);
104   }
105   catch(xbt_ex& e){
106      XBT_VERB("CATCH EXCEPTION MIGRATION %s",e.what());
107      jxbt_throw_host_failure(env, (char*)"during migration");
108   }
109 }
110
111 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_suspend(JNIEnv *env, jobject jvm)
112 {
113   msg_vm_t vm = jvm_get_native(env,jvm);
114   MSG_vm_suspend(vm);
115 }
116
117 JNIEXPORT void JNICALL Java_org_simgrid_msg_VM_resume(JNIEnv *env, jobject jvm)
118 {
119   msg_vm_t vm = jvm_get_native(env,jvm);
120   MSG_vm_resume(vm);
121 }
122
123 SG_END_DECL()