| /rocksdb-6.9/utilities/merge_operators/ |
| D | bytesxor.cc | 18 const Slice* existing_value, in Merge() argument
22 XOR(existing_value, value, new_value); in Merge()
26 void BytesXOROperator::XOR(const Slice* existing_value, in XOR() argument
28 if (!existing_value) { in XOR()
34 size_t min_size = std::min(existing_value->size(), value.size()); in XOR()
35 size_t max_size = std::max(existing_value->size(), value.size()); in XOR()
40 const char* existing_value_data = existing_value->data(); in XOR()
47 if (existing_value->size() == max_size) { in XOR()
|
| D | uint64add.cc | 23 bool Merge(const Slice& /*key*/, const Slice* existing_value, in Merge() argument
27 if (existing_value){ in Merge()
28 orig_value = DecodeInteger(*existing_value, logger); in Merge()
|
| D | max.cc | 25 if (merge_in.existing_value) { in FullMergeV2()
26 max = Slice(merge_in.existing_value->data(), in FullMergeV2()
27 merge_in.existing_value->size()); in FullMergeV2()
|
| D | bytesxor.h | 26 const Slice* existing_value,
35 void XOR(const Slice* existing_value, const Slice& value,
|
| /rocksdb-6.9/examples/ |
| D | compaction_filter_example.cc | 16 if (merge_in.existing_value != nullptr) { in FullMergeV2()
17 merge_out->new_value.assign(merge_in.existing_value->data(), in FullMergeV2()
18 merge_in.existing_value->size()); in FullMergeV2()
35 const ROCKSDB_NAMESPACE::Slice& existing_value, in Filter() argument
45 const ROCKSDB_NAMESPACE::Slice& existing_value) const override { in FilterMergeOperand()
48 return existing_value == "bad"; in FilterMergeOperand()
|
| D | options_file_example.cc | 30 virtual bool Filter(int level, const Slice& key, const Slice& existing_value, in Filter() argument
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend.cc | 25 const Slice* existing_value, in Merge() argument
32 if (!existing_value) { in Merge()
38 new_value->reserve(existing_value->size() + 1 + value.size()); in Merge()
39 new_value->assign(existing_value->data(),existing_value->size()); in Merge()
|
| D | stringappend2.cc | 30 if (merge_in.existing_value == nullptr && merge_in.operand_list.size() == 1) { in FullMergeV2()
47 if (merge_in.existing_value) { in FullMergeV2()
48 merge_out->new_value.reserve(numBytes + merge_in.existing_value->size()); in FullMergeV2()
49 merge_out->new_value.append(merge_in.existing_value->data(), in FullMergeV2()
50 merge_in.existing_value->size()); in FullMergeV2()
|
| D | stringappend.h | 19 const Slice* existing_value,
|
| /rocksdb-6.9/db/ |
| D | merge_operator.cc | 22 return FullMerge(merge_in.key, merge_in.existing_value, operand_list_str, in FullMergeV2()
59 const Slice* existing_value = merge_in.existing_value; in FullMergeV2() local
62 if (!Merge(merge_in.key, existing_value, operand, &temp_value, in FullMergeV2()
68 existing_value = &temp_existing; in FullMergeV2()
|
| D | merge_test.cc | 41 bool Merge(const Slice& key, const Slice* existing_value, const Slice& value, in Merge() argument
45 if (existing_value == nullptr) { in Merge()
52 *existing_value, in Merge()
|
| D | manual_compaction_test.cc | 52 bool Filter(int /*level*/, const Slice& /*key*/, const Slice& existing_value, in Filter() argument
55 return existing_value.ToString() == "destroy"; in Filter()
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_compaction_filter.cc | 20 const Slice& existing_value, std::string* new_value, in FilterV2() argument
24 existing_value.data(), existing_value.size()); in FilterV2()
|
| D | merge_operator.cc | 26 if (merge_in.existing_value) { in FullMergeV2()
28 RowValue::Deserialize(merge_in.existing_value->data(), in FullMergeV2()
29 merge_in.existing_value->size())); in FullMergeV2()
|
| D | cassandra_compaction_filter.h | 34 const Slice& existing_value, std::string* new_value,
|
| /rocksdb-6.9/include/rocksdb/ |
| D | compaction_filter.h | 158 const Slice& existing_value, std::string* new_value, in FilterV2() argument
163 bool rv = Filter(level, key, existing_value, new_value, &value_changed); in FilterV2()
170 bool rv = FilterMergeOperand(level, key, existing_value); in FilterV2()
|
| D | merge_operator.h | 83 existing_value(_existing_value), in MergeOperationInput()
91 const Slice* existing_value; member
243 virtual bool Merge(const Slice& key, const Slice* existing_value,
|
| D | advanced_options.h | 274 UpdateStatus (*inplace_callback)(char* existing_value,
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.h | 249 if (merge_in.existing_value && merge_in.existing_value->size() < ts_len) { in FullMergeV2()
272 if (merge_in.existing_value) { in FullMergeV2()
273 Slice existing_value_without_ts(merge_in.existing_value->data(), in FullMergeV2()
274 merge_in.existing_value->size() - ts_len); in FullMergeV2()
|
| /rocksdb-6.9/utilities/compaction_filters/ |
| D | remove_emptyvalue_compactionfilter.cc | 21 const Slice& existing_value, in Filter() argument
25 return existing_value.empty(); in Filter()
|
| D | remove_emptyvalue_compactionfilter.h | 22 const Slice& existing_value,
|
| /rocksdb-6.9/utilities/ |
| D | util_merge_operators_test.cc | 16 std::string FullMergeV2(std::string existing_value, in FullMergeV2() argument
22 Slice existing_value_slice(existing_value); in FullMergeV2()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator_test.cc | 379 const Slice& existing_value, std::string* /*new_value*/, in TEST_P() argument
382 std::string v = existing_value.ToString(); in TEST_P()
561 const Slice& existing_value, std::string* /*new_value*/, in TEST_P() argument
564 std::string v = existing_value.ToString(); in TEST_P()
598 if (merge_in.existing_value != nullptr) { in TEST_P()
599 temp_value = merge_in.existing_value->ToString(); in TEST_P()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_compaction_filter.cc | 84 const Slice& key, const Slice& existing_value, in PrepareBlobOutput() argument
95 const Status s = blob_index.DecodeFrom(existing_value); in PrepareBlobOutput()
|
| D | blob_compaction_filter.h | 93 BlobDecision PrepareBlobOutput(const Slice& key, const Slice& existing_value,
|