| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | OptionsTest.java | 41 try (final Options opt = new Options()) { in setIncreaseParallelism() method
49 try (final Options opt = new Options()) { in writeBufferSize() method
58 try (final Options opt = new Options()) { in maxWriteBufferNumber() method
67 try (final Options opt = new Options()) { in minWriteBufferNumberToMerge() method
76 try (final Options opt = new Options()) { in numLevels() method
85 try (final Options opt = new Options()) { in levelZeroFileNumCompactionTrigger() method
94 try (final Options opt = new Options()) { in levelZeroSlowdownWritesTrigger() method
103 try (final Options opt = new Options()) { in levelZeroStopWritesTrigger() method
112 try (final Options opt = new Options()) { in targetFileSizeBase() method
121 try (final Options opt = new Options()) { in targetFileSizeMultiplier() method
[all …]
|
| D | DBOptionsTest.java | 81 try (final DBOptions opt = new DBOptions()) { in linkageOfPrepMethods() method
88 try (final DBOptions opt = new DBOptions(); in env() method
97 try(final DBOptions opt = new DBOptions()) { in setIncreaseParallelism() method
105 try(final DBOptions opt = new DBOptions()) { in createIfMissing() method
114 try(final DBOptions opt = new DBOptions()) { in createMissingColumnFamilies() method
123 try(final DBOptions opt = new DBOptions()) { in errorIfExists() method
132 try(final DBOptions opt = new DBOptions()) { in paranoidChecks() method
141 try(final DBOptions opt = new DBOptions()) { in maxTotalWalSize() method
150 try(final DBOptions opt = new DBOptions()) { in maxOpenFiles() method
159 try(final DBOptions opt = new DBOptions()) { in maxFileOpeningThreads() method
[all …]
|
| D | BackupableDBOptionsTest.java | 225 try (final BackupableDBOptions options = in failBackupDirIfDisposed() method
233 try (final BackupableDBOptions options = in failSetShareTableFilesIfDisposed() method
241 try (BackupableDBOptions options = in failShareTableFilesIfDisposed() method
249 try (final BackupableDBOptions options = in failSetSyncIfDisposed() method
257 try (final BackupableDBOptions options = in failSyncIfDisposed() method
265 try (final BackupableDBOptions options = in failSetDestroyOldDataIfDisposed() method
273 try (final BackupableDBOptions options = in failDestroyOldDataIfDisposed() method
281 try (final BackupableDBOptions options = in failSetBackupLogFilesIfDisposed() method
289 try (final BackupableDBOptions options = in failBackupLogFilesIfDisposed() method
297 try (final BackupableDBOptions options = in failSetBackupRateLimitIfDisposed() method
[all …]
|
| D | ColumnFamilyOptionsTest.java | 46 try (final ColumnFamilyOptions opt = ColumnFamilyOptions. in getColumnFamilyOptionsFromProps() method
64 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithIllegalValue() method
72 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithNullValue() method
79 try (final ColumnFamilyOptions opt = in failColumnFamilyOptionsFromPropsWithEmptyProps() method
395 try (final ColumnFamilyOptions columnFamilyOptions in compressionTypes() method
410 try (final ColumnFamilyOptions columnFamilyOptions in compressionPerLevel() method
428 try (final ColumnFamilyOptions columnFamilyOptions in differentCompressionsPerLevel() method
454 try (final ColumnFamilyOptions columnFamilyOptions in bottommostCompressionType() method
469 try (final ColumnFamilyOptions columnFamilyOptions = in bottommostCompressionOptions() method
486 try (final ColumnFamilyOptions columnFamilyOptions in compressionOptions() method
[all …]
|
| D | CompactionJobStatsTest.java | 21 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in reset() method
29 try (final CompactionJobStats compactionJobStats = new CompactionJobStats(); in add() method
37 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in elapsedMicros() method
44 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in numInputRecords() method
51 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in numInputFiles() method
58 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in numInputFilesAtOutputLevel() method
65 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in numOutputRecords() method
72 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in numOutputFiles() method
79 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in isManualCompaction() method
86 try (final CompactionJobStats compactionJobStats = new CompactionJobStats()) { in totalInputBytes() method
[all …]
|
| D | AbstractTransactionTest.java | 40 try(final DBContainer dbContainer = startDb(); in setSnapshot() method
48 try(final DBContainer dbContainer = startDb(); in setSnapshotOnNextOperation() method
57 try(final DBContainer dbContainer = startDb(); in setSnapshotOnNextOperation_transactionNotifier() method
74 try(final DBContainer dbContainer = startDb(); in getSnapshot() method
84 try(final DBContainer dbContainer = startDb(); in getSnapshot_null() method
93 try(final DBContainer dbContainer = startDb(); in clearSnapshot() method
102 try(final DBContainer dbContainer = startDb(); in clearSnapshot_none() method
149 try(final DBContainer dbContainer = startDb(); in savePoint() method
184 try(final DBContainer dbContainer = startDb(); in getPut_cf() method
198 try(final DBContainer dbContainer = startDb(); in getPut() method
[all …]
|
| D | ReadOptionsTest.java | 208 try (final ReadOptions readOptions = in failSetVerifyChecksumUninitialized() method
216 try (final ReadOptions readOptions = in failVerifyChecksumUninitialized() method
224 try (final ReadOptions readOptions = in failSetFillCacheUninitialized() method
232 try (final ReadOptions readOptions = in failFillCacheUninitialized() method
240 try (final ReadOptions readOptions = in failSetTailingUninitialized() method
248 try (final ReadOptions readOptions = in failTailingUninitialized() method
256 try (final ReadOptions readOptions = in failSetSnapshotUninitialized() method
264 try (final ReadOptions readOptions = in failSnapshotUninitialized() method
272 try (final ReadOptions readOptions = in failSetIterateUpperBoundUninitialized() method
280 try (final ReadOptions readOptions = in failIterateUpperBoundUninitialized() method
[all …]
|
| D | WriteBatchTest.java | 44 try (final WriteBatch batch = new WriteBatch()) { in emptyWriteBatch() method
61 try (final WriteBatch batch = new WriteBatch()) { in multipleBatchOperations() method
70 try(final CapturingWriteBatchHandler handler = in multipleBatchOperations() method
90 try (WriteBatch batch = new WriteBatch()) { in multipleBatchOperationsDirect() method
122 try (final WriteBatch b1 = new WriteBatch(); in testAppendOperation() method
155 try (final WriteBatch batch = new WriteBatch()) { in blobOperation() method
176 try (final WriteBatch batch = new WriteBatch()) { in savePoints() method
245 try (final WriteBatch batch = new WriteBatch()) { in restorePoints() method
269 try (final WriteBatch batch = new WriteBatch()) { in restorePoints_withoutSavePoints() method
276 try (final WriteBatch batch = new WriteBatch()) { in restorePoints_withoutSavePoints_nested() method
[all …]
|
| D | OptimisticTransactionTest.java | 25 try(final DBContainer dbContainer = startDb(); in getForUpdate_cf_conflict() method
29 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() method
35 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() method
63 try(final DBContainer dbContainer = startDb(); in getForUpdate_conflict() method
66 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_conflict() method
72 try(final Transaction txn2 = dbContainer.beginTransaction()) { in getForUpdate_conflict() method
105 try(final DBContainer dbContainer = startDb(); in multiGetForUpdate_cf_conflict() method
152 try(final DBContainer dbContainer = startDb(); in multiGetForUpdate_conflict() method
191 try(final DBContainer dbContainer = startDb(); in undoGetForUpdate_cf_conflict() method
226 try(final DBContainer dbContainer = startDb(); in undoGetForUpdate_conflict() method
[all …]
|
| D | TransactionTest.java | 25 try(final DBContainer dbContainer = startDb(); in getForUpdate_cf_conflict() method
29 try(final Transaction txn = dbContainer.beginTransaction()) { in getForUpdate_cf_conflict() method
59 try(final DBContainer dbContainer = startDb(); in getForUpdate_conflict() method
97 try(final DBContainer dbContainer = startDb(); in multiGetForUpdate_cf_conflict() method
139 try(final DBContainer dbContainer = startDb(); in multiGetForUpdate_conflict() method
170 try(final DBContainer dbContainer = startDb(); in name() method
181 try(final DBContainer dbContainer = startDb(); in ID() method
189 try(final DBContainer dbContainer = startDb(); in deadlockDetect() method
197 try(final DBContainer dbContainer = startDb(); in waitingTxns() method
205 try(final DBContainer dbContainer = startDb()) { in state() method
[all …]
|
| D | ReadOnlyTest.java | 29 try (final Options options = new Options() in readOnlyOpen() method
34 try (final RocksDB db2 = RocksDB.openReadOnly( in readOnlyOpen() method
64 try (final ColumnFamilyOptions newCfOpts2 = in readOnlyOpen() method
115 try (final Options options = new Options() in failToWriteInReadOnly() method
118 try (final RocksDB db = RocksDB.open(options, in failToWriteInReadOnly() method
131 try (final RocksDB rDb = RocksDB.openReadOnly( in failToWriteInReadOnly() method
161 try (final RocksDB rDb = RocksDB.openReadOnly( in failToCFWriteInReadOnly() method
193 try (final RocksDB rDb = RocksDB.openReadOnly( in failToRemoveInReadOnly() method
223 try (final RocksDB rDb = RocksDB.openReadOnly( in failToCFRemoveInReadOnly() method
254 try (final RocksDB rDb = RocksDB.openReadOnly( in failToWriteBatchReadOnly() method
[all …]
|
| D | WriteBatchWithIndexTest.java | 33 try (final Options options = new Options().setCreateIfMissing(true); in readYourOwnWrites() method
45 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex(true); in readYourOwnWrites() method
106 try (final Options options = new Options().setCreateIfMissing(true); in writeBatchWithIndex() method
115 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex(); in writeBatchWithIndex() method
130 try (final Options options = new Options().setCreateIfMissing(true); in write_writeBatchWithIndexDirect() method
141 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in write_writeBatchWithIndexDirect() method
212 try (final WBWIRocksIterator it = wbwi.newIterator()) { in iterator() method
264 try (final WBWIRocksIterator it = wbwi.newIterator()) { in zeroByteTests() method
340 try (final WriteBatchWithIndex wbwi = new WriteBatchWithIndex()) { in restorePoints() method
352 try(final DBOptions options = new DBOptions()) { in restorePoints() method
[all …]
|
| D | MergeTest.java | 32 try (final Options opt = new Options() in stringOption() method
64 try (final Options opt = new Options() in uint64AddOption() method
95 try (final DBOptions opt = new DBOptions() in cFStringOption() method
336 try (final Options opt = new Options() in operatorGcBehaviour() method
345 try (final Options opt = new Options() in operatorGcBehaviour() method
362 try (final Options opt = new Options() in operatorGcBehaviour() method
378 try (final Options opt = new Options() in uint64AddOperatorGcBehaviour() method
387 try (final Options opt = new Options() in uint64AddOperatorGcBehaviour() method
404 try (final Options opt = new Options() in uint64AddOperatorGcBehaviour() method
418 try (final Options opt = new Options() in emptyStringInSetMergeOperatorByName() method
[all …]
|
| D | RocksDBTest.java | 32 try (final RocksDB db = in open() method
51 try (final RocksDB db1 = RocksDB.open(dbPath)) { in openWhenOpen() method
69 try (final ColumnFamilyHandle col1 = in createColumnFamily() method
322 try (final RocksDB db = in getWithOutValue() method
596 try ( in getIntProperty() method
618 try (final Options opt = new Options(). in fullCompactRange() method
645 try ( in fullCompactRangeColumnFamily() method
693 try (final Options opt = new Options(). in compactRangeWithKeys() method
720 try ( in compactRangeWithKeysReduce() method
865 try (final Options opt = new Options(). in compactRangeToLevel() method
[all …]
|
| D | SnapshotTest.java | 25 try (final Options options = new Options().setCreateIfMissing(true); in snapshots() method
30 try (final Snapshot snapshot = db.getSnapshot()) { in snapshots() method
33 try (final ReadOptions readOptions = new ReadOptions()) { in snapshots() method
54 try (final Snapshot sameSnapshot = readOptions.snapshot()) { in snapshots() method
92 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshot() method
98 try (final RocksIterator iterator = db.newIterator()) { in iteratorWithSnapshot() method
110 try (final RocksIterator snapshotIterator = in iteratorWithSnapshot() method
127 try (final Options options = new Options() in iteratorWithSnapshotOnColumnFamily() method
136 try (final Snapshot snapshot = db.getSnapshot(); in iteratorWithSnapshotOnColumnFamily() method
142 try (final RocksIterator iterator = db.newIterator( in iteratorWithSnapshotOnColumnFamily() method
[all …]
|
| D | EnvOptionsTest.java | 24 try (final DBOptions dbOptions = new DBOptions() in dbOptionsConstructor() method
35 try (final EnvOptions envOptions = new EnvOptions()) { in useMmapReads() method
44 try (final EnvOptions envOptions = new EnvOptions()) { in useMmapWrites() method
53 try (final EnvOptions envOptions = new EnvOptions()) { in useDirectReads() method
62 try (final EnvOptions envOptions = new EnvOptions()) { in useDirectWrites() method
71 try (final EnvOptions envOptions = new EnvOptions()) { in allowFallocate() method
80 try (final EnvOptions envOptions = new EnvOptions()) { in setFdCloexecs() method
89 try (final EnvOptions envOptions = new EnvOptions()) { in bytesPerSync() method
98 try (final EnvOptions envOptions = new EnvOptions()) { in fallocateWithKeepSize() method
107 try (final EnvOptions envOptions = new EnvOptions()) { in compactionReadaheadSize() method
[all …]
|
| D | CompactionJobInfoTest.java | 21 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in columnFamilyName() method
29 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in status() method
37 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in threadId() method
45 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in jobId() method
53 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in baseInputLevel() method
61 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in outputLevel() method
69 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in inputFiles() method
77 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in outputFiles() method
85 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in tableProperties() method
93 try (final CompactionJobInfo compactionJobInfo = new CompactionJobInfo()) { in compactionReason() method
[all …]
|
| D | OptimisticTransactionDBTest.java | 25 try (final Options options = new Options().setCreateIfMissing(true); in open() method
34 try(final DBOptions dbOptions = new DBOptions().setCreateIfMissing(true) in open_columnFamilies() method
61 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction() method
66 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction() method
74 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_transactionOptions() method
81 try(final Transaction txn = otdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() method
90 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_withOld() method
95 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() method
105 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_withOld_transactionOptions() method
112 try(final Transaction txn = otdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() method
[all …]
|
| D | TransactionLogIteratorTest.java | 21 try (final Options options = new Options() in transactionLogIterator() method
34 try (final Options options = new Options() in getBatch() method
53 try (final ColumnFamilyHandle cfHandle = db.createColumnFamily( in getBatch() method
65 try (final TransactionLogIterator transactionLogIterator = in getBatch() method
82 try (final Options options = new Options() in transactionLogIteratorStallAtLastRecord() method
91 try (final TransactionLogIterator transactionLogIterator = in transactionLogIteratorStallAtLastRecord() method
110 try (final Options options = new Options() in transactionLogIteratorCheckAfterRestart() method
115 try (final RocksDB db = RocksDB.open(options, in transactionLogIteratorCheckAfterRestart() method
124 try (final RocksDB db = RocksDB.open(options, in transactionLogIteratorCheckAfterRestart() method
128 try (final TransactionLogIterator transactionLogIterator = in transactionLogIteratorCheckAfterRestart() method
|
| D | TransactionDBTest.java | 24 try (final Options options = new Options().setCreateIfMissing(true); in open() method
34 try(final DBOptions dbOptions = new DBOptions().setCreateIfMissing(true) in open_columnFamilies() method
62 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction() method
68 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction() method
76 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_transactionOptions() method
83 try(final Transaction txn = tdb.beginTransaction(writeOptions, in beginTransaction_transactionOptions() method
92 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_withOld() method
98 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld() method
108 try (final Options options = new Options().setCreateIfMissing(true); in beginTransaction_withOld_transactionOptions() method
115 try(final Transaction txn = tdb.beginTransaction(writeOptions)) { in beginTransaction_withOld_transactionOptions() method
[all …]
|
| D | BackupEngineTest.java | 33 try(final Options opt = new Options().setCreateIfMissing(true); in backupDb() method
41 try(final BackupableDBOptions bopt = new BackupableDBOptions( in backupDb() method
54 try(final Options opt = new Options().setCreateIfMissing(true); in deleteBackup() method
60 try(final BackupableDBOptions bopt = new BackupableDBOptions( in deleteBackup() method
82 try(final Options opt = new Options().setCreateIfMissing(true); in purgeOldBackups() method
88 try(final BackupableDBOptions bopt = new BackupableDBOptions( in purgeOldBackups() method
110 try(final Options opt = new Options().setCreateIfMissing(true)) { in restoreLatestBackup() method
119 try (final BackupableDBOptions bopt = new BackupableDBOptions( in restoreLatestBackup() method
161 try(final Options opt = new Options().setCreateIfMissing(true)) { in restoreFromBackup() method
212 try (final Options opt = new Options().setCreateIfMissing(true); in backupDbWithMetadata() method
[all …]
|
| D | SliceTest.java | 20 try (final Slice slice = new Slice("testSlice")) { in slice() method
26 try (final Slice otherSlice = new Slice("otherSlice".getBytes())) { in slice() method
30 try (final Slice thirdSlice = new Slice("otherSlice".getBytes(), 5)) { in slice() method
37 try (final Slice slice = new Slice("abc")) { in sliceClear() method
47 try (final Slice slice = new Slice("abc")) { in sliceRemovePrefix() method
56 try (final Slice slice = new Slice("abc"); in sliceEquals() method
65 try (final Slice slice = new Slice("matchpoint"); in sliceStartWith() method
75 try (final Slice slice = new Slice("stringTest")) { in sliceToString() method
|
| D | LoggerTest.java | 27 try (final Options options = new Options(). in customLogger() method
43 try (final RocksDB db = RocksDB.open(options, in customLogger() method
55 try (final Options options = new Options(). in warnLogger() method
73 try (final RocksDB db = RocksDB.open(options, in warnLogger() method
86 try (final Options options = new Options(). in fatalLogger() method
104 try (final RocksDB db = RocksDB.open(options, in fatalLogger() method
116 try (final DBOptions options = new DBOptions(). in dbOptionsLogger() method
137 try (final RocksDB db = RocksDB.open(options, in dbOptionsLogger() method
156 try (final Options options = new Options(). in setWarnLogLevel() method
180 try (final Options options = new Options(). in setInfoLogLevel() method
[all …]
|
| D | CheckPointTest.java | 26 try (final Options options = new Options(). in checkPoint() method
29 try (final RocksDB db = RocksDB.open(options, in checkPoint() method
32 try (final Checkpoint checkpoint = Checkpoint.create(db)) { in checkPoint() method
41 try (final RocksDB db = RocksDB.open(options, in checkPoint() method
49 try (final RocksDB db = RocksDB.open(options, in checkPoint() method
62 try (final Checkpoint checkpoint = Checkpoint.create(null)) { in failIfDbIsNull() method
69 try (final RocksDB db = RocksDB.open( in failIfDbNotInitialized() method
78 try (final RocksDB db = RocksDB.open(dbFolder.getRoot().getAbsolutePath()); in failWithIllegalPath() method
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | RocksDBSample.java | 30 try (final Options options = new Options(); in main() method
37 try (final RocksDB db = RocksDB.open(options, db_path_not_found)) { in main() method
112 try (final RocksDB db = RocksDB.open(options, db_path)) { in main() method
125 try (final RocksDB db = RocksDB.open(options, db_path)) { in main() method
147 try (final WriteOptions writeOpt = new WriteOptions()) { in main() method
149 try (final WriteBatch batch = new WriteBatch()) { in main() method
211 try (final WriteOptions writeOpts = new WriteOptions()) { in main() method
245 try (final RocksIterator iterator = db.newIterator()) { in main() method
281 try (final RocksIterator iterator = db.newIterator()) { in main() method
|