Searched refs:flush_req (Results 1 – 3 of 3) sorted by relevance
1592 FlushRequest flush_req; in FlushMemTable() local1646 if (s.ok() && !flush_req.empty()) { in FlushMemTable()1647 for (auto& elem : flush_req) { in FlushMemTable()1656 for (auto& elem : flush_req) { in FlushMemTable()1677 for (auto& iter : flush_req) { in FlushMemTable()1714 FlushRequest flush_req; in AtomicFlushMemTables() local1780 for (auto& iter : flush_req) { in AtomicFlushMemTables()2083 return flush_req; in PopFirstFromFlushQueue()2114 if (flush_req.empty()) { in SchedulePendingFlush()2117 for (auto& iter : flush_req) { in SchedulePendingFlush()[all …]
1303 FlushRequest flush_req; in SwitchWAL() local1304 GenerateFlushRequest(cfds, &flush_req); in SwitchWAL()1305 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferManager); in SwitchWAL()1382 FlushRequest flush_req; in HandleWriteBufferFull() local1383 GenerateFlushRequest(cfds, &flush_req); in HandleWriteBufferFull()1384 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferFull); in HandleWriteBufferFull()1606 FlushRequest flush_req; in ScheduleFlushes() local1607 GenerateFlushRequest(cfds, &flush_req); in ScheduleFlushes()1608 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferFull); in ScheduleFlushes()
483 const FlushRequest& flush_req = PopFirstFromFlushQueue(); in CloseHelper() local484 for (const auto& iter : flush_req) { in CloseHelper()