Lines Matching refs:db_
503 ASSERT_OK(db_->Put(wopt, handles_[1], "foo", "first")); in TEST_F()
504 ASSERT_OK(db_->Put(wopt, handles_[1], "bar", "one")); in TEST_F()
514 ASSERT_TRUE(db_->Get(ropt, handles_[1], "foo", &value).IsNotFound()); in TEST_F()
515 ASSERT_TRUE(db_->Get(ropt, handles_[1], "bar", &value).IsNotFound()); in TEST_F()
517 ASSERT_OK(db_->Get(ropt, handles_[1], "foo", &value)); in TEST_F()
518 ASSERT_OK(db_->Get(ropt, handles_[1], "bar", &value)); in TEST_F()
530 db_->MultiGet(ropt, multiget_cfs, multiget_keys, &multiget_values); in TEST_F()
541 ASSERT_OK(db_->Put(wopt, handles_[1], "rocksdb", "hello")); in TEST_F()
545 ASSERT_TRUE(db_->Get(ropt, handles_[1], "foo", &value).ok()); in TEST_F()
547 ASSERT_TRUE(db_->Get(ropt, handles_[1], "bar", &value).ok()); in TEST_F()
551 db_->Get(ropt, handles_[1], "rocksdb", &value).IsNotFound()); in TEST_F()
553 ASSERT_OK(db_->Get(ropt, handles_[1], "rocksdb", &value)); in TEST_F()
561 db_->MultiGet(ropt, multiget_cfs, multiget_keys, &multiget_values); in TEST_F()
573 ASSERT_OK(db_->Delete(wopt, handles_[1], "foo")); in TEST_F()
575 ASSERT_OK(db_->Delete(wopt, handles_[1], "bar")); in TEST_F()
577 ASSERT_TRUE(db_->Get(ropt, handles_[1], "foo", &value).IsNotFound()); in TEST_F()
581 ASSERT_TRUE(db_->Get(ropt, handles_[1], "bar", &value).ok()); in TEST_F()
584 ASSERT_TRUE(db_->Get(ropt, handles_[1], "bar", &value).IsNotFound()); in TEST_F()
586 ASSERT_TRUE(db_->Get(ropt, handles_[1], "rocksdb", &value).ok()); in TEST_F()
590 db_->MultiGet(ropt, multiget_cfs, multiget_keys, &multiget_values); in TEST_F()
728 Status s = db_->Get(ReadOptions(), key1, &value); in TEST_F()
733 s = db_->Get(ReadOptions(), key2, &value); in TEST_F()
740 db_->CompactRange(CompactRangeOptions(), nullptr, nullptr); in TEST_F()
745 s = db_->Get(ReadOptions(), key1, &value); in TEST_F()
750 s = db_->Get(ReadOptions(), key2, &value); in TEST_F()
800 ASSERT_OK(DB::Open(options, dbname_, &db_)); in TEST_F()
917 ASSERT_OK(db_->Put(wo, handles_[a & 1], RandomString(&rnd, 13), "")); in TEST_F()
929 auto default_tables = GetNumberOfSstFilesForColumnFamily(db_, "default"); in TEST_F()
930 auto pikachu_tables = GetNumberOfSstFilesForColumnFamily(db_, "pikachu"); in TEST_F()
1151 dbfull()->TEST_GetFilesMetaData(db_->DefaultColumnFamily(), &files_by_level); in TEST_F()
1157 db_->GetColumnFamilyMetaData(&cf_meta); in TEST_F()
1161 db_->GetLiveFilesMetaData(&live_file_meta); in TEST_F()
1368 auto default_cf = db_->DefaultColumnFamily(); in TEST_F()
1383 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1387 db_->GetApproximateSizes(&r, 1, &size); in TEST_F()
1393 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1403 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1409 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1416 default_cf = db_->DefaultColumnFamily(); in TEST_F()
1433 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1439 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1445 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1452 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, in TEST_F()
1455 db_->GetApproximateSizes(&r, 1, &size_without_mt); in TEST_F()
1467 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, in TEST_F()
1469 db_->GetApproximateSizes(&r, 1, &size_without_mt); in TEST_F()
1475 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1484 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1487 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size2); in TEST_F()
1498 const auto default_cf = db_->DefaultColumnFamily(); in TEST_F()
1508 db_->CompactRange(CompactRangeOptions(), default_cf, nullptr, nullptr); in TEST_F()
1531 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size); in TEST_F()
1538 db_->GetApproximateSizes(size_approx_options, default_cf, &r, 1, &size2); in TEST_F()
1562 db_->GetApproximateMemTableStats(r, &count, &size); in TEST_F()
1571 db_->GetApproximateMemTableStats(r, &count, &size); in TEST_F()
1580 db_->GetApproximateMemTableStats(r, &count, &size); in TEST_F()
1591 db_->GetApproximateMemTableStats(r, &count, &size); in TEST_F()
1701 const Snapshot* s1 = db_->GetSnapshot(); in TEST_F()
1711 const Snapshot* s2 = db_->GetSnapshot(); in TEST_F()
1719 ManagedSnapshot s3(db_); in TEST_F()
1746 db_->ReleaseSnapshot(s1); in TEST_F()
1755 db_->ReleaseSnapshot(s2); in TEST_F()
1775 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
1784 db_->ReleaseSnapshot(snapshot); in TEST_F()
1821 const Snapshot* snapshot = db_->GetSnapshot(); in TEST_F()
1843 db_->ReleaseSnapshot(snapshot); in TEST_F()
2097 ASSERT_TRUE(db_ != nullptr); in TEST_F()
2110 ASSERT_TRUE(db_ == nullptr); in TEST_F()
2385 DB* db = t->state->test->db_; in MTThreadBody()
2606 thread[id].db = db_; in TEST_F()
2620 Iterator* itr = db_->NewIterator(ReadOptions()); in TEST_F()
3131 ASSERT_OK(db_->Put(WriteOptions(), k, v)); in TEST_P()
3135 ASSERT_OK(db_->Delete(WriteOptions(), k)); in TEST_P()
3154 ASSERT_OK(db_->Write(WriteOptions(), &b)); in TEST_P()
3163 ASSERT_TRUE(CompareIterators(step, &model, db_, nullptr, nullptr)); in TEST_P()
3164 ASSERT_TRUE(CompareIterators(step, &model, db_, model_snap, db_snap)); in TEST_P()
3171 if (db_snap != nullptr) db_->ReleaseSnapshot(db_snap); in TEST_P()
3174 ASSERT_TRUE(CompareIterators(step, &model, db_, nullptr, nullptr)); in TEST_P()
3177 db_snap = db_->GetSnapshot(); in TEST_P()
3181 if (db_snap != nullptr) db_->ReleaseSnapshot(db_snap); in TEST_P()
3233 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_F()
3243 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
3252 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
3327 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_P()
3760 ASSERT_EQ(db_->GetOptions().allow_mmap_reads, false); in TEST_F()
3797 ASSERT_NOK(db_->CreateColumnFamily(cf_options, "name", &handle)); in TEST_F()
3881 db_->Put(wopt, db_->DefaultColumnFamily(), "a" + istr, "b" + istr); in TEST_F()
3896 db_->FlushWAL(false); in TEST_F()
3909 db_->Get(ropt, db_->DefaultColumnFamily(), "a" + istr, &pval)); in TEST_F()
4149 db_->DropColumnFamily(handles_[2]); in TEST_F()
4191 db_->GetIntProperty(DB::Properties::kNumRunningFlushes, &num_running_flushes); in TEST_F()
4201 db_->GetIntProperty(DB::Properties::kNumRunningFlushes, &num_running_flushes); in TEST_F()
4251 db_->GetIntProperty(DB::Properties::kNumRunningCompactions, in TEST_P()
4268 db_->GetIntProperty(DB::Properties::kNumRunningCompactions, in TEST_P()
4314 CancelAllBackgroundWork(db_); in TEST_P()
4315 db_->CompactRange(CompactRangeOptions(), handles_[1], nullptr, nullptr); in TEST_P()
4332 CancelAllBackgroundWork(db_); in TEST_F()
4334 db_->CompactRange(CompactRangeOptions(), handles_[1], nullptr, nullptr); in TEST_F()
4413 CancelAllBackgroundWork(db_); in TEST_P()
4499 CancelAllBackgroundWork(db_); in TEST_P()
4521 CancelAllBackgroundWork(db_); in TEST_F()
4591 db_->GetColumnFamilyMetaData(&cf_meta); in TEST_F()
4599 std::unique_ptr<Iterator> iter(db_->NewIterator(ReadOptions())); in TEST_F()
4778 db_->GetLiveFilesMetaData(&metadata); in TEST_F()
4797 db_->GetLiveFilesMetaData(&metadata); in TEST_F()
5148 std::unique_ptr<Iterator> iter(db_->NewIterator(ReadOptions())); in TEST_F()
5392 db_->Put(WriteOptions(), "foo", one); in TEST_F()
5394 ASSERT_OK(db_->Merge(WriteOptions(), "foo", two)); in TEST_F()
5396 ASSERT_OK(db_->Merge(WriteOptions(), "foo", three)); in TEST_F()
5403 db_->Get(opt, "foo", &result); in TEST_F()
5408 std::unique_ptr<Iterator> iter(db_->NewIterator(read_options)); in TEST_F()
5436 ASSERT_OK(db_->Merge(WriteOptions(), "foo", "TEST")); in TEST_P()
5466 ASSERT_OK(db_->CompactRange(cro, nullptr, nullptr)); in TEST_P()
5471 Iterator* itr = db_->NewIterator(ReadOptions()); in TEST_P()
5583 ASSERT_OK(experimental::SuggestCompactRange(db_, nullptr, nullptr)); in TEST_F()
5596 ASSERT_OK(experimental::SuggestCompactRange(db_, &start, &end)); in TEST_F()
5604 ASSERT_OK(experimental::SuggestCompactRange(db_, &start, &end)); 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()
5669 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
5676 status = experimental::PromoteL0(db_, db_->DefaultColumnFamily()); in TEST_F()
5697 ASSERT_OK(db_->CompactRange(CompactRangeOptions(), nullptr, nullptr)); in TEST_F()
5737 ASSERT_OK(db_->CompactRange(croptions, nullptr, nullptr)); in TEST_F()
5779 db_->GetColumnFamilyMetaData(db_->DefaultColumnFamily(), &cf_meta_data); in TEST_F()
5794 auto s = db_->CompactFiles(CompactionOptions(), in TEST_F()
5795 db_->DefaultColumnFamily(), input_files, 0); in TEST_F()
5807 db_->GetColumnFamilyMetaData(db_->DefaultColumnFamily(), &cf_meta_data); in TEST_F()
5816 db_->GetColumnFamilyMetaData(db_->DefaultColumnFamily(), &cf_meta_data); in TEST_F()
6289 ASSERT_TRUE(!db_->CreateColumnFamily(cf_options, "name", &handle).ok()); in TEST_F()
6303 ASSERT_OK(db_->CreateColumnFamily(cf_options, "pikachu", &handle)); in TEST_F()
6380 ASSERT_OK(db_->DropColumnFamily(handles_[0])); in TEST_F()
6395 Status s = db_->SyncWAL(); in TEST_F()
6410 db_->PauseBackgroundWork(); in TEST_F()
6421 db_->ContinueBackgroundWork(); in TEST_F()
6441 ASSERT_OK(db_->Put(WriteOptions(), Slice("hi"), in TEST_F()
6443 ASSERT_OK(db_->Flush(FlushOptions())); in TEST_F()
6455 auto it = db_->NewIterator(ReadOptions()); in TEST_F()