src/java/jmsg_process.c

   1 /* Functions related to the java process instances.                         */
   2
   3 /* Copyright (c) 2007, 2008, 2009, 2010. The SimGrid Team.
   4  * All rights reserved.                                                     */
   5
   6 /* This program is free software; you can redistribute it and/or modify it
   7   * under the terms of the license (GNU LGPL) which comes with this package. */
   8
   9 #include "jmsg_process.h"
  10 #include "jmsg.h"
  11 #include "jxbt_utilities.h"
  12
  13 #include "simix/smx_context_java.h"
  14
  15 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(jmsg);
  16
  17 jobject jprocess_new_global_ref(jobject jprocess, JNIEnv * env)
  18 {
  19   return (*env)->NewGlobalRef(env, jprocess);
  20 }
  21
  22 void jprocess_delete_global_ref(jobject jprocess, JNIEnv * env)
  23 {
  24   (*env)->DeleteGlobalRef(env, jprocess);
  25 }
  26
  27 jboolean jprocess_is_alive(jobject jprocess, JNIEnv * env)
  28 {
  29   jmethodID id =
  30       jxbt_get_smethod(env, "simgrid/msg/Process", "isAlive", "()Z");
  31
  32   if (!id)
  33     return 0;
  34
  35   return (*env)->CallBooleanMethod(env, jprocess, id);
  36 }
  37
  38 void jprocess_join(jobject jprocess, JNIEnv * env)
  39 {
  40   jmethodID id =
  41       jxbt_get_smethod(env, "simgrid/msg/Process", "join", "()V");
  42
  43   if (!id)
  44     return;
  45
  46   (*env)->CallVoidMethod(env, jprocess, id);
  47 }
  48
  49 void jprocess_exit(jobject jprocess, JNIEnv * env)
  50 {
  51   jmethodID id =
  52       jxbt_get_smethod(env, "simgrid/msg/Process", "interrupt", "()V");
  53
  54   if (!id)
  55     return;
  56
  57   (*env)->CallVoidMethod(env, jprocess, id);
  58 }
  59
  60 void jprocess_yield(jobject jprocess, JNIEnv * env)
  61 {
  62   jmethodID id =
  63       jxbt_get_smethod(env, "simgrid/msg/Process", "switchProcess", "()V");
  64
  65   if (!id)
  66     return;
  67
  68   (*env)->CallVoidMethod(env, jprocess, id);
  69 }
  70
  71 void jprocess_lock_mutex(jobject jprocess, JNIEnv * env)
  72 {
  73   jmethodID id =
  74       jxbt_get_smethod(env, "simgrid/msg/Process", "lockMutex", "()V");
  75
  76   if (!id)
  77     return;
  78
  79   (*env)->CallVoidMethod(env, jprocess, id);
  80 }
  81
  82 void jprocess_unlock_mutex(jobject jprocess, JNIEnv * env)
  83 {
  84   jmethodID id =
  85       jxbt_get_smethod(env, "simgrid/msg/Process", "unlockMutex", "()V");
  86
  87   if (!id)
  88     return;
  89
  90   (*env)->CallVoidMethod(env, jprocess, id);
  91 }
  92
  93
  94 void jprocess_signal_cond(jobject jprocess, JNIEnv * env)
  95 {
  96   jmethodID id =
  97       jxbt_get_smethod(env, "simgrid/msg/Process", "signalCond", "()V");
  98
  99   if (!id)
 100     return;
 101
 102   (*env)->CallVoidMethod(env, jprocess, id);
 103 }
 104
 105 void jprocess_wait_cond(jobject jprocess, JNIEnv * env)
 106 {
 107   jmethodID id =
 108       jxbt_get_smethod(env, "simgrid/msg/Process", "waitCond", "()V");
 109
 110   if (!id)
 111     return;
 112
 113   (*env)->CallVoidMethod(env, jprocess, id);
 114 }
 115
 116
 117 void jprocess_start(jobject jprocess, JNIEnv * env)
 118 {
 119   jmethodID id =
 120       jxbt_get_smethod(env, "simgrid/msg/Process", "start", "()V");
 121
 122   if (!id)
 123     return;
 124
 125   DEBUG2("jprocess_start(jproc=%p,env=%p)", jprocess, env);
 126   (*env)->CallVoidMethod(env, jprocess, id);
 127   DEBUG0("jprocess started");
 128 }
 129
 130 m_process_t jprocess_to_native_process(jobject jprocess, JNIEnv * env)
 131 {
 132   jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J");
 133
 134   if (!id)
 135     return NULL;
 136
 137   return (m_process_t) (long) (*env)->GetLongField(env, jprocess, id);
 138 }
 139
 140 void jprocess_bind(jobject jprocess, m_process_t process, JNIEnv * env)
 141 {
 142   jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J");
 143
 144   if (!id)
 145     return;
 146
 147   (*env)->SetLongField(env, jprocess, id, (jlong) (long) (process));
 148 }
 149
 150 jlong jprocess_get_id(jobject jprocess, JNIEnv * env)
 151 {
 152   jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "id", "J");
 153
 154   if (!id)
 155     return 0;
 156
 157   return (*env)->GetLongField(env, jprocess, id);
 158 }
 159
 160 jstring jprocess_get_name(jobject jprocess, JNIEnv * env)
 161 {
 162   jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "name",
 163                                 "Ljava/lang/String;");
 164   jobject jname;
 165
 166   if (!id)
 167     return NULL;
 168
 169   jname = (jstring) (*env)->GetObjectField(env, jprocess, id);
 170
 171   return (*env)->NewGlobalRef(env, jname);
 172
 173 }
 174
 175 jboolean jprocess_is_valid(jobject jprocess, JNIEnv * env)
 176 {
 177   jfieldID id = jxbt_get_sfield(env, "simgrid/msg/Process", "bind", "J");
 178
 179   if (!id)
 180     return JNI_FALSE;
 181
 182   return (*env)->GetLongField(env, jprocess, id) ? JNI_TRUE : JNI_FALSE;
 183 }
 184
 185 void jprocess_schedule(smx_context_t context)
 186 {
 187   JNIEnv *env;
 188   jmethodID id;
 189
 190   env = get_current_thread_env();
 191
 192   id = jxbt_get_smethod(env, "simgrid/msg/Process", "schedule", "()V");
 193
 194   if (!id)
 195     return;
 196
 197   (*env)->CallVoidMethod(env, ((smx_ctx_java_t) context)->jprocess, id);
 198 }
 199
 200
 201
 202 void jprocess_unschedule(smx_context_t context)
 203 {
 204   JNIEnv *env;
 205   jmethodID id;
 206
 207   env = get_current_thread_env();
 208
 209
 210   id = jxbt_get_smethod(env, "simgrid/msg/Process", "unschedule", "()V");
 211
 212   if (!id)
 213     return;
 214
 215   (*env)->CallVoidMethod(env, ((smx_ctx_java_t) context)->jprocess, id);
 216 }