Lines Matching refs:cfds

1195     autovector<ColumnFamilyData*>* cfds) {  in SelectColumnFamiliesForAtomicFlush()  argument
1202 cfds->push_back(cfd); in SelectColumnFamiliesForAtomicFlush()
1208 void DBImpl::AssignAtomicFlushSeq(const autovector<ColumnFamilyData*>& cfds) { in AssignAtomicFlushSeq() argument
1211 for (auto cfd : cfds) { in AssignAtomicFlushSeq()
1265 autovector<ColumnFamilyData*> cfds; in SwitchWAL() local
1267 SelectColumnFamiliesForAtomicFlush(&cfds); in SwitchWAL()
1274 cfds.push_back(cfd); in SwitchWAL()
1277 MaybeFlushStatsCF(&cfds); in SwitchWAL()
1284 for (const auto cfd : cfds) { in SwitchWAL()
1298 AssignAtomicFlushSeq(cfds); in SwitchWAL()
1300 for (auto cfd : cfds) { in SwitchWAL()
1304 GenerateFlushRequest(cfds, &flush_req); in SwitchWAL()
1329 autovector<ColumnFamilyData*> cfds; in HandleWriteBufferFull() local
1331 SelectColumnFamiliesForAtomicFlush(&cfds); in HandleWriteBufferFull()
1351 cfds.push_back(cfd_picked); in HandleWriteBufferFull()
1353 MaybeFlushStatsCF(&cfds); in HandleWriteBufferFull()
1360 for (const auto cfd : cfds) { in HandleWriteBufferFull()
1377 AssignAtomicFlushSeq(cfds); in HandleWriteBufferFull()
1379 for (const auto cfd : cfds) { in HandleWriteBufferFull()
1383 GenerateFlushRequest(cfds, &flush_req); in HandleWriteBufferFull()
1505 void DBImpl::MaybeFlushStatsCF(autovector<ColumnFamilyData*>* cfds) { in MaybeFlushStatsCF() argument
1506 assert(cfds != nullptr); in MaybeFlushStatsCF()
1507 if (!cfds->empty() && immutable_db_options_.persist_stats_to_disk) { in MaybeFlushStatsCF()
1512 for (ColumnFamilyData* cfd : *cfds) { in MaybeFlushStatsCF()
1530 cfds->push_back(cfd_stats); in MaybeFlushStatsCF()
1540 autovector<ColumnFamilyData*> cfds; in TrimMemtableHistory() local
1544 cfds.push_back(tmp_cfd); in TrimMemtableHistory()
1546 for (auto& cfd : cfds) { in TrimMemtableHistory()
1566 autovector<ColumnFamilyData*> cfds; in ScheduleFlushes() local
1568 SelectColumnFamiliesForAtomicFlush(&cfds); in ScheduleFlushes()
1569 for (auto cfd : cfds) { in ScheduleFlushes()
1576 cfds.push_back(tmp_cfd); in ScheduleFlushes()
1578 MaybeFlushStatsCF(&cfds); in ScheduleFlushes()
1586 for (auto& cfd : cfds) { in ScheduleFlushes()
1604 AssignAtomicFlushSeq(cfds); in ScheduleFlushes()
1607 GenerateFlushRequest(cfds, &flush_req); in ScheduleFlushes()