Home
last modified time | relevance | path

Searched refs:db_ (Results 1 – 25 of 104) sorted by relevance

12345

/rocksdb-6.9/db/
Ddb_range_del_test.cc37 ASSERT_TRUE(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
53 ASSERT_OK(db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
266 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
301 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
360 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
388 ASSERT_OK(db_->SetOptions(db_->DefaultColumnFamily(), in TEST_F()
601 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
755 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), in TEST_F()
913 db_->EnableAutoCompaction({db_->DefaultColumnFamily()}); in TEST_F()
1007 ASSERT_OK(db_->SetOptions(db_->DefaultColumnFamily(), in TEST_F()
[all …]
Dcorruption_test.cc46 DB* db_; member in ROCKSDB_NAMESPACE::CorruptionTest
58 db_ = nullptr; in CorruptionTest()
68 delete db_; in ~CorruptionTest()
73 delete db_; in CloseDb()
74 db_ = nullptr; in CloseDb()
78 delete db_; in TryReopen()
79 db_ = nullptr; in TryReopen()
99 delete db_; in RepairDB()
100 db_ = nullptr; in RepairDB()
577 delete db_; in TEST_F()
[all …]
Ddb_merge_operand_test.cc62 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k0", in TEST_F()
70 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k0.1", in TEST_F()
81 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k1", in TEST_F()
104 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k1.1", in TEST_F()
117 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2", in TEST_F()
131 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2.1", in TEST_F()
142 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k2.2", in TEST_F()
160 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k3", in TEST_F()
176 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k3.1", in TEST_F()
208 db_->GetMergeOperands(ReadOptions(), db_->DefaultColumnFamily(), "k4", in TEST_F()
[all …]
Dimport_column_family_test.cc25 db_->DropColumnFamily(import_cfh_); in ~ImportColumnFamilyTest()
26 db_->DestroyColumnFamilyHandle(import_cfh_); in ~ImportColumnFamilyTest()
30 db_->DropColumnFamily(import_cfh2_); in ~ImportColumnFamilyTest()
31 db_->DestroyColumnFamilyHandle(import_cfh2_); in ~ImportColumnFamilyTest()
99 ASSERT_OK(db_->CreateColumnFamilyWithImport( in TEST_F()
108 ASSERT_OK(db_->DropColumnFamily(import_cfh_)); in TEST_F()
120 ASSERT_OK(db_->CreateColumnFamilyWithImport( in TEST_F()
208 ASSERT_OK(db_->CreateColumnFamilyWithImport( in TEST_F()
232 ASSERT_OK(db_->Flush(FlushOptions(), import_cfh_)); in TEST_F()
296 ASSERT_OK(Checkpoint::Create(db_, &checkpoint)); in TEST_F()
[all …]
Ddeletefile_test.cc145 db_->GetLiveFilesMetaData(&metadata); in TEST_F()
179 status = db_->DeleteFile(level1file); in TEST_F()
212 itr = db_->NewIterator(ReadOptions()); in TEST_F()
239 itr = db_->NewIterator(read_options); in TEST_F()
281 ASSERT_OK(db_->Flush(fo, cfh)); in TEST_F()
421 db_->GetLiveFilesMetaData(&metadata); in TEST_F()
455 db_->GetSortedWalFiles(logfiles); in TEST_F()
472 db_->Flush(fopts); in TEST_F()
474 db_->Flush(fopts); in TEST_F()
475 db_->GetSortedWalFiles(logfiles); in TEST_F()
[all …]
Ddb_merge_operator_test.cc174 auto* iter = db_->NewIterator(ReadOptions()); in TEST_F()
179 iter = db_->NewIterator(ReadOptions()); in TEST_F()
193 iter = db_->NewIterator(ReadOptions()); in TEST_F()
403 Iterator* iter = db_->NewIterator(ro); in TEST_P()
450 db_->Merge(WriteOptions(), "key", "sst"); in TEST_F()
525 ASSERT_EQ(1, db_->GetLatestSequenceNumber()); in TEST_F()
528 ASSERT_EQ(2, db_->GetLatestSequenceNumber()); in TEST_F()
543 ASSERT_EQ(3, db_->GetLatestSequenceNumber()); in TEST_F()
546 ASSERT_EQ(4, db_->GetLatestSequenceNumber()); in TEST_F()
576 db_->ReleaseSnapshot(snapshot1); in TEST_F()
[all …]
Dfault_injection_test.cc75 DB* db_; member in ROCKSDB_NAMESPACE::FaultInjectionTest
84 db_(nullptr) {} in FaultInjectionTest()
145 assert(db_ == nullptr); in NewDB()
256 delete db_; in CloseDB()
257 db_ = nullptr; in CloseDB()
264 assert(db_ != nullptr); in OpenDB()
279 db_->Flush(flush_options); in DeleteAllData()
411 db_->FlushWAL(false); in TEST_P()
452 db_->Flush(flush_options); in TEST_P()
496 ASSERT_OK(db_->FlushWAL(true)); in TEST_P()
[all …]
Ddb_test2.cc1431 db_->ReleaseSnapshot(s1); in TEST_F()
1463 db_->ReleaseSnapshot(s); in TEST_F()
2662 ASSERT_OK(db_->Get(ReadOptions(), db_->DefaultColumnFamily(), "foo", &value)); in TEST_F()
3069 db_->Flush(flush_opts); in TEST_F()
3989 ASSERT_NOK(db_->Close()); in TEST_F()
3990 db_->ReleaseSnapshot(ss); in TEST_F()
3991 ASSERT_OK(db_->Close()); in TEST_F()
3992 delete db_; in TEST_F()
3993 db_ = nullptr; in TEST_F()
4110 db_->ReleaseSnapshot(s1); in TEST_F()
[all …]
Ddb_tailing_iter_test.cc30 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
35 ASSERT_OK(db_->Put(WriteOptions(), "mirko", "fodor")); in TEST_F()
237 iter.reset(db_->NewIterator(read_options, handles_[1])); in TEST_F()
338 ASSERT_OK(db_->Put(WriteOptions(), key, value)); in TEST_F()
340 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
367 ASSERT_OK(db_->Put(WriteOptions(), key, value)); in TEST_F()
466 db_->GetColumnFamilyMetaData(handles_[1], &meta); in TEST_F()
490 ASSERT_OK(db_->Put(WriteOptions(), "aa", "SEEN")); in TEST_F()
494 ASSERT_OK(db_->Put(WriteOptions(), "zz", "NOT-SEEN")); in TEST_F()
512 ASSERT_OK(db_->Put(WriteOptions(), "aa", "SEEN")); in TEST_F()
[all …]
Ddb_properties_test.cc304 db_->Flush(FlushOptions()); in TEST_F()
344 ManagedSnapshot snapshot(db_); in TEST_F()
363 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), start, end); in TEST_F()
365 db_->Flush(FlushOptions()); in TEST_F()
541 ManagedSnapshot snapshot(db_); in TEST_F()
563 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), start, end); in TEST_F()
565 db_->Flush(FlushOptions()); in TEST_F()
569 db_->GetProperty( in TEST_F()
1185 db_->Flush(FlushOptions()); in TEST_F()
1576 DB* db_ = nullptr; in TEST_F() member in ROCKSDB_NAMESPACE::TEST_F::TestListener
[all …]
Ddb_test_util.cc87 db_ = nullptr; in DBTestBase()
640 delete db_; in Close()
641 db_ = nullptr; in Close()
706 return db_->Merge(wo, k, v); in Put()
708 return db_->Put(wo, k, v); in Put()
722 return db_->Merge(wo, k, v); in Merge()
1032 EXPECT_TRUE(db_->GetProperty( in NumTableFilesAtLevel()
1060 levels = (cf == 0) ? db_->NumberLevels() : db_->NumberLevels(handles_[1]); in TotalTableFiles()
1072 (cf == 0) ? db_->NumberLevels() : db_->NumberLevels(handles_[1]); in FilesPerLevel()
1258 iter = db_->NewIterator(ro); in VerifyIterLast()
[all …]
Dcolumn_family_test.cc179 db_->DestroyColumnFamilyHandle(h); in Close()
184 delete db_; in Close()
185 db_ = nullptr; in Close()
210 &db_);
337 db_->FlushWAL(false); in PutRandomData()
427 db_->GetLiveFilesMetaData(&metadata); in CountLiveFiles()
547 DB* db_ = nullptr; member in ROCKSDB_NAMESPACE::ColumnFamilyTestBase
659 db_->FlushWAL(false); in TEST_P()
722 db_->FlushWAL(false); in TEST_P()
2950 ASSERT_OK(db_->DropColumnFamily(cfh)); in TEST_P()
[all …]
Ddb_dynamic_level_test.cc106 db_->GetColumnFamilyMetaData(&cf_meta); in TEST_F()
155 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
168 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
186 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
188 ASSERT_TRUE(db_->GetProperty("rocksdb.num-files-at-level1", &str_prop)); in TEST_F()
207 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
236 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
271 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
308 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
325 ASSERT_TRUE(db_->GetIntProperty("rocksdb.base-level", &int_prop)); in TEST_F()
[all …]
Ddb_compaction_filter_test.cc468 Iterator* itr = db_->NewIterator(ReadOptions()); in TEST_F()
555 ASSERT_OK(db_->Put(WriteOptions(), "foo", two)); in TEST_F()
557 ASSERT_OK(db_->Merge(WriteOptions(), "foo", one)); in TEST_F()
567 ASSERT_OK(db_->Put(WriteOptions(), "bar", two)); in TEST_F()
572 ASSERT_OK(db_->Merge(WriteOptions(), "bar", two)); in TEST_F()
714 snapshot = db_->GetSnapshot(); in TEST_F()
752 db_->ReleaseSnapshot(snapshot); in TEST_F()
786 Status s = db_->Get(ReadOptions(), key, &val); in TEST_F()
822 s = db_->Get(ReadOptions(), "0000000010", &val); in TEST_F()
826 s = db_->Get(ReadOptions(), "0000000020", &val); in TEST_F()
[all …]
Ddb_test.cc1746 db_->ReleaseSnapshot(s1); in TEST_F()
1755 db_->ReleaseSnapshot(s2); in TEST_F()
2606 thread[id].db = db_; in TEST_F()
3881 db_->Put(wopt, db_->DefaultColumnFamily(), "a" + istr, "b" + istr); in TEST_F()
3909 db_->Get(ropt, db_->DefaultColumnFamily(), "a" + istr, &pval)); in TEST_F()
5641 ASSERT_OK(experimental::PromoteL0(db_, db_->DefaultColumnFamily(), 2)); in TEST_F()
5666 status = experimental::PromoteL0(db_, db_->DefaultColumnFamily()); in TEST_F()
5676 status = experimental::PromoteL0(db_, db_->DefaultColumnFamily()); in TEST_F()
5779 db_->GetColumnFamilyMetaData(db_->DefaultColumnFamily(), &cf_meta_data); in TEST_F()
5807 db_->GetColumnFamilyMetaData(db_->DefaultColumnFamily(), &cf_meta_data); in TEST_F()
[all …]
Dcuckoo_table_db_test.cc24 DB* db_; member in ROCKSDB_NAMESPACE::CuckooTableDBTest
30 db_ = nullptr; in CuckooTableDBTest()
35 delete db_; in ~CuckooTableDBTest()
50 return reinterpret_cast<DBImpl*>(db_); in dbfull()
55 delete db_; in Reopen()
56 db_ = nullptr; in Reopen()
64 ASSERT_OK(DB::Open(opts, dbname_, &db_)); in Reopen()
68 return db_->Put(WriteOptions(), k, v); in Put()
72 return db_->Delete(WriteOptions(), k); in Delete()
78 Status s = db_->Get(options, k, &result); in Get()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dstackable_db.h23 explicit StackableDB(DB* db) : db_(db) {} in StackableDB()
31 delete db_; in ~StackableDB() local
33 assert(shared_db_ptr_.get() == db_); in ~StackableDB()
35 db_ = nullptr; in ~StackableDB()
40 virtual DB* GetBaseDB() { return db_; } in GetBaseDB()
180 return db_->Write(opts, updates); in Write()
263 return db_->PauseBackgroundWork(); in PauseBackgroundWork()
303 return db_->GetFileSystem(); in GetFileSystem()
313 return db_->GetDBOptions(); in GetDBOptions()
396 return db_->DeleteFile(name); in DeleteFile()
[all …]
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc55 s = db_->GetEnv()->DeleteFile(subchild_path); in CleanStagingDirectory()
60 s = db_->GetEnv()->DeleteDir(full_private_path); in CleanStagingDirectory()
75 DBOptions db_options = db_->GetDBOptions(); in CreateCheckpoint()
107 s = db_->GetEnv()->CreateDir(full_private_path); in CreateCheckpoint()
110 db_->DisableFileDeletions(); in CreateCheckpoint()
134 db_->EnableFileDeletions(false); in CreateCheckpoint()
246 db_->FlushWAL(false /* sync */); in CreateCustomCheckpoint()
250 s = db_->GetSortedWalFiles(live_wal_files); in CreateCustomCheckpoint()
345 const auto db_options = db_->GetDBOptions(); in ExportColumnFamily()
368 s = db_->GetEnv()->CreateDir(tmp_export_dir); in ExportColumnFamily()
[all …]
Dcheckpoint_test.cc44 DB* db_; member in ROCKSDB_NAMESPACE::CheckpointTest
63 db_ = nullptr; in CheckpointTest()
171 delete db_; in Close()
172 db_ = nullptr; in Close()
270 delete db_; in TEST_F()
271 db_ = nullptr; in TEST_F()
294 delete db_; in TEST_F()
295 db_ = nullptr; in TEST_F()
305 delete db_; in TEST_F()
746 delete db_; in TEST_F()
[all …]
/rocksdb-6.9/utilities/backupable/
Dbackupable_db_test.cc588 db_.reset(db); in OpenDBAndBackupEngine()
600 db_.reset(); in CloseDBAndBackupEngine()
677 std::unique_ptr<DB> db_; member in ROCKSDB_NAMESPACE::__anon6f9a36820111::BackupableDBTest
1096 db_.reset(); in TEST_F()
1097 db_.reset(OpenDB()); in TEST_F()
1196 FillDB(db_.get(), 0, 300); in TEST_F()
1371 FillDB(db_.get(), 0, 100); in TEST_F()
1447 FillDB(db_.get(), 0, 100); in TEST_F()
1479 FillDB(db_.get(), 0, 100); in TEST_F()
1482 db_.get(), true, in TEST_F()
[all …]
/rocksdb-6.9/tools/
Dreduce_levels_test.cc25 db_ = nullptr; in ReduceLevelTest()
31 return db_->Put(WriteOptions(), k, v); in Put()
37 Status s = db_->Get(options, k, &result); in Get()
47 if (db_ == nullptr) { in Flush()
50 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db_); in Flush()
55 DBImpl* db_impl = reinterpret_cast<DBImpl*>(db_); in MoveL0FileToLevel()
62 if (db_ != nullptr) { in CloseDB()
63 delete db_; in CloseDB()
64 db_ = nullptr; in CloseDB()
72 EXPECT_TRUE(db_->GetProperty( in FilesOnLevel()
[all …]
/rocksdb-6.9/monitoring/
Dstats_history_test.cc172 db_->GetStatsHistory(0 /*start_time*/, 6 /*end_time*/, &stats_iter); in TEST_F()
188 db_->GetStatsHistory(0 /*start_time*/, 20 /*end_time*/, &stats_iter); in TEST_F()
231 Iterator* iterator = db_->NewIterator(ReadOptions()); in TEST_F()
238 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
250 iterator = db_->NewIterator(ReadOptions()); in TEST_F()
256 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
262 db_->GetStatsHistory(0 /*start_time*/, 10 /*end_time*/, &stats_iter); in TEST_F()
282 db_->GetStatsHistory(0 /*start_time*/, 20 /*end_time*/, &stats_iter); in TEST_F()
348 db_->GetStatsHistory(0 /*start_time*/, 16 /*end_time*/, &stats_iter); in TEST_F()
498 db_->GetStatsHistory(0 /*start_time*/, 5 /*end_time*/, &stats_iter); in TEST_F()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc88 DB* db_; member in ROCKSDB_NAMESPACE::CompactionJobStatsTest
108 db_ = nullptr; in CompactionJobStatsTest()
130 return reinterpret_cast<DBImpl*>(db_); in dbfull()
190 delete db_; in Close()
191 db_ = nullptr; in Close()
217 return db_->Flush(FlushOptions()); in Flush()
224 return db_->Put(wo, k, v); in Put()
233 return db_->Delete(WriteOptions(), k); in Delete()
273 EXPECT_TRUE(db_->GetProperty( in NumTableFilesAtLevel()
276 EXPECT_TRUE(db_->GetProperty( in NumTableFilesAtLevel()
[all …]
/rocksdb-6.9/util/
Dslice_transform_test.cc52 DB* db_; member in ROCKSDB_NAMESPACE::SliceTransformDBTest
55 SliceTransformDBTest() : env_(Env::Default()), db_(nullptr) { in SliceTransformDBTest()
61 delete db_; in ~SliceTransformDBTest()
65 DB* db() { return db_; } in db()
77 delete db_; in Destroy()
78 db_ = nullptr; in Destroy()
83 delete db_; in TryReopen()
84 db_ = nullptr; in TryReopen()
87 return DB::Open(last_options_, dbname_, &db_); in TryReopen()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc26 db_(nullptr), in StressTest()
67 delete db_; in ~StressTest()
406 delete db_; in PreloadDbAndReopenAsReadOnly()
407 db_ = nullptr; in PreloadDbAndReopenAsReadOnly()
1729 assert(db_ == nullptr); in Open()
1974 db_ = blob_db; in Open()
2007 db_ = txn_db_; in Open()
2072 db_ = db_with_ttl; in Open()
2127 Status s = db_->Close(); in Reopen()
2135 delete db_; in Reopen()
[all …]

12345