Lines Matching refs:key
109 if (comparator_->Equal(delta_iterator_->Entry().key, in Next()
110 base_iterator_->key())) { in Next()
145 if (comparator_->Equal(delta_iterator_->Entry().key, in Prev()
146 base_iterator_->key())) { in Prev()
155 Slice key() const override { in key() function in ROCKSDB_NAMESPACE::BaseDeltaIterator
156 return current_at_base_ ? base_iterator_->key() in key()
157 : delta_iterator_->Entry().key; in key()
207 int compare = comparator_->Compare(delta_iterator_->Entry().key, in AssertInvariants()
208 base_iterator_->key()); in AssertInvariants()
286 if (comparator_->Compare(delta_entry.key, *iterate_upper_bound_) >= in UpdateCurrent()
306 comparator_->Compare(delta_entry.key, base_iterator_->key()); in UpdateCurrent()
360 const WriteBatchIndexEntry* iter_entry = skip_list_iter_.key(); in Valid()
384 void Seek(const Slice& key) override { in Seek() argument
385 WriteBatchIndexEntry search_entry(&key, column_family_id_, in Seek()
391 void SeekForPrev(const Slice& key) override { in SeekForPrev() argument
392 WriteBatchIndexEntry search_entry(&key, column_family_id_, in SeekForPrev()
405 const WriteBatchIndexEntry* iter_entry = skip_list_iter_.key(); in Entry()
410 iter_entry->offset, &ret.type, &ret.key, &ret.value, &blob, &xid); in Entry()
425 return skip_list_iter_.key(); in GetRawEntry()
464 bool UpdateExistingEntry(ColumnFamilyHandle* column_family, const Slice& key);
465 bool UpdateExistingEntryWithCfId(uint32_t column_family_id, const Slice& key);
469 void AddOrUpdateIndex(ColumnFamilyHandle* column_family, const Slice& key);
470 void AddOrUpdateIndex(const Slice& key);
486 ColumnFamilyHandle* column_family, const Slice& key) { in UpdateExistingEntry() argument
488 return UpdateExistingEntryWithCfId(cf_id, key); in UpdateExistingEntry()
492 uint32_t column_family_id, const Slice& key) { in UpdateExistingEntryWithCfId() argument
498 iter.Seek(key); in UpdateExistingEntryWithCfId()
502 if (comparator.CompareKey(column_family_id, key, iter.Entry().key) != 0) { in UpdateExistingEntryWithCfId()
516 ColumnFamilyHandle* column_family, const Slice& key) { in AddOrUpdateIndex() argument
517 if (!UpdateExistingEntry(column_family, key)) { in AddOrUpdateIndex()
527 void WriteBatchWithIndex::Rep::AddOrUpdateIndex(const Slice& key) { in AddOrUpdateIndex() argument
528 if (!UpdateExistingEntryWithCfId(0, key)) { in AddOrUpdateIndex()
538 Slice key; in AddNewEntry() local
541 ReadKeyFromWriteBatchEntry(&entry_ptr, &key, column_family_id != 0); in AddNewEntry()
547 key.data() - wb_data.data(), key.size()); in AddNewEntry()
584 Slice key, value, blob, xid; in ReBuildIndex() local
591 s = ReadRecordFromWriteBatch(&input, &tag, &column_family_id, &key, in ReBuildIndex()
607 if (!UpdateExistingEntryWithCfId(column_family_id, key)) { in ReBuildIndex()
683 const Slice& key, const Slice& value) { in Put() argument
685 auto s = rep->write_batch.Put(column_family, key, value); in Put()
687 rep->AddOrUpdateIndex(column_family, key); in Put()
692 Status WriteBatchWithIndex::Put(const Slice& key, const Slice& value) { in Put() argument
694 auto s = rep->write_batch.Put(key, value); in Put()
696 rep->AddOrUpdateIndex(key); in Put()
702 const Slice& key) { in Delete() argument
704 auto s = rep->write_batch.Delete(column_family, key); in Delete()
706 rep->AddOrUpdateIndex(column_family, key); in Delete()
711 Status WriteBatchWithIndex::Delete(const Slice& key) { in Delete() argument
713 auto s = rep->write_batch.Delete(key); in Delete()
715 rep->AddOrUpdateIndex(key); in Delete()
721 const Slice& key) { in SingleDelete() argument
723 auto s = rep->write_batch.SingleDelete(column_family, key); in SingleDelete()
725 rep->AddOrUpdateIndex(column_family, key); in SingleDelete()
730 Status WriteBatchWithIndex::SingleDelete(const Slice& key) { in SingleDelete() argument
732 auto s = rep->write_batch.SingleDelete(key); in SingleDelete()
734 rep->AddOrUpdateIndex(key); in SingleDelete()
740 const Slice& key, const Slice& value) { in Merge() argument
742 auto s = rep->write_batch.Merge(column_family, key, value); in Merge()
744 rep->AddOrUpdateIndex(column_family, key); in Merge()
749 Status WriteBatchWithIndex::Merge(const Slice& key, const Slice& value) { in Merge() argument
751 auto s = rep->write_batch.Merge(key, value); in Merge()
753 rep->AddOrUpdateIndex(key); in Merge()
766 const Slice& key, std::string* value) { in GetFromBatch() argument
773 immuable_db_options, this, column_family, key, &merge_context, in GetFromBatch()
797 const Slice& key, in GetFromBatchAndDB() argument
802 auto s = GetFromBatchAndDB(db, read_options, db->DefaultColumnFamily(), key, in GetFromBatchAndDB()
812 const Slice& key, in GetFromBatchAndDB() argument
814 return GetFromBatchAndDB(db, read_options, db->DefaultColumnFamily(), key, in GetFromBatchAndDB()
821 const Slice& key, in GetFromBatchAndDB() argument
827 GetFromBatchAndDB(db, read_options, column_family, key, &pinnable_val); in GetFromBatchAndDB()
837 const Slice& key, in GetFromBatchAndDB() argument
839 return GetFromBatchAndDB(db, read_options, column_family, key, pinnable_val, in GetFromBatchAndDB()
845 const Slice& key, PinnableSlice* pinnable_val, ReadCallback* callback) { in GetFromBatchAndDB() argument
858 immuable_db_options, this, column_family, key, &merge_context, in GetFromBatchAndDB()
884 s = db->Get(read_options, column_family, key, pinnable_val); in GetFromBatchAndDB()
891 ->GetImpl(read_options, key, get_impl_options); in GetFromBatchAndDB()
913 s = MergeHelper::TimedFullMerge(merge_operator, key, merge_data, in GetFromBatchAndDB()
990 for (KeyContext& key : key_context) { in MultiGetFromBatchAndDB()
991 sorted_keys.emplace_back(&key); in MultiGetFromBatchAndDB()
1005 KeyContext& key = *iter; in MultiGetFromBatchAndDB() local
1006 if (key.s->ok() || key.s->IsNotFound()) { // DB Get Succeeded in MultiGetFromBatchAndDB()
1018 if (key.s->ok()) { in MultiGetFromBatchAndDB()
1025 *key.s = MergeHelper::TimedFullMerge( in MultiGetFromBatchAndDB()
1026 merge_operator, *key.key, merge_data, in MultiGetFromBatchAndDB()
1027 merge_result.second.GetOperands(), key.value->GetSelf(), logger, in MultiGetFromBatchAndDB()
1029 key.value->PinSelf(); in MultiGetFromBatchAndDB()
1031 *key.s = in MultiGetFromBatchAndDB()