Lines Matching refs:key
151 Status PutCF(uint32_t, const Slice& key, const Slice&) override { in PutCF() argument
152 AssignTimestamp(key); in PutCF()
157 Status DeleteCF(uint32_t, const Slice& key) override { in DeleteCF() argument
158 AssignTimestamp(key); in DeleteCF()
163 Status SingleDeleteCF(uint32_t, const Slice& key) override { in SingleDeleteCF() argument
164 AssignTimestamp(key); in SingleDeleteCF()
177 Status MergeCF(uint32_t, const Slice& key, const Slice&) override { in MergeCF() argument
178 AssignTimestamp(key); in MergeCF()
219 void AssignTimestamp(const Slice& key) { in AssignTimestamp() argument
223 char* ptr = const_cast<char*>(key.data() + key.size() - ts_sz); in AssignTimestamp()
381 bool ReadKeyFromWriteBatchEntry(Slice* input, Slice* key, bool cf_record) { in ReadKeyFromWriteBatchEntry() argument
382 assert(input != nullptr && key != nullptr); in ReadKeyFromWriteBatchEntry()
395 return GetLengthPrefixedSlice(input, key); in ReadKeyFromWriteBatchEntry()
415 uint32_t* column_family, Slice* key, in ReadRecordFromWriteBatch() argument
417 assert(key != nullptr && value != nullptr); in ReadRecordFromWriteBatch()
428 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
441 if (!GetLengthPrefixedSlice(input, key)) { in ReadRecordFromWriteBatch()
452 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
463 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
474 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
534 Slice key, value, blob, xid; in Iterate() local
557 s = ReadRecordFromWriteBatch(&input, &tag, &column_family, &key, &value, in Iterate()
579 s = handler->PutCF(column_family, key, value); in Iterate()
589 s = handler->DeleteCF(column_family, key); in Iterate()
599 s = handler->SingleDeleteCF(column_family, key); in Iterate()
609 s = handler->DeleteRangeCF(column_family, key, value); in Iterate()
619 s = handler->MergeCF(column_family, key, value); in Iterate()
629 s = handler->PutBlobIndexCF(column_family, key, value); in Iterate()
756 const Slice& key, const Slice& value) { in Put() argument
757 if (key.size() > size_t{port::kMaxUint32}) { in Put()
773 PutLengthPrefixedSlice(&b->rep_, key); in Put()
776 static_cast<uint32_t>(key.size() + b->timestamp_size_)); in Put()
777 b->rep_.append(key.data(), key.size()); in Put()
787 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const Slice& key, in Put() argument
789 return WriteBatchInternal::Put(this, GetColumnFamilyID(column_family), key, in Put()
793 Status WriteBatchInternal::CheckSlicePartsLength(const SliceParts& key, in CheckSlicePartsLength() argument
796 for (int i = 0; i < key.num_parts; ++i) { in CheckSlicePartsLength()
797 total_key_bytes += key.parts[i].size(); in CheckSlicePartsLength()
814 const SliceParts& key, const SliceParts& value) { in Put() argument
815 Status s = CheckSlicePartsLength(key, value); in Put()
829 PutLengthPrefixedSliceParts(&b->rep_, key); in Put()
831 PutLengthPrefixedSlicePartsWithPadding(&b->rep_, key, b->timestamp_size_); in Put()
840 Status WriteBatch::Put(ColumnFamilyHandle* column_family, const SliceParts& key, in Put() argument
842 return WriteBatchInternal::Put(this, GetColumnFamilyID(column_family), key, in Put()
902 const Slice& key) { in Delete() argument
911 PutLengthPrefixedSlice(&b->rep_, key); in Delete()
918 Status WriteBatch::Delete(ColumnFamilyHandle* column_family, const Slice& key) { in Delete() argument
920 key); in Delete()
924 const SliceParts& key) { in Delete() argument
933 PutLengthPrefixedSliceParts(&b->rep_, key); in Delete()
941 const SliceParts& key) { in Delete() argument
943 key); in Delete()
948 const Slice& key) { in SingleDelete() argument
957 PutLengthPrefixedSlice(&b->rep_, key); in SingleDelete()
965 const Slice& key) { in SingleDelete() argument
967 this, GetColumnFamilyID(column_family), key); in SingleDelete()
972 const SliceParts& key) { in SingleDelete() argument
981 PutLengthPrefixedSliceParts(&b->rep_, key); in SingleDelete()
989 const SliceParts& key) { in SingleDelete() argument
991 this, GetColumnFamilyID(column_family), key); in SingleDelete()
1046 const Slice& key, const Slice& value) { in Merge() argument
1047 if (key.size() > size_t{port::kMaxUint32}) { in Merge()
1062 PutLengthPrefixedSlice(&b->rep_, key); in Merge()
1070 Status WriteBatch::Merge(ColumnFamilyHandle* column_family, const Slice& key, in Merge() argument
1072 return WriteBatchInternal::Merge(this, GetColumnFamilyID(column_family), key, in Merge()
1077 const SliceParts& key, in Merge() argument
1079 Status s = CheckSlicePartsLength(key, value); in Merge()
1092 PutLengthPrefixedSliceParts(&b->rep_, key); in Merge()
1101 const SliceParts& key, const SliceParts& value) { in Merge() argument
1102 return WriteBatchInternal::Merge(this, GetColumnFamilyID(column_family), key, in Merge()
1108 const Slice& key, const Slice& value) { in PutBlobIndex() argument
1117 PutLengthPrefixedSlice(&b->rep_, key); in PutBlobIndex()
1252 bool IsDuplicateKeySeq(uint32_t column_family_id, const Slice& key) { in IsDuplicateKeySeq() argument
1260 (&duplicate_detector_)->IsDuplicateKeySeq(column_family_id, key, sequence_); in IsDuplicateKeySeq()
1398 Status PutCFImpl(uint32_t column_family_id, const Slice& key, in PutCFImpl() argument
1402 WriteBatchInternal::Put(rebuilding_trx_, column_family_id, key, value); in PutCFImpl()
1414 WriteBatchInternal::Put(rebuilding_trx_, column_family_id, key, value); in PutCFImpl()
1415 batch_boundry = IsDuplicateKeySeq(column_family_id, key); in PutCFImpl()
1429 mem->Add(sequence_, value_type, key, value, in PutCFImpl()
1440 mem->Update(sequence_, key, value); in PutCFImpl()
1443 if (mem->UpdateCallback(sequence_, key, value)) { in PutCFImpl()
1463 s = db_->Get(ropts, cf_handle, key, &prev_value); in PutCFImpl()
1475 sequence_, value_type, key, Slice(prev_buffer, prev_size)); in PutCFImpl()
1482 mem->Add(sequence_, value_type, key, Slice(merged_value)); in PutCFImpl()
1493 WriteBatchInternal::Put(rebuilding_trx_, column_family_id, key, value); in PutCFImpl()
1503 Status PutCF(uint32_t column_family_id, const Slice& key, in PutCF() argument
1505 return PutCFImpl(column_family_id, key, value, kTypeValue); in PutCF()
1508 Status DeleteImpl(uint32_t /*column_family_id*/, const Slice& key, in DeleteImpl() argument
1513 mem->Add(sequence_, delete_type, key, value, in DeleteImpl()
1527 Status DeleteCF(uint32_t column_family_id, const Slice& key) override { in DeleteCF() argument
1530 WriteBatchInternal::Delete(rebuilding_trx_, column_family_id, key); in DeleteCF()
1542 WriteBatchInternal::Delete(rebuilding_trx_, column_family_id, key); in DeleteCF()
1543 batch_boundry = IsDuplicateKeySeq(column_family_id, key); in DeleteCF()
1549 auto ret_status = DeleteImpl(column_family_id, key, Slice(), kTypeDeletion); in DeleteCF()
1555 WriteBatchInternal::Delete(rebuilding_trx_, column_family_id, key); in DeleteCF()
1560 Status SingleDeleteCF(uint32_t column_family_id, const Slice& key) override { in SingleDeleteCF() argument
1563 WriteBatchInternal::SingleDelete(rebuilding_trx_, column_family_id, key); in SingleDeleteCF()
1576 key); in SingleDeleteCF()
1577 batch_boundry = IsDuplicateKeySeq(column_family_id, key); in SingleDeleteCF()
1584 DeleteImpl(column_family_id, key, Slice(), kTypeSingleDeletion); in SingleDeleteCF()
1590 WriteBatchInternal::SingleDelete(rebuilding_trx_, column_family_id, key); in SingleDeleteCF()
1648 Status MergeCF(uint32_t column_family_id, const Slice& key, in MergeCF() argument
1652 WriteBatchInternal::Merge(rebuilding_trx_, column_family_id, key, value); in MergeCF()
1664 WriteBatchInternal::Merge(rebuilding_trx_, column_family_id, key, in MergeCF()
1666 batch_boundry = IsDuplicateKeySeq(column_family_id, key); in MergeCF()
1686 LookupKey lkey(key, sequence_); in MergeCF()
1712 db_->Get(read_options, cf_handle, key, &get_value); in MergeCF()
1722 merge_operator, key, &get_value_slice, {value}, &new_value, in MergeCF()
1732 bool mem_res = mem->Add(sequence_, kTypeValue, key, new_value); in MergeCF()
1745 mem->Add(sequence_, kTypeMerge, key, value, in MergeCF()
1760 WriteBatchInternal::Merge(rebuilding_trx_, column_family_id, key, value); in MergeCF()
1767 Status PutBlobIndexCF(uint32_t column_family_id, const Slice& key, in PutBlobIndexCF() argument
1770 return PutCFImpl(column_family_id, key, value, kTypeBlobIndex); in PutBlobIndexCF()