| /rocksdb-6.9/table/plain/ |
| D | plain_table_key_coding.cc | 324 if (internal_key != nullptr) { in NextPlainEncodingKey()
325 *internal_key = cur_key_.GetInternalKey(); in NextPlainEncodingKey()
327 } else if (internal_key != nullptr) { in NextPlainEncodingKey()
329 *internal_key = decoded_internal_key; in NextPlainEncodingKey()
333 *internal_key = cur_key_.GetInternalKey(); in NextPlainEncodingKey()
382 if (internal_key != nullptr) { in NextPrefixEncodingKey()
383 *internal_key = cur_key_.GetInternalKey(); in NextPrefixEncodingKey()
386 if (internal_key != nullptr) { in NextPrefixEncodingKey()
387 *internal_key = decoded_internal_key; in NextPrefixEncodingKey()
438 if (internal_key != nullptr) { in NextPrefixEncodingKey()
[all …]
|
| D | plain_table_builder.cc | 123 ParsedInternalKey internal_key; in Add() local
124 if (!ParseInternalKey(key, &internal_key)) { in Add()
128 if (internal_key.type == kTypeRangeDeletion) { in Add()
136 keys_or_prefixes_hashes_.push_back(GetSliceHash(internal_key.user_key)); in Add()
139 moptions_.prefix_extractor->Transform(internal_key.user_key); in Add()
151 index_builder_->AddKeyPrefix(GetPrefix(internal_key), prev_offset); in Add()
174 if (internal_key.type == kTypeDeletion || in Add()
175 internal_key.type == kTypeSingleDeletion) { in Add()
177 } else if (internal_key.type == kTypeMerge) { in Add()
|
| D | plain_table_key_coding.h | 159 Slice* internal_key, Slice* value, uint32_t* bytes_read,
163 Slice* internal_key, uint32_t* bytes_read,
178 Slice* internal_key, uint32_t* bytes_read,
182 Slice* internal_key, uint32_t* bytes_read,
186 bool* internal_key_valid, Slice* internal_key);
|
| D | plain_table_reader.h | 230 ParsedInternalKey* parsed_key, Slice* internal_key, Slice* value,
|
| D | plain_table_reader.cc | 526 Slice* internal_key, Slice* value, in Next() argument
538 Status s = decoder->NextKey(*offset, parsed_key, internal_key, value, in Next()
|
| /rocksdb-6.9/db/ |
| D | dbformat.h | 152 extern bool ParseInternalKey(const Slice& internal_key,
156 inline Slice ExtractUserKey(const Slice& internal_key) { in ExtractUserKey() argument
157 assert(internal_key.size() >= 8); in ExtractUserKey()
158 return Slice(internal_key.data(), internal_key.size() - 8); in ExtractUserKey()
163 assert(internal_key.size() >= 8 + ts_sz); in ExtractUserKeyAndStripTimestamp()
164 return Slice(internal_key.data(), internal_key.size() - 8 - ts_sz); in ExtractUserKeyAndStripTimestamp()
178 assert(internal_key.size() >= 8); in ExtractInternalKeyFooter()
179 const size_t n = internal_key.size(); in ExtractInternalKeyFooter()
180 return DecodeFixed64(internal_key.data() + n - 8); in ExtractInternalKeyFooter()
297 const size_t n = internal_key.size(); in ParseInternalKey()
[all …]
|
| D | forward_iterator.cc | 114 void Seek(const Slice& internal_key) override { in Seek() argument
127 file_iter_->Seek(internal_key); in Seek()
335 ExtractUserKey(internal_key), in IsOverUpperBound()
339 void ForwardIterator::Seek(const Slice& internal_key) { in Seek() argument
347 SeekInternal(internal_key, false); in Seek()
355 mutable_iter_->Seek(internal_key); in SeekInternal()
361 if (seek_to_first || NeedToSeekImmutable(internal_key)) { in SeekInternal()
376 : mutable_iter_->Seek(internal_key); in SeekInternal()
394 target_user_key = ExtractUserKey(internal_key); in SeekInternal()
416 l0_iters_[i]->Seek(internal_key); in SeekInternal()
[all …]
|
| D | forward_iterator.h | 100 void SeekInternal(const Slice& internal_key, bool seek_to_first);
102 bool NeedToSeekImmutable(const Slice& internal_key);
105 const std::vector<FileMetaData*>& files, const Slice& internal_key,
108 bool IsOverUpperBound(const Slice& internal_key) const;
|
| D | flush_job_test.cc | 169 InternalKey internal_key(key, SequenceNumber(i), kTypeValue); in TEST_F() local
170 inserted_keys.insert({internal_key.Encode().ToString(), value}); in TEST_F()
176 InternalKey internal_key("9995", SequenceNumber(10000), kTypeRangeDeletion); in TEST_F() local
177 inserted_keys.insert({internal_key.Encode().ToString(), "9999a"}); in TEST_F()
205 InternalKey internal_key(key, seq, kTypeBlobIndex); in TEST_F() local
207 internal_key.Encode().ToString(), blob_index); in TEST_F()
460 InternalKey internal_key(key, seqno, kTypeValue); in TEST_F() local
461 inserted_keys.insert({internal_key.Encode().ToString(), value}); in TEST_F()
|
| D | compacted_db_impl.cc | 42 files_.files[FindFile(key)].fd.table_reader->Get(options, lkey.internal_key(), in Get()
60 f.fd.table_reader->Prepare(lkey.internal_key()); in MultiGet()
75 r->Get(options, lkey.internal_key(), &get_context, nullptr); in MultiGet()
|
| D | memtable.cc | 793 GetInternalKeySeqno(key.internal_key()))); in Get()
915 read_options, GetInternalKeySeqno(iter->lkey->internal_key()))); in MultiGet()
947 iter->Seek(lkey.internal_key(), mem_key.data()); in Update()
1006 iter->Seek(lkey.internal_key(), memkey.data()); in UpdateCallback()
1084 iter->Seek(key.internal_key(), memkey.data()); in CountSuccessiveMergeEntries()
1114 for (iter->Seek(k.internal_key(), k.memtable_key().data()); in Get()
|
| D | dbformat.cc | 54 bool ParseFullKey(const Slice& internal_key, FullKey* fkey) { in ParseFullKey() argument
56 if (!ParseInternalKey(internal_key, &ikey)) { in ParseFullKey()
|
| D | lookup_key.h | 35 Slice internal_key() const { in internal_key() function
|
| D | db_iter_stress_test.cc | 471 ParsedInternalKey internal_key(e.key, e.sequence, e.type); in TEST_F() local
472 AppendInternalKey(&e.ikey, internal_key); in TEST_F()
|
| D | table_cache.h | 210 const Slice& internal_key,
|
| D | table_cache.cc | 283 const Slice& internal_key, in CreateRowCacheKeyPrefix() argument
307 seq_no = 1 + GetInternalKeySeqno(internal_key); in CreateRowCacheKeyPrefix()
|
| /rocksdb-6.9/memtable/ |
| D | hash_linklist_rep.cc | 216 Slice GetPrefix(const Slice& internal_key) const { in GetPrefix()
217 return transform_->Transform(ExtractUserKey(internal_key)); in GetPrefix()
296 memtable_key : EncodeKey(&tmp_, internal_key); in Seek()
301 void SeekForPrev(const Slice& internal_key, in SeekForPrev() argument
361 void Seek(const Slice& internal_key, in Seek() argument
574 Slice internal_key = GetLengthPrefixedSlice(x->key); in Insert() local
575 auto transformed = GetPrefix(internal_key); in Insert()
669 if (KeyIsAfterNode(internal_key, cur)) { in Insert()
694 Slice internal_key = GetLengthPrefixedSlice(key); in Contains() local
696 auto transformed = GetPrefix(internal_key); in Contains()
[all …]
|
| D | skiplistrep.cc | 207 void Seek(const Slice& internal_key, const char* memtable_key) override { in Seek() argument
210 memtable_key : EncodeKey(&tmp_, internal_key); in Seek()
230 void SeekForPrev(const Slice& internal_key, in SeekForPrev() argument
234 : EncodeKey(&tmp_, internal_key); in SeekForPrev()
|
| D | hash_skiplist_rep.cc | 120 void Seek(const Slice& internal_key, const char* memtable_key) override { in Seek() argument
124 memtable_key : EncodeKey(&tmp_, internal_key); in Seek()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | memtablerep.h | 227 virtual void Seek(const Slice& internal_key, const char* memtable_key) = 0;
230 virtual void SeekForPrev(const Slice& internal_key,
|
| D | types.h | 52 bool ParseFullKey(const Slice& internal_key, FullKey* result);
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer.h | 105 ParsedInternalKey internal_key; in AddAccess() local
106 ParseInternalKey(access.referenced_key, &internal_key); in AddAccess()
|
| /rocksdb-6.9/table/ |
| D | table_test.cc | 1098 InternalKey internal_key(user_key, 0, kTypeValue); in SetupTracingTest() local
1104 InternalKey internal_key(user_key, 0, kTypeValue); in SetupTracingTest() local
2527 InternalKey internal_key(user_key, 0, kTypeValue); in TEST_P() local
2528 std::string encoded_key = internal_key.Encode().ToString(); in TEST_P()
2602 InternalKey internal_key(user_key, 0, kTypeValue); in TEST_P() local
2943 InternalKey internal_key(user_key, 0, kTypeValue); in TEST_P() local
2944 c3.Add(internal_key.Encode().ToString(), "hello"); in TEST_P()
3037 InternalKey internal_key(user_key, 0, kTypeValue); in TEST_P() local
3069 internal_key = InternalKey(user_key, 0, kTypeValue); in TEST_P()
3070 encoded_key = internal_key.Encode().ToString(); in TEST_P()
[all …]
|
| D | multiget_context.h | 111 sorted_keys_[iter]->ikey = sorted_keys_[iter]->lkey->internal_key(); in MultiGetContext()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job_test.cc | 222 InternalKey internal_key(key, ++sequence_number, kTypeValue); in CreateTwoFiles() local
230 test::CorruptKeyType(&internal_key); in CreateTwoFiles()
233 contents.insert({ internal_key.Encode().ToString(), value }); in CreateTwoFiles()
|