Home
last modified time | relevance | path

Searched refs:user_key (Results 1 – 25 of 84) sorted by relevance

1234

/rocksdb-6.9/db/
Ddbformat.h100 Slice user_key; member
113 user_key.clear(); in clear()
121 return key.user_key.size() + 8; in InternalKeyEncodingLength()
168 assert(user_key.size() >= ts_sz); in StripTimestampFromUserKey()
169 return Slice(user_key.data(), user_key.size() - ts_sz); in StripTimestampFromUserKey()
173 assert(user_key.size() >= ts_sz); in ExtractTimestampFromUserKey()
174 return Slice(user_key.data() + user_key.size() - ts_sz, ts_sz); in ExtractTimestampFromUserKey()
453 size_t usize = user_key.size();
561 auto user_key = ExtractUserKey(src); in Transform() local
566 auto user_key = ExtractUserKey(src); in InDomain() local
[all …]
Ddbformat.cc59 fkey->user_key = ikey.user_key; in ParseFullKey()
74 result->append(key.user_key.data(), key.user_key.size()); in AppendInternalKey()
81 assert(key.user_key.size() >= ts.size()); in AppendInternalKeyWithDifferentTimestamp()
82 result->append(key.user_key.data(), key.user_key.size() - ts.size()); in AppendInternalKeyWithDifferentTimestamp()
97 result += user_key.ToString(hex); in DebugString()
122 int r = user_comparator_.Compare(a.user_key, b.user_key); in Compare()
157 Slice user_key = ExtractUserKey(*key); in FindShortSuccessor() local
158 std::string tmp(user_key.data(), user_key.size()); in FindShortSuccessor()
160 if (tmp.size() <= user_key.size() && in FindShortSuccessor()
161 user_comparator_.Compare(user_key, tmp) < 0) { in FindShortSuccessor()
Ddb_iter.cc247 assert(ikey_.user_key.size() >= timestamp_size_); in FindNextUserEntryInternal()
304 ikey_.user_key, in FindNextUserEntryInternal()
342 ikey_.user_key, in FindNextUserEntryInternal()
372 ikey_.user_key, saved_key_.GetUserKey()); in FindNextUserEntryInternal()
377 ikey_.user_key, in FindNextUserEntryInternal()
736 assert(ikey.user_key.size() >= timestamp_size_); in FindValueForCurrentKey()
739 ts = Slice(ikey.user_key.data() + ikey.user_key.size() - timestamp_size_, in FindValueForCurrentKey()
898 assert(ikey.user_key.size() >= timestamp_size_); in FindValueForCurrentKeyUsingSeek()
901 ts = Slice(ikey.user_key.data() + ikey.user_key.size() - timestamp_size_, in FindValueForCurrentKeyUsingSeek()
1053 assert(ikey.user_key.size() >= timestamp_size_); in FindUserKeyBeforeSavedKey()
[all …]
Dmerge_helper.cc165 assert(user_comparator_->Equal(ikey.user_key, orig_ikey.user_key)); in MergeUntil()
167 } else if (!user_comparator_->Equal(ikey.user_key, orig_ikey.user_key)) { in MergeUntil()
214 s = TimedFullMerge(user_merge_operator_, ikey.user_key, val_ptr, in MergeUntil()
253 : FilterMerge(orig_ikey.user_key, value_slice); in MergeUntil()
322 s = TimedFullMerge(user_merge_operator_, orig_ikey.user_key, nullptr, in MergeUntil()
350 orig_ikey.user_key, in MergeUntil()
389 CompactionFilter::Decision MergeHelper::FilterMerge(const Slice& user_key, in FilterMerge() argument
400 level_, user_key, CompactionFilter::ValueType::kMergeOperand, value_slice, in FilterMerge()
404 user_key) <= 0) { in FilterMerge()
Dfile_indexer.cc112 return ucmp_->CompareWithoutTimestamp(a->smallest.user_key(), in UpdateIndex()
113 b->largest.user_key()); in UpdateIndex()
119 return ucmp_->CompareWithoutTimestamp(a->largest.user_key(), in UpdateIndex()
120 b->largest.user_key()); in UpdateIndex()
126 return ucmp_->CompareWithoutTimestamp(a->smallest.user_key(), in UpdateIndex()
127 b->smallest.user_key()); in UpdateIndex()
133 return ucmp_->CompareWithoutTimestamp(a->largest.user_key(), in UpdateIndex()
134 b->smallest.user_key()); in UpdateIndex()
Ddbformat_test.cc16 static std::string IKey(const std::string& user_key, in IKey() argument
20 AppendInternalKey(&encoded, ParsedInternalKey(user_key, seq, vt)); in IKey()
45 ASSERT_EQ(key, decoded.user_key.ToString()); in TestKey()
177 std::string user_key("abcdefghijklmnopqrstuvwxyz"); in TEST_F() local
182 AppendInternalKey(&ikey, ParsedInternalKey(user_key, 100U, kTypeValue)); in TEST_F()
190 ASSERT_EQ(user_key, decoded.user_key.ToString()); in TEST_F()
Dmemtable.cc686 s->mem->GetLock(s->key->user_key())->ReadLock(); in SaveValue()
694 merge_operator, s->key->user_key(), &v, in SaveValue()
713 s->mem->GetLock(s->key->user_key())->ReadUnlock(); in SaveValue()
732 merge_operator, s->key->user_key(), nullptr, in SaveValue()
760 merge_operator, s->key->user_key(), nullptr, in SaveValue()
800 Slice user_key = key.user_key(); in Get() local
814 !prefix_extractor_->InDomain(user_key) || in Get()
963 Slice(key_ptr, key_length - 8), lkey.user_key())) { in Update()
979 WriteLock wl(GetLock(lkey.user_key())); in Update()
1022 Slice(key_ptr, key_length - 8), lkey.user_key())) { in UpdateCallback()
[all …]
Drange_del_aggregator.cc95 icmp_->user_comparator()->Compare(target, smallest_->user_key) < 0) { in Seek()
96 iter_->Seek(smallest_->user_key); in Seek()
111 icmp_->user_comparator()->Compare(largest_->user_key, target) < 0) { in SeekForPrev()
112 iter_->SeekForPrev(largest_->user_key); in SeekForPrev()
120 iter_->Seek(smallest_->user_key); in SeekToFirst()
128 iter_->SeekForPrev(largest_->user_key); in SeekToLast()
425 cur_start_key_.Set(top->start_key().user_key, top->seq(), in key()
433 return top->end_key().user_key; in value()
447 int cmp = icmp_->user_comparator()->Compare(iter->start_key().user_key, in BeforeEndKey()
Dtable_cache.cc317 bool TableCache::GetFromRowCache(const Slice& user_key, IterKey& row_cache_key, in GetFromRowCache() argument
321 row_cache_key.TrimAppend(prefix_size, user_key.data(), user_key.size()); in GetFromRowCache()
342 replayGetContextLog(*found_row_cache_entry, user_key, get_context, in GetFromRowCache()
370 auto user_key = ExtractUserKey(k); in Get() local
372 done = GetFromRowCache(user_key, row_cache_key, row_cache_key.Size(), in Get()
465 const Slice& user_key = miter->ukey; in MultiGet() local
469 if (GetFromRowCache(user_key, row_cache_key, row_cache_key_prefix_size, in MultiGet()
529 const Slice& user_key = miter->ukey; in MultiGet() local
535 row_cache_key.TrimAppend(row_cache_key_prefix_size, user_key.data(), in MultiGet()
536 user_key.size()); in MultiGet()
Dtable_properties_collector_test.cc90 Status AddUserKey(const Slice& user_key, const Slice& /*value*/, in AddUserKey() argument
94 if (user_key.data()[0] == 'A') { in AddUserKey()
142 Status Add(const Slice& user_key, const Slice& /*value*/) override { in Add() argument
144 if (user_key.data()[0] == 'A') { in Add()
170 Status InternalAdd(const Slice& user_key, const Slice& /*value*/, in InternalAdd() argument
173 if (user_key.data()[0] == 'A') { in InternalAdd()
/rocksdb-6.9/table/
Dsst_file_writer.cc61 Status Add(const Slice& user_key, const Slice& value, in Add()
68 file_info.smallest_key.assign(user_key.data(), user_key.size()); in Add()
71 user_key, file_info.largest_key) <= 0) { in Add()
81 ikey.Set(user_key, 0 /* Sequence Number */, in Add()
85 ikey.Set(user_key, 0 /* Sequence Number */, in Add()
89 ikey.Set(user_key, 0 /* Sequence Number */, in Add()
99 file_info.largest_key.assign(user_key.data(), user_key.size()); in Add()
262 return rep_->Add(user_key, value, ValueType::kTypeValue); in Add()
266 return rep_->Add(user_key, value, ValueType::kTypeValue); in Put()
270 return rep_->Add(user_key, value, ValueType::kTypeMerge); in Merge()
[all …]
Dget_context.cc43 Statistics* statistics, GetState init_state, const Slice& user_key, in GetContext() argument
54 user_key_(user_key), in GetContext()
76 Statistics* statistics, GetState init_state, const Slice& user_key, in GetContext() argument
81 : GetContext(ucmp, merge_operator, logger, statistics, init_state, user_key, in GetContext()
199 if (ucmp_->CompareWithoutTimestamp(parsed_key.user_key, user_key_) == 0) { in SaveValue()
276 Slice ts = ExtractTimestampFromUserKey(parsed_key.user_key, ts_sz); in SaveValue()
359 void replayGetContextLog(const Slice& replay_log, const Slice& user_key, in replayGetContextLog() argument
375 ParsedInternalKey(user_key, kMaxSequenceNumber, type), value, in replayGetContextLog()
380 (void)user_key; in replayGetContextLog()
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.cc107 smallest_user_key_.assign(ikey.user_key.data(), ikey.user_key.size()); in Add()
108 largest_user_key_.assign(ikey.user_key.data(), ikey.user_key.size()); in Add()
109 key_size_ = is_last_level_file_ ? ikey.user_key.size() : key.size(); in Add()
127 kvs_.append(ikey.user_key.data(), ikey.user_key.size()); in Add()
135 deleted_keys_.append(ikey.user_key.data(), ikey.user_key.size()); in Add()
147 if (ikey.user_key.compare(smallest_user_key_) < 0) { in Add()
148 smallest_user_key_.assign(ikey.user_key.data(), ikey.user_key.size()); in Add()
149 } else if (ikey.user_key.compare(largest_user_key_) > 0) { in Add()
150 largest_user_key_.assign(ikey.user_key.data(), ikey.user_key.size()); in Add()
193 Slice user_key = GetUserKey(vector_idx); in MakeHashTable() local
[all …]
Dcuckoo_table_factory.h18 const Slice& user_key, uint32_t hash_cnt, bool use_module_hash, in CuckooHash() argument
25 return get_slice_hash(user_key, hash_cnt, table_size_); in CuckooHash()
33 value = (*reinterpret_cast<const int64_t*>(user_key.data())); in CuckooHash()
35 value = MurmurHash(user_key.data(), static_cast<int>(user_key.size()), in CuckooHash()
Dcuckoo_table_reader.cc149 Slice user_key = ExtractUserKey(key); in Get() local
152 user_key, hash_cnt, use_module_hash_, table_size_, in Get()
157 if (ucomp_->Equal(Slice(unused_key_.data(), user_key.size()), in Get()
158 Slice(bucket, user_key.size()))) { in Get()
163 if (ucomp_->Equal(user_key, Slice(bucket, user_key.size()))) { in Get()
189 Slice user_key = ExtractUserKey(key); in Prepare() local
191 bucket_length_ * CuckooHash(user_key, 0, use_module_hash_, table_size_, in Prepare()
Dcuckoo_table_builder_test.cc204 for (auto& user_key : user_keys) { in TEST_F() local
205 keys.push_back(GetInternalKey(user_key, false, type)); in TEST_F()
254 for (auto& user_key : user_keys) { in TEST_F() local
255 keys.push_back(GetInternalKey(user_key, false)); in TEST_F()
303 for (auto& user_key : user_keys) { in TEST_F() local
304 keys.push_back(GetInternalKey(user_key, false)); in TEST_F()
358 for (auto& user_key : user_keys) { in TEST_F() local
359 keys.push_back(GetInternalKey(user_key, false)); in TEST_F()
409 for (auto& user_key : user_keys) { in TEST_F() local
410 keys.push_back(GetInternalKey(user_key, false)); in TEST_F()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc158 ikey_.user_key = current_key_.GetUserKey(); in Next()
201 Slice& filter_key = ikey_.type == kTypeValue ? ikey_.user_key : key_; in InvokeFilterIfNeeded()
285 !cmp_->Equal(ikey_.user_key, current_user_key_)) { in NextFromInput()
289 current_user_key_ = ikey_.user_key; in NextFromInput()
309 ikey_.user_key = current_key_.GetUserKey(); in NextFromInput()
408 cmp_->Equal(ikey_.user_key, next_ikey.user_key)) { in NextFromInput()
474 compaction_->KeyNotExistsBeyondOutputLevel(ikey_.user_key, in NextFromInput()
552 cmp_->Equal(ikey_.user_key, next_ikey.user_key) && in NextFromInput()
560 cmp_->Equal(ikey_.user_key, next_ikey.user_key)) { in NextFromInput()
600 ikey_.user_key = current_key_.GetUserKey(); in NextFromInput()
[all …]
Dcompaction.cc26 auto c = user_cmp->Compare(a.user_key(), b.user_key()); in sstableKeyCompare()
88 const Slice& start_user_key = f->smallest.user_key(); in GetBoundaryKeys()
93 const Slice& end_user_key = f->largest.user_key(); in GetBoundaryKeys()
102 const Slice& start_user_key = inputs[i].files[0]->smallest.user_key(); in GetBoundaryKeys()
107 const Slice& end_user_key = inputs[i].files.back()->largest.user_key(); in GetBoundaryKeys()
357 const Slice& user_key, std::vector<size_t>* level_ptrs) const { in KeyNotExistsBeyondOutputLevel() argument
372 if (user_cmp->Compare(user_key, f->largest.user_key()) <= 0) { in KeyNotExistsBeyondOutputLevel()
374 if (user_cmp->Compare(user_key, f->smallest.user_key()) >= 0) { in KeyNotExistsBeyondOutputLevel()
/rocksdb-6.9/java/rocksjni/
Dwrite_batch_test.cc73 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
81 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
89 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
95 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
101 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
109 state.append(ikey.user_key.ToString()); in Java_org_rocksdb_WriteBatchTest_getContents()
/rocksdb-6.9/table/block_based/
Dblock_based_table_iterator.cc39 block_iter_.user_key()) > 0 && in SeekImpl()
41 index_iter_->user_key()) < 0) { in SeekImpl()
303 index_iter_->user_key(), /*b_has_ts=*/true) <= 0); in FindBlockForward()
362 *read_options_.iterate_upper_bound, /*a_has_ts=*/false, user_key(), in CheckOutOfBound()
373 index_iter_->user_key(), in CheckDataBlockWithinUpperBound()
/rocksdb-6.9/include/rocksdb/
Dsst_file_writer.h106 ROCKSDB_DEPRECATED_FUNC Status Add(const Slice& user_key, const Slice& value);
110 Status Put(const Slice& user_key, const Slice& value);
114 Status Merge(const Slice& user_key, const Slice& value);
118 Status Delete(const Slice& user_key);
Dtypes.h33 Slice user_key; member
39 : user_key(u), sequence(seq), type(t) {} in FullKey()
43 user_key.clear(); in clear()
/rocksdb-6.9/memtable/
Dvectorrep.cc82 void Seek(const Slice& user_key, const char* memtable_key) override;
85 void SeekForPrev(const Slice& user_key, const char* memtable_key) override;
213 void VectorRep::Iterator::Seek(const Slice& user_key, in Seek() argument
218 (memtable_key != nullptr) ? memtable_key : EncodeKey(&tmp_, user_key); in Seek()
264 for (iter.Seek(k.user_key(), k.memtable_key().data()); in Get()
/rocksdb-6.9/include/rocksdb/utilities/
Ddebug.h19 KeyVersion() : user_key(""), value(""), sequence(0), type(0) {} in KeyVersion()
23 : user_key(_user_key), value(_value), sequence(_sequence), type(_type) {} in KeyVersion()
25 std::string user_key; member
/rocksdb-6.9/table/plain/
Dplain_table_builder.h128 return GetPrefixFromUserKey(target.user_key); in GetPrefix()
135 Slice GetPrefixFromUserKey(const Slice& user_key) const { in GetPrefixFromUserKey() argument
137 return prefix_extractor_->Transform(user_key); in GetPrefixFromUserKey()

1234