Home
last modified time | relevance | path

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

123

/rocksdb-6.9/file/
Dfilename.cc159 return dbname + buf; in DescriptorFileName()
163 return dbname + "/CURRENT"; in CurrentFileName()
167 return dbname + "/LOCK"; in LockFileName()
190 return dbname + "/LOG"; in InfoLogFileName()
204 return dbname + "/LOG.old." + buf; in OldInfoLogFileName()
215 return dbname + "/" + buffer; in OptionsFileName()
223 return dbname + "/" + buffer; in TempOptionsFileName()
230 return dbname + buf; in MetaDatabaseName()
234 return dbname + "/IDENTITY"; in IdentityFileName()
378 contents.remove_prefix(dbname.size() + 1); in SetCurrentFile()
[all …]
Dfilename.h61 extern std::string BlobFileName(const std::string& dbname,
66 extern std::string ArchivalDirectory(const std::string& dbname);
70 extern std::string ArchivedLogFileName(const std::string& dbname,
100 extern std::string DescriptorFileName(const std::string& dbname,
106 extern std::string CurrentFileName(const std::string& dbname);
110 extern std::string LockFileName(const std::string& dbname);
127 extern std::string InfoLogFileName(const std::string& dbname,
141 extern std::string OptionsFileName(const std::string& dbname,
151 extern std::string MetaDatabaseName(const std::string& dbname,
157 extern std::string IdentityFileName(const std::string& dbname);
[all …]
/rocksdb-6.9/utilities/option_change_migration/
Doption_change_migration.cc27 Status OpenDb(const Options& options, const std::string& dbname, in OpenDb() argument
31 Status s = DB::Open(options, dbname, &tmpdb); in OpenDb()
38 Status CompactToLevel(const Options& options, const std::string& dbname, in CompactToLevel() argument
51 Status s = OpenDb(no_compact_opts, dbname, &db); in CompactToLevel()
74 s = OpenDb(no_compact_opts, dbname, &db); in CompactToLevel()
79 Status MigrateToUniversal(std::string dbname, const Options& old_opts, in MigrateToUniversal() argument
89 Status s = OpenDb(opts, dbname, &db); in MigrateToUniversal()
122 return CompactToLevel(opts, dbname, 1, true); in MigrateToLevelBase()
147 return MigrateToUniversal(dbname, old_opts, new_opts); in OptionChangeMigration()
150 return MigrateToLevelBase(dbname, old_opts, new_opts); in OptionChangeMigration()
[all …]
/rocksdb-6.9/db/
Dmerge_test.cc82 DestroyDB(dbname, Options()); in OpenDb()
90 s = DB::Open(options, dbname, &db); in OpenDb()
94 s = DB::Open(options, dbname, &db); in OpenDb()
403 auto db = OpenDb(dbname, use_ttl); in runTest()
416 DestroyDB(dbname, Options()); in runTest()
420 auto db = OpenDb(dbname, use_ttl, max_merge); in runTest()
425 DestroyDB(dbname, Options()); in runTest()
436 DestroyDB(dbname, Options()); in runTest()
443 DestroyDB(dbname, Options()); in runTest()
449 auto db = OpenDb(dbname); in runTest()
[all …]
Dc_test.c43 static char dbname[200]; variable
304 db = rocksdb_open(options, dbname, &err); in CheckCompaction()
450 snprintf(dbname, sizeof(dbname), in main()
517 rocksdb_destroy_db(options, dbname, &err); in main()
521 rocksdb_open(options, dbname, &err); in main()
527 db = rocksdb_open(options, dbname, &err); in main()
570 rocksdb_destroy_db(options, dbname, &err); in main()
575 rocksdb_backup_engine_restore_db_from_latest_backup(be, dbname, dbname, restore_options, &err); in main()
580 db = rocksdb_open(options, dbname, &err); in main()
614 db = rocksdb_open(options, dbname, &err); in main()
[all …]
Ddb_info_dumper.cc20 const std::string& dbname) { in DumpDBFileSummary() argument
36 if (!env->GetChildren(dbname, &files).ok()) { in DumpDBFileSummary()
38 "Error when reading %s dir\n", dbname.c_str()); in DumpDBFileSummary()
53 env->GetFileSize(dbname + "/" + file, &file_size); in DumpDBFileSummary()
58 env->GetFileSize(dbname + "/" + file, &file_size); in DumpDBFileSummary()
76 if (dbname.compare(db_path.path) != 0) { in DumpDBFileSummary()
100 if (dbname.compare(options.wal_dir) != 0) { in DumpDBFileSummary()
Dfilename_test.cc109 std::string dbname = ("/data/rocksdb"); in TEST_F() local
111 Env::Default()->GetAbsolutePath(dbname, &db_absolute_path); in TEST_F()
113 ASSERT_EQ("/data/rocksdb/LOG", InfoLogFileName(dbname, db_absolute_path, "")); in TEST_F()
115 OldInfoLogFileName(dbname, 666u, db_absolute_path, "")); in TEST_F()
118 InfoLogFileName(dbname, db_absolute_path, "/data/rocksdb_log")); in TEST_F()
121 OldInfoLogFileName(dbname, 666u, db_absolute_path, "/data/rocksdb_log")); in TEST_F()
Dwrite_callback_test.cc29 string dbname; member in ROCKSDB_NAMESPACE::WriteCallbackTest
32 dbname = test::PerThreadDBPath("write_callback_testdb"); in WriteCallbackTest()
160 DestroyDB(dbname, options); in TEST_F()
169 DBImpl::Open(db_options, dbname, column_families, &handles, in TEST_F()
364 DestroyDB(dbname, options); in TEST_F()
383 DestroyDB(dbname, options); in TEST_F()
386 Status s = DB::Open(options, dbname, &db); in TEST_F()
433 DestroyDB(dbname, options); in TEST_F()
Dcompacted_db_impl.cc19 const DBOptions& options, const std::string& dbname) in CompactedDBImpl() argument
20 : DBImpl(options, dbname), cfd_(nullptr), version_(nullptr), in CompactedDBImpl()
137 const std::string& dbname, DB** dbptr) { in Open() argument
147 std::unique_ptr<CompactedDBImpl> db(new CompactedDBImpl(db_options, dbname)); in Open()
Drepair.cc92 Repairer(const std::string& dbname, const DBOptions& db_options, in Repairer() argument
96 : dbname_(dbname), in Repairer()
645 Status RepairDB(const std::string& dbname, const DBOptions& db_options, in RepairDB() argument
651 Repairer repairer(dbname, db_options, column_families, in RepairDB()
660 Status RepairDB(const std::string& dbname, const DBOptions& db_options, in RepairDB() argument
666 Repairer repairer(dbname, db_options, in RepairDB()
674 Status RepairDB(const std::string& dbname, const Options& options) { in RepairDB() argument
679 Repairer repairer(dbname, db_options, in RepairDB()
Dbuilder.cc69 const std::string& dbname, Env* env, FileSystem* fs, in BuildTable() argument
107 ioptions.listeners, dbname, column_family_name, fname, job_id, reason); in BuildTable()
128 event_logger, ioptions.listeners, dbname, column_family_name, fname, in BuildTable()
268 event_logger, ioptions.listeners, dbname, column_family_name, fname, in BuildTable()
Dmemtable_list_test.cc24 std::string dbname; member in ROCKSDB_NAMESPACE::MemTableListTest
31 dbname = test::PerThreadDBPath("memtable_list_test"); in MemTableListTest()
33 DestroyDB(dbname, options); in MemTableListTest()
40 DestroyDB(dbname, options); in CreateDB()
45 Status s = DB::Open(options, dbname, cf_descs, &handles, &db); in CreateDB()
49 cf_opt1.cf_paths.emplace_back(dbname + "_one_1", in CreateDB()
51 cf_opt2.cf_paths.emplace_back(dbname + "_two_1", in CreateDB()
79 DestroyDB(dbname, options, cf_descs); in ~MemTableListTest()
101 VersionSet versions(dbname, &immutable_db_options, env_options, in Mock_InstallMemtableFlushResults()
149 VersionSet versions(dbname, &immutable_db_options, env_options, in Mock_InstallMemtableAtomicFlushResults()
/rocksdb-6.9/tools/
Ddb_crashtest.py128 shutil.rmtree(dbname, True)
129 os.mkdir(dbname)
130 return dbname
133 def is_direct_io_supported(dbname): argument
134 with tempfile.NamedTemporaryFile(dir=dbname) as f:
290 dbname = get_dbname('blackbox')
303 + list({'db': dbname}.items())), unknown_args)
342 shutil.rmtree(dbname, True)
349 dbname = get_dbname('whitebox')
470 shutil.rmtree(dbname, True)
[all …]
Dldb_cmd_test.cc85 std::string dbname = test::TmpDir(); in TEST_F() local
86 ASSERT_OK(DB::Open(opts, dbname, &db)); in TEST_F()
102 snprintf(arg2, sizeof(arg2), "--db=%s", dbname.c_str()); in TEST_F()
265 std::string dbname = test::TmpDir(); in TEST_F() local
266 ASSERT_OK(DB::Open(opts, dbname, &db)); in TEST_F()
315 FileChecksumTestHelper fct_helper(opts, db, dbname); in TEST_F()
352 std::string dbname = test::TmpDir(); in TEST_F() local
353 ASSERT_OK(DB::Open(opts, dbname, &db)); in TEST_F()
402 FileChecksumTestHelper fct_helper(opts, db, dbname); in TEST_F()
475 std::string dbname = test::TmpDir(); in TEST_F() local
[all …]
Ddb_sanity_test.cc39 std::string dbname = path_ + Name(); in Create() local
40 DestroyDB(dbname, options); in Create()
42 Status s = DB::Open(options, dbname, &db); in Create()
59 std::string dbname = path_ + Name(); in Verify() local
60 Status s = DB::Open(GetOptions(), dbname, &db); in Verify()
/rocksdb-6.9/logging/
Dauto_roll_logger.cc18 AutoRollLogger::AutoRollLogger(Env* env, const std::string& dbname, in AutoRollLogger() argument
25 dbname_(dbname), in AutoRollLogger()
37 Status s = env->GetAbsolutePath(dbname, &db_absolute_path_); in AutoRollLogger()
39 db_absolute_path_ = dbname; in AutoRollLogger()
250 Status CreateLoggerFromOptions(const std::string& dbname, in CreateLoggerFromOptions() argument
260 env->GetAbsolutePath(dbname, &db_absolute_path); in CreateLoggerFromOptions()
262 InfoLogFileName(dbname, db_absolute_path, options.db_log_dir); in CreateLoggerFromOptions()
264 env->CreateDirIfMissing(dbname); // In case it does not exist in CreateLoggerFromOptions()
269 env, dbname, options.db_log_dir, options.max_log_file_size, in CreateLoggerFromOptions()
283 OldInfoLogFileName(dbname, env->NowMicros(), db_absolute_path, in CreateLoggerFromOptions()
/rocksdb-6.9/utilities/transactions/
Doptimistic_transaction_db_impl.cc39 const std::string& dbname, in Open() argument
47 Status s = Open(db_options, dbname, column_families, &handles, dbptr); in Open()
59 const DBOptions& db_options, const std::string& dbname, in Open() argument
64 OptimisticTransactionDBOptions(), dbname, in Open()
71 const std::string& dbname, in Open() argument
92 s = DB::Open(db_options, dbname, column_families_copy, handles, &db); in Open()
Dtransaction_test.h45 std::string dbname; variable
64 dbname = test::PerThreadDBPath("transaction_testdb"); in TransactionTestBase()
66 DestroyDB(dbname, options); in TransactionTestBase()
79 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in TransactionTestBase()
94 DestroyDB(dbname, options); in ~TransactionTestBase()
106 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in ReOpenNoDelete()
127 s = TransactionDB::Open(options, txn_db_options, dbname, cfs, handles, in ReOpenNoDelete()
139 DestroyDB(dbname, options); in ReOpen()
142 s = TransactionDB::Open(options, txn_db_options, dbname, &db); in ReOpen()
162 Status s = DBImpl::Open(options_copy, dbname, cfs, handles, &root_db, in OpenWithStackableDB()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_readonly.cc20 const std::string& dbname) in DBImplReadOnly() argument
21 : DBImpl(db_options, dbname) { in DBImplReadOnly()
129 Status DB::OpenForReadOnly(const Options& options, const std::string& dbname, in OpenForReadOnly() argument
135 s = CompactedDBImpl::Open(options, dbname, dbptr); in OpenForReadOnly()
147 s = DB::OpenForReadOnly(db_options, dbname, column_families, &handles, dbptr); in OpenForReadOnly()
158 const DBOptions& db_options, const std::string& dbname, in OpenForReadOnly() argument
166 DBImplReadOnly* impl = new DBImplReadOnly(db_options, dbname); in OpenForReadOnly()
Ddb_impl_open.cc27 Options SanitizeOptions(const std::string& dbname, const Options& src) { in SanitizeOptions() argument
28 auto db_options = SanitizeOptions(dbname, DBOptions(src)); in SanitizeOptions()
35 DBOptions SanitizeOptions(const std::string& dbname, const DBOptions& src) { in SanitizeOptions() argument
54 Status s = CreateLoggerFromOptions(dbname, result, &result.info_log); in SanitizeOptions()
104 result.wal_dir = dbname; in SanitizeOptions()
111 result.db_paths.emplace_back(dbname, std::numeric_limits<uint64_t>::max()); in SanitizeOptions()
322 IOStatus io_s = DBImpl::CreateAndNewDirectory(fs, dbname, &db_dir_); in SetDirectories()
326 if (!wal_dir.empty() && dbname != wal_dir) { in SetDirectories()
336 if (db_path == dbname) { in SetDirectories()
1317 Status DB::Open(const DBOptions& db_options, const std::string& dbname, in Open() argument
[all …]
Ddb_impl_secondary.cc20 const std::string& dbname) in DBImplSecondary() argument
21 : DBImpl(db_options, dbname) { in DBImplSecondary()
567 Status DB::OpenAsSecondary(const Options& options, const std::string& dbname, in OpenAsSecondary() argument
577 Status s = DB::OpenAsSecondary(db_options, dbname, secondary_path, in OpenAsSecondary()
587 const DBOptions& db_options, const std::string& dbname, in OpenAsSecondary() argument
609 DBImplSecondary* impl = new DBImplSecondary(tmp_opts, dbname); in OpenAsSecondary()
611 dbname, &impl->immutable_db_options_, impl->file_options_, in OpenAsSecondary()
/rocksdb-6.9/utilities/blob_db/
Dblob_db.cc17 const std::string& dbname, BlobDB** blob_db) { in Open() argument
25 Status s = BlobDB::Open(db_options, bdb_options, dbname, column_families, in Open()
37 const BlobDBOptions& bdb_options, const std::string& dbname, in Open() argument
47 BlobDBImpl* blob_db_impl = new BlobDBImpl(dbname, bdb_options, db_options, in Open()
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.cc58 Status UtilityDB::OpenTtlDB(const Options& options, const std::string& dbname, in OpenTtlDB() argument
61 Status s = DBWithTTL::Open(options, dbname, &db, ttl, read_only); in OpenTtlDB()
70 Status DBWithTTL::Open(const Options& options, const std::string& dbname, in Open() argument
79 Status s = DBWithTTL::Open(db_options, dbname, column_families, &handles, in Open()
91 const DBOptions& db_options, const std::string& dbname, in Open() argument
112 st = DB::OpenForReadOnly(db_options, dbname, column_families_sanitized, in Open()
115 st = DB::Open(db_options, dbname, column_families_sanitized, handles, &db); in Open()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc987 DestroyDB(dbname, options); in TEST_F()
1024 DestroyDB(dbname, options); in TEST_F()
1035 DestroyDB(dbname, options); in TEST_F()
1084 DestroyDB(dbname, options); in TEST_F()
1093 DestroyDB(dbname, options); in TEST_F()
1134 DestroyDB(dbname, options); in TEST_F()
1146 DestroyDB(dbname, options); in TEST_F()
1260 DestroyDB(dbname, options); in TEST_F()
1272 DestroyDB(dbname, options); in TEST_F()
1308 DestroyDB(dbname, options); in TEST_F()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Doptimistic_transaction_db.h57 static Status Open(const Options& options, const std::string& dbname,
60 static Status Open(const DBOptions& db_options, const std::string& dbname,
67 const std::string& dbname,

123