Home
last modified time | relevance | path

Searched refs:kTypeMerge (Results 1 – 25 of 27) sorted by relevance

12

/rocksdb-6.9/db/
Dmerge_helper_test.cc61 AddKeyVal("a", 20, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
62 AddKeyVal("a", 10, kTypeMerge, test::EncodeInt(3U)); in TEST_F()
77 AddKeyVal("a", 40, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
78 AddKeyVal("a", 30, kTypeMerge, test::EncodeInt(3U)); in TEST_F()
80 AddKeyVal("a", 10, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
94 AddKeyVal("a", 50, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
96 AddKeyVal("a", 30, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
98 AddKeyVal("a", 10, kTypeMerge, test::EncodeInt(1U)); in TEST_F()
113 AddKeyVal("a", 50, kTypeMerge, "v2"); in TEST_F()
115 AddKeyVal("a", 30, kTypeMerge, "v"); in TEST_F()
[all …]
Dexternal_sst_file_basic_test.cc91 case ValueType::kTypeMerge: in GenerateAndAddExternalFile()
391 options, {1, 4, 6}, ValueType::kTypeMerge, file_id++, in TEST_P()
403 options, {120, 130}, ValueType::kTypeMerge, file_id++, in TEST_P()
448 options, {40, 41, 42}, ValueType::kTypeMerge, file_id++, in TEST_P()
508 ValueType::kTypeMerge, ValueType::kTypeValue, ValueType::kTypeMerge}, in TEST_P()
517 ValueType::kTypeMerge}, in TEST_P()
526 ValueType::kTypeMerge}, in TEST_P()
534 {ValueType::kTypeDeletion, ValueType::kTypeMerge, in TEST_P()
557 {ValueType::kTypeValue, ValueType::kTypeMerge, in TEST_P()
574 {ValueType::kTypeValue, ValueType::kTypeMerge, in TEST_P()
[all …]
Ddb_memtable_test.cc155 res = mem->Add(seq, kTypeMerge, "key", "value2"); in TEST_F()
158 res = mem->Add(seq + 1, kTypeMerge, "key", "value2"); in TEST_F()
241 mem->Add(seq, kTypeMerge, "key", v1, true, &post_process_info1); in TEST_F()
252 mem->Add(seq, kTypeMerge, "key", v2, true, &post_process_info2); in TEST_F()
Ddb_iter.cc340 case kTypeMerge: in FindNextUserEntryInternal()
504 } else if (kTypeMerge == ikey.type) { in MergeValuesNewToOld()
778 case kTypeMerge: in FindValueForCurrentKey()
815 case kTypeMerge: in FindValueForCurrentKey()
944 assert(ikey.type == kTypeMerge); in FindValueForCurrentKeyUsingSeek()
983 } else if (ikey.type == kTypeMerge) { in FindValueForCurrentKeyUsingSeek()
Ddb_iter_stress_test.cc327 assert(e.type == kTypeMerge); in FindValueForCurrentKey()
439 {kTypeValue, kTypeDeletion, kTypeMerge}) { in TEST_F()
465 kTypeMerge}; in TEST_F()
Dmerge_helper.cc184 if (ikey.type != kTypeMerge) { in MergeUntil()
318 assert(kTypeMerge == orig_ikey.type); in MergeUntil()
Dtable_properties_collector_test.cc388 InternalKey("b ", 8, ValueType::kTypeMerge), in TestInternalKeyPropertiesCollector()
389 InternalKey("c ", 9, ValueType::kTypeMerge), in TestInternalKeyPropertiesCollector()
Ddbformat.h47 kTypeMerge = 0x2, enumerator
82 return t <= kTypeMerge || t == kTypeSingleDeletion || t == kTypeBlobIndex; in IsValueType()
Dmemtable.cc664 if ((type == kTypeValue || type == kTypeMerge || type == kTypeBlobIndex) && in SaveValue()
742 case kTypeMerge: { in SaveValue()
1101 if (type != kTypeMerge) { in CountSuccessiveMergeEntries()
Dwrite_batch.cc462 case kTypeMerge: in ReadRecordFromWriteBatch()
616 case kTypeMerge: in Iterate()
1057 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge()
1087 b->rep_.push_back(static_cast<char>(kTypeMerge)); in Merge()
1745 mem->Add(sequence_, kTypeMerge, key, value, in MergeCF()
Ddbformat.cc43 case kTypeMerge: in GetEntryType()
Dwrite_batch_test.cc99 case kTypeMerge: in PrintContents()
Ddb_test_util.cc944 case kTypeMerge: in AllEntriesFor()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator_test.cc437 test::KeyStr("a", 45, kTypeMerge), in TEST_P()
440 test::KeyStr("d", 70, kTypeMerge), in TEST_P()
643 {test::KeyStr("a", 50, kTypeMerge), in TEST_P()
645 test::KeyStr("b", 70, kTypeMerge), test::KeyStr("b", 60, kTypeMerge), in TEST_P()
737 {test::KeyStr("foo", 3, kTypeMerge), test::KeyStr("foo", 2, kTypeMerge), in TEST_F()
796 {test::KeyStr("foo", 5, kTypeMerge), test::KeyStr("foo", 4, kTypeMerge), in TEST_F()
797 test::KeyStr("foo", 3, kTypeMerge), test::KeyStr("foo", 2, kTypeMerge), in TEST_F()
800 {test::KeyStr("foo", 5, kTypeMerge), test::KeyStr("foo", 4, kTypeMerge), in TEST_F()
951 RunTest({test::KeyStr("a", 3, kTypeMerge), test::KeyStr("a", 2, kTypeMerge), in TEST_F()
952 test::KeyStr("a", 1, kTypeMerge)}, in TEST_F()
[all …]
Dcompaction_job_test.cc501 {KeyStr("a", 5U, kTypeMerge), "5"}, in TEST_F()
502 {KeyStr("a", 4U, kTypeMerge), "4"}, in TEST_F()
525 {KeyStr("a", 5U, kTypeMerge), "5"}, in TEST_F()
526 {KeyStr("a", 4U, kTypeMerge), "4"}, in TEST_F()
527 {KeyStr("a", 3U, kTypeMerge), "3"}, in TEST_F()
532 {{KeyStr("b", 2U, kTypeMerge), "2"}, {KeyStr("b", 1U, kTypeMerge), "1"}}); in TEST_F()
551 {{KeyStr("a", 5U, kTypeMerge), test::EncodeInt(5U)}, in TEST_F()
553 {KeyStr("a", 3U, kTypeMerge), test::EncodeInt(3U)}}); in TEST_F()
557 {KeyStr("b", 2U, kTypeMerge), test::EncodeInt(2U)}, in TEST_F()
577 {{KeyStr("a", 5U, kTypeMerge), test::EncodeInt(5U)}, in TEST_F()
[all …]
Dcompaction_iterator.cc564 } else if (ikey_.type == kTypeMerge) { in NextFromInput()
674 IN_EARLIEST_SNAPSHOT(ikey_.sequence) && ikey_.type != kTypeMerge) { in PrepareOutput()
/rocksdb-6.9/db/blob/
Ddb_blob_index_test.cc235 /*11*/ {kTypeMerge, kTypeMerge, kTypeMerge, kTypeBlobIndex}, in TEST_F()
238 {kTypeMerge, kTypeMerge, kTypeMerge, kTypeDeletion, kTypeBlobIndex}, in TEST_F()
347 case kTypeMerge: in TEST_F()
/rocksdb-6.9/table/
Dsst_file_writer.cc84 case ValueType::kTypeMerge: in Add()
86 ValueType::kTypeMerge /* Merge */); in Add()
270 return rep_->Add(user_key, value, ValueType::kTypeMerge); in Merge()
Dget_context.cc197 assert((state_ != kMerge && parsed_key.type != kTypeMerge) || in SaveValue()
217 if ((type == kTypeValue || type == kTypeMerge || type == kTypeBlobIndex) && in SaveValue()
312 case kTypeMerge: in SaveValue()
/rocksdb-6.9/java/rocksjni/
Dwrite_batch_test.cc79 case ROCKSDB_NAMESPACE::kTypeMerge: in Java_org_rocksdb_WriteBatchTest_getContents()
/rocksdb-6.9/table/block_based/
Dblock.cc541 value_type == ValueType::kTypeMerge || in ParseNextDataKey()
650 value_type == ValueType::kTypeMerge || in DecodeCurrentValue()
Dblock_based_table_builder.cc580 } else if (value_type == kTypeMerge) { in Add()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc66 case kTypeMerge: in GetEntryFromDataOffset()
Dwrite_batch_with_index.cc605 case kTypeMerge: in ReBuildIndex()
/rocksdb-6.9/table/plain/
Dplain_table_builder.cc177 } else if (internal_key.type == kTypeMerge) { in Add()

12