| /rocksdb-6.9/db/ |
| D | internal_stats.cc | 359 {DB::Properties::kLevelStats,
361 {DB::Properties::kStats,
363 {DB::Properties::kCFStats,
369 {DB::Properties::kCFFileHistogram,
372 {DB::Properties::kDBStats,
374 {DB::Properties::kSSTables,
418 {DB::Properties::kEstimateNumKeys,
427 {DB::Properties::kNumSnapshots,
436 {DB::Properties::kNumLiveVersions,
451 {DB::Properties::kBaseLevel,
[all …]
|
| D | db_logical_block_size_cache_test.cc | 70 DB* db; in TEST_F()
102 DB* db; in TEST_F()
133 DB* db; in TEST_F()
179 DB* db; in TEST_F()
237 DB* db; in TEST_F()
323 DB* db; in TEST_F()
352 ASSERT_OK(DB::Open( in TEST_F()
396 DB* db0; in TEST_F()
411 DB* db1; in TEST_F()
462 DB* db0; in TEST_F()
[all …]
|
| D | compact_files_test.cc | 78 DB* db = nullptr; in TEST_F()
80 Status s = DB::Open(options, db_name_, &db); in TEST_F()
137 DB* db = nullptr; in TEST_F()
176 DB* db = nullptr; in TEST_F()
212 DB* db = nullptr; in TEST_F()
250 s = DB::Open(options, db_name_, &db); in TEST_F()
270 void SetDB(DB* db) { in TEST_F()
277 DB* db_; in TEST_F()
287 DB* db = nullptr; in TEST_F()
336 DB* db = nullptr; in TEST_F()
[all …]
|
| D | db_properties_test.cc | 153 DB::Properties::kEstimateTableReadersMem, &before_flush_trm)); in TEST_F()
159 DB::Properties::kEstimateTableReadersMem, &after_flush_trm)); in TEST_F()
634 handles_[1], DB::Properties::kNumImmutableMemTableFlushed, &num)); in TEST_F()
1432 DB::Properties::kEstimateOldestKeyTime, &oldest_key_time)); in TEST_F()
1493 void OnCompactionCompleted(DB* db, in TEST_F()
1500 bool ok = db->GetIntProperty(DB::Properties::kTotalSstFilesSize, in TEST_F()
1566 void SetDB(DB* db) { db_ = db; } in TEST_F()
1576 DB* db_ = nullptr; in TEST_F()
1608 db_->GetIntProperty(DB::Properties::kBlockCacheCapacity, &value)); in TEST_F()
1616 db_->GetIntProperty(DB::Properties::kBlockCacheCapacity, &value)); in TEST_F()
[all …]
|
| D | merge_test.cc | 76 DB* db; in OpenDb()
90 s = DB::Open(options, dbname, &db); in OpenDb()
94 s = DB::Open(options, dbname, &db); in OpenDb()
100 return std::shared_ptr<DB>(db); in OpenDb()
111 std::shared_ptr<DB> db_;
120 explicit Counters(std::shared_ptr<DB> db, uint64_t defaultCount = 0) in Counters()
243 void dumpDb(DB* db) { in dumpDb()
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()
457 DB* reopen_db; in runTest()
[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()
33 Status SuggestCompactRange(DB* /*db*/, ColumnFamilyHandle* /*column_family*/,
38 Status PromoteL0(DB* /*db*/, ColumnFamilyHandle* /*column_family*/,
45 Status SuggestCompactRange(DB* db, const Slice* begin, const Slice* end) { in SuggestCompactRange()
|
| D | compacted_db_impl.h | 24 DB** dbptr);
27 using DB::Get;
31 using DB::MultiGet;
85 using DB::IngestExternalFile;
92 using DB::CreateColumnFamilyWithImport;
103 friend class DB;
|
| D | convenience.cc | 16 void CancelAllBackgroundWork(DB* db, bool wait) { in CancelAllBackgroundWork()
17 (static_cast_with_check<DBImpl, DB>(db->GetRootDB())) in CancelAllBackgroundWork()
21 Status DeleteFilesInRange(DB* db, ColumnFamilyHandle* column_family, in DeleteFilesInRange()
28 Status DeleteFilesInRanges(DB* db, ColumnFamilyHandle* column_family, in DeleteFilesInRanges()
31 return (static_cast_with_check<DBImpl, DB>(db->GetRootDB())) in DeleteFilesInRanges()
|
| /rocksdb-6.9/include/rocksdb/utilities/ |
| D | stackable_db.h | 77 using DB::Put;
84 using DB::Get;
102 using DB::MultiGet;
150 using DB::KeyMayExist;
158 using DB::Delete;
172 using DB::Merge;
183 using DB::NewIterator;
203 using DB::GetProperty;
306 using DB::GetOptions;
316 using DB::Flush;
[all …]
|
| D | write_batch_with_index.h | 30 class DB; variable
206 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
210 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
213 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
218 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
222 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
264 Status GetFromBatchAndDB(DB* db, const ReadOptions& read_options,
267 void MultiGetFromBatchAndDB(DB* db, const ReadOptions& read_options,
|
| /rocksdb-6.9/java/rocksjni/ |
| D | rocksjni.cc | 43 ROCKSDB_NAMESPACE::DB* db = nullptr; in rocksdb_open_helper()
80 ROCKSDB_NAMESPACE::DB** db) { in Java_org_rocksdb_RocksDB_openROnly__JLjava_lang_String_2()
92 ROCKSDB_NAMESPACE::DB**)> in rocksdb_open_helper()
133 ROCKSDB_NAMESPACE::DB* db = nullptr; in rocksdb_open_helper()
185 ROCKSDB_NAMESPACE::DB** db) { in Java_org_rocksdb_RocksDB_openROnly__JLjava_lang_String_2_3_3B_3J()
205 ROCKSDB_NAMESPACE::DB**)) & in Java_org_rocksdb_RocksDB_open__JLjava_lang_String_2_3_3B_3J()
206 ROCKSDB_NAMESPACE::DB::Open); in Java_org_rocksdb_RocksDB_open__JLjava_lang_String_2_3_3B_3J()
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()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 139 using DB::Resume;
142 using DB::Put;
146 using DB::Merge;
150 using DB::Delete;
158 using DB::Write;
162 using DB::Get;
185 using DB::MultiGet;
311 using DB::SetOptions;
333 using DB::Flush;
429 using DB::EndTrace;
[all …]
|
| D | db_impl_readonly.cc | 129 Status DB::OpenForReadOnly(const Options& options, const std::string& dbname, in OpenForReadOnly()
130 DB** dbptr, bool /*error_if_log_file_exist*/) { in OpenForReadOnly()
147 s = DB::OpenForReadOnly(db_options, dbname, column_families, &handles, dbptr); in OpenForReadOnly()
157 Status DB::OpenForReadOnly( in OpenForReadOnly()
160 std::vector<ColumnFamilyHandle*>* handles, DB** dbptr, in OpenForReadOnly()
208 Status DB::OpenForReadOnly(const Options& /*options*/,
209 const std::string& /*dbname*/, DB** /*dbptr*/,
214 Status DB::OpenForReadOnly(
217 std::vector<ColumnFamilyHandle*>* /*handles*/, DB** /*dbptr*/,
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2014-03-27-how-to-backup-rocksdb.markdown | 10 In RocksDB, we have implemented an easy way to backup your DB. Here is a simple example:
18 DB* db;
19 DB::Open(Options(), "/tmp/rocksdb", &db);
28 …create a backup of your DB in "/tmp/rocksdb_backup". Creating new BackupableDB consumes DB* and yo…
41 …arameter is the location of log files (In some DBs they are different from DB directory, but usual…
51 DB* db;
52 DB::Open(Options(), "/tmp/rocksdb", &db);
77 `RestoreDBFromLatestBackup()` will restore the DB from the latest consistent backup. An alternative…
84 Let's say you want to backup your DB to HDFS. There is an option in `BackupableDBOptions` to set `b…
92 …e, `BackupableDB` will first issue a memtable flush and only then copy the DB files to the backup …
[all …]
|
| D | 2017-01-06-rocksdb-5-0-1-released.markdown | 12 * Introduce DB::DeleteRange for optimized deletion of large ranges of contiguous keys.
15 …usion if statistics object is shared among RocksDB instance. Alternatively DB::GetLatestSequenceNu…
19 …* DB::AddFile() is deprecated and is replaced with DB::IngestExternalFile(). DB::IngestExternalFil…
23 …* Add avoid_flush_during_shutdown option, which speeds up DB shutdown by not flushing unpersisted …
|
| D | 2015-01-16-migrating-from-leveldb-to-rocksdb-2.markdown | 23 DB *db;
30 Status s = DB::Open(opt, "/tmp/mydb", &db);
46 DB *db;
56 Status s = DB::Open(rocksdb_options, "/tmp/mydb_rocks", &db);
75 - Status s = DB::Open(opt, "/tmp/mydb", &db);
79 + Status s = DB::Open(rocksdb_options, "/tmp/mydb_rocks", &db);
96 DB *db;
106 Status s = DB::Open(opt, "/tmp/mydb_rocks", &db);
|
| D | 2017-02-17-bulkoad-ingest-sst-file.markdown | 10 … of RocksDB is writing to RocksDB, Writes happen when user call (DB::Put, DB::Write, DB::Delete ..…
11 - User insert a new key/value by calling DB::Put() (or DB::Write())
20 - Write all of our keys and values into SST file outside of the DB
39 // Ingest the external SST file into the DB
|
| /rocksdb-6.9/utilities/checkpoint/ |
| D | checkpoint_test.cc | 44 DB* db_;
203 return DB::Open(options, dbname_, &db_); in TryReopen()
264 DB* snapshotDB; in TEST_F()
277 ASSERT_OK(DB::Open(options, dbname_, &db_)); in TEST_F()
433 DB* snapshotDB; in TEST_F()
471 ASSERT_OK(DB::Open(options, snapshot_name_, in TEST_F()
497 DB* snapshotDB; in TEST_F()
579 DB* snapshotDB; in TEST_F()
739 DB* snapshot_db; in TEST_F()
762 DB* snapshot_db = nullptr; in TEST_F()
[all …]
|
| /rocksdb-6.9/examples/ |
| D | compact_files_example.cc | 29 DB* db, const std::string& cf_name) = 0;
38 DB* _db, Compactor* _compactor, in CompactionTask()
51 DB* db;
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()
148 Status s = DB::Open(options, kDBPath, &db); in main()
|
| /rocksdb-6.9/tools/ |
| D | check_format_compatible.sh | 100 echo ==== Error ingesting external SST in $2 to DB at $1 ====
116 echo == Generating DB with extern SST file in "$checkout_obj" ...
136 echo == Build "$checkout_obj" and try to open DB generated using $checkout_flag
150 echo == Generating DB from "$checkout_obj" ...
164 echo == Generate compare base DB to $compare_base_db_dir
169 echo == Opening DB from "$checkout_obj" using debug build of $checkout_flag ...
175 echo == Build "$checkout_obj" and try to open DB generated using $checkout_flag...
184 …echo == Build "$checkout_obj" and try to open DB generated using $checkout_flag with its options...
|
| D | db_repl_stress.cc | 37 DB* db; // Assumption DB is Open'ed already.
48 DB* db = t->db; in DataPumpThreadBody()
63 DB* db;
69 DB* db = t->db; in ReplicationThreadBody()
115 DB* db; in main()
118 Status s = DB::Open(options, default_db_path, &db); in main()
|
| /rocksdb-6.9/utilities/ |
| D | env_librados_test.cc | 333 DB* db; in TEST_F()
381 DB* db1; in TEST_F()
416 DB* db2; in TEST_F()
459 DB* db1; in TEST_F()
497 DB* db2; in TEST_F()
543 DB* db1; in TEST_F()
581 DB* db2; in TEST_F()
628 DB* db1; in TEST_F()
678 DB* db2; in TEST_F()
875 DB* db; in TEST_F()
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_listener.h | 24 void OnFlushBegin(DB* /*db*/, const FlushJobInfo& /*info*/) override { in OnFlushBegin() argument
29 void OnFlushCompleted(DB* /*db*/, const FlushJobInfo& /*info*/) override { in OnFlushCompleted() argument
34 void OnCompactionCompleted(DB* /*db*/, in OnCompactionCompleted() argument
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/test_util/ |
| D | transaction_test_util.h | 17 class DB; variable
72 bool DBInsert(DB* db);
75 static Status DBGet(DB* db, Transaction* txn, ReadOptions& read_options,
81 static Status Verify(DB* db, uint16_t num_sets, uint64_t num_keys_per_set = 0,
127 bool DoInsert(DB* db, Transaction* txn, bool is_optimistic);
|
| /rocksdb-6.9/include/rocksdb/ |
| D | snapshot.h | 12 class DB; variable
34 explicit ManagedSnapshot(DB* db);
37 ManagedSnapshot(DB* db, const Snapshot* _snapshot);
44 DB* db_;
|