| /rocksdb-6.9/db/blob/ |
| D | db_blob_index_test.cc | 225 /*01*/ {kTypeBlobIndex}, in TEST_F()
227 /*03*/ {kTypeBlobIndex, kTypeValue}, in TEST_F()
229 /*05*/ {kTypeValue, kTypeBlobIndex}, in TEST_F()
231 /*07*/ {kTypeDeletion, kTypeBlobIndex}, in TEST_F()
233 /*09*/ {kTypeSingleDeletion, kTypeBlobIndex}, in TEST_F()
235 /*11*/ {kTypeMerge, kTypeMerge, kTypeMerge, kTypeBlobIndex}, in TEST_F()
238 {kTypeMerge, kTypeMerge, kTypeMerge, kTypeDeletion, kTypeBlobIndex}, in TEST_F()
240 /*15*/ {kTypeBlobIndex}, in TEST_F()
350 case kTypeBlobIndex: in TEST_F()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator_test.cc | 756 RunTest({test::KeyStr("foo", 3, kTypeBlobIndex), in TEST_F()
757 test::KeyStr("foo", 2, kTypeBlobIndex), in TEST_F()
758 test::KeyStr("foo", 1, kTypeBlobIndex)}, in TEST_F()
760 {test::KeyStr("foo", 3, kTypeBlobIndex), in TEST_F()
761 test::KeyStr("foo", 2, kTypeBlobIndex)}, in TEST_F()
819 RunTest({test::KeyStr("foo", 4, kTypeBlobIndex), in TEST_F()
820 test::KeyStr("foo", 3, kTypeBlobIndex), in TEST_F()
821 test::KeyStr("foo", 2, kTypeBlobIndex), in TEST_F()
822 test::KeyStr("foo", 1, kTypeBlobIndex)}, in TEST_F()
824 {test::KeyStr("foo", 4, kTypeBlobIndex), in TEST_F()
[all …]
|
| D | compaction_job_test.cc | 164 if (parsed && key.type == kTypeBlobIndex) { in AddMockFile()
1026 const stl_wrappers::KVMap::value_type blob2(KeyStr("b", 2U, kTypeBlobIndex), in TEST_F()
1028 const stl_wrappers::KVMap::value_type blob3(KeyStr("c", 3U, kTypeBlobIndex), in TEST_F()
1033 const stl_wrappers::KVMap::value_type blob4(KeyStr("d", 4U, kTypeBlobIndex), in TEST_F()
1038 KeyStr("f", 6U, kTypeBlobIndex), in TEST_F()
1044 KeyStr("a", 0U, kTypeBlobIndex), blob1.second); in TEST_F()
1046 KeyStr("b", 0U, kTypeBlobIndex), blob2.second); in TEST_F()
1048 KeyStr("c", 0U, kTypeBlobIndex), blob3.second); in TEST_F()
1050 KeyStr("d", 0U, kTypeBlobIndex), blob4.second); in TEST_F()
1052 KeyStr("e", 0U, kTypeBlobIndex), blob5.second); in TEST_F()
[all …]
|
| D | compaction_iterator.cc | 188 (ikey_.type == kTypeValue || ikey_.type == kTypeBlobIndex)) { in InvokeFilterIfNeeded()
436 next_ikey.type != kTypeBlobIndex) { in NextFromInput()
643 if (compaction_filter_ && ikey_.type == kTypeBlobIndex) { in PrepareOutput()
|
| /rocksdb-6.9/db/ |
| D | db_iter.cc | 291 case kTypeBlobIndex: in FindNextUserEntryInternal()
295 assert(ikey_.type != kTypeBlobIndex); in FindNextUserEntryInternal()
321 } else if (ikey_.type == kTypeBlobIndex) { in FindNextUserEntryInternal()
510 } else if (kTypeBlobIndex == ikey.type) { in MergeValuesNewToOld()
760 case kTypeBlobIndex: in FindValueForCurrentKey()
824 } else if (last_not_merge_type == kTypeBlobIndex) { in FindValueForCurrentKey()
847 case kTypeBlobIndex: in FindValueForCurrentKey()
926 if (ikey.type == kTypeBlobIndex && !allow_blob_) { in FindValueForCurrentKeyUsingSeek()
934 if (ikey.type == kTypeValue || ikey.type == kTypeBlobIndex) { in FindValueForCurrentKeyUsingSeek()
937 is_blob_ = (ikey.type == kTypeBlobIndex); in FindValueForCurrentKeyUsingSeek()
[all …]
|
| D | dbformat.cc | 26 const ValueType kValueTypeForSeek = kTypeBlobIndex;
47 case kTypeBlobIndex: in GetEntryType()
|
| D | version_edit_test.cc | 70 edit.AddFile(5, 303, 0, 100, InternalKey("foo", kBig + 503, kTypeBlobIndex), in TEST_F()
71 InternalKey("zoo", kBig + 603, kTypeBlobIndex), kBig + 503, in TEST_F()
|
| D | dbformat.h | 62 kTypeBlobIndex = 0x11, // Blob DB only enumerator
82 return t <= kTypeMerge || t == kTypeSingleDeletion || t == kTypeBlobIndex; in IsValueType()
|
| D | memtable.cc | 664 if ((type == kTypeValue || type == kTypeMerge || type == kTypeBlobIndex) && in SaveValue()
669 case kTypeBlobIndex: in SaveValue()
717 *(s->is_blob_index) = (type == kTypeBlobIndex); in SaveValue()
|
| D | flush_job_test.cc | 203 new_mem->Add(seq, kTypeBlobIndex, key, blob_index); in TEST_F()
205 InternalKey internal_key(key, seq, kTypeBlobIndex); in TEST_F()
|
| D | write_batch.cc | 473 case kTypeBlobIndex: in ReadRecordFromWriteBatch()
626 case kTypeBlobIndex: in Iterate()
1112 b->rep_.push_back(static_cast<char>(kTypeBlobIndex)); in PutBlobIndex()
1770 return PutCFImpl(column_family_id, key, value, kTypeBlobIndex); in PutBlobIndexCF()
|
| D | version_edit.cc | 103 if (value_type == kTypeBlobIndex) { in UpdateBoundaries()
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 217 if ((type == kTypeValue || type == kTypeMerge || type == kTypeBlobIndex) && in SaveValue()
224 case kTypeBlobIndex: in SaveValue()
226 if (type == kTypeBlobIndex && is_blob_index_ == nullptr) { in SaveValue()
281 *is_blob_index_ = (type == kTypeBlobIndex); in SaveValue()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_test.cc | 238 ASSERT_EQ(kTypeBlobIndex, versions[i].type); in VerifyBaseDB()
263 if (versions[i].type != kTypeBlobIndex) { in VerifyBaseDBBlobIndex()
1094 (is_small_value && !has_ttl) ? kTypeValue : kTypeBlobIndex); in TEST_F()
1399 blob_value_versions[key] = KeyVersion(key, value, sequence, kTypeBlobIndex); in TEST_F()
1402 sequence, kTypeBlobIndex); in TEST_F()
1417 blob_value_versions[key] = KeyVersion(key, value, sequence, kTypeBlobIndex); in TEST_F()
1420 sequence, kTypeBlobIndex); in TEST_F()
1434 blob_value_versions[key] = KeyVersion(key, value, sequence, kTypeBlobIndex); in TEST_F()
1436 key, kInvalidBlobFileNumber, kExpiration, sequence, kTypeBlobIndex); in TEST_F()
|
| /rocksdb-6.9/table/block_based/ |
| D | block.cc | 368 value_type != ValueType::kTypeBlobIndex) { in SeekForGetImpl()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2018-08-23-data-block-hash-index.markdown | 98 kTypeBlobIndex, <=== supported
|
| /rocksdb-6.9/tools/ |
| D | sst_dump_tool.cc | 388 if (!decode_blob_index_ || ikey.type != kTypeBlobIndex) { in ReadSequential()
|