Lines Matching refs:c_iter

118   std::unique_ptr<CompactionIterator> c_iter;  member
1168 sub_compact->c_iter.reset(new CompactionIterator( in ProcessKeyValueCompaction()
1177 auto c_iter = sub_compact->c_iter.get(); in ProcessKeyValueCompaction() local
1178 c_iter->SeekToFirst(); in ProcessKeyValueCompaction()
1179 if (c_iter->Valid() && sub_compact->compaction->output_level() != 0) { in ProcessKeyValueCompaction()
1183 sub_compact->ShouldStopBefore(c_iter->key(), in ProcessKeyValueCompaction()
1186 const auto& c_iter_stats = c_iter->iter_stats(); in ProcessKeyValueCompaction()
1194 while (status.ok() && !cfd->IsDropped() && c_iter->Valid()) { in ProcessKeyValueCompaction()
1197 const Slice& key = c_iter->key(); in ProcessKeyValueCompaction()
1198 const Slice& value = c_iter->value(); in ProcessKeyValueCompaction()
1203 cfd->user_comparator()->Compare(c_iter->user_key(), *end) >= 0) { in ProcessKeyValueCompaction()
1209 c_iter->ResetRecordCounts(); in ProcessKeyValueCompaction()
1227 const ParsedInternalKey& ikey = c_iter->ikey(); in ProcessKeyValueCompaction()
1253 last_key_for_partitioner.assign(c_iter->user_key().data_, in ProcessKeyValueCompaction()
1254 c_iter->user_key().size_); in ProcessKeyValueCompaction()
1256 c_iter->Next(); in ProcessKeyValueCompaction()
1257 if (c_iter->status().IsManualCompactionPaused()) { in ProcessKeyValueCompaction()
1260 if (!output_file_ended && c_iter->Valid()) { in ProcessKeyValueCompaction()
1263 last_key_for_partitioner, c_iter->user_key(), in ProcessKeyValueCompaction()
1267 c_iter->key(), sub_compact->current_output_file_size))) && in ProcessKeyValueCompaction()
1277 if (c_iter->Valid()) { in ProcessKeyValueCompaction()
1278 next_key = &c_iter->key(); in ProcessKeyValueCompaction()
1328 status = c_iter->status(); in ProcessKeyValueCompaction()
1380 if (sub_compact->c_iter) { in ProcessKeyValueCompaction()
1381 sub_compact->c_iter->status().PermitUncheckedError(); in ProcessKeyValueCompaction()
1389 sub_compact->c_iter.reset(); in ProcessKeyValueCompaction()