Searched refs:logs_ (Results 1 – 10 of 10) sorted by relevance
56 logs_.push_back(buffered_log); in AddLogToBuffer()60 for (BufferedLog* log : logs_) { in FlushBufferToLog()70 logs_.clear(); in FlushBufferToLog()
29 size_t IsEmpty() const { return logs_.empty(); } in IsEmpty()45 autovector<BufferedLog*> logs_; variable
183 if (!alive_log_files_.empty() && !logs_.empty()) { in FindObsoleteFiles()215 while (!logs_.empty() && logs_.front().number < min_log_number) { in FindObsoleteFiles()216 auto& log = logs_.front(); in FindObsoleteFiles()225 logs_.pop_front(); in FindObsoleteFiles()229 assert(!logs_.empty()); in FindObsoleteFiles()
241 log::Writer* log_writer = logs_.back().writer; in WriteImpl()484 log::Writer* log_writer = logs_.back().writer; in PipelinedWriteImpl()931 while (logs_.front().getting_synced) { in PreprocessWrite()934 for (auto& log : logs_) { in PreprocessWrite()1062 for (auto& log : logs_) { in WriteToWAL()1121 log::Writer* log_writer = logs_.back().writer; in ConcurrentWriteToWAL()1709 if (!logs_.empty()) { in SwitchMemtable()1711 log::Writer* cur_log_writer = logs_.back().writer; in SwitchMemtable()1725 logs_.emplace_back(logfile_number_, new_log); in SwitchMemtable()
533 for (auto& log : logs_) { in CloseHelper()548 logs_.clear(); in CloseHelper()1190 assert(!logs_.empty()); in SyncWAL()1196 logs_.front().getting_synced) { in SyncWAL()1200 for (auto it = logs_.begin(); in SyncWAL()1210 for (auto it = logs_.begin(); in SyncWAL()1279 for (auto it = logs_.begin(); it != logs_.end() && it->number <= up_to;) { in MarkLogsSynced()1282 if (status.ok() && logs_.size() > 1) { in MarkLogsSynced()1286 it = logs_.erase(it); in MarkLogsSynced()1292 assert(!status.ok() || logs_.empty() || logs_[0].number > up_to || in MarkLogsSynced()[all …]
36 log::Writer* cur_log_writer = logs_.back().writer; in TEST_WALBufferIsEmpty()
87 while (logs_.front().number < current_log_number && in SyncClosedLogs()88 logs_.front().getting_synced) { in SyncClosedLogs()91 for (auto it = logs_.begin(); in SyncClosedLogs()92 it != logs_.end() && it->number < current_log_number; ++it) { in SyncClosedLogs()
1440 impl->logs_.emplace_back(new_log_number, new_log); in Open()1505 log::Writer* log_writer = impl->logs_.back().writer; in Open()
1844 std::deque<LogWriterNumber> logs_; variable
251 std::vector<uint64_t> logs_; member in ROCKSDB_NAMESPACE::__anon8d55d6080111::Repairer301 logs_.push_back(number); in FindFiles()319 for (size_t i = 0; i < logs_.size(); i++) { in ConvertLogFilesToTables()321 std::string logname = LogFileName(db_options_.wal_dir, logs_[i]); in ConvertLogFilesToTables()322 Status status = ConvertLogToTable(logs_[i]); in ConvertLogFilesToTables()326 logs_[i], status.ToString().c_str()); in ConvertLogFilesToTables()