Lines Matching refs:flush_req
1592 FlushRequest flush_req; in FlushMemTable() local
1614 flush_req.emplace_back(cfd, flush_memtable_id); in FlushMemTable()
1640 flush_req.emplace_back(cfd_stats, flush_memtable_id); in FlushMemTable()
1646 if (s.ok() && !flush_req.empty()) { in FlushMemTable()
1647 for (auto& elem : flush_req) { in FlushMemTable()
1656 for (auto& elem : flush_req) { in FlushMemTable()
1661 SchedulePendingFlush(flush_req, flush_reason); in FlushMemTable()
1677 for (auto& iter : flush_req) { in FlushMemTable()
1714 FlushRequest flush_req; in AtomicFlushMemTables() local
1764 GenerateFlushRequest(cfds, &flush_req); in AtomicFlushMemTables()
1765 SchedulePendingFlush(flush_req, flush_reason); in AtomicFlushMemTables()
1780 for (auto& iter : flush_req) { in AtomicFlushMemTables()
2080 FlushRequest flush_req = flush_queue_.front(); in PopFirstFromFlushQueue() local
2083 return flush_req; in PopFirstFromFlushQueue()
2112 void DBImpl::SchedulePendingFlush(const FlushRequest& flush_req, in SchedulePendingFlush() argument
2114 if (flush_req.empty()) { in SchedulePendingFlush()
2117 for (auto& iter : flush_req) { in SchedulePendingFlush()
2123 flush_queue_.push_back(flush_req); in SchedulePendingFlush()
2226 const FlushRequest& flush_req = PopFirstFromFlushQueue(); in BackgroundFlush() local
2228 superversion_contexts.reserve(flush_req.size()); in BackgroundFlush()
2230 for (const auto& iter : flush_req) { in BackgroundFlush()