Searched refs:logfile_number_ (Results 1 – 7 of 7) sorted by relevance
425 MarkLogsSynced(logfile_number_, need_log_dir_sync, status); in WriteImpl()549 MarkLogsSynced(logfile_number_, need_log_dir_sync, w.status); in PipelinedWriteImpl()1015 *log_used = logfile_number_; in WriteToWAL()1037 write_group.leader->log_used = logfile_number_; in WriteToWAL()1040 writer->log_used = logfile_number_; in WriteToWAL()1111 write_group.leader->log_used = logfile_number_; in ConcurrentWriteToWAL()1114 writer->log_used = logfile_number_; in ConcurrentWriteToWAL()1722 logfile_number_ = new_log_number; in SwitchMemtable()1725 logs_.emplace_back(logfile_number_, new_log); in SwitchMemtable()1761 loop_cfd->SetLogNumber(logfile_number_); in SwitchMemtable()[all …]
201 return logfile_number_; in TEST_LogfileNumber()
1438 impl->logfile_number_ = new_log_number; in Open()1482 DBImpl::LogFileNumberSize(impl->logfile_number_)); in Open()
86 uint64_t current_log_number = logfile_number_; in SyncClosedLogs()171 if (logfile_number_ > 0 && in FlushMemTableToOutputFile()366 if (logfile_number_ > 0) { in AtomicFlushMemTablesToOutputFiles()
170 logfile_number_(0), in DBImpl()1193 current_log_number = logfile_number_; in SyncWAL()1276 if (synced_dir && logfile_number_ == up_to && status.ok()) { in MarkLogsSynced()2343 edit.SetLogNumber(logfile_number_); in CreateColumnFamilyImpl()
1808 uint64_t logfile_number_; variable
170 current_logfile_number = logfile_number_; in GetCurrentWalFile()