Home
last modified time | relevance | path

Searched refs:wal_dir (Results 1 – 25 of 48) sorted by relevance

12

/rocksdb-6.9/include/rocksdb/utilities/
Dbackupable_db.h255 const std::string& wal_dir) = 0;
259 BackupID backup_id, const std::string& db_dir, const std::string& wal_dir,
261 return RestoreDBFromBackup(options, backup_id, db_dir, wal_dir);
267 const std::string& wal_dir) = 0;
271 const std::string& db_dir, const std::string& wal_dir,
273 return RestoreDBFromLatestBackup(options, db_dir, wal_dir);
375 const std::string& wal_dir) = 0;
381 return RestoreDBFromBackup(options, backup_id, db_dir, wal_dir);
387 const std::string& wal_dir) = 0;
391 const std::string& db_dir, const std::string& wal_dir,
[all …]
Denv_librados.h144 const std::string& db_pool, const std::string& wal_dir,
/rocksdb-6.9/tools/
Drun_flash_bench.sh93 wal_dir=${LOG_DIR:-"/tmp/rocksdb/"}
112 WAL_DIR=$wal_dir \
169 if [[ $db_dir != $wal_dir ]]; then
170 rm -rf $wal_dir
172 if [ ! -d ${wal_dir}.bak ]; then
173 echo WAL backup does not exist at ${wal_dir}.bak
177 echo Restore WAL from ${wal_dir}.bak
178 cp -p -r ${wal_dir}.bak $wal_dir
186 if [[ $db_dir != $wal_dir ]]; then
187 echo Save WAL to ${wal_dir}.bak
[all …]
Ddb_bench_tool_test.cc115 opt.wal_dir = wal_path_; in TEST_F()
138 opt.wal_dir = wal_path_; in TEST_F()
161 opt.wal_dir = wal_path_; in TEST_F()
300 opt.wal_dir = wal_path_; in TEST_F()
/rocksdb-6.9/java/rocksjni/
Dbackupenginejni.cc208 const char* wal_dir = env->GetStringUTFChars(jwal_dir, nullptr); in Java_org_rocksdb_BackupEngine_restoreDbFromBackup() local
209 if (wal_dir == nullptr) { in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
217 static_cast<ROCKSDB_NAMESPACE::BackupID>(jbackup_id), db_dir, wal_dir, in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
220 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromBackup()
245 const char* wal_dir = env->GetStringUTFChars(jwal_dir, nullptr); in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup() local
246 if (wal_dir == nullptr) { in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup()
253 auto status = backup_engine->RestoreDBFromLatestBackup(db_dir, wal_dir, in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup()
256 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_BackupEngine_restoreDbFromLatestBackup()
Doptions.cc623 reinterpret_cast<ROCKSDB_NAMESPACE::Options*>(jhandle)->wal_dir.c_str()); in Java_org_rocksdb_Options_walDir()
633 const char* wal_dir = env->GetStringUTFChars(jwal_dir, nullptr); in Java_org_rocksdb_Options_setWalDir() local
634 if (wal_dir == nullptr) { in Java_org_rocksdb_Options_setWalDir()
638 reinterpret_cast<ROCKSDB_NAMESPACE::Options*>(jhandle)->wal_dir.assign( in Java_org_rocksdb_Options_setWalDir()
639 wal_dir); in Java_org_rocksdb_Options_setWalDir()
640 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_Options_setWalDir()
5149 const char* wal_dir = env->GetStringUTFChars(jwal_dir, 0); in Java_org_rocksdb_DBOptions_setWalDir() local
5150 reinterpret_cast<ROCKSDB_NAMESPACE::DBOptions*>(jhandle)->wal_dir.assign( in Java_org_rocksdb_DBOptions_setWalDir()
5151 wal_dir); in Java_org_rocksdb_DBOptions_setWalDir()
5152 env->ReleaseStringUTFChars(jwal_dir, wal_dir); in Java_org_rocksdb_DBOptions_setWalDir()
[all …]
/rocksdb-6.9/db/
Dwal_manager.cc40 auto s = env_->DeleteFile(db_options_.wal_dir + "/" + fname); in DeleteFile()
55 s = GetSortedWalsOfType(db_options_.wal_dir, logs, kAliveLogFile); in GetSortedWalFiles()
68 std::string archivedir = ArchivalDirectory(db_options_.wal_dir); in GetSortedWalFiles()
123 db_options_.wal_dir, &db_options_, read_options, file_options_, seq, in GetUpdatesSince()
162 std::string archival_dir = ArchivalDirectory(db_options_.wal_dir); in PurgeObsoleteWALFiles()
257 s = DeleteDBFile(&db_options_, db_options_.wal_dir + "/" + file_path, in PurgeObsoleteWALFiles()
258 db_options_.wal_dir, false, in PurgeObsoleteWALFiles()
272 auto archived_log_name = ArchivedLogFileName(db_options_.wal_dir, number); in ArchiveWALFile()
390 std::string fname = LogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
401 ArchivedLogFileName(db_options_.wal_dir, number); in ReadFirstRecord()
[all …]
Ddb_info_dumper.cc100 if (dbname.compare(options.wal_dir) != 0) { in DumpDBFileSummary()
101 if (!env->GetChildren(options.wal_dir, &files).ok()) { in DumpDBFileSummary()
104 options.wal_dir.c_str()); in DumpDBFileSummary()
111 env->GetFileSize(options.wal_dir + "/" + file, &file_size); in DumpDBFileSummary()
121 options.wal_dir.c_str(), wal_info.c_str()); in DumpDBFileSummary()
Ddb_wal_test.cc349 options.wal_dir = dbname_ + "/logs"; in TEST_F()
362 env_->GetChildren(options.wal_dir, &logs); in TEST_F()
365 CopyFile(options.wal_dir + "/" + log, backup_logs + "/" + log); in TEST_F()
378 CopyFile(backup_logs + "/" + log, options.wal_dir + "/" + log); in TEST_F()
393 env_->CreateDirIfMissing(options.wal_dir); in TEST_F()
396 CopyFile(backup_logs + "/" + log, options.wal_dir + "/" + log); in TEST_F()
408 env_->CreateDirIfMissing(options.wal_dir); in TEST_F()
411 CopyFile(backup_logs + "/" + log, options.wal_dir + "/" + log); in TEST_F()
532 options.wal_dir = alternative_wal_dir_; in TEST_F()
569 options.wal_dir = alternative_wal_dir_; in TEST_F()
Drepair.cc269 Status status = env_->AreFilesSame(db_options_.wal_dir, dbname_, &same); in FindFiles()
271 same = db_options_.wal_dir == dbname_; in FindFiles()
278 to_search_paths.push_back(db_options_.wal_dir); in FindFiles()
321 std::string logname = LogFileName(db_options_.wal_dir, logs_[i]); in ConvertLogFilesToTables()
345 std::string logname = LogFileName(db_options_.wal_dir, log); in ConvertLogToTable()
Ddb_sst_test.cc537 options.wal_dir = dbname_ + wal_dir_; in TEST_P()
570 env->NewWritableFile(options.wal_dir + "/1000.log.trash", &result, in TEST_P()
574 env->GetChildren(options.wal_dir, &filenames); in TEST_P()
587 env->GetChildren(options.wal_dir, &filenames); in TEST_P()
Dfault_injection_test.cc110 options.wal_dir = test::PerThreadDBPath(env_, "fault_test_wal"); in CurrentOptions()
121 options.wal_dir = test::PerThreadDBPath(env_, "/fault_test_wal"); in CurrentOptions()
Dobsolete_files_test.cc98 options.wal_dir = wal_dir_; in ReopenDB()
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc102 if (result.wal_dir.empty()) { in SanitizeOptions()
104 result.wal_dir = dbname; in SanitizeOptions()
106 if (result.wal_dir.back() == '/') { in SanitizeOptions()
107 result.wal_dir = result.wal_dir.substr(0, result.wal_dir.size() - 1); in SanitizeOptions()
140 result.env->GetChildren(result.wal_dir, &filenames); in SanitizeOptions()
145 std::string trash_file = result.wal_dir + "/" + filename; in SanitizeOptions()
320 const std::string& wal_dir, in SetDirectories() argument
326 if (!wal_dir.empty() && dbname != wal_dir) { in SetDirectories()
327 io_s = DBImpl::CreateAndNewDirectory(fs, wal_dir, &wal_dir_); in SetDirectories()
515 immutable_db_options_.wal_dir); in Recover()
[all …]
Ddb_impl_files.cc159 if (immutable_db_options_.wal_dir != dbname_) { in FindObsoleteFiles()
161 env_->GetChildren(immutable_db_options_.wal_dir, in FindObsoleteFiles()
165 log_file, immutable_db_options_.wal_dir); in FindObsoleteFiles()
333 immutable_db_options_.wal_dir); in PurgeObsoleteFiles()
472 (type == kLogFile) ? immutable_db_options_.wal_dir : dbname_; in PurgeObsoleteFiles()
Ddb_impl_secondary.cc97 s = env_->GetChildren(immutable_db_options_.wal_dir, &filenames); in FindNewLogNumbers()
100 immutable_db_options_.wal_dir); in FindNewLogNumbers()
140 std::string fname = LogFileName(immutable_db_options_.wal_dir, log_number); in MaybeInitLogReader()
/rocksdb-6.9/utilities/
Denv_librados.md18 …wal_dir. The dir for WAL files. Because RocksDB only has 2-level structure (dir_name/file_name), t…
25 wal_dir = "/wal";
28 env_ = new EnvLibrados(db_name, config, db_pool, wal_dir, wal_pool, write_buffer_size);
34 options.wal_dir = "/tmp/wal";
Denv_librados_test.cc738 const std::string wal_dir = "/wal"; member in ROCKSDB_NAMESPACE::EnvLibradosMutipoolTest
748 …env_ = new EnvLibrados(client_name, cluster_name, flags, db_name, config, db_pool, wal_dir, wal_po… in EnvLibradosMutipoolTest()
883 options.wal_dir = walPath; in TEST_F()
972 options2.wal_dir = walPath; in TEST_F()
/rocksdb-6.9/utilities/backupable/
Dbackupable_db.cc118 const std::string& wal_dir) override;
123 const std::string& wal_dir) override { in RestoreDBFromLatestBackup() argument
125 wal_dir); in RestoreDBFromLatestBackup()
1157 db_env_->CreateDirIfMissing(wal_dir); in RestoreDBFromBackup()
1163 std::string archive_dir = ArchivalDirectory(wal_dir); in RestoreDBFromBackup()
1184 DeleteChildren(wal_dir); in RestoreDBFromBackup()
1185 DeleteChildren(ArchivalDirectory(wal_dir)); in RestoreDBFromBackup()
1220 dst = ((type == kLogFile) ? wal_dir : db_dir) + in RestoreDBFromBackup()
1975 const std::string& wal_dir) override { in RestoreDBFromBackup() argument
1977 wal_dir); in RestoreDBFromBackup()
[all …]
/rocksdb-6.9/docs/_posts/
D2014-03-27-how-to-persist-in-memory-rocksdb-database.markdown18 Options::wal_dir is the directory where RocksDB stores write-ahead log files. If you configure this…
19 … obsolete log files will be moved to `archive/` directory under Options::wal_dir. Those archived l…
21 Let's assume Options::wal_dir is a directory on persistent storage and Options::WAL_ttl_seconds is …
/rocksdb-6.9/options/
Ddb_options.cc39 wal_dir(options.wal_dir), in ImmutableDBOptions()
153 wal_dir.c_str()); in Dump()
Ddb_options.h36 std::string wal_dir; member
/rocksdb-6.9/file/
Dfile_util.cc116 Status s = db_options->env->AreFilesSame(db_options->wal_dir, in IsWalDirSameAsDBPath()
119 same = db_options->wal_dir == db_options->db_paths[0].path; in IsWalDirSameAsDBPath()
/rocksdb-6.9/utilities/checkpoint/
Dcheckpoint_impl.cc315 s = copy_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), in CreateCustomCheckpoint()
321 s = link_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), in CreateCustomCheckpoint()
329 s = copy_file_cb(db_options.wal_dir, live_wal_files[i]->PathName(), 0, in CreateCustomCheckpoint()
/rocksdb-6.9/examples/
Drocksdb_option_file_example.ini44 wal_dir=

12