Lines Matching refs:ColumnFamilyData
28 ColumnFamilyData* cfd, const std::vector<CompactionInputFiles>& inputs, in EnoughRoomForCompaction()
61 bool DBImpl::RequestCompactionToken(ColumnFamilyData* cfd, bool force, in RequestCompactionToken()
138 ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options, in FlushMemTableToOutputFile()
260 ColumnFamilyData* cfd = arg.cfd_; in FlushMemTablesToOutputFiles()
293 autovector<ColumnFamilyData*> cfds; in AtomicFlushMemTablesToOutputFiles()
509 autovector<ColumnFamilyData*> tmp_cfds; in AtomicFlushMemTablesToOutputFiles()
587 void DBImpl::NotifyOnFlushBegin(ColumnFamilyData* cfd, FileMetaData* file_meta, in NotifyOnFlushBegin()
639 ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options, in NotifyOnFlushCompleted()
704 autovector<ColumnFamilyData*> cfds; in CompactRange()
731 s = RunManualCompaction(cfd, ColumnFamilyData::kCompactAllLevels, in CompactRange()
806 output_level = ColumnFamilyData::kCompactToBaseLevel; in CompactRange()
814 if (output_level == ColumnFamilyData::kCompactToBaseLevel) { in CompactRange()
932 const CompactionOptions& compact_options, ColumnFamilyData* cfd, in CompactFilesImpl()
1144 void DBImpl::NotifyOnCompactionBegin(ColumnFamilyData* cfd, Compaction* c, in NotifyOnCompactionBegin()
1220 ColumnFamilyData* cfd, Compaction* c, const Status& st, in NotifyOnCompactionCompleted()
1262 Status DBImpl::ReFitLevel(ColumnFamilyData* cfd, int level, int target_level) { in ReFitLevel()
1400 autovector<ColumnFamilyData*> cfds; in Flush()
1423 ColumnFamilyData* cfd, int input_level, int output_level, in RunManualCompaction()
1427 assert(input_level == ColumnFamilyData::kCompactAllLevels || in RunManualCompaction()
1565 void DBImpl::GenerateFlushRequest(const autovector<ColumnFamilyData*>& cfds, in GenerateFlushRequest()
1579 Status DBImpl::FlushMemTable(ColumnFamilyData* cfd, in FlushMemTable()
1617 ColumnFamilyData* cfd_stats = in FlushMemTable()
1648 ColumnFamilyData* loop_cfd = elem.first; in FlushMemTable()
1657 ColumnFamilyData* loop_cfd = elem.first; in FlushMemTable()
1675 autovector<ColumnFamilyData*> cfds; in FlushMemTable()
1695 const autovector<ColumnFamilyData*>& column_family_datas, in AtomicFlushMemTables()
1715 autovector<ColumnFamilyData*> cfds; in AtomicFlushMemTables()
1799 Status DBImpl::WaitUntilFlushWouldNotStallWrites(ColumnFamilyData* cfd, in WaitUntilFlushWouldNotStallWrites()
1857 ColumnFamilyData::GetWriteStallConditionAndCause( in WaitUntilFlushWouldNotStallWrites()
1878 const autovector<ColumnFamilyData*>& cfds, in WaitForFlushMemTables()
2062 void DBImpl::AddToCompactionQueue(ColumnFamilyData* cfd) { in AddToCompactionQueue()
2069 ColumnFamilyData* DBImpl::PopFirstFromCompactionQueue() { in PopFirstFromCompactionQueue()
2086 ColumnFamilyData* DBImpl::PickCompactionFromQueue( in PickCompactionFromQueue()
2090 autovector<ColumnFamilyData*> throttled_candidates; in PickCompactionFromQueue()
2091 ColumnFamilyData* cfd = nullptr; in PickCompactionFromQueue()
2118 ColumnFamilyData* cfd = iter.first; in SchedulePendingFlush()
2126 void DBImpl::SchedulePendingCompaction(ColumnFamilyData* cfd) { in SchedulePendingCompaction()
2223 autovector<ColumnFamilyData*> column_families_not_to_flush; in BackgroundFlush()
2231 ColumnFamilyData* cfd = iter.first; in BackgroundFlush()
2249 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush()
2267 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush()
2998 bool DBImpl::HaveManualCompaction(ColumnFamilyData* cfd) { in HaveManualCompaction()
3041 const ColumnFamilyData* cfd, Compaction* c, const Status& st, in BuildCompactionJobInfo()
3099 ColumnFamilyData* cfd, SuperVersionContext* sv_context, in InstallSuperVersionAndScheduleWork()