| /rocksdb-6.9/db/ |
| D | db_iter.cc | 467 ParsedInternalKey ikey; in MergeValuesNewToOld() local
471 if (!ParseKey(&ikey)) { in MergeValuesNewToOld()
478 } else if (kTypeDeletion == ikey.type || kTypeSingleDeletion == ikey.type || in MergeValuesNewToOld()
604 ParsedInternalKey ikey; in ReverseToForward() local
739 ts = Slice(ikey.user_key.data() + ikey.user_key.size() - timestamp_size_, in FindValueForCurrentKey()
887 ParsedInternalKey ikey; in FindValueForCurrentKeyUsingSeek() local
901 ts = Slice(ikey.user_key.data() + ikey.user_key.size() - timestamp_size_, in FindValueForCurrentKeyUsingSeek()
920 if (ikey.type == kTypeDeletion || ikey.type == kTypeSingleDeletion || in FindValueForCurrentKeyUsingSeek()
934 if (ikey.type == kTypeValue || ikey.type == kTypeBlobIndex) { in FindValueForCurrentKeyUsingSeek()
966 if (ikey.type == kTypeDeletion || ikey.type == kTypeSingleDeletion || in FindValueForCurrentKeyUsingSeek()
[all …]
|
| D | merge_helper.cc | 154 ParsedInternalKey ikey; in MergeUntil() local
157 if (!ParseInternalKey(iter->key(), &ikey)) { in MergeUntil()
165 assert(user_comparator_->Equal(ikey.user_key, orig_ikey.user_key)); in MergeUntil()
171 } else if (stop_before > 0 && ikey.sequence <= stop_before && in MergeUntil()
173 snapshot_checker_->CheckInSnapshot(ikey.sequence, in MergeUntil()
183 assert(IsValueType(ikey.type)); in MergeUntil()
184 if (ikey.type != kTypeMerge) { in MergeUntil()
205 if (kTypeValue == ikey.type && in MergeUntil()
208 ikey, RangeDelPositioningMode::kForwardTraversal))) { in MergeUntil()
214 s = TimedFullMerge(user_merge_operator_, ikey.user_key, val_ptr, in MergeUntil()
[all …]
|
| D | table_properties_collector.cc | 35 ParsedInternalKey ikey; in InternalAdd() local
36 if (!ParseInternalKey(key, &ikey)) { in InternalAdd()
40 return collector_->AddUserKey(ikey.user_key, value, GetEntryType(ikey.type), in InternalAdd()
41 ikey.sequence, file_size); in InternalAdd()
|
| D | dbformat_test.cc | 181 std::string ikey; in TEST_F() local
182 AppendInternalKey(&ikey, ParsedInternalKey(user_key, 100U, kTypeValue)); in TEST_F()
183 size_t ikey_size = ikey.size(); in TEST_F()
184 UpdateInternalKey(&ikey, new_seq, new_val_type); in TEST_F()
185 ASSERT_EQ(ikey_size, ikey.size()); in TEST_F()
187 Slice in(ikey); in TEST_F()
|
| D | dbformat.cc | 55 ParsedInternalKey ikey; in ParseFullKey() local
56 if (!ParseInternalKey(internal_key, &ikey)) { in ParseFullKey()
59 fkey->user_key = ikey.user_key; in ParseFullKey()
60 fkey->sequence = ikey.sequence; in ParseFullKey()
61 fkey->type = GetEntryType(ikey.type); in ParseFullKey()
|
| D | db_compaction_filter_test.cc | 344 ParsedInternalKey ikey(Slice(), 0, kTypeValue); in TEST_F() local
345 ASSERT_EQ(ParseInternalKey(iter->key(), &ikey), true); in TEST_F()
347 if (ikey.sequence != 0) { in TEST_F()
434 ParsedInternalKey ikey(Slice(), 0, kTypeValue); in TEST_F() local
435 ASSERT_EQ(ParseInternalKey(iter->key(), &ikey), true); in TEST_F()
436 ASSERT_NE(ikey.sequence, (unsigned)0); in TEST_F()
652 ParsedInternalKey ikey(Slice(), 0, kTypeValue); in TEST_F() local
653 ASSERT_EQ(ParseInternalKey(iter->key(), &ikey), true); in TEST_F()
655 if (ikey.sequence != 0) { in TEST_F()
|
| D | write_batch_test.cc | 63 ParsedInternalKey ikey; in PrintContents() local
64 ikey.clear(); in PrintContents()
65 EXPECT_TRUE(ParseInternalKey(iter->key(), &ikey)); in PrintContents()
66 switch (ikey.type) { in PrintContents()
69 state.append(ikey.user_key.ToString()); in PrintContents()
78 state.append(ikey.user_key.ToString()); in PrintContents()
85 state.append(ikey.user_key.ToString()); in PrintContents()
92 state.append(ikey.user_key.ToString()); in PrintContents()
101 state.append(ikey.user_key.ToString()); in PrintContents()
113 state.append(NumberToString(ikey.sequence)); in PrintContents()
|
| D | builder.cc | 163 const ParsedInternalKey& ikey = c_iter.ikey(); in BuildTable() local
165 meta->UpdateBoundaries(key, value, ikey.sequence, ikey.type); in BuildTable()
|
| D | db_iter_stress_test.cc | 47 std::string ikey; // internal key, made from `key`, `sequence` and `type` member
201 [&](const Entry& e) { return cmp.Compare(e.ikey, target) < 0; }); in Seek()
213 [&](const Entry& e) { return cmp.Compare(e.ikey, target) <= 0; }); in SeekForPrev()
236 return data->entries[iter].ikey; in key()
472 AppendInternalKey(&e.ikey, internal_key); in TEST_F()
|
| D | dbformat.h | 310 inline void UpdateInternalKey(std::string* ikey, uint64_t seq, ValueType t) { in UpdateInternalKey() argument
311 size_t ikey_sz = ikey->size(); in UpdateInternalKey()
317 EncodeFixed64(&(*ikey)[ikey_sz - 8], newval); in UpdateInternalKey()
420 Slice SetInternalKey(const Slice& key, ParsedInternalKey* ikey) { in SetInternalKey() argument
424 ikey->user_key = Slice(key_, key_n - 8); in SetInternalKey()
|
| D | db_test_util.cc | 929 ParsedInternalKey ikey(Slice(), 0, kTypeValue); in AllEntriesFor() local
930 if (!ParseInternalKey(iter->key(), &ikey)) { in AllEntriesFor()
933 if (!last_options_.comparator->Equal(ikey.user_key, user_key)) { in AllEntriesFor()
940 switch (ikey.type) { in AllEntriesFor()
1339 ParsedInternalKey ikey; in validateNumberOfEntries() local
1340 ikey.clear(); in validateNumberOfEntries()
1341 ASSERT_EQ(ParseInternalKey(iter->key(), &ikey), true); in validateNumberOfEntries()
1344 ASSERT_EQ(ikey.sequence, (unsigned)seq--); in validateNumberOfEntries()
1540 ParsedInternalKey ikey; in VerifyDBInternal() local
1541 ASSERT_TRUE(ParseInternalKey(iter->key(), &ikey)); in VerifyDBInternal()
[all …]
|
| /rocksdb-6.9/table/cuckoo/ |
| D | cuckoo_table_builder.cc | 89 ParsedInternalKey ikey; in Add() local
90 if (!ParseInternalKey(key, &ikey)) { in Add()
94 if (ikey.type != kTypeDeletion && ikey.type != kTypeValue) { in Add()
105 is_last_level_file_ = ikey.sequence == 0; in Add()
107 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()
116 if (ikey.type == kTypeValue) { 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()
148 smallest_user_key_.assign(ikey.user_key.data(), ikey.user_key.size()); in Add()
[all …]
|
| D | cuckoo_table_reader_test.cc | 135 ParsedInternalKey ikey(user_keys[i], in UpdateKeys() local
138 AppendInternalKey(&keys[i], ikey); in UpdateKeys()
231 ParsedInternalKey ikey(user_keys[i], i + 1000, kTypeValue); in TEST_F() local
232 AppendInternalKey(&keys[i], ikey); in TEST_F()
260 AppendInternalKey(&keys[i], ikey); in TEST_F()
286 ParsedInternalKey ikey(user_keys[i], 1000, kTypeValue); in TEST_F() local
287 AppendInternalKey(&keys[i], ikey); in TEST_F()
306 ParsedInternalKey ikey(user_keys[i], 1000, kTypeValue); in TEST_F() local
307 AppendInternalKey(&keys[i], ikey); in TEST_F()
327 AppendInternalKey(&keys[i], ikey); in TEST_F()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | write_batch_test.cc | 64 ROCKSDB_NAMESPACE::ParsedInternalKey ikey; in Java_org_rocksdb_WriteBatchTest_getContents() local
65 ikey.clear(); in Java_org_rocksdb_WriteBatchTest_getContents()
70 switch (ikey.type) { in Java_org_rocksdb_WriteBatchTest_getContents()
73 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()
116 state.append(std::to_string(ikey.type)); in Java_org_rocksdb_WriteBatchTest_getContents()
[all …]
|
| /rocksdb-6.9/utilities/ |
| D | debug.cc | 47 InternalKey ikey; in GetAllKeyVersions() local
48 ikey.SetMinPossibleForUserKey(begin_key); in GetAllKeyVersions()
49 iter->Seek(ikey.Encode()); in GetAllKeyVersions()
56 ParsedInternalKey ikey; in GetAllKeyVersions() local
57 if (!ParseInternalKey(iter->key(), &ikey)) { in GetAllKeyVersions()
63 icmp.user_comparator()->Compare(ikey.user_key, end_key) > 0) { in GetAllKeyVersions()
67 key_versions->emplace_back(ikey.user_key.ToString() /* _user_key */, in GetAllKeyVersions()
69 ikey.sequence /* _sequence */, in GetAllKeyVersions()
70 static_cast<int>(ikey.type) /* _type */); in GetAllKeyVersions()
|
| /rocksdb-6.9/table/block_based/ |
| D | partitioned_filter_block_test.cc | 169 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in VerifyReader() local
170 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
178 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
185 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in VerifyReader() local
186 const Slice ikey_slice = Slice(*ikey.rep()); in VerifyReader()
341 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in TEST_P() local
342 const Slice ikey_slice = Slice(*ikey.rep()); in TEST_P()
351 auto ikey = InternalKey(key, 0, ValueType::kTypeValue); in TEST_P() local
352 const Slice ikey_slice = Slice(*ikey.rep()); in TEST_P()
389 auto ikey = InternalKey(prefix, 0, ValueType::kTypeValue); in TEST_P() local
[all …]
|
| D | filter_block.h | 112 const Slice ikey = iter->ikey; in KeysMayMatch() local
114 if (!KeyMayMatch(ukey, prefix_extractor, block_offset, no_io, &ikey, in KeysMayMatch()
137 const Slice ikey = iter->ikey; in PrefixesMayMatch() local
141 block_offset, no_io, &ikey, get_context, in PrefixesMayMatch()
|
| D | data_block_hash_index_test.cc | 276 InternalKey ikey(ukey, 0, kTypeValue); in TEST() local
277 builder.Add(ikey.Encode().ToString(), "value"); in TEST()
298 InternalKey ikey(ukey, 0, kTypeValue); in TEST() local
299 builder.Add(ikey.Encode().ToString(), "value"); in TEST()
319 InternalKey ikey(ukey, 0, kTypeValue); in TEST() local
330 builder.Add(ikey.Encode().ToString(), value); in TEST()
354 builder.Add(ikey.Encode().ToString(), value); in TEST()
382 InternalKey ikey(ukey, 10, kTypeValue); in TEST() local
463 InternalKey ikey(ukey, 0, kTypeValue); in TEST() local
483 InternalKey ikey(ukey, 0, kTypeValue); in TEST() local
[all …]
|
| D | block.h | 475 inline int Compare(const IterKey& ikey, const Slice& b) const { in Compare() argument
476 return comparator_->Compare(ikey.GetInternalKey(), b); in Compare()
615 inline int Compare(const IterKey& ikey, const Slice& b) const { in Compare() argument
616 return comparator_->Compare(ikey.GetKey(), b); in Compare()
|
| D | block_based_table_iterator.h | 192 bool CheckPrefixMayMatch(const Slice& ikey, IterDirection direction) { in CheckPrefixMayMatch() argument
200 !table_->PrefixMayMatch(ikey, read_options_, prefix_extractor_, in CheckPrefixMayMatch()
|
| /rocksdb-6.9/tools/ |
| D | sst_dump_tool.cc | 356 InternalKey ikey; in ReadSequential() local
357 ikey.SetMinPossibleForUserKey(from_key); in ReadSequential()
358 iter->Seek(ikey.Encode()); in ReadSequential()
369 ParsedInternalKey ikey; in ReadSequential() local
370 if (!ParseInternalKey(key, &ikey)) { in ReadSequential()
378 if (use_from_as_prefix && !ikey.user_key.starts_with(from_key)) { in ReadSequential()
388 if (!decode_blob_index_ || ikey.type != kTypeBlobIndex) { in ReadSequential()
397 ikey.DebugString(output_hex_).c_str()); in ReadSequential()
586 ParsedInternalKey ikey; in Run() local
588 if (!ParseInternalKey(sl_key, &ikey)) { in Run()
[all …]
|
| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 51 InternalKey ikey; member
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()
95 builder->Add(ikey.Encode(), value); in Add()
|
| D | mock_table.cc | 137 ParsedInternalKey ikey; in AssertLatestFile() local
140 ParseInternalKey(Slice(key), &ikey); in AssertLatestFile()
141 std::cout << ikey.DebugString(false) << " -> " << value << std::endl; in AssertLatestFile()
|
| D | table_test.cc | 272 AppendInternalKey(&encoded, ikey); in Seek()
278 AppendInternalKey(&encoded, ikey); in SeekForPrev()
2145 auto ikey = [](Slice user_key) { in TEST_P() local
2149 iter->Seek(ikey("pika")); in TEST_P()
2154 iter->Seek(ikey("pika")); in TEST_P()
2257 iter->Seek(ikey("aaba")); in TEST_P()
2267 iter->Seek(ikey("caab")); in TEST_P()
2277 iter->Seek(ikey("baaa")); in TEST_P()
2283 iter->Seek(ikey("caae")); in TEST_P()
2314 iter->Seek(ikey("aaca")); in TEST_P()
[all …]
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_compaction_filter.cc | 46 ParsedInternalKey ikey; in FilterV2() local
47 bool ok = ParseInternalKey(key, &ikey); in FilterV2()
50 if (ok && ikey.sequence < context_.fifo_eviction_seq) { in FilterV2()
|