host = MSG_process_get_host(process);
- if (!host->data) {
+ if (!MSG_host_get_data(host)) {
jxbt_throw_jni(env, "MSG_process_get_host() failed");
return NULL;
}
/* return the global reference to the java host instance */
- return (jobject) host->data;
+ return (jobject) MSG_host_get_data(host);
}
return NULL;
}
- if (!host->data) { /* native host not associated yet with java host */
+ if (!MSG_host_get_data(host)) { /* native host not associated yet with java host */
/* instanciate a new java host */
jhost = jhost_new_instance(env);
/* the native host data field is set with the global reference to the
* java host returned by this function
*/
- host->data = (void *) jhost;
+ MSG_host_set_data(host,(void *) jhost);
}
/* return the global reference to the java host instance */
- return (jobject) host->data;
+ return (jobject) MSG_host_get_data(host);
}
JNIEXPORT jstring JNICALL
return NULL;
}
- return (*env)->NewStringUTF(env, host->name);
+ return (*env)->NewStringUTF(env, MSG_host_get_name(host));
}
JNIEXPORT jint JNICALL
m_host_t host = MSG_host_self();
- if (!host->data) {
+ if (!MSG_host_get_data(host)) {
/* the native host not yet associated with the java host instance */
/* instanciate a new java host instance */
/* Bind & store it */
jhost_bind(jhost, host, env);
- host->data = (void *) jhost;
+ MSG_host_set_data(host,(void *) jhost);
} else {
- jhost = (jobject) host->data;
+ jhost = (jobject) MSG_host_get_data(host);
}
return jhost;
/* bind & store the task */
jtask_bind(jtask, task, env);
- task->data = jtask;
+ MSG_task_set_data(task,jtask);
}
JNIEXPORT void JNICALL
/* associate the java task object and the native task */
jtask_bind(jtask, task, env);
- task->data = (void *) jtask;
+ MSG_task_set_data(task,(void*) jtask);
- if (!task->data)
+ if (!MSG_task_get_data(task))
jxbt_throw_jni(env, "global ref allocation failed");
}
host = MSG_task_get_source(task);
- if (!host->data) {
+ if (!MSG_host_get_data(host)) {
jxbt_throw_jni(env, "MSG_task_get_source() failed");
return NULL;
}
- return (jobject) host->data;
+ return (jobject) MSG_host_get_data(host);
}
return NULL;
}
- return (*env)->NewStringUTF(env, task->name);
+ return (*env)->NewStringUTF(env, MSG_task_get_name(task));
}
JNIEXPORT void JNICALL
jxbt_throw_notbound(env, "task", task);
return;
}
- jtask = (jobject) task->data;
+ jtask = (jobject) MSG_task_get_data(task);
MSG_error_t rv = MSG_task_destroy(task);
for (index = 0; index < count; index++) {
host = table[index];
- jhost = (jobject) (host->data);
+ jhost = (jobject) (MSG_host_get_data(host));
if (!jhost) {
- jname = (*env)->NewStringUTF(env, host->name);
+ jname = (*env)->NewStringUTF(env, MSG_host_get_name(host));
jhost = Java_simgrid_msg_MsgNative_hostGetByName(env, cls_arg, jname);
/* FIXME: leak of jname ? */
}
/* Pass a global ref to the Jtask into the Ctask so that the receiver can use it */
- task->data = (void *) (*env)->NewGlobalRef(env, jtask);
+ MSG_task_set_data(task,(void *) (*env)->NewGlobalRef(env, jtask));
rv = MSG_task_send_with_timeout(task, alias, (double) jtimeout);
(*env)->ReleaseStringUTFChars(env, jalias, alias);
alias = (*env)->GetStringUTFChars(env, jalias, 0);
/* Pass a global ref to the Jtask into the Ctask so that the receiver can use it */
- task->data = (void *) (*env)->NewGlobalRef(env, jtask);
+ MSG_task_set_data(task,(void *) (*env)->NewGlobalRef(env, jtask));
rv = MSG_task_send_bounded(task, alias, (double) jmaxRate);
(*env)->ReleaseStringUTFChars(env, jalias, alias);
alias = (*env)->GetStringUTFChars(env, jalias, 0);
rv = MSG_task_receive_ext(&task, alias, (double) jtimeout, host);
- jtask_global = task->data;
+ jtask_global = MSG_task_get_data(task);
/* Convert the global ref into a local ref so that the JVM can free the stuff */
jtask_local = (*env)->NewLocalRef(env, jtask_global);
(*env)->DeleteGlobalRef(env, jtask_global);
- task->data = NULL;
+ MSG_task_set_data(task,NULL);
(*env)->ReleaseStringUTFChars(env, jalias, alias);