Lines Matching defs:cfd

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() local
299 for (const auto cfd : cfds) { in AtomicFlushMemTablesToOutputFiles() local
318 auto cfd = cfds[i]; in AtomicFlushMemTablesToOutputFiles() local
587 void DBImpl::NotifyOnFlushBegin(ColumnFamilyData* cfd, FileMetaData* file_meta, in NotifyOnFlushBegin()
639 ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options, in NotifyOnFlushCompleted()
682 auto cfd = cfh->cfd(); in CompactRange() local
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()
1423 ColumnFamilyData* cfd, int input_level, int output_level, in RunManualCompaction()
1569 for (const auto cfd : cfds) { in GenerateFlushRequest() local
1579 Status DBImpl::FlushMemTable(ColumnFamilyData* cfd, in FlushMemTable()
1701 for (auto cfd : column_family_datas) { in AtomicFlushMemTables() local
1730 for (auto cfd : column_family_datas) { in AtomicFlushMemTables() local
1739 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1752 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1760 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1786 for (auto* cfd : cfds) { in AtomicFlushMemTables() local
1799 Status DBImpl::WaitUntilFlushWouldNotStallWrites(ColumnFamilyData* cfd, in WaitUntilFlushWouldNotStallWrites()
2062 void DBImpl::AddToCompactionQueue(ColumnFamilyData* cfd) { in AddToCompactionQueue()
2071 auto cfd = *compaction_queue_.begin(); in PopFirstFromCompactionQueue() local
2091 ColumnFamilyData* cfd = nullptr; in PickCompactionFromQueue() local
2118 ColumnFamilyData* cfd = iter.first; in SchedulePendingFlush() local
2126 void DBImpl::SchedulePendingCompaction(ColumnFamilyData* cfd) { in SchedulePendingCompaction()
2231 ColumnFamilyData* cfd = iter.first; in BackgroundFlush() local
2249 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush() local
2267 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush() local
2273 for (auto cfd : column_families_not_to_flush) { in BackgroundFlush() local
2590 auto cfd = PickCompactionFromQueue(&task_token, log_buffer); in BackgroundCompaction() local
2888 auto cfd = c->column_family_data(); in BackgroundCompaction() local
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()