| /rocksdb-6.9/db/ |
| D | compacted_db_impl.cc | 41 LookupKey lkey(key, kMaxSequenceNumber); in Get() local
42 files_.files[FindFile(key)].fd.table_reader->Get(options, lkey.internal_key(), in Get()
59 LookupKey lkey(key, kMaxSequenceNumber); in MultiGet() local
60 f.fd.table_reader->Prepare(lkey.internal_key()); in MultiGet()
74 LookupKey lkey(keys[idx], kMaxSequenceNumber); in MultiGet() local
75 r->Get(options, lkey.internal_key(), &get_context, nullptr); in MultiGet()
|
| D | memtable.cc | 921 GetFromTable(*(iter->lkey), iter->max_covering_tombstone_seq, true, in MultiGet()
942 LookupKey lkey(key, seq); in Update() local
943 Slice mem_key = lkey.memtable_key(); in Update()
947 iter->Seek(lkey.internal_key(), mem_key.data()); in Update()
963 Slice(key_ptr, key_length - 8), lkey.user_key())) { in Update()
979 WriteLock wl(GetLock(lkey.user_key())); in Update()
1001 LookupKey lkey(key, seq); in UpdateCallback() local
1002 Slice memkey = lkey.memtable_key(); in UpdateCallback()
1006 iter->Seek(lkey.internal_key(), memkey.data()); in UpdateCallback()
1022 Slice(key_ptr, key_length - 8), lkey.user_key())) { in UpdateCallback()
[all …]
|
| D | db_memtable_test.cc | 263 LookupKey lkey("key", kMaxSequenceNumber); in TEST_F() local
264 res = mem->Get(lkey, &value, /*timestamp=*/nullptr, &status, &merge_context, in TEST_F()
|
| D | memtable_list_test.cc | 222 LookupKey lkey("key1", seq); in TEST_F() local
224 lkey, &value, /*timestamp*/nullptr, &s, &merge_context, in TEST_F()
339 LookupKey lkey("key1", seq); in TEST_F() local
341 lkey, &value, /*timestamp*/nullptr, &s, &merge_context, in TEST_F()
|
| D | write_batch.cc | 1686 LookupKey lkey(key, sequence_); in MergeCF() local
1690 size_t num_merges = mem->CountSuccessiveMergeEntries(lkey); in MergeCF()
|
| D | version_set.cc | 2005 Status::Corruption("corrupted key for ", iter->lkey->user_key()); in MultiGet()
2028 Slice user_key = iter->lkey->user_key(); in MultiGet()
|
| /rocksdb-6.9/table/ |
| D | multiget_context.h | 22 LookupKey* lkey; member
38 lkey(nullptr), in KeyContext()
108 sorted_keys_[iter]->lkey = new (&lookup_key_ptr_[iter]) in MultiGetContext()
110 sorted_keys_[iter]->ukey = sorted_keys_[iter]->lkey->user_key(); in MultiGetContext()
111 sorted_keys_[iter]->ikey = sorted_keys_[iter]->lkey->internal_key(); in MultiGetContext()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_readonly.cc | 49 LookupKey lkey(key, snapshot); in Get() local
51 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in Get()
58 super_version->current->Get(read_options, lkey, pinnable_val, in Get()
|
| D | db_impl_secondary.cc | 339 LookupKey lkey(key, snapshot); in GetImpl() local
343 if (super_version->mem->Get(lkey, pinnable_val->GetSelf(), in GetImpl()
351 lkey, pinnable_val->GetSelf(), /*timestamp=*/nullptr, &s, in GetImpl()
363 super_version->current->Get(read_options, lkey, pinnable_val, in GetImpl()
|
| D | db_impl.cc | 1601 LookupKey lkey(key, snapshot, read_options.timestamp); in GetImpl() local
1622 sv->imm->Get(lkey, get_impl_options.value->GetSelf(), in GetImpl()
1634 if (sv->mem->Get(lkey, /*value*/ nullptr, /*timestamp=*/nullptr, &s, in GetImpl()
1640 sv->imm->GetMergeOperands(lkey, &s, &merge_context, in GetImpl()
1655 read_options, lkey, get_impl_options.value, timestamp, &s, in GetImpl()
1767 LookupKey lkey(keys[i], consistent_seqnum, read_options.timestamp); in MultiGet() local
1784 lkey, value, timestamp, &s, &merge_context, in MultiGet()
3863 LookupKey lkey(key, current_seq); in GetLatestSequenceForKey() local
3869 sv->mem->Get(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
3896 sv->imm->Get(lkey, nullptr, nullptr, &s, &merge_context, in GetLatestSequenceForKey()
[all …]
|