| /rocksdb-6.9/java/rocksjni/ |
| D | portal.h | 120 if(env->ExceptionCheck()) { in setHandle()
425 if(env->ExceptionCheck()) { in construct()
953 if(!env->IsInstanceOf(jrocksdb_exception, getJClass(env))) { in toCppStatus()
1573 JNIEnv *env; in getJniEnv() local
1580 return env; in getJniEnv()
1586 return env; in getJniEnv()
1637 env, jss, env->GetArrayLength(jss), has_exception); in copyStrings()
1705 env->ExceptionCheck(); in copyString()
1743 env->ExceptionCheck(); in copyStdString()
7048 JNIEnv* env, in fromCppSstFileMetaData() argument
[all …]
|
| D | comparatorjnicallback.cc | 16 : JniCallback(env, jcomparator), in ComparatorJniCallback()
21 static_cast<jclass>(env->NewGlobalRef(AbstractComparatorJniBridge::getJClass(env))); in ComparatorJniCallback()
31 if (env->ExceptionCheck()) { in ComparatorJniCallback()
45 static_cast<jclass>(env->NewGlobalRef(ByteBufferJni::getJClass(env))); in ComparatorJniCallback()
166 assert(env != nullptr); in ~ComparatorJniCallback()
230 assert(env != nullptr); in Compare()
261 env->CallStaticIntMethod( in Compare()
267 if (env->ExceptionCheck()) { in Compare()
295 assert(env != nullptr); in FindShortestSeparator()
332 if (env->ExceptionCheck()) { in FindShortestSeparator()
[all …]
|
| D | rocksjni.cc | 111 env, jcolumn_names, in rocksdb_open_helper()
308 env, jcf_names, in Java_org_rocksdb_RocksDB_createColumnFamilies__JJ_3_3B()
370 env, jcf_name, in Java_org_rocksdb_RocksDB_createColumnFamilies__J_3J_3_3B()
710 JNIEnv* env, jobject, in Java_org_rocksdb_RocksDB_delete__JJ_3BII() argument
789 JNIEnv* env, jobject, in Java_org_rocksdb_RocksDB_singleDelete__J_3BI() argument
942 env, in rocksdb_get_helper_direct()
949 env, in rocksdb_get_helper_direct()
959 env, in rocksdb_get_helper_direct()
967 env, in rocksdb_get_helper_direct()
1103 env, db_handle, in Java_org_rocksdb_RocksDB_getDirect()
[all …]
|
| D | transaction.cc | 195 if (env->ExceptionCheck()) { in txn_get_helper()
282 JNIEnv* env, in free_parts() argument
290 env->DeleteLocalRef(jk); in free_parts()
309 if (env->ExceptionCheck()) { in txn_multi_get_helper()
318 env->DeleteLocalRef(jk); in txn_multi_get_helper()
325 env->DeleteLocalRef(jk); in txn_multi_get_helper()
366 env->SetByteArrayRegion( in txn_multi_get_helper()
369 if (env->ExceptionCheck()) { in txn_multi_get_helper()
654 if (env->ExceptionCheck()) { in txn_write_kv_parts_helper()
660 if (env->ExceptionCheck()) { in txn_write_kv_parts_helper()
[all …]
|
| D | transaction_db.cc | 84 if (env->ExceptionCheck()) { in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
94 env->DeleteLocalRef(jcn); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
104 env->DeleteLocalRef(jcn); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
116 env->DeleteLocalRef(jcn); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
146 if (env->ExceptionCheck()) { in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
148 env->DeleteLocalRef(jresults); in Java_org_rocksdb_TransactionDB_open__JJLjava_lang_String_2_3_3B_3J()
176 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_TransactionDB_closeDatabase() argument
311 if (env->ExceptionCheck()) { in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()
313 env->DeleteLocalRef(jtxns); in Java_org_rocksdb_TransactionDB_getAllPreparedTransactions()
424 if (env->ExceptionCheck()) { in Java_org_rocksdb_TransactionDB_getDeadlockInfoBuffer()
[all …]
|
| D | loggerjnicallback.cc | 19 : JniCallback(env, jlogger) { in LoggerJniCallback()
139 assert(env != nullptr); in Logv()
144 if (env->ExceptionCheck()) { in Logv()
150 if (env->ExceptionCheck()) { in Logv()
153 env->DeleteLocalRef(jmsg); in Logv()
159 if (env->ExceptionCheck()) { in Logv()
162 env->DeleteLocalRef(jmsg); in Logv()
167 env->DeleteLocalRef(jmsg); in Logv()
192 assert(env != nullptr); in ~LoggerJniCallback()
199 env->DeleteGlobalRef(m_jinfo_level); in ~LoggerJniCallback()
[all …]
|
| D | wal_filter_jnicallback.cc | 14 JNIEnv* env, jobject jwal_filter) in WalFilterJniCallback() argument
15 : JniCallback(env, jwal_filter) { in WalFilterJniCallback()
24 if(env->ExceptionCheck()) { in WalFilterJniCallback()
29 m_name = JniUtil::copyString(env, jname, in WalFilterJniCallback()
56 if (env == nullptr) { in ColumnFamilyLogNumberMap()
79 env->CallVoidMethod(m_jcallback_obj, in ColumnFamilyLogNumberMap()
85 env->DeleteLocalRef(jcf_name_id_map); in ColumnFamilyLogNumberMap()
87 if(env->ExceptionCheck()) { in ColumnFamilyLogNumberMap()
100 if (env == nullptr) { in LogRecordFound()
119 env->DeleteLocalRef(jlog_file_name); in LogRecordFound()
[all …]
|
| D | sst_file_writerjni.cc | 84 env->ReleaseStringUTFChars(jfile_path, file_path); in Java_org_rocksdb_SstFileWriter_open()
118 jbyte *key = env->GetByteArrayElements(jkey, nullptr); in Java_org_rocksdb_SstFileWriter_put__J_3B_3B()
129 env->ReleaseByteArrayElements(jkey, key, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_put__J_3B_3B()
139 env->ReleaseByteArrayElements(jkey, key, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_put__J_3B_3B()
140 env->ReleaseByteArrayElements(jval, value, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_put__J_3B_3B()
212 jbyte *key = env->GetByteArrayElements(jkey, nullptr); in Java_org_rocksdb_SstFileWriter_merge__J_3B_3B()
223 env->ReleaseByteArrayElements(jkey, key, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_merge__J_3B_3B()
233 env->ReleaseByteArrayElements(jkey, key, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_merge__J_3B_3B()
234 env->ReleaseByteArrayElements(jval, value, JNI_ABORT); in Java_org_rocksdb_SstFileWriter_merge__J_3B_3B()
249 jbyte *key = env->GetByteArrayElements(jkey, nullptr); in Java_org_rocksdb_SstFileWriter_delete__J_3B()
[all …]
|
| D | backupenginejni.cc | 35 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_BackupEngine_open()
58 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_BackupEngine_createNewBackup()
75 env, japp_metadata, &has_exception); in Java_org_rocksdb_BackupEngine_createNewBackupWithMetadata()
78 env, "Could not copy jstring to std::string"); in Java_org_rocksdb_BackupEngine_createNewBackupWithMetadata()
89 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_BackupEngine_createNewBackupWithMetadata()
211 env->ReleaseStringUTFChars(jdb_dir, db_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
220 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
221 env->ReleaseStringUTFChars(jdb_dir, db_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
248 env->ReleaseStringUTFChars(jdb_dir, db_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup()
256 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup()
[all …]
|
| D | optimistic_transaction_db.cc | 38 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2()
66 if (env->EnsureLocalCapacity(len_cols) != 0) { in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
68 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
75 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
81 if (env->ExceptionCheck()) { in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
92 env->DeleteLocalRef(jcn); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
101 env->DeleteLocalRef(jcn); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
115 env->DeleteLocalRef(jcn); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
128 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
146 if (env->ExceptionCheck()) { in Java_org_rocksdb_OptimisticTransactionDB_open__JLjava_lang_String_2_3_3B_3J()
[all …]
|
| D | write_batch_with_index.cc | 433 JNIEnv* env, jobject /*jobj*/, jlong jwbwi_handle) { in Java_org_rocksdb_WriteBatchWithIndex_rollbackToSavePoint0() argument
444 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WriteBatchWithIndex_rollbackToSavePoint0()
465 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WriteBatchWithIndex_popSavePoint()
499 return ROCKSDB_NAMESPACE::WriteBatchJni::construct(env, wb); in Java_org_rocksdb_WriteBatchWithIndex_getWriteBatch()
743 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_WBWIRocksIterator_seek0()
784 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_WBWIRocksIterator_seekForPrev0()
801 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WBWIRocksIterator_status0()
836 jlongArray jresults = env->NewLongArray(3); in Java_org_rocksdb_WBWIRocksIterator_entry1()
848 env->SetLongArrayRegion(jresults, 0, 3, results); in Java_org_rocksdb_WBWIRocksIterator_entry1()
849 if (env->ExceptionCheck()) { in Java_org_rocksdb_WBWIRocksIterator_entry1()
[all …]
|
| D | ttl.cc | 39 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_TtlDB_open()
70 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_TtlDB_openCF()
77 env, jcolumn_names, in Java_org_rocksdb_TtlDB_openCF()
93 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_TtlDB_openCF()
101 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_TtlDB_openCF()
104 const jsize len_ttls = env->GetArrayLength(jttls); in Java_org_rocksdb_TtlDB_openCF()
108 env->ReleaseIntArrayElements(jttls, jttlv, JNI_ABORT); in Java_org_rocksdb_TtlDB_openCF()
117 env->ReleaseStringUTFChars(jdb_path, db_path); in Java_org_rocksdb_TtlDB_openCF()
136 if (env->ExceptionCheck()) { in Java_org_rocksdb_TtlDB_openCF()
138 env->DeleteLocalRef(jresults); in Java_org_rocksdb_TtlDB_openCF()
[all …]
|
| D | trace_writer_jnicallback.cc | 14 JNIEnv* env, jobject jtrace_writer) in TraceWriterJniCallback() argument
15 : JniCallback(env, jtrace_writer) { in TraceWriterJniCallback()
40 JNIEnv* env = getJniEnv(&attached_thread); in Write() local
41 if (env == nullptr) { in Write()
49 if(env->ExceptionCheck()) { in Write()
68 JNIEnv* env = getJniEnv(&attached_thread); in Close() local
69 if (env == nullptr) { in Close()
76 if(env->ExceptionCheck()) { in Close()
95 JNIEnv* env = getJniEnv(&attached_thread); in GetFileSize() local
96 if (env == nullptr) { in GetFileSize()
[all …]
|
| D | write_batch.cc | 43 jlong Java_org_rocksdb_WriteBatch_newWriteBatch___3BI(JNIEnv* env, in Java_org_rocksdb_WriteBatch_newWriteBatch___3BI() argument
49 env, jserialized, jserialized_length, in Java_org_rocksdb_WriteBatch_newWriteBatch___3BI()
106 void Java_org_rocksdb_WriteBatch_rollbackToSavePoint0(JNIEnv* env, in Java_org_rocksdb_WriteBatch_rollbackToSavePoint0() argument
117 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WriteBatch_rollbackToSavePoint0()
135 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WriteBatch_popSavePoint()
172 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_WriteBatch_put__J_3BI_3BI()
197 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_WriteBatch_put__J_3BI_3BIJ()
245 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_WriteBatch_merge__J_3BI_3BI()
270 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, status); in Java_org_rocksdb_WriteBatch_merge__J_3BI_3BIJ()
474 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_WriteBatch_iterate()
[all …]
|
| D | options_util.cc | 20 JNIEnv* env, jobject jcfds, in build_column_family_descriptor_list() argument
33 if (env->ExceptionCheck()) { in build_column_family_descriptor_list()
36 env->DeleteLocalRef(jcfd); in build_column_family_descriptor_list()
42 jboolean rs = env->CallBooleanMethod(jcfds, add_mid, jcfd); in build_column_family_descriptor_list()
43 if (env->ExceptionCheck() || rs == JNI_FALSE) { in build_column_family_descriptor_list()
46 env->DeleteLocalRef(jcfd); in build_column_family_descriptor_list()
75 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_OptionsUtil_loadLatestOptions()
77 build_column_family_descriptor_list(env, jcfds, cf_descs); in Java_org_rocksdb_OptionsUtil_loadLatestOptions()
91 env, jopts_file_name, &has_exception); in Java_org_rocksdb_OptionsUtil_loadOptionsFromFile()
103 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_OptionsUtil_loadOptionsFromFile()
[all …]
|
| D | slice.cc | 30 const auto* str = env->GetStringUTFChars(jstr, nullptr); in Java_org_rocksdb_AbstractSlice_createNewSliceFromString()
44 env->ReleaseStringUTFChars(jstr, str); in Java_org_rocksdb_AbstractSlice_createNewSliceFromString()
81 return env->NewStringUTF(s.c_str()); in Java_org_rocksdb_AbstractSlice_toString0()
134 const jsize dataSize = env->GetArrayLength(data); in Java_org_rocksdb_Slice_createNewSlice0()
140 env->GetByteArrayRegion(data, offset, len, buf); in Java_org_rocksdb_Slice_createNewSlice0()
141 if (env->ExceptionCheck()) { in Java_org_rocksdb_Slice_createNewSlice0()
162 const int len = env->GetArrayLength(data) + 1; in Java_org_rocksdb_Slice_createNewSlice1()
186 const jbyteArray data = env->NewByteArray(len); in Java_org_rocksdb_Slice_data0()
192 env->SetByteArrayRegion( in Java_org_rocksdb_Slice_data0()
195 if (env->ExceptionCheck()) { in Java_org_rocksdb_Slice_data0()
[all …]
|
| D | thread_status.cc | 21 JNIEnv* env, jclass, jbyte jthread_type_value) { in Java_org_rocksdb_ThreadStatus_getThreadTypeName() argument
24 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getThreadTypeName()
33 JNIEnv* env, jclass, jbyte joperation_type_value) { in Java_org_rocksdb_ThreadStatus_getOperationName() argument
37 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &name, true); in Java_org_rocksdb_ThreadStatus_getOperationName()
46 JNIEnv* env, jclass, jlong jmicros) { in Java_org_rocksdb_ThreadStatus_microsToStringNative() argument
49 return ROCKSDB_NAMESPACE::JniUtil::toJavaString(env, &str, true); in Java_org_rocksdb_ThreadStatus_microsToStringNative()
58 JNIEnv* env, jclass, jbyte joperation_stage_value) { in Java_org_rocksdb_ThreadStatus_getOperationStageName() argument
85 JNIEnv* env, jclass, jbyte joperation_type_value, in Java_org_rocksdb_ThreadStatus_interpretOperationProperties() argument
89 const jsize len = env->GetArrayLength(joperation_properties); in Java_org_rocksdb_ThreadStatus_interpretOperationProperties()
107 if (env->ExceptionCheck()) { in Java_org_rocksdb_ThreadStatus_interpretOperationProperties()
[all …]
|
| D | iterator.cc | 89 void Java_org_rocksdb_RocksIterator_seek0(JNIEnv* env, jobject /*jobj*/, in Java_org_rocksdb_RocksIterator_seek0() argument
92 jbyte* target = env->GetByteArrayElements(jtarget, nullptr); in Java_org_rocksdb_RocksIterator_seek0()
104 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_RocksIterator_seek0()
120 ROCKSDB_NAMESPACE::JniUtil::k_op_direct(seek, env, jtarget, jtarget_off, in Java_org_rocksdb_RocksIterator_seekDirect0()
130 JNIEnv* env, jobject /*jobj*/, jlong handle, jobject jtarget, in Java_org_rocksdb_RocksIterator_seekForPrevDirect0() argument
149 jbyte* target = env->GetByteArrayElements(jtarget, nullptr); in Java_org_rocksdb_RocksIterator_seekForPrev0()
161 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_RocksIterator_seekForPrev0()
178 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_RocksIterator_status0()
196 env->SetByteArrayRegion( in Java_org_rocksdb_RocksIterator_key0()
228 env->NewByteArray(static_cast<jsize>(value_slice.size())); in Java_org_rocksdb_RocksIterator_value0()
[all …]
|
| D | sst_file_reader_iterator.cc | 94 jbyte* target = env->GetByteArrayElements(jtarget, nullptr); in Java_org_rocksdb_SstFileReaderIterator_seek0()
106 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_SstFileReaderIterator_seek0()
119 jbyte* target = env->GetByteArrayElements(jtarget, nullptr); in Java_org_rocksdb_SstFileReaderIterator_seekForPrev0()
131 env->ReleaseByteArrayElements(jtarget, target, JNI_ABORT); in Java_org_rocksdb_SstFileReaderIterator_seekForPrev0()
139 void Java_org_rocksdb_SstFileReaderIterator_status0(JNIEnv* env, in Java_org_rocksdb_SstFileReaderIterator_status0() argument
149 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, s); in Java_org_rocksdb_SstFileReaderIterator_status0()
168 env->SetByteArrayRegion( in Java_org_rocksdb_SstFileReaderIterator_key0()
185 env->NewByteArray(static_cast<jsize>(value_slice.size())); in Java_org_rocksdb_SstFileReaderIterator_value0()
201 JNIEnv* env, jobject /*jobj*/, jlong handle, jobject jtarget, in Java_org_rocksdb_SstFileReaderIterator_keyDirect0() argument
215 JNIEnv* env, jobject /*jobj*/, jlong handle, jobject jtarget, in Java_org_rocksdb_SstFileReaderIterator_valueDirect0() argument
[all …]
|
| D | statistics.cc | 24 JNIEnv* env, jclass jcls) { in Java_org_rocksdb_Statistics_newStatistics__() argument
26 env, jcls, nullptr, 0); in Java_org_rocksdb_Statistics_newStatistics__()
35 JNIEnv* env, jclass jcls, jlong jother_statistics_handle) { in Java_org_rocksdb_Statistics_newStatistics__J() argument
37 env, jcls, nullptr, jother_statistics_handle); in Java_org_rocksdb_Statistics_newStatistics__J()
46 JNIEnv* env, jclass jcls, jbyteArray jhistograms) { in Java_org_rocksdb_Statistics_newStatistics___3B() argument
48 env, jcls, jhistograms, 0); in Java_org_rocksdb_Statistics_newStatistics___3B()
68 const jsize len = env->GetArrayLength(jhistograms); in Java_org_rocksdb_Statistics_newStatistics___3BJ()
231 return env->NewStringUTF(str.c_str()); in Java_org_rocksdb_Statistics_getHistogramString()
240 JNIEnv* env, jobject, jlong jhandle) { in Java_org_rocksdb_Statistics_reset() argument
257 JNIEnv* env, jobject, jlong jhandle) { in Java_org_rocksdb_Statistics_toString() argument
[all …]
|
| D | compaction_job_info.cc | 44 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_CompactionJobInfo_columnFamilyName() argument
56 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_CompactionJobInfo_status() argument
116 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_CompactionJobInfo_inputFiles() argument
120 env, &compact_job_info->input_files); in Java_org_rocksdb_CompactionJobInfo_inputFiles()
129 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_CompactionJobInfo_outputFiles() argument
142 JNIEnv* env, jclass, jlong jhandle) { in Java_org_rocksdb_CompactionJobInfo_tableProperties() argument
159 [env](const std::pair< in Java_org_rocksdb_CompactionJobInfo_tableProperties()
164 env, &(kv.first), false); in Java_org_rocksdb_CompactionJobInfo_tableProperties()
165 if (env->ExceptionCheck()) { in Java_org_rocksdb_CompactionJobInfo_tableProperties()
173 if (env->ExceptionCheck()) { in Java_org_rocksdb_CompactionJobInfo_tableProperties()
[all …]
|
| D | rocksdb_exception_test.cc | 19 void Java_org_rocksdb_RocksDBExceptionTest_raiseException(JNIEnv* env, in Java_org_rocksdb_RocksDBExceptionTest_raiseException() argument
21 ROCKSDB_NAMESPACE::RocksDBExceptionJni::ThrowNew(env, in Java_org_rocksdb_RocksDBExceptionTest_raiseException()
31 JNIEnv* env, jobject /*jobj*/) { in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCode() argument
33 env, "test message", ROCKSDB_NAMESPACE::Status::NotSupported()); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCode()
42 JNIEnv* env, jobject /*jobj*/) { in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionNoMsgWithStatusCode() argument
44 env, ROCKSDB_NAMESPACE::Status::NotSupported()); in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionNoMsgWithStatusCode()
53 JNIEnv* env, jobject /*jobj*/) { in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCodeSubCode() argument
55 env, "test message", in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionWithStatusCodeSubCode()
66 JNIEnv* env, jobject /*jobj*/) { in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionNoMsgWithStatusCodeSubCode() argument
68 env, ROCKSDB_NAMESPACE::Status::TimedOut( in Java_org_rocksdb_RocksDBExceptionTest_raiseExceptionNoMsgWithStatusCodeSubCode()
[all …]
|
| /rocksdb-6.9/db/ |
| D | write_controller_test.cc | 25 TimeSetEnv env; in TEST_F() local
31 controller.GetDelay(&env, 20000000u)); in TEST_F()
34 controller.GetDelay(&env, 20000000u)); in TEST_F()
37 controller.GetDelay(&env, 20000000u)); in TEST_F()
59 TimeSetEnv env; in TEST_F() local
76 env.now_micros_ += 1124u; // sleep debt 0 in TEST_F()
82 env.now_micros_ += 100u; // sleep credit 100 in TEST_F()
86 env.now_micros_ += 100u; // sleep credit 200 in TEST_F()
91 env.now_micros_ += 200u; // sleep debt 824 in TEST_F()
95 env.now_micros_ += 200u; // sleep debt 624 in TEST_F()
[all …]
|
| /rocksdb-6.9/ |
| D | .travis.yml | 39 env:
77 env: TEST_GROUP=1
81 env: TEST_GROUP=1
85 env: TEST_GROUP=1
88 env: TEST_GROUP=2
92 env: TEST_GROUP=2
96 env: TEST_GROUP=2
99 env: TEST_GROUP=3
103 env: TEST_GROUP=3
107 env: TEST_GROUP=3
[all …]
|
| /rocksdb-6.9/util/ |
| D | thread_list_test.cc | 63 env->SleepForMicroseconds(1000); in WaitUntilScheduled()
122 Env* env = Env::Default(); in TEST_F() local
148 env->GetThreadList(&thread_list); in TEST_F()
169 env->GetThreadList(&thread_list); in TEST_F()
215 Env* env = Env::Default(); in TEST_F() local
249 env->SetBackgroundThreads( in TEST_F()
251 env->SetBackgroundThreads( in TEST_F()
284 env->GetThreadList(&thread_list); in TEST_F()
296 env->GetThreadList(&thread_list); in TEST_F()
308 env->GetThreadList(&thread_list); in TEST_F()
[all …]
|