| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | RocksDBTest.java | 32 try (final RocksDB db = in open()
322 try (final RocksDB db = in getWithOutValue()
668 try (final RocksDB db = RocksDB.open(opt, in fullCompactRangeColumnFamily()
779 try (final RocksDB db = RocksDB.open(opt, in compactRangeWithKeysColumnFamily()
828 try (final RocksDB db = RocksDB.open(opt, in compactRangeWithKeysReduceColumnFamily()
1024 try (final RocksDB db = RocksDB.open(opt, in compactRangeToLevelColumnFamily()
1128 try (final RocksDB db = RocksDB.open(options, in setOptions()
1151 try (final RocksDB db = RocksDB.open(options, dbPath)) { in destroyDB()
1245 try (final RocksDB db = RocksDB.open(options, dbPath); in compactFiles()
1364 try (final RocksDB db = RocksDB.open(options, dbPath); in flush()
[all …]
|
| D | CheckPointTest.java | 29 try (final RocksDB db = RocksDB.open(options, in checkPoint()
41 try (final RocksDB db = RocksDB.open(options, in checkPoint()
49 try (final RocksDB db = RocksDB.open(options, in checkPoint()
69 try (final RocksDB db = RocksDB.open( in failIfDbNotInitialized()
78 try (final RocksDB db = RocksDB.open(dbFolder.getRoot().getAbsolutePath()); in failWithIllegalPath()
|
| D | LoggerTest.java | 43 try (final RocksDB db = RocksDB.open(options, in customLogger()
73 try (final RocksDB db = RocksDB.open(options, in warnLogger()
104 try (final RocksDB db = RocksDB.open(options, in fatalLogger()
137 try (final RocksDB db = RocksDB.open(options, in dbOptionsLogger()
221 try (final RocksDB db = RocksDB.open(options, in changeLogLevelAtRuntime()
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend_test.cc | 31 DB* db; in OpenNormalDb() local
42 DBWithTTL* db; in OpenTtlDb() local
227 auto db = OpenDb(','); in TEST_F() local
242 auto db = OpenDb('|'); in TEST_F() local
255 auto db = OpenDb('!'); in TEST_F() local
266 auto db = OpenDb('\n'); in TEST_F() local
292 auto db = OpenDb(' '); in TEST_F() local
343 auto db = OpenDb(' '); in TEST_F() local
396 auto db = OpenDb('\n'); in TEST_F() local
419 auto db = OpenDb('\n'); in TEST_F() local
[all …]
|
| /rocksdb-6.9/db/ |
| D | merge_test.cc | 76 DB* db; in OpenDb() local
120 explicit Counters(std::shared_ptr<DB> db, uint64_t defaultCount = 0) in Counters()
243 void dumpDb(DB* db) { in dumpDb()
252 void testCounters(Counters& counters, DB* db, bool test_compaction) { in testCounters()
322 void testPartialMerge(Counters* counters, DB* db, size_t max_merge, in testPartialMerge()
360 void testSingleBatchSuccessiveMerge(DB* db, size_t max_num_merges, in testSingleBatchSuccessiveMerge()
403 auto db = OpenDb(dbname, use_ttl); in runTest() local
420 auto db = OpenDb(dbname, use_ttl, max_merge); in runTest() local
433 auto db = OpenDb(dbname, use_ttl, max_merge); in runTest() local
439 auto db = OpenDb(dbname, use_ttl, max_merge); in runTest() local
[all …]
|
| D | experimental.cc | 15 Status SuggestCompactRange(DB* db, ColumnFamilyHandle* column_family, in SuggestCompactRange()
24 Status PromoteL0(DB* db, ColumnFamilyHandle* column_family, int target_level) { in PromoteL0()
45 Status SuggestCompactRange(DB* db, const Slice* begin, const Slice* end) { in SuggestCompactRange()
|
| D | compact_files_test.cc | 78 DB* db = nullptr; in TEST_F() local
137 DB* db = nullptr; in TEST_F() local
176 DB* db = nullptr; in TEST_F() local
212 DB* db = nullptr; in TEST_F() local
270 void SetDB(DB* db) { in TEST_F()
287 DB* db = nullptr; in TEST_F() local
336 DB* db = nullptr; in TEST_F() local
376 DB* db = nullptr; in TEST_F() local
|
| D | snapshot_impl.cc | 12 ManagedSnapshot::ManagedSnapshot(DB* db) : db_(db), in ManagedSnapshot()
15 ManagedSnapshot::ManagedSnapshot(DB* db, const Snapshot* _snapshot) in ManagedSnapshot()
|
| D | prefix_test.cc | 135 void PutKey(DB* db, WriteOptions write_options, uint64_t prefix, in PutKey()
143 void PutKey(DB* db, WriteOptions write_options, const TestKey& test_key, in PutKey()
221 DB* db; in OpenDb() local
297 DB* db; in TEST() local
354 auto db = OpenDb(); in TEST_F() local
527 auto db = OpenDb(); in TEST_F() local
579 auto db = OpenDb(); in TEST_F() local
686 auto db = OpenDb(); in TEST_F() local
802 auto db = OpenDb(); in TEST_F() local
835 auto db = OpenDb(); in TEST_F() local
[all …]
|
| D | db_logical_block_size_cache_test.cc | 70 DB* db; in TEST_F() local
102 DB* db; in TEST_F() local
133 DB* db; in TEST_F() local
179 DB* db; in TEST_F() local
237 DB* db; in TEST_F() local
323 DB* db; in TEST_F() local
|
| D | convenience.cc | 16 void CancelAllBackgroundWork(DB* db, bool wait) { in CancelAllBackgroundWork()
21 Status DeleteFilesInRange(DB* db, ColumnFamilyHandle* column_family, in DeleteFilesInRange()
28 Status DeleteFilesInRanges(DB* db, ColumnFamilyHandle* column_family, in DeleteFilesInRanges()
|
| D | options_file_test.cc | 24 void UpdateOptionsFiles(DB* db, in UpdateOptionsFiles()
42 DB* db, const std::unordered_set<std::string>& past_filenames) { in VerifyOptionsFileName()
70 DB* db; in TEST_F() local
|
| /rocksdb-6.9/java/rocksjni/ |
| D | rocksjni.cc | 43 ROCKSDB_NAMESPACE::DB* db = nullptr; in rocksdb_open_helper() local
80 ROCKSDB_NAMESPACE::DB** db) { in Java_org_rocksdb_RocksDB_openROnly__JLjava_lang_String_2()
133 ROCKSDB_NAMESPACE::DB* db = nullptr; in rocksdb_open_helper() local
185 ROCKSDB_NAMESPACE::DB** db) { in Java_org_rocksdb_RocksDB_openROnly__JLjava_lang_String_2_3_3B_3J()
216 auto* db = reinterpret_cast<ROCKSDB_NAMESPACE::DB*>(jhandle); in Java_org_rocksdb_RocksDB_disposeInternal() local
228 auto* db = reinterpret_cast<ROCKSDB_NAMESPACE::DB*>(jhandle); in Java_org_rocksdb_RocksDB_closeDatabase() local
751 JNIEnv* env, ROCKSDB_NAMESPACE::DB* db, in rocksdb_single_delete_helper()
870 JNIEnv* env, ROCKSDB_NAMESPACE::DB* db, in rocksdb_delete_range_helper()
930 JNIEnv* env, ROCKSDB_NAMESPACE::DB* db, in rocksdb_get_helper_direct()
1331 JNIEnv* env, ROCKSDB_NAMESPACE::DB* db, in rocksdb_get_helper()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | db_repl_stress.cc | 37 DB* db; // Assumption DB is Open'ed already. member
48 DB* db = t->db; in DataPumpThreadBody() local
63 DB* db; member
69 DB* db = t->db; in ReplicationThreadBody() local
115 DB* db; in main() local
|
| /rocksdb-6.9/test_util/ |
| D | transaction_test_util.cc | 51 TransactionDB* db, const TransactionOptions& txn_options) { in TransactionDBInsert()
75 OptimisticTransactionDB* db, in OptimisticTransactionDBInsert()
83 bool RandomTransactionInserter::DBInsert(DB* db) { in DBInsert()
88 DB* db, Transaction* txn, ReadOptions& read_options, uint16_t set_i, in DBGet()
131 bool RandomTransactionInserter::DoInsert(DB* db, Transaction* txn, in DoInsert()
279 Status RandomTransactionInserter::Verify(DB* db, uint16_t num_sets, in Verify()
|
| /rocksdb-6.9/examples/ |
| D | compact_files_example.cc | 51 DB* db; member
74 DB* db, const FlushJobInfo& info) override { in OnFlushCompleted()
87 DB* db, const std::string& cf_name) override { in PickCompaction()
146 DB* db = nullptr; in main() local
|
| /rocksdb-6.9/utilities/memory/ |
| D | memory_util.cc | 21 for (auto* db : dbs) { in GetApproximateMemoryUsageByType() local
34 for (auto* db : dbs) { in GetApproximateMemoryUsageByType() local
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | RocksDBSample.java | 37 try (final RocksDB db = RocksDB.open(options, db_path_not_found)) { in main()
112 try (final RocksDB db = RocksDB.open(options, db_path)) { in main()
125 try (final RocksDB db = RocksDB.open(options, db_path)) { in main()
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/util/ |
| D | BytewiseComparatorIntTest.java | 153 try (final RocksDB db = RocksDB.open(opt, db_path.toString())) { in testRoundtrip()
163 try (final RocksDB db = RocksDB.open(opt, db_path.toString()); in testRoundtrip()
212 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
233 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
|
| D | ReverseBytewiseComparatorIntTest.java | 156 try (final RocksDB db = RocksDB.open(opt, db_path.toString())) { in testRoundtrip()
166 try (final RocksDB db = RocksDB.open(opt, db_path.toString()); in testRoundtrip()
215 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
236 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
|
| D | IntComparatorTest.java | 152 try (final RocksDB db = RocksDB.open(opt, db_path.toString())) { in testRoundtrip()
162 try (final RocksDB db = RocksDB.open(opt, db_path.toString()); in testRoundtrip()
211 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
232 try (final RocksDB db = RocksDB.open(opt, db_path.toString(), in testRoundtripCf()
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | Checkpoint.java | 26 public static Checkpoint create(final RocksDB db) { in create()
54 private Checkpoint(final RocksDB db) { in Checkpoint()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_listener.h | 49 void OnFlushCompleted(DB* db, const FlushJobInfo& info) override { in OnFlushCompleted()
56 void OnCompactionCompleted(DB* db, const CompactionJobInfo& info) override { in OnCompactionCompleted()
|
| /rocksdb-6.9/utilities/option_change_migration/ |
| D | option_change_migration.cc | 28 std::unique_ptr<DB>* db) { in OpenDb()
40 std::unique_ptr<DB> db; in CompactToLevel() local
87 std::unique_ptr<DB> db; in MigrateToUniversal() local
|
| /rocksdb-6.9/utilities/ |
| D | debug.cc | 14 Status GetAllKeyVersions(DB* db, Slice begin_key, Slice end_key, in GetAllKeyVersions()
24 Status GetAllKeyVersions(DB* db, ColumnFamilyHandle* cfh, Slice begin_key, in GetAllKeyVersions()
|