|
|
@ -14,52 +14,70 @@ |
|
|
|
#include "rocksjni/portal.h" |
|
|
|
#include "rocksjni/portal.h" |
|
|
|
#include "rocksdb/iterator.h" |
|
|
|
#include "rocksdb/iterator.h" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: isValid0 |
|
|
|
|
|
|
|
* Signature: (J)Z |
|
|
|
|
|
|
|
*/ |
|
|
|
jboolean Java_org_rocksdb_Iterator_isValid0( |
|
|
|
jboolean Java_org_rocksdb_Iterator_isValid0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
return it->Valid(); |
|
|
|
|
|
|
|
|
|
|
|
return st->Valid(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: close0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_seekToFirst0( |
|
|
|
void Java_org_rocksdb_Iterator_seekToFirst0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
it->SeekToFirst(); |
|
|
|
|
|
|
|
|
|
|
|
st->SeekToFirst(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: seekToFirst0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_seekToLast0( |
|
|
|
void Java_org_rocksdb_Iterator_seekToLast0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
it->SeekToLast(); |
|
|
|
|
|
|
|
|
|
|
|
st->SeekToLast(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: seekToLast0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_next0( |
|
|
|
void Java_org_rocksdb_Iterator_next0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
it->Next(); |
|
|
|
|
|
|
|
|
|
|
|
st->Next(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: next0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_prev0( |
|
|
|
void Java_org_rocksdb_Iterator_prev0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
it->Prev(); |
|
|
|
|
|
|
|
|
|
|
|
st->Prev(); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: prev0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
jbyteArray Java_org_rocksdb_Iterator_key0( |
|
|
|
jbyteArray Java_org_rocksdb_Iterator_key0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
rocksdb::Slice key_slice = it->key(); |
|
|
|
|
|
|
|
|
|
|
|
rocksdb::Slice key_slice = st->key(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
jbyteArray jkey = env->NewByteArray(key_slice.size()); |
|
|
|
jbyteArray jkey = env->NewByteArray(key_slice.size()); |
|
|
|
env->SetByteArrayRegion( |
|
|
|
env->SetByteArrayRegion( |
|
|
@ -68,12 +86,15 @@ jbyteArray Java_org_rocksdb_Iterator_key0( |
|
|
|
return jkey; |
|
|
|
return jkey; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: key0 |
|
|
|
|
|
|
|
* Signature: (J)[B |
|
|
|
|
|
|
|
*/ |
|
|
|
jbyteArray Java_org_rocksdb_Iterator_value0( |
|
|
|
jbyteArray Java_org_rocksdb_Iterator_value0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
rocksdb::Slice value_slice = it->value(); |
|
|
|
|
|
|
|
|
|
|
|
rocksdb::Slice value_slice = st->value(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
jbyteArray jvalue = env->NewByteArray(value_slice.size()); |
|
|
|
jbyteArray jvalue = env->NewByteArray(value_slice.size()); |
|
|
|
env->SetByteArrayRegion( |
|
|
|
env->SetByteArrayRegion( |
|
|
@ -82,27 +103,33 @@ jbyteArray Java_org_rocksdb_Iterator_value0( |
|
|
|
return jvalue; |
|
|
|
return jvalue; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: value0 |
|
|
|
|
|
|
|
* Signature: (J)[B |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_seek0( |
|
|
|
void Java_org_rocksdb_Iterator_seek0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle, |
|
|
|
JNIEnv* env, jobject jobj, jlong handle, |
|
|
|
jbyteArray jtarget, jint jtarget_len) { |
|
|
|
jbyteArray jtarget, jint jtarget_len) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
jbyte* target = env->GetByteArrayElements(jtarget, 0); |
|
|
|
jbyte* target = env->GetByteArrayElements(jtarget, 0); |
|
|
|
rocksdb::Slice target_slice( |
|
|
|
rocksdb::Slice target_slice( |
|
|
|
reinterpret_cast<char*>(target), jtarget_len); |
|
|
|
reinterpret_cast<char*>(target), jtarget_len); |
|
|
|
|
|
|
|
|
|
|
|
st->Seek(target_slice); |
|
|
|
it->Seek(target_slice); |
|
|
|
|
|
|
|
|
|
|
|
env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); |
|
|
|
env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: seek0 |
|
|
|
|
|
|
|
* Signature: (J[BI)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_status0( |
|
|
|
void Java_org_rocksdb_Iterator_status0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
rocksdb::Status s = it->status(); |
|
|
|
|
|
|
|
|
|
|
|
rocksdb::Status s = st->status(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (s.ok()) { |
|
|
|
if (s.ok()) { |
|
|
|
return; |
|
|
|
return; |
|
|
@ -111,12 +138,15 @@ void Java_org_rocksdb_Iterator_status0( |
|
|
|
rocksdb::RocksDBExceptionJni::ThrowNew(env, s); |
|
|
|
rocksdb::RocksDBExceptionJni::ThrowNew(env, s); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
|
|
|
* Class: org_rocksdb_Iterator |
|
|
|
|
|
|
|
* Method: status0 |
|
|
|
|
|
|
|
* Signature: (J)V |
|
|
|
|
|
|
|
*/ |
|
|
|
void Java_org_rocksdb_Iterator_close0( |
|
|
|
void Java_org_rocksdb_Iterator_close0( |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
JNIEnv* env, jobject jobj, jlong handle) { |
|
|
|
auto st = reinterpret_cast<rocksdb::Iterator*>(handle); |
|
|
|
auto it = rocksdb::IteratorJni::getIterator(handle); |
|
|
|
assert(st != nullptr); |
|
|
|
delete it; |
|
|
|
|
|
|
|
|
|
|
|
delete st; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
rocksdb::IteratorJni::setHandle(env, jobj, nullptr); |
|
|
|
rocksdb::IteratorJni::setHandle(env, jobj, nullptr); |
|
|
|
} |
|
|
|
} |