Searched refs:wal_manager_ (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/db/ |
| D | wal_manager_test.cc | 58 wal_manager_.reset(new WalManager(db_options_, env_options_)); in Init()
62 wal_manager_.reset(new WalManager(db_options_, env_options_)); in Reopen()
101 Status status = wal_manager_->GetUpdatesSince( in OpenTransactionLogIter()
115 std::unique_ptr<WalManager> wal_manager_; member in ROCKSDB_NAMESPACE::WalManagerTest
129 ASSERT_OK(wal_manager_->TEST_ReadFirstLine(path, 1 /* number */, &s)); in TEST_F()
133 wal_manager_->TEST_ReadFirstRecord(kAliveLogFile, 1 /* number */, &s)); in TEST_F()
151 ASSERT_OK(wal_manager_->TEST_ReadFirstRecord(kAliveLogFile, 1, &s)); in TEST_F()
157 ASSERT_OK(wal_manager_->TEST_ReadFirstRecord(kAliveLogFile, 1, &s)); in TEST_F()
238 wal_manager_->PurgeObsoleteWALFiles(); in TEST_F()
246 wal_manager_->PurgeObsoleteWALFiles(); in TEST_F()
[all …]
|
| D | db_filesnapshot.cc | 163 return wal_manager_.GetSortedWalFiles(files); in GetSortedWalFiles()
173 return wal_manager_.GetLiveWalFile(current_logfile_number, current_log_file); in GetCurrentWalFile()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_files.cc | 484 wal_manager_.ArchiveWALFile(fname, number); in PurgeObsoleteFiles()
553 wal_manager_.PurgeObsoleteWALFiles(); in PurgeObsoleteFiles()
|
| D | db_impl.cc | 199 wal_manager_(immutable_db_options_, file_options_, seq_per_batch), in DBImpl()
3155 return wal_manager_.GetUpdatesSince(seq, iter, read_options, versions_.get()); in GetUpdatesSince()
3178 status = wal_manager_.DeleteFile(name, number); in DeleteFile()
|
| D | db_impl.h | 2020 WalManager wal_manager_; variable
|