Lines Matching refs:c_iter

109   std::unique_ptr<CompactionIterator> c_iter;  member
884 sub_compact->c_iter.reset(new CompactionIterator( in ProcessKeyValueCompaction()
891 auto c_iter = sub_compact->c_iter.get(); in ProcessKeyValueCompaction() local
892 c_iter->SeekToFirst(); in ProcessKeyValueCompaction()
893 if (c_iter->Valid() && sub_compact->compaction->output_level() != 0) { in ProcessKeyValueCompaction()
897 sub_compact->ShouldStopBefore(c_iter->key(), in ProcessKeyValueCompaction()
900 const auto& c_iter_stats = c_iter->iter_stats(); in ProcessKeyValueCompaction()
902 while (status.ok() && !cfd->IsDropped() && c_iter->Valid()) { in ProcessKeyValueCompaction()
905 const Slice& key = c_iter->key(); in ProcessKeyValueCompaction()
906 const Slice& value = c_iter->value(); in ProcessKeyValueCompaction()
911 cfd->user_comparator()->Compare(c_iter->user_key(), *end) >= 0) { in ProcessKeyValueCompaction()
917 c_iter->ResetRecordCounts(); in ProcessKeyValueCompaction()
932 const ParsedInternalKey& ikey = c_iter->ikey(); in ProcessKeyValueCompaction()
959 c_iter->Next(); in ProcessKeyValueCompaction()
960 if (c_iter->status().IsManualCompactionPaused()) { in ProcessKeyValueCompaction()
963 if (!output_file_ended && c_iter->Valid() && in ProcessKeyValueCompaction()
965 sub_compact->ShouldStopBefore(c_iter->key(), in ProcessKeyValueCompaction()
976 if (c_iter->Valid()) { in ProcessKeyValueCompaction()
977 next_key = &c_iter->key(); in ProcessKeyValueCompaction()
1023 status = c_iter->status(); in ProcessKeyValueCompaction()
1065 sub_compact->c_iter.reset(); in ProcessKeyValueCompaction()