| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Options.java | 1808 long handle, boolean flag); in setCreateMissingColumnFamilies() argument
1845 long handle, long micros); in setDeleteObsoleteFilesPeriodMicros() argument
1910 final long handle); in statsPersistPeriodSec() argument
1914 final long handle); in statsHistoryBufferSize() argument
1949 final long handle); in strictBytesPerSync() argument
2024 long handle, String name); in setMergeOperatorName() argument
2057 long handle, int numLevels); in setNumLevels() argument
2060 long handle, int numFiles); in setLevelZeroFileNumCompactionTrigger() argument
2063 long handle, int numFiles); in setLevelZeroSlowdownWritesTrigger() argument
2066 long handle, int numFiles); in setLevelZeroStopWritesTrigger() argument
[all …]
|
| D | DBOptions.java | 96 long handle = getDBOptionsFromProps( in getDBOptionsFromProps() local
98 if (handle != 0){ in getDBOptionsFromProps()
99 dbOptions = new DBOptions(handle); in getDBOptionsFromProps()
1191 long handle, boolean flag); in setCreateMissingColumnFamilies() argument
1197 long handle, boolean paranoidChecks); in setParanoidChecks() argument
1229 long handle, long micros); in setDeleteObsoleteFilesPeriodMicros() argument
1277 long handle, boolean allowMmapReads); in setAllowMmapReads() argument
1291 final long handle); in statsPersistPeriodSec() argument
1295 final long handle); in statsHistoryBufferSize() argument
1323 long handle, long bytesPerSync); in setBytesPerSync() argument
[all …]
|
| D | ColumnFamilyOptions.java | 74 ColumnFamilyOptions(final long handle) { in ColumnFamilyOptions() argument
75 super(handle); in ColumnFamilyOptions()
113 if (handle != 0){ in getColumnFamilyOptionsFromProps()
874 long handle, int prefixLength); in useFixedLengthPrefixExtractor() argument
876 long handle, int prefixLength); in useCappedPrefixExtractor() argument
878 long handle, int numLevels); in setNumLevels() argument
881 long handle, int numFiles); in setLevelZeroFileNumCompactionTrigger() argument
884 long handle, int numFiles); in setLevelZeroSlowdownWritesTrigger() argument
887 long handle, int numFiles); in setLevelZeroStopWritesTrigger() argument
893 long handle, int multiplier); in setTargetFileSizeMultiplier() argument
[all …]
|
| D | ReadOptions.java | 582 private native boolean verifyChecksums(long handle); in verifyChecksums() argument
584 private native boolean fillCache(long handle); in fillCache() argument
586 private native long snapshot(long handle); in snapshot() argument
588 private native byte readTier(long handle); in readTier() argument
590 private native boolean tailing(long handle); in tailing() argument
592 private native boolean managed(long handle); in managed() argument
594 private native boolean totalOrderSeek(long handle); in totalOrderSeek() argument
596 private native boolean prefixSameAsStart(long handle); in prefixSameAsStart() argument
598 private native boolean pinData(long handle); in pinData() argument
603 private native long readaheadSize(final long handle); in readaheadSize() argument
[all …]
|
| D | Transaction.java | 1884 private native void setSnapshot(final long handle); in setSnapshot() argument
1888 private native long getSnapshot(final long handle); in getSnapshot() argument
1901 private native byte[][] multiGet(final long handle, in multiGet() argument
1919 private native long getIterator(final long handle, in getIterator() argument
1921 private native long getIterator(final long handle, in getIterator() argument
1989 private native long getNumKeys(final long handle); in getNumKeys() argument
1990 private native long getNumPuts(final long handle); in getNumPuts() argument
2010 private native String getName(final long handle); in getName() argument
2011 private native long getID(final long handle); in getID() argument
2014 private native byte getState(final long handle); in getState() argument
[all …]
|
| D | CompactionJobStats.java | 269 private static native void reset(final long handle); in reset() argument
270 private static native void add(final long handle, in add() argument
272 private static native long elapsedMicros(final long handle); in elapsedMicros() argument
273 private static native long numInputRecords(final long handle); in numInputRecords() argument
274 private static native long numInputFiles(final long handle); in numInputFiles() argument
276 private static native long numOutputRecords(final long handle); in numOutputRecords() argument
277 private static native long numOutputFiles(final long handle); in numOutputFiles() argument
279 private static native long totalInputBytes(final long handle); in totalInputBytes() argument
286 private static native long numCorruptKeys(final long handle); in numCorruptKeys() argument
287 private static native long fileWriteNanos(final long handle); in fileWriteNanos() argument
[all …]
|
| D | WriteBatchWithIndex.java | 254 @Override final native int count0(final long handle); in count0() argument
255 @Override final native void put(final long handle, final byte[] key, in put() argument
257 @Override final native void put(final long handle, final byte[] key, in put() argument
264 @Override final native void merge(final long handle, final byte[] key, in merge() argument
290 @Override final native void clear0(final long handle); in clear0() argument
291 @Override final native void setSavePoint0(final long handle); in setSavePoint0() argument
292 @Override final native void rollbackToSavePoint0(final long handle); in rollbackToSavePoint0() argument
296 @Override final native WriteBatch getWriteBatch(final long handle); in getWriteBatch() argument
304 private native long iterator0(final long handle); in iterator0() argument
312 private native byte[] getFromBatchAndDB(final long handle, in getFromBatchAndDB() argument
[all …]
|
| D | EnvOptions.java | 330 private native void setUseMmapReads(final long handle, in setUseMmapReads() argument
332 private native boolean useMmapReads(final long handle); in useMmapReads() argument
333 private native void setUseMmapWrites(final long handle, in setUseMmapWrites() argument
335 private native boolean useMmapWrites(final long handle); in useMmapWrites() argument
336 private native void setUseDirectReads(final long handle, in setUseDirectReads() argument
342 private native void setAllowFallocate(final long handle, in setAllowFallocate() argument
345 private native void setSetFdCloexec(final long handle, in setSetFdCloexec() argument
347 private native boolean setFdCloexec(final long handle); in setFdCloexec() argument
348 private native void setBytesPerSync(final long handle, in setBytesPerSync() argument
350 private native long bytesPerSync(final long handle); in bytesPerSync() argument
[all …]
|
| D | BackupableDBOptions.java | 438 private native String backupDir(long handle); in backupDir() argument
441 private native boolean shareTableFiles(long handle); in shareTableFiles() argument
443 private native void setSync(long handle, boolean flag); in setSync() argument
444 private native boolean sync(long handle); in sync() argument
446 private native boolean destroyOldData(long handle); in destroyOldData() argument
448 private native boolean backupLogFiles(long handle); in backupLogFiles() argument
450 private native long backupRateLimit(long handle); in backupRateLimit() argument
453 private native long restoreRateLimit(long handle); in restoreRateLimit() argument
454 private native void setRestoreRateLimiter(final long handle, in setRestoreRateLimiter() argument
457 private native boolean shareFilesWithChecksum(long handle); in shareFilesWithChecksum() argument
[all …]
|
| D | WriteBatch.java | 193 WriteBatch getWriteBatch(final long handle) { in getWriteBatch() argument
222 @Override final native int count0(final long handle); in count0() argument
223 @Override final native void put(final long handle, final byte[] key, in put() argument
225 @Override final native void put(final long handle, final byte[] key, in put() argument
232 @Override final native void merge(final long handle, final byte[] key, in merge() argument
234 @Override final native void merge(final long handle, final byte[] key, in merge() argument
237 @Override final native void delete(final long handle, final byte[] key, in delete() argument
254 @Override final native void putLogData(final long handle, in putLogData() argument
256 @Override final native void clear0(final long handle); in clear0() argument
257 @Override final native void setSavePoint0(final long handle); in setSavePoint0() argument
[all …]
|
| D | CompactionOptionsUniversal.java | 254 private native int sizeRatio(final long handle); in sizeRatio() argument
256 final long handle, final int minMergeWidth); in setMinMergeWidth() argument
257 private native int minMergeWidth(final long handle); in minMergeWidth() argument
259 final long handle, final int maxMergeWidth); in setMaxMergeWidth() argument
260 private native int maxMergeWidth(final long handle); in maxMergeWidth() argument
265 final long handle, final int compressionSizePercent); in setCompressionSizePercent() argument
266 private native int compressionSizePercent(final long handle); in compressionSizePercent() argument
268 final long handle, final byte stopStyle); in setStopStyle() argument
269 private native byte stopStyle(final long handle); in stopStyle() argument
271 final long handle, final boolean allowTrivialMove); in setAllowTrivialMove() argument
[all …]
|
| D | RocksIterator.java | 99 @Override protected final native void disposeInternal(final long handle); in disposeInternal() argument
100 @Override final native boolean isValid0(long handle); in isValid0() argument
101 @Override final native void seekToFirst0(long handle); in seekToFirst0() argument
102 @Override final native void seekToLast0(long handle); in seekToLast0() argument
103 @Override final native void next0(long handle); in next0() argument
104 @Override final native void prev0(long handle); in prev0() argument
105 @Override final native void seek0(long handle, byte[] target, int targetLen); in seek0() argument
111 long handle, ByteBuffer target, int targetOffset, int targetLen); in seekForPrevDirect0() argument
112 @Override final native void status0(long handle) throws RocksDBException; in status0() argument
114 private native byte[] key0(long handle); in key0() argument
[all …]
|
| D | SstFileReaderIterator.java | 99 @Override protected final native void disposeInternal(final long handle); in disposeInternal() argument
100 @Override final native boolean isValid0(long handle); in isValid0() argument
101 @Override final native void seekToFirst0(long handle); in seekToFirst0() argument
102 @Override final native void seekToLast0(long handle); in seekToLast0() argument
103 @Override final native void next0(long handle); in next0() argument
104 @Override final native void prev0(long handle); in prev0() argument
105 @Override final native void seek0(long handle, byte[] target, int targetLen); in seek0() argument
107 @Override final native void status0(long handle) throws RocksDBException; in status0() argument
109 private native byte[] key0(long handle); in key0() argument
110 private native byte[] value0(long handle); in value0() argument
[all …]
|
| D | CompactRangeOptions.java | 219 private native boolean changeLevel(final long handle); in changeLevel() argument
220 private native void setChangeLevel(final long handle, in setChangeLevel() argument
222 private native int targetLevel(final long handle); in targetLevel() argument
223 private native void setTargetLevel(final long handle, in setTargetLevel() argument
225 private native int targetPathId(final long handle); in targetPathId() argument
226 private native void setTargetPathId(final long handle, in setTargetPathId() argument
228 private native int bottommostLevelCompaction(final long handle); in bottommostLevelCompaction() argument
231 private native boolean allowWriteStall(final long handle); in allowWriteStall() argument
232 private native void setAllowWriteStall(final long handle, in setAllowWriteStall() argument
234 private native void setMaxSubcompactions(final long handle, in setMaxSubcompactions() argument
[all …]
|
| D | CompressionOptions.java | 136 @Override protected final native void disposeInternal(final long handle); in disposeInternal() argument
139 private native int windowBits(final long handle); in windowBits() argument
140 private native void setLevel(final long handle, final int level); in setLevel() argument
141 private native int level(final long handle); in level() argument
142 private native void setStrategy(final long handle, final int strategy); in setStrategy() argument
143 private native int strategy(final long handle); in strategy() argument
145 private native int maxDictBytes(final long handle); in maxDictBytes() argument
146 private native void setZstdMaxTrainBytes(final long handle, in setZstdMaxTrainBytes() argument
148 private native int zstdMaxTrainBytes(final long handle); in zstdMaxTrainBytes() argument
149 private native void setEnabled(final long handle, final boolean enabled); in setEnabled() argument
[all …]
|
| D | AbstractWriteBatch.java | 161 abstract int count0(final long handle); in count0() argument
181 abstract void delete(final long handle, final byte[] key, in delete() argument
184 abstract void delete(final long handle, final byte[] key, in delete() argument
187 abstract void singleDelete(final long handle, final byte[] key, in singleDelete() argument
190 abstract void singleDelete(final long handle, final byte[] key, in singleDelete() argument
202 abstract void putLogData(final long handle, final byte[] blob, in putLogData() argument
205 abstract void clear0(final long handle); in clear0() argument
207 abstract void setSavePoint0(final long handle); in setSavePoint0() argument
209 abstract void rollbackToSavePoint0(final long handle); in rollbackToSavePoint0() argument
213 abstract void setMaxBytes(final long handle, long maxBytes); in setMaxBytes() argument
[all …]
|
| D | TransactionOptions.java | 172 private native boolean isSetSnapshot(final long handle); in isSetSnapshot() argument
173 private native void setSetSnapshot(final long handle, in setSetSnapshot() argument
175 private native boolean isDeadlockDetect(final long handle); in isDeadlockDetect() argument
176 private native void setDeadlockDetect(final long handle, in setDeadlockDetect() argument
178 private native long getLockTimeout(final long handle); in getLockTimeout() argument
180 private native long getExpiration(final long handle); in getExpiration() argument
182 private native long getDeadlockDetectDepth(final long handle); in getDeadlockDetectDepth() argument
183 private native void setDeadlockDetectDepth(final long handle, in setDeadlockDetectDepth() argument
185 private native long getMaxWriteBatchSize(final long handle); in getMaxWriteBatchSize() argument
186 private native void setMaxWriteBatchSize(final long handle, in setMaxWriteBatchSize() argument
[all …]
|
| D | CompactionJobInfo.java | 147 private static native Status status(final long handle); in status() argument
148 private static native long threadId(final long handle); in threadId() argument
149 private static native int jobId(final long handle); in jobId() argument
150 private static native int baseInputLevel(final long handle); in baseInputLevel() argument
151 private static native int outputLevel(final long handle); in outputLevel() argument
152 private static native String[] inputFiles(final long handle); in inputFiles() argument
153 private static native String[] outputFiles(final long handle); in outputFiles() argument
155 final long handle); in tableProperties() argument
156 private static native byte compactionReason(final long handle); in compactionReason() argument
157 private static native byte compression(final long handle); in compression() argument
[all …]
|
| D | IngestExternalFileOptions.java | 210 private native boolean moveFiles(final long handle); in moveFiles() argument
212 private native boolean snapshotConsistency(final long handle); in snapshotConsistency() argument
213 private native void setSnapshotConsistency(final long handle, in setSnapshotConsistency() argument
215 private native boolean allowGlobalSeqNo(final long handle); in allowGlobalSeqNo() argument
216 private native void setAllowGlobalSeqNo(final long handle, in setAllowGlobalSeqNo() argument
218 private native boolean allowBlockingFlush(final long handle); in allowBlockingFlush() argument
219 private native void setAllowBlockingFlush(final long handle, in setAllowBlockingFlush() argument
221 private native boolean ingestBehind(final long handle); in ingestBehind() argument
222 private native void setIngestBehind(final long handle, in setIngestBehind() argument
224 private native boolean writeGlobalSeqno(final long handle); in writeGlobalSeqno() argument
[all …]
|
| /rocksdb-6.9/cache/ |
| D | clock_cache.cc | 391 (*handle.deleter)(handle.key, handle.value); in ~ClockCacheShard()
416 callback(handle.value, handle.charge); in ApplyToAllCacheEntries()
427 assert(!InCache(handle->flags) && CountRefs(handle->flags) == 0); in RecycleHandle()
431 handle->key.clear(); in RecycleHandle()
441 (*handle.deleter)(handle.key, handle.value); in Cleanup()
514 table_.erase(CacheKey(handle->key, handle->hash)); in TryEvict()
591 handle->key = key; in Insert()
592 handle->hash = hash; in Insert()
609 return handle; in Insert()
650 if (hash != handle->hash || key != handle->key) { in Lookup()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | iterator.cc | 25 jlong handle) { in Java_org_rocksdb_RocksIterator_disposeInternal() argument
26 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_RocksIterator_disposeInternal()
38 jlong handle) { in Java_org_rocksdb_RocksIterator_isValid0() argument
49 jlong handle) { in Java_org_rocksdb_RocksIterator_seekToFirst0() argument
60 jlong handle) { in Java_org_rocksdb_RocksIterator_seekToLast0() argument
70 jlong handle) { in Java_org_rocksdb_RocksIterator_next0() argument
71 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Next(); in Java_org_rocksdb_RocksIterator_next0()
80 jlong handle) { in Java_org_rocksdb_RocksIterator_prev0() argument
146 jlong handle, in Java_org_rocksdb_RocksIterator_seekForPrev0() argument
170 jlong handle) { in Java_org_rocksdb_RocksIterator_status0() argument
[all …]
|
| D | sst_file_reader_iterator.cc | 25 auto* it = reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle); in Java_org_rocksdb_SstFileReaderIterator_disposeInternal()
70 jlong handle) { in Java_org_rocksdb_SstFileReaderIterator_next0() argument
71 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Next(); in Java_org_rocksdb_SstFileReaderIterator_next0()
81 jlong handle) { in Java_org_rocksdb_SstFileReaderIterator_prev0() argument
82 reinterpret_cast<ROCKSDB_NAMESPACE::Iterator*>(handle)->Prev(); in Java_org_rocksdb_SstFileReaderIterator_prev0()
91 jlong handle, in Java_org_rocksdb_SstFileReaderIterator_seek0() argument
141 jlong handle) { in Java_org_rocksdb_SstFileReaderIterator_status0() argument
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
229 JNIEnv* env, jobject /*jobj*/, jlong handle, jobject jtarget, in Java_org_rocksdb_SstFileReaderIterator_seekDirect0() argument
[all …]
|
| D | slice.cc | 56 jlong handle) { in Java_org_rocksdb_AbstractSlice_size0() argument
104 jlong handle, in Java_org_rocksdb_AbstractSlice_startsWith0() argument
119 jlong handle) { in Java_org_rocksdb_AbstractSlice_disposeInternal() argument
120 delete reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_AbstractSlice_disposeInternal()
183 jlong handle) { in Java_org_rocksdb_Slice_data0() argument
212 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_Slice_clear0()
227 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_Slice_removePrefix0()
302 jlong handle) { in Java_org_rocksdb_DirectSlice_data0() argument
314 jlong handle, jint offset) { in Java_org_rocksdb_DirectSlice_get0() argument
327 auto* slice = reinterpret_cast<ROCKSDB_NAMESPACE::Slice*>(handle); in Java_org_rocksdb_DirectSlice_clear0()
[all …]
|
| D | ratelimiterjni.cc | 41 auto* handle = in Java_org_rocksdb_RateLimiter_disposeInternal() local
44 delete handle; // delete std::shared_ptr in Java_org_rocksdb_RateLimiter_disposeInternal()
54 jlong handle, in Java_org_rocksdb_RateLimiter_setBytesPerSecond() argument
68 jlong handle) { in Java_org_rocksdb_RateLimiter_getBytesPerSecond() argument
70 handle) in Java_org_rocksdb_RateLimiter_getBytesPerSecond()
81 jlong handle, jlong jbytes) { in Java_org_rocksdb_RateLimiter_request() argument
94 jlong handle) { in Java_org_rocksdb_RateLimiter_getSingleBurstBytes() argument
96 handle) in Java_org_rocksdb_RateLimiter_getSingleBurstBytes()
110 handle) in Java_org_rocksdb_RateLimiter_getTotalBytesThrough()
122 jlong handle) { in Java_org_rocksdb_RateLimiter_getTotalRequests() argument
[all …]
|
| /rocksdb-6.9/utilities/simulator_cache/ |
| D | cache_simulator_test.cc | 86 auto handle = in AssertCache() local
137 ASSERT_NE(nullptr, handle); in TEST_F()
138 sim_cache->Release(handle); in TEST_F()
140 ASSERT_EQ(nullptr, handle); in TEST_F()
175 ASSERT_NE(nullptr, handle); in TEST_F()
176 sim_cache->Release(handle); in TEST_F()
232 auto handle = in TEST_F() local
235 ASSERT_NE(nullptr, handle); in TEST_F()
236 sim_cache->Release(handle); in TEST_F()
258 handle = in TEST_F()
[all …]
|