Lines Matching refs:cfd
341 const auto* cfd = compact_->compaction->column_family_data(); in CompactionJob() local
342 ThreadStatusUtil::SetColumnFamily(cfd, cfd->ioptions()->env, in CompactionJob()
354 const auto* cfd = compact_->compaction->column_family_data(); in ReportStartedCompaction() local
355 ThreadStatusUtil::SetColumnFamily(cfd, cfd->ioptions()->env, in ReportStartedCompaction()
440 auto* cfd = c->column_family_data(); in GenSubcompactionBoundaries() local
441 const Comparator* cfd_comparator = cfd->user_comparator(); in GenSubcompactionBoundaries()
633 ColumnFamilyData* cfd = compact_->compaction->column_family_data(); in Run() local
649 InternalIterator* iter = cfd->table_cache()->NewIterator( in Run()
650 ReadOptions(), file_options_, cfd->internal_comparator(), in Run()
653 cfd->internal_stats()->GetFileReadHist( in Run()
717 ColumnFamilyData* cfd = compact_->compaction->column_family_data(); in Install() local
718 cfd->internal_stats()->AddCompactionStats( in Install()
729 auto vstorage = cfd->current()->storage_info(); in Install()
759 cfd->GetName().c_str(), vstorage->LevelSummary(&tmp), bytes_read_per_sec, in Install()
818 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in ProcessKeyValueCompaction() local
823 cfd->ioptions()->compaction_filter; in ProcessKeyValueCompaction()
837 CompactionRangeDelAggregator range_del_agg(&cfd->internal_comparator(), in ProcessKeyValueCompaction()
869 env_, cfd->user_comparator(), cfd->ioptions()->merge_operator, in ProcessKeyValueCompaction()
894 input.get(), cfd->user_comparator(), &merge, versions_->LastSequence(), in ProcessKeyValueCompaction()
911 while (status.ok() && !cfd->IsDropped() && c_iter->Valid()) { in ProcessKeyValueCompaction()
920 cfd->user_comparator()->Compare(c_iter->user_key(), *end) >= 0) { in ProcessKeyValueCompaction()
1015 if (status.ok() && cfd->IsDropped()) { in ProcessKeyValueCompaction()
1131 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in FinishCompactionOutputFile() local
1132 const Comparator* ucmp = cfd->user_comparator(); in FinishCompactionOutputFile()
1288 cfd->internal_comparator()); in FinishCompactionOutputFile()
1366 cfd->GetName().c_str(), job_id_, output_number, in FinishCompactionOutputFile()
1383 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, in FinishCompactionOutputFile()
1471 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in OpenCompactionOutputFile() local
1474 cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, job_id_, in OpenCompactionOutputFile()
1494 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), in OpenCompactionOutputFile()
1542 cfd->ioptions()->optimize_filters_for_hits && bottommost_level_; in OpenCompactionOutputFile()
1545 *cfd->ioptions(), *(sub_compact->compaction->mutable_cf_options()), in OpenCompactionOutputFile()
1546 cfd->internal_comparator(), cfd->int_tbl_prop_collector_factories(), in OpenCompactionOutputFile()
1547 cfd->GetID(), cfd->GetName(), sub_compact->outfile.get(), in OpenCompactionOutputFile()
1686 ColumnFamilyData* cfd = compaction->column_family_data(); in LogCompaction() local
1694 cfd->GetName().c_str(), job_id_, in LogCompaction()
1699 cfd->GetName().c_str(), scratch); in LogCompaction()