#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: java_locked.c,v 1.1.1.1 2003/02/15 04:56:08 zarzycki Exp $";
#endif
#include <jni.h>
#include <errno.h>
#include <stdlib.h>
#include <string.h>
#include "db_int.h"
#include "java_util.h"
int
locked_dbt_get(LOCKED_DBT *ldbt, JNIEnv *jnienv, DB_ENV *dbenv,
jobject jdbt, OpKind kind)
{
DBT *dbt;
COMPQUIET(dbenv, NULL);
ldbt->jdbt = jdbt;
ldbt->java_array_len = 0;
ldbt->flags = 0;
ldbt->kind = kind;
ldbt->java_data = 0;
ldbt->before_data = 0;
ldbt->javainfo =
(DBT_JAVAINFO *)get_private_dbobj(jnienv, name_DBT, jdbt);
if (!verify_non_null(jnienv, ldbt->javainfo)) {
report_exception(jnienv, "Dbt is gc'ed?", 0, 0);
F_SET(ldbt, LOCKED_ERROR);
return (EINVAL);
}
if (F_ISSET(ldbt->javainfo, DBT_JAVAINFO_LOCKED)) {
report_exception(jnienv, "Dbt is already in use", 0, 0);
F_SET(ldbt, LOCKED_ERROR);
return (EINVAL);
}
dbt = &ldbt->javainfo->dbt;
if ((*jnienv)->GetBooleanField(jnienv,
jdbt, fid_Dbt_must_create_data) != 0)
F_SET(ldbt, LOCKED_CREATE_DATA);
else
ldbt->javainfo->array =
(*jnienv)->GetObjectField(jnienv, jdbt, fid_Dbt_data);
dbt->size = (*jnienv)->GetIntField(jnienv, jdbt, fid_Dbt_size);
dbt->ulen = (*jnienv)->GetIntField(jnienv, jdbt, fid_Dbt_ulen);
dbt->dlen = (*jnienv)->GetIntField(jnienv, jdbt, fid_Dbt_dlen);
dbt->doff = (*jnienv)->GetIntField(jnienv, jdbt, fid_Dbt_doff);
dbt->flags = (*jnienv)->GetIntField(jnienv, jdbt, fid_Dbt_flags);
ldbt->javainfo->offset = (*jnienv)->GetIntField(jnienv, jdbt,
fid_Dbt_offset);
if (kind != inOp &&
!F_ISSET(dbt, DB_DBT_USERMEM | DB_DBT_MALLOC | DB_DBT_REALLOC))
F_SET(dbt, DB_DBT_MALLOC);
if (F_ISSET(dbt, DB_DBT_REALLOC) && ldbt->javainfo->array != NULL) {
F_CLR(dbt, DB_DBT_REALLOC);
F_SET(dbt, DB_DBT_USERMEM);
F_SET(ldbt, LOCKED_REALLOC_NONNULL);
}
if ((F_ISSET(dbt, DB_DBT_USERMEM) || kind != outOp) &&
!F_ISSET(ldbt, LOCKED_CREATE_DATA)) {
if (!ldbt->javainfo->array) {
report_exception(jnienv, "Dbt.data is null", 0, 0);
F_SET(ldbt, LOCKED_ERROR);
return (EINVAL);
}
ldbt->java_array_len = (*jnienv)->GetArrayLength(jnienv,
ldbt->javainfo->array);
if (ldbt->javainfo->offset < 0 ) {
report_exception(jnienv, "Dbt.offset illegal", 0, 0);
F_SET(ldbt, LOCKED_ERROR);
return (EINVAL);
}
if (dbt->size + ldbt->javainfo->offset > ldbt->java_array_len) {
report_exception(jnienv,
"Dbt.size + Dbt.offset greater than array length",
0, 0);
F_SET(ldbt, LOCKED_ERROR);
return (EINVAL);
}
ldbt->java_data = (*jnienv)->GetByteArrayElements(jnienv,
ldbt->javainfo->array,
(jboolean *)0);
dbt->data = ldbt->before_data = ldbt->java_data +
ldbt->javainfo->offset;
}
else if (!F_ISSET(ldbt, LOCKED_CREATE_DATA)) {
dbt->data = ldbt->before_data = 0;
}
if (dbt->data == NULL)
dbt->size = dbt->ulen = 0;
F_SET(ldbt->javainfo, DBT_JAVAINFO_LOCKED);
return (0);
}
void
locked_dbt_put(LOCKED_DBT *ldbt, JNIEnv *jnienv, DB_ENV *dbenv)
{
DBT *dbt;
dbt = &ldbt->javainfo->dbt;
if (F_ISSET(ldbt, LOCKED_ERROR))
return;
if (((F_ISSET(dbt, DB_DBT_USERMEM) ||
F_ISSET(ldbt, LOCKED_REALLOC_NONNULL)) ||
ldbt->kind == inOp) && !F_ISSET(ldbt, LOCKED_CREATE_DATA)) {
if (ldbt->before_data != ldbt->java_data) {
(*jnienv)->SetByteArrayRegion(jnienv,
ldbt->javainfo->array,
ldbt->javainfo->offset,
dbt->ulen,
ldbt->before_data);
}
(*jnienv)->ReleaseByteArrayElements(jnienv,
ldbt->javainfo->array,
ldbt->java_data, 0);
dbt->data = 0;
}
else if (F_ISSET(dbt, DB_DBT_MALLOC | DB_DBT_REALLOC) &&
ldbt->kind != inOp && !F_ISSET(ldbt, LOCKED_CREATE_DATA)) {
if (dbt->data) {
if (dbt->data != ldbt->before_data) {
jbyteArray newarr;
if ((newarr = (*jnienv)->NewByteArray(jnienv,
dbt->size)) == NULL) {
F_SET(ldbt, LOCKED_ERROR);
return;
}
(*jnienv)->SetObjectField(jnienv, ldbt->jdbt,
fid_Dbt_data,
newarr);
ldbt->javainfo->offset = 0;
(*jnienv)->SetByteArrayRegion(jnienv,
newarr, 0, dbt->size,
(jbyte *)dbt->data);
(void)__os_ufree(dbenv, dbt->data);
dbt->data = 0;
}
}
}
(*jnienv)->SetIntField(jnienv, ldbt->jdbt, fid_Dbt_size, dbt->size);
ldbt->javainfo->array = NULL;
F_CLR(ldbt->javainfo, DBT_JAVAINFO_LOCKED);
}
int locked_dbt_realloc(LOCKED_DBT *ldbt, JNIEnv *jnienv, DB_ENV *dbenv)
{
DBT *dbt;
COMPQUIET(dbenv, NULL);
dbt = &ldbt->javainfo->dbt;
if (!F_ISSET(ldbt, LOCKED_REALLOC_NONNULL) ||
F_ISSET(ldbt, LOCKED_ERROR) || dbt->size <= dbt->ulen)
return (0);
(*jnienv)->ReleaseByteArrayElements(jnienv, ldbt->javainfo->array,
ldbt->java_data, 0);
if ((ldbt->javainfo->array = (*jnienv)->NewByteArray(jnienv,
dbt->size)) == NULL) {
F_SET(ldbt, LOCKED_ERROR);
return (0);
}
ldbt->java_array_len = dbt->ulen = dbt->size;
ldbt->javainfo->offset = 0;
(*jnienv)->SetObjectField(jnienv, ldbt->jdbt, fid_Dbt_data,
ldbt->javainfo->array);
ldbt->java_data = (*jnienv)->GetByteArrayElements(jnienv,
ldbt->javainfo->array, (jboolean *)0);
memcpy(ldbt->java_data, ldbt->before_data, dbt->ulen);
dbt->data = ldbt->before_data = ldbt->java_data;
return (1);
}
int
locked_string_get(LOCKED_STRING *ls, JNIEnv *jnienv, jstring jstr)
{
ls->jstr = jstr;
if (jstr == 0)
ls->string = 0;
else
ls->string = (*jnienv)->GetStringUTFChars(jnienv, jstr,
(jboolean *)0);
return (0);
}
void locked_string_put(LOCKED_STRING *ls, JNIEnv *jnienv)
{
if (ls->jstr)
(*jnienv)->ReleaseStringUTFChars(jnienv, ls->jstr, ls->string);
}