Packages
rocksdb
1.6.0
3.1.1
3.1.0
3.0.0
2.6.2
2.6.1
retired
2.6.0
retired
2.5.0
2.4.1
2.4.0
2.3.0
2.2.0
2.1.0
2.0.0
1.9.0
1.8.0
1.7.0
1.6.0
1.5.1
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.0
1.1.1
1.1.0
1.0.0
0.26.2
0.26.1
0.26.0
0.25.0
0.24.0
0.23.3
0.23.2
0.23.1
0.23.0
0.22.0
0.21.0
0.20.1
0.20.0
0.19.0
0.18.0
0.17.0
0.16.0
0.15.0
0.14.0
0.13.1
0.13.0
0.12.0
0.11.0
0.10.0
0.9.1
0.9.0
0.8.2
0.8.1
0.8.0
0.7.1
0.7.0
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
RocksDB for Erlang
Current section
Files
Jump to
Current section
Files
deps/rocksdb/java/rocksjni/concurrent_task_limiter.cc
#include "rocksdb/concurrent_task_limiter.h"
#include <jni.h>
#include <memory>
#include <string>
#include "include/org_rocksdb_ConcurrentTaskLimiterImpl.h"
#include "rocksjni/portal.h"
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: newConcurrentTaskLimiterImpl0
* Signature: (Ljava/lang/String;I)J
*/
jlong Java_org_rocksdb_ConcurrentTaskLimiterImpl_newConcurrentTaskLimiterImpl0(
JNIEnv* env, jclass, jstring jname, jint limit) {
jboolean has_exception;
std::string name =
ROCKSDB_NAMESPACE::JniUtil::copyStdString(env, jname, &has_exception);
if (JNI_TRUE == has_exception) {
return 0;
}
auto* ptr = new std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>(
ROCKSDB_NAMESPACE::NewConcurrentTaskLimiter(name, limit));
return reinterpret_cast<jlong>(ptr);
}
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: name
* Signature: (J)Ljava/lang/String;
*/
jstring Java_org_rocksdb_ConcurrentTaskLimiterImpl_name(JNIEnv* env, jclass,
jlong handle) {
const auto& limiter = *reinterpret_cast<
std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>*>(handle);
return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &limiter->GetName());
}
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: setMaxOutstandingTask
* Signature: (JI)V
*/
void Java_org_rocksdb_ConcurrentTaskLimiterImpl_setMaxOutstandingTask(
JNIEnv*, jclass, jlong handle, jint max_outstanding_task) {
const auto& limiter = *reinterpret_cast<
std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>*>(handle);
limiter->SetMaxOutstandingTask(static_cast<int32_t>(max_outstanding_task));
}
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: resetMaxOutstandingTask
* Signature: (J)V
*/
void Java_org_rocksdb_ConcurrentTaskLimiterImpl_resetMaxOutstandingTask(
JNIEnv*, jclass, jlong handle) {
const auto& limiter = *reinterpret_cast<
std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>*>(handle);
limiter->ResetMaxOutstandingTask();
}
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: outstandingTask
* Signature: (J)I
*/
jint Java_org_rocksdb_ConcurrentTaskLimiterImpl_outstandingTask(JNIEnv*, jclass,
jlong handle) {
const auto& limiter = *reinterpret_cast<
std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>*>(handle);
return static_cast<jint>(limiter->GetOutstandingTask());
}
/*
* Class: org_rocksdb_ConcurrentTaskLimiterImpl
* Method: disposeInternal
* Signature: (J)V
*/
void Java_org_rocksdb_ConcurrentTaskLimiterImpl_disposeInternal(JNIEnv*,
jobject,
jlong jhandle) {
auto* ptr = reinterpret_cast<
std::shared_ptr<ROCKSDB_NAMESPACE::ConcurrentTaskLimiter>*>(jhandle);
delete ptr; // delete std::shared_ptr
}