Lines Matching refs:db_
65 std::unique_ptr<Iterator> iter(db_->NewIterator(ReadOptions())); in TEST_P()
92 Iterator* iter1 = db_->NewIterator(ReadOptions()); in TEST_F()
102 Iterator* iter2 = db_->NewIterator(ReadOptions()); in TEST_F()
112 Iterator* iter3 = db_->NewIterator(ReadOptions()); in TEST_F()
160 db_->Merge(WriteOptions(), "poi", "Reese"); in TEST_F()
161 db_->Merge(WriteOptions(), "poi", "Shaw"); in TEST_F()
162 db_->Merge(WriteOptions(), "poi", "Root"); in TEST_F()
233 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
235 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
254 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
256 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "pikachu"), in TEST_P()
258 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "dobrynia"), in TEST_P()
260 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
270 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
272 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "pikachu"), in TEST_P()
274 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "dobrynia"), in TEST_P()
276 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
288 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
290 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "pikachu"), in TEST_P()
292 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "dobrynia"), in TEST_P()
294 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
311 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
313 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "pikachu"), in TEST_P()
315 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "dobrynia"), in TEST_P()
317 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
333 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_P()
335 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "pikachu"), in TEST_P()
337 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "dobrynia"), in TEST_P()
339 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "nikitich"), in TEST_P()
412 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default") + in TEST_F()
413 GetNumberOfSstFilesForColumnFamily(db_, "cf1") + in TEST_F()
414 GetNumberOfSstFilesForColumnFamily(db_, "cf2"), in TEST_F()
426 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_F()
428 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "cf1"), in TEST_F()
430 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "cf2"), in TEST_F()
443 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "default"), in TEST_F()
445 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "cf1"), in TEST_F()
447 ASSERT_EQ(GetNumberOfSstFilesForColumnFamily(db_, "cf2"), in TEST_F()
658 ValidateKeyExistence(db_, keys_must_exist, keys_must_not_exist); in TEST_F()
792 ValidateKeyExistence(db_, keys_must_exist, keys_must_not_exist); in TEST_F()
869 ValidateKeyExistence(db_, keys_must_exist, keys_must_not_exist); in TEST_F()
968 db_->Flush(FlushOptions(), handles_[0]); in TEST_F()
1217 ASSERT_OK(db_->CompactRange(compact_range_opts, nullptr, nullptr)); in TEST_F()
1426 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
1431 db_->ReleaseSnapshot(s1); in TEST_F()
1439 DBImpl* dbi = reinterpret_cast<DBImpl*>(db_); in TEST_F()
1443 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1444 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1446 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1451 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1453 snapshots.push_back(db_->GetSnapshot()); in TEST_F()
1463 db_->ReleaseSnapshot(s); in TEST_F()
1547 db_->KeyMayExist(ReadOptions(), handles_[1], "key", &value); in TEST_P()
1735 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
1879 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
1912 iter = db_->NewIterator(ReadOptions()); in TEST_F()
2104 ASSERT_OK(db_->Get(ReadOptions(), key, &value)); in TEST_F()
2129 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
2210 ASSERT_OK(db_->Get(ReadOptions(), key, &value)); in TEST_F()
2238 ASSERT_OK(db_->Get(ReadOptions(), key, &value)); in TEST_F()
2285 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
2330 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
2357 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
2369 ASSERT_OK(db_->CompactRange(cro, &k1s, &k2s)); in TEST_F()
2404 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
2624 ASSERT_OK(DB::Open(options, dbname_, &db_)); in TEST_F()
2647 ASSERT_OK(DB::Open(options, dbname_, &db_)); in TEST_F()
2662 ASSERT_OK(db_->Get(ReadOptions(), db_->DefaultColumnFamily(), "foo", &value)); in TEST_F()
2733 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
2751 ASSERT_OK(db_->Get(ropt, handles_[1], "foo", &value)); in TEST_F()
2753 ASSERT_OK(db_->Get(ropt, handles_[1], "bar", &value)); in TEST_F()
2757 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2771 ASSERT_OK(db_->Get(ropt, handles_[1], "foo", &value)); in TEST_F()
2773 ASSERT_OK(db_->Get(ropt, handles_[1], "bar", &value)); in TEST_F()
2776 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2788 it = db_->NewIterator(ropt, handles_[1]); in TEST_F()
2908 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
3069 db_->Flush(flush_opts); in TEST_F()
3072 db_->DisableFileDeletions(); in TEST_F()
3074 db_->GetSortedWalFiles(log_files); in TEST_F()
3080 db_->EnableFileDeletions(); in TEST_F()
3125 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
3150 ASSERT_TRUE(db_->EndTrace().IsIOError()); in TEST_F()
3155 ASSERT_OK(db_->StartTrace(trace_opts, std::move(trace_writer))); in TEST_F()
3161 ASSERT_OK(db_->DeleteRange(wo, dbfull()->DefaultColumnFamily(), "e", "f")); in TEST_F()
3169 ASSERT_OK(db_->Write(wo, &batch)); in TEST_F()
3171 single_iter = db_->NewIterator(ro); in TEST_F()
3183 ASSERT_OK(db_->EndTrace()); in TEST_F()
3258 ASSERT_OK(db_->StartTrace(trace_opts, std::move(trace_writer))); in TEST_F()
3262 ASSERT_OK(db_->EndTrace()); in TEST_F()
3325 ASSERT_OK(db_->StartTrace(trace_opts, std::move(trace_writer))); in TEST_F()
3331 ASSERT_OK(db_->EndTrace()); in TEST_F()
3398 ASSERT_OK(db_->StartTrace(trace_opts, std::move(trace_writer))); in TEST_F()
3404 ASSERT_OK(db_->DeleteRange(wo, dbfull()->DefaultColumnFamily(), "e", "f")); in TEST_F()
3412 ASSERT_OK(db_->Write(wo, &batch)); in TEST_F()
3414 single_iter = db_->NewIterator(ro); in TEST_F()
3426 ASSERT_OK(db_->EndTrace()); in TEST_F()
3628 std::unique_ptr<Iterator> iter(db_->NewIterator(ReadOptions())); in TEST_F()
3695 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
3733 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
3778 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
3800 DBImpl* dbi = reinterpret_cast<DBImpl*>(db_); in TEST_F()
3838 auto* handle = db_->DefaultColumnFamily(); in TEST_F()
3839 ASSERT_EQ(db_->NumberLevels(handle), 2); in TEST_F()
3862 ASSERT_OK(db_->IngestExternalFile(handle, {external_file1, external_file3}, in TEST_F()
3870 [&]() { db_->CompactFiles(CompactionOptions(), handle, files, 1); }); in TEST_F()
3873 ASSERT_OK(db_->IngestExternalFile(handle, {external_file2}, in TEST_F()
3982 const Snapshot* ss = db_->GetSnapshot(); in TEST_F()
3985 db_->DestroyColumnFamilyHandle(h); 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()
4015 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
4019 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
4055 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
4057 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
4079 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
4085 const Snapshot* s2 = db_->GetSnapshot(); in TEST_F()
4087 const Snapshot* s3 = db_->GetSnapshot(); in TEST_F()
4110 db_->ReleaseSnapshot(s1); in TEST_F()
4111 db_->ReleaseSnapshot(s2); in TEST_F()
4112 db_->ReleaseSnapshot(s3); in TEST_F()
4192 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
4194 db_->DeleteRange(WriteOptions(), db_->DefaultColumnFamily(), "a", "f")); in TEST_F()
4205 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
4210 std::unique_ptr<Iterator> iter(db_->NewIterator(ro)); in TEST_F()
4215 db_->ReleaseSnapshot(s1); in TEST_F()
4227 Iterator* iter = db_->NewIterator(ReadOptions()); in TEST_F()
4232 db_->GetEnv()->SetBackgroundThreads(1, Env::Priority::HIGH); in TEST_F()
4234 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
4246 db_->GetEnv()->Schedule(&test::SleepingBackgroundTask::DoSleepTask, in TEST_F()
4284 ASSERT_OK(db_->Merge(WriteOptions(), "key", "3")); in TEST_F()
4285 ASSERT_OK(db_->Merge(WriteOptions(), "key", "4")); in TEST_F()
4290 ASSERT_OK(dbfull()->CompactRange(cro, db_->DefaultColumnFamily(), nullptr, in TEST_F()
4293 ASSERT_OK(db_->Merge(WriteOptions(), "key", "5")); in TEST_F()
4295 ASSERT_OK(db_->Merge(WriteOptions(), "key", "6")); in TEST_F()
4297 ASSERT_OK(db_->Merge(WriteOptions(), "key", "7")); in TEST_F()
4299 ASSERT_OK(db_->Merge(WriteOptions(), "key", "8")); in TEST_F()
4331 std::unique_ptr<Iterator> iterator(db_->NewIterator(ReadOptions())); in TEST_F()
4412 std::unique_ptr<Iterator> iterator(db_->NewIterator(ReadOptions())); in TEST_F()
4436 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4450 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4470 ASSERT_OK(db_->CompactRange(compact_range_opts, nullptr, nullptr)); in TEST_F()
4471 ASSERT_OK(db_->CompactRange(compact_range_opts, nullptr, nullptr)); in TEST_F()
4475 std::unique_ptr<Iterator> iterator(db_->NewIterator(ReadOptions())); in TEST_F()
4499 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4519 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4596 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4608 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4617 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4627 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()
4639 std::unique_ptr<Iterator> iterator(db_->NewIterator(ro)); in TEST_F()