Home
last modified time | relevance | path

Searched refs:dbname_ (Results 1 – 25 of 64) sorted by relevance

123

/rocksdb-6.9/db/
Ddb_logical_block_size_cache_test.cc38 cf_path_0_(dbname_ + "/cf_path_0"), in DBLogicalBlockSizeCacheTest()
39 cf_path_1_(dbname_ + "/cf_path_1") { in DBLogicalBlockSizeCacheTest()
52 std::string dbname_; member in ROCKSDB_NAMESPACE::DBLogicalBlockSizeCacheTest
136 ASSERT_TRUE(cache_->Contains(dbname_)); in TEST_F()
142 ASSERT_TRUE(cache_->Contains(dbname_)); in TEST_F()
152 ASSERT_TRUE(cache_->Contains(dbname_)); in TEST_F()
161 ASSERT_TRUE(cache_->Contains(dbname_)); in TEST_F()
220 ASSERT_OK(DestroyDB(dbname_, options, in TEST_F()
309 ASSERT_OK(DestroyDB(dbname_, options, in TEST_F()
353 options, dbname_, in TEST_F()
[all …]
Drepair_test.cc57 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
80 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
106 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
123 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
142 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
163 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
188 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
216 ASSERT_OK(RepairDB(dbname_, options)); in TEST_F()
259 ASSERT_OK(RepairDB(dbname_, CurrentOptions())); in TEST_F()
323 ASSERT_OK(RepairDB(dbname_, opts, {{"default", opts}}, in TEST_F()
[all …]
Dwal_manager_test.cc35 dbname_(test::PerThreadDBPath("wal_manager_test")), in WalManagerTest()
40 DestroyDB(dbname_, Options()); in WalManagerTest()
44 ASSERT_OK(env_->CreateDirIfMissing(dbname_)); in Init()
45 ASSERT_OK(env_->CreateDirIfMissing(ArchivalDirectory(dbname_))); in Init()
46 db_options_.db_paths.emplace_back(dbname_, in Init()
48 db_options_.wal_dir = dbname_; in Init()
53 versions_.reset(new VersionSet(dbname_, &db_options_, env_options_, in Init()
108 std::string dbname_; member in ROCKSDB_NAMESPACE::WalManagerTest
124 std::string path = dbname_ + "/000001.log"; in TEST_F()
229 std::string archive_dir = ArchivalDirectory(dbname_); in TEST_F()
[all …]
Ddeletefile_test.cc40 wal_dir_(dbname_ + "/wal_files") {} in DeleteFileTest()
198 CheckFileTypeCounts(dbname_, 0, 2, 1); in TEST_F()
206 CheckFileTypeCounts(dbname_, 0, 1, 1); in TEST_F()
215 CheckFileTypeCounts(dbname_, 0, 3, 1); in TEST_F()
218 CheckFileTypeCounts(dbname_, 0, 1, 1); in TEST_F()
242 CheckFileTypeCounts(dbname_, 0, 3, 1); in TEST_F()
252 CheckFileTypeCounts(dbname_, 0, 3, 1); in TEST_F()
260 CheckFileTypeCounts(dbname_, 0, 1, 1); in TEST_F()
353 CheckFileTypeCounts(dbname_, 0, 3, 1); in TEST_F()
364 CheckFileTypeCounts(dbname_, 0, 1, 1); in TEST_F()
[all …]
Dmanual_compaction_test.cc41 dbname_ = test::PerThreadDBPath("rocksdb_manual_compaction_test"); in ManualCompactionTest()
42 DestroyDB(dbname_, Options()); in ManualCompactionTest()
45 std::string dbname_; member in __anon80cb0b6e0111::ManualCompactionTest
101 ASSERT_OK(DB::Open(options, dbname_, &db)); in TEST_F()
120 DestroyDB(dbname_, options); in TEST_F()
133 ASSERT_OK(DB::Open(db_options, dbname_, &db)); in TEST_F()
176 DestroyDB(dbname_, Options()); in TEST_F()
190 ASSERT_OK(DB::Open(options, dbname_, &db)); in TEST_F()
288 DestroyDB(dbname_, options); in TEST_F()
Ddb_universal_compaction_test.cc1294 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
1300 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
1306 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
1315 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
1326 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
1337 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
1634 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
1639 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
1644 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
1649 ASSERT_EQ(0, GetSstFileCount(dbname_)); in TEST_P()
[all …]
Dflush_job_test.cc34 dbname_(test::PerThreadDBPath("flush_job_test")), in FlushJobTest()
42 EXPECT_OK(env_->CreateDirIfMissing(dbname_));
43 db_options_.db_paths.emplace_back(dbname_,
56 versions_.reset(new VersionSet(dbname_, &db_options_, env_options_,
64 SetIdentityFile(env_, dbname_); in NewDB()
67 DBImpl* impl = new DBImpl(DBOptions(), dbname_); in NewDB()
89 const std::string manifest = DescriptorFileName(dbname_, 1); in NewDB()
111 s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in NewDB()
116 std::string dbname_; member in ROCKSDB_NAMESPACE::FlushJobTest
136 FlushJob flush_job(dbname_, versions_->GetColumnFamilySet()->GetDefault(), in TEST_F()
[all …]
Dcorruption_test.cc43 std::string dbname_; member in ROCKSDB_NAMESPACE::CorruptionTest
55 dbname_ = test::PerThreadDBPath("corruption_test"); in CorruptionTest()
56 DestroyDB(dbname_, options_); in CorruptionTest()
69 DestroyDB(dbname_, Options()); in ~CorruptionTest()
91 return DB::Open(opt, dbname_, &db_); in TryReopen()
101 ASSERT_OK(::ROCKSDB_NAMESPACE::RepairDB(dbname_, options_)); in RepairDB()
199 ASSERT_OK(env_.GetChildren(dbname_, &filenames)); in Corrupt()
208 fname = dbname_ + "/" + filenames[i]; in Corrupt()
542 std::string filename = dbname_ + metadata[0].name; in TEST_F()
575 std::string filename = dbname_ + metadata[0].name; in TEST_F()
[all …]
Drepair.cc96 : dbname_(dbname), in Repairer()
99 db_options_(SanitizeOptions(dbname_, db_options)), in Repairer()
118 vset_(dbname_, &immutable_db_options_, env_options_, in Repairer()
174 Status status = env_->LockFile(LockFileName(dbname_), &db_lock_); in Run()
182 ArchiveFile(dbname_ + "/" + manifests_[i]); in Run()
185 DBImpl* db_impl = new DBImpl(db_options_, dbname_); in Run()
219 dbname_.c_str(), tables_.size(), bytes); in Run()
231 std::string const dbname_; member in ROCKSDB_NAMESPACE::__anon8d55d6080111::Repairer
271 same = db_options_.wal_dir == dbname_; in FindFiles()
313 return Status::Corruption(dbname_, "repair found no files"); in FindFiles()
[all …]
Dversion_set_test.cc620 dbname_(test::PerThreadDBPath(name)), in VersionSetTestBase()
646 EXPECT_OK(env_->CreateDirIfMissing(dbname_)); in VersionSetTestBase()
657 db_options_.db_paths.emplace_back(dbname_, in VersionSetTestBase()
663 fprintf(stdout, "DB is still at %s\n", dbname_.c_str()); in ~VersionSetTestBase()
667 EXPECT_OK(DestroyDB(dbname_, options)); in ~VersionSetTestBase()
743 SetIdentityFile(env_, dbname_); in NewDB()
768 const std::string dbname_; member in ROCKSDB_NAMESPACE::VersionSetTestBase
1244 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_P()
1906 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_F()
1957 Status s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in TEST_F()
[all …]
Ddb_sst_test.cc102 int const num_files = GetSstFileCount(dbname_); in TEST_F()
114 GetSstFiles(env_, dbname_, &filenames); in TEST_F()
120 std::string const rdb_name = dbname_ + "/" + filenames[i]; in TEST_F()
126 ASSERT_EQ(num_files, GetSstFileCount(dbname_)); in TEST_F()
256 listener->SetExpectedFileName(dbname_ + file_on_L2); in TEST_F()
537 options.wal_dir = dbname_ + wal_dir_; in TEST_P()
611 env_->CreateDirIfMissing(dbname_); in TEST_F()
641 options.db_paths.emplace_back(dbname_, 1024 * 100); in TEST_F()
642 options.db_paths.emplace_back(dbname_ + "_2", 1024 * 100); in TEST_F()
736 env_->GetChildren(dbname_, &db_files); in TEST_F()
[all …]
Doptions_file_test.cc18 OptionsFileTest() : dbname_(test::PerThreadDBPath("options_file_test")) {} in OptionsFileTest()
20 std::string dbname_; member in ROCKSDB_NAMESPACE::OptionsFileTest
68 DestroyDB(dbname_, opt); in TEST_F()
72 ASSERT_OK(DB::Open(opt, dbname_, &db)); in TEST_F()
Ddb_test_util.cc77 dbname_ = test::PerThreadDBPath(env_, path); in DBTestBase()
78 alternative_wal_dir_ = dbname_ + "/wal"; in DBTestBase()
84 EXPECT_OK(DestroyDB(dbname_, delete_options)); in DBTestBase()
86 EXPECT_OK(DestroyDB(dbname_, options)); in DBTestBase()
98 options.db_paths.emplace_back(dbname_, 0); in ~DBTestBase()
99 options.db_paths.emplace_back(dbname_ + "_2", 0); in ~DBTestBase()
107 EXPECT_OK(DestroyDB(dbname_, options)); in ~DBTestBase()
678 return DB::Open(options, dbname_, &db_); in TryReopen()
1091 env_->GetChildren(dbname_, &files); in CountFiles()
1094 if (dbname_ != last_options_.wal_dir) { in CountFiles()
[all …]
Ddb_compaction_test.cc2000 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2007 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2014 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2021 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2028 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2035 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2042 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2049 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2056 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
2118 ASSERT_EQ(1, GetSstFileCount(dbname_)); in TEST_P()
[all …]
Ddb_wal_test.cc334 std::string backup_logs = dbname_ + "/backup_logs"; in TEST_F()
349 options.wal_dir = dbname_ + "/logs"; in TEST_F()
739 auto tables = ListTableFiles(env_, dbname_); in TEST_F()
794 auto tables = ListTableFiles(env_, dbname_); in TEST_F()
818 auto tables = ListTableFiles(env_, dbname_); in TEST_F()
827 std::vector<uint64_t> table_files = ListTableFiles(env_, dbname_); in TEST_F()
997 std::string fname = LogFileName(test->dbname_, wal_file_id); in CorruptWAL()
1125 std::string fname = LogFileName(dbname_, wal_file_id); in TEST_F()
1533 std::string fname_test_fallocate = dbname_ + "/preallocate_testfile"; in TEST_F()
1559 ASSERT_GE(GetAllocatedFileSize(dbname_ + file_before->PathName()), in TEST_F()
[all …]
/rocksdb-6.9/utilities/options/
Doptions_util_test.cc35 dbname_ = test::PerThreadDBPath("options_util_test"); in OptionsUtilTest()
41 std::string dbname_; member in ROCKSDB_NAMESPACE::OptionsUtilTest
239 DestroyDB(dbname_, Options(db_opt, cf_descs[0].options)); in TEST_F()
243 ASSERT_OK(DB::Open(db_opt, dbname_, cf_descs, &handles, &db)); in TEST_F()
253 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
264 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
268 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
272 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
284 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
288 CheckOptionsCompatibility(dbname_, Env::Default(), db_opt, cf_descs)); in TEST_F()
[all …]
/rocksdb-6.9/utilities/backupable/
Dbackupable_db_test.cc132 std::string dbname_; member in ROCKSDB_NAMESPACE::__anon6f9a36820111::DummyDB
535 dbname_ = "/tempdb"; in BackupableDBTest()
630 ASSERT_OK(backup_engine_->RestoreDBFromBackup(backup_id, dbname_, dbname_, in AssertBackupConsistency()
633 ASSERT_OK(backup_engine_->RestoreDBFromLatestBackup(dbname_, dbname_, in AssertBackupConsistency()
661 std::string dbname_; member in ROCKSDB_NAMESPACE::__anon6f9a36820111::BackupableDBTest
819 Status s = backup_engine_->RestoreDBFromBackup(2, dbname_, dbname_); in TEST_P()
981 s = backup_engine_->RestoreDBFromBackup(5, dbname_, dbname_); in TEST_F()
988 s = backup_engine_->RestoreDBFromBackup(4, dbname_, dbname_); in TEST_F()
1003 s = backup_engine_->RestoreDBFromBackup(2, dbname_, dbname_); in TEST_F()
1192 ASSERT_OK(backup_engine_->RestoreDBFromBackup(3, dbname_, dbname_)); in TEST_F()
[all …]
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_test.cc41 std::string dbname_; member in ROCKSDB_NAMESPACE::CheckpointTest
56 alternative_wal_dir_ = dbname_ + "/wal"; in CheckpointTest()
62 EXPECT_OK(DestroyDB(dbname_, options)); in CheckpointTest()
95 EXPECT_OK(DestroyDB(dbname_, options)); in ~CheckpointTest()
183 ASSERT_OK(DestroyDB(dbname_, options)); in Destroy()
203 return DB::Open(options, dbname_, &db_); in TryReopen()
272 ASSERT_OK(DestroyDB(dbname_, options)); in TEST_F()
298 ASSERT_OK(DestroyDB(dbname_, options)); in TEST_F()
302 dbname_ = snapshot_name_; in TEST_F()
307 ASSERT_OK(DestroyDB(dbname_, options)); in TEST_F()
[all …]
/rocksdb-6.9/util/
Dslice_transform_test.cc50 std::string dbname_; member in ROCKSDB_NAMESPACE::SliceTransformDBTest
56 dbname_ = test::PerThreadDBPath("slice_transform_db_test"); in SliceTransformDBTest()
57 EXPECT_OK(DestroyDB(dbname_, last_options_)); in SliceTransformDBTest()
62 EXPECT_OK(DestroyDB(dbname_, last_options_)); in ~SliceTransformDBTest()
79 ASSERT_OK(DestroyDB(dbname_, last_options_)); in Destroy()
87 return DB::Open(last_options_, dbname_, &db_); in TryReopen()
/rocksdb-6.9/tools/
Dreduce_levels_test.cc23 dbname_ = test::PerThreadDBPath("db_reduce_levels_test"); in ReduceLevelTest()
24 DestroyDB(dbname_, Options()); in ReduceLevelTest()
78 std::string dbname_; member in ROCKSDB_NAMESPACE::ReduceLevelTest
87 ROCKSDB_NAMESPACE::DB::Open(opt, dbname_, &db_); in OpenDB()
97 dbname_, target_level, false); in ReduceLevels()
Dldb_cmd_test.cc114 std::string dbname_; member in ROCKSDB_NAMESPACE::FileChecksumTestHelper
123 std::string file_path = dbname_ + "/" + file_meta.name; in VerifyChecksum()
171 : options_(options), db_(db), dbname_(db_name) {} in FileChecksumTestHelper()
178 if (dbname_[dbname_.length() - 1] != '/') { in VerifyChecksumInManifest()
179 dbname_.append("/"); in VerifyChecksumInManifest()
188 options_.db_paths.emplace_back(dbname_, 0); in VerifyChecksumInManifest()
193 VersionSet versions(dbname_, &immutable_db_options, sopt, tc.get(), &wb, in VerifyChecksumInManifest()
197 s = versions.ListColumnFamilies(&cf_name_list, dbname_, in VerifyChecksumInManifest()
/rocksdb-6.9/db/compaction/
Dcompaction_job_stats_test.cc85 std::string dbname_; member in ROCKSDB_NAMESPACE::CompactionJobStatsTest
98 alternative_wal_dir_ = dbname_ + "/wal"; in CompactionJobStatsTest()
105 EXPECT_OK(DestroyDB(dbname_, delete_options)); in CompactionJobStatsTest()
107 EXPECT_OK(DestroyDB(dbname_, options)); in CompactionJobStatsTest()
118 options.db_paths.emplace_back(dbname_, 0); in ~CompactionJobStatsTest()
119 options.db_paths.emplace_back(dbname_ + "_2", 0); in ~CompactionJobStatsTest()
120 options.db_paths.emplace_back(dbname_ + "_3", 0); in ~CompactionJobStatsTest()
121 options.db_paths.emplace_back(dbname_ + "_4", 0); in ~CompactionJobStatsTest()
122 EXPECT_OK(DestroyDB(dbname_, options)); in ~CompactionJobStatsTest()
202 ASSERT_OK(DestroyDB(dbname_, options)); in Destroy()
[all …]
Dcompaction_job_test.cc76 dbname_(test::PerThreadDBPath("compaction_job_test")), in CompactionJobTest()
81 versions_(new VersionSet(dbname_, &db_options_, env_options_, in CompactionJobTest()
89 EXPECT_OK(env_->CreateDirIfMissing(dbname_)); in CompactionJobTest()
92 db_options_.db_paths.emplace_back(dbname_, in CompactionJobTest()
249 DestroyDB(dbname_, Options()); in NewDB()
250 EXPECT_OK(env_->CreateDirIfMissing(dbname_)); in NewDB()
256 SetIdentityFile(env_, dbname_); in NewDB()
260 DBImpl* impl = new DBImpl(DBOptions(), dbname_); in NewDB()
269 const std::string manifest = DescriptorFileName(dbname_, 1); in NewDB()
284 s = SetCurrentFile(fs_.get(), dbname_, 1, nullptr); in NewDB()
[all …]
/rocksdb-6.9/utilities/ttl/
Dttl_test.cc47 dbname_ = test::PerThreadDBPath("db_ttl"); in TtlTest()
54 DestroyDB(dbname_, Options()); in TtlTest()
59 DestroyDB(dbname_, Options()); in ~TtlTest()
66 ASSERT_OK(DBWithTTL::Open(options_, dbname_, &db_ttl_)); in OpenTtl()
72 ASSERT_OK(DBWithTTL::Open(options_, dbname_, &db_ttl_, ttl)); in OpenTtl()
86 ASSERT_OK(DBWithTTL::Open(options_, dbname_, &db_ttl_, ttl, true)); in OpenReadOnlyTtl()
378 std::string dbname_; member in ROCKSDB_NAMESPACE::TtlTest
614 DB::Open(options, dbname_, &db); in TEST_F()
630 ASSERT_OK(DBWithTTL::Open(DBOptions(options), dbname_, column_families, in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_files.cc110 dbname_); in FindObsoleteFiles()
159 if (immutable_db_options_.wal_dir != dbname_) { in FindObsoleteFiles()
170 immutable_db_options_.db_log_dir != dbname_) { in FindObsoleteFiles()
337 candidate_files.emplace_back(filename, dbname_); in PurgeObsoleteFiles()
359 dbname_); in PurgeObsoleteFiles()
472 (type == kLogFile) ? immutable_db_options_.wal_dir : dbname_; in PurgeObsoleteFiles()
529 ? dbname_ in PurgeObsoleteFiles()
671 paths.push_back(dbname_); in CleanupFilesAfterRecovery()

123