| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend2.cc | 28 merge_out->new_value.clear(); in FullMergeV2()
49 merge_out->new_value.append(merge_in.existing_value->data(), in FullMergeV2()
53 merge_out->new_value.reserve( in FullMergeV2()
61 merge_out->new_value.append(1, delim_); in FullMergeV2()
63 merge_out->new_value.append(it->data(), it->size()); in FullMergeV2()
80 std::string* new_value, Logger* /*logger*/) const { in _AssocPartialMergeMulti() argument
82 assert(new_value); in _AssocPartialMergeMulti()
83 new_value->clear(); in _AssocPartialMergeMulti()
93 new_value->reserve(size); in _AssocPartialMergeMulti()
100 new_value->append(1, delim_); in _AssocPartialMergeMulti()
[all …]
|
| D | stringappend.cc | 26 const Slice& value, std::string* new_value, in Merge() argument
29 assert(new_value); in Merge()
30 new_value->clear(); in Merge()
34 new_value->assign(value.data(),value.size()); 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()
40 new_value->append(1,delim_); in Merge()
41 new_value->append(value.data(), value.size()); in Merge()
|
| D | stringappend2.h | 33 std::string* new_value, Logger* logger) const
43 std::string* new_value, Logger* logger) const;
|
| D | stringappend.h | 21 std::string* new_value,
|
| /rocksdb-6.9/utilities/merge_operators/ |
| D | bytesxor.cc | 20 std::string* new_value, in Merge() argument
22 XOR(existing_value, value, new_value); in Merge()
27 const Slice& value, std::string* new_value) const { in XOR()
29 new_value->clear(); in XOR()
30 new_value->assign(value.data(), value.size()); in XOR()
37 new_value->clear(); in XOR()
38 new_value->reserve(max_size); in XOR()
44 new_value->push_back(existing_value_data[i] ^ value_data[i]); in XOR()
49 new_value->push_back(existing_value_data[i]); in XOR()
54 new_value->push_back(value_data[i]); in XOR()
|
| D | put.cc | 27 std::string* new_value, Logger* /*logger*/) const override { in FullMerge() argument
30 assert(new_value != nullptr); in FullMerge()
31 new_value->assign(operand_sequence.back()); in FullMerge()
36 const Slice& right_operand, std::string* new_value, in PartialMerge() argument
38 new_value->assign(right_operand.data(), right_operand.size()); in PartialMerge()
45 std::string* new_value, in PartialMergeMulti() argument
47 new_value->assign(operand_list.back().data(), operand_list.back().size()); in PartialMergeMulti()
|
| D | sortlist.cc | 25 merge_out->new_value.append(std::to_string(left[i])).append(","); in FullMergeV2()
27 merge_out->new_value.append(std::to_string(left.back())); in FullMergeV2()
32 const Slice& right_operand, std::string* new_value, in PartialMerge() argument
40 new_value->append(std::to_string(left[i])).append(","); in PartialMerge()
42 new_value->append(std::to_string(left.back())); in PartialMerge()
48 std::string* new_value, in PartialMergeMulti() argument
51 (void)new_value; in PartialMergeMulti()
|
| D | max.cc | 42 const Slice& right_operand, std::string* new_value, in PartialMerge() argument
45 new_value->assign(left_operand.data(), left_operand.size()); in PartialMerge()
47 new_value->assign(right_operand.data(), right_operand.size()); in PartialMerge()
54 std::string* new_value, in PartialMergeMulti() argument
63 new_value->assign(max.data(), max.size()); in PartialMergeMulti()
|
| D | uint64add.cc | 24 const Slice& value, std::string* new_value, in Merge() argument
32 assert(new_value); in Merge()
33 new_value->clear(); in Merge()
34 PutFixed64(new_value, orig_value + operand); in Merge()
|
| D | bytesxor.h | 28 std::string* new_value,
36 std::string* new_value) const;
|
| D | sortlist.h | 23 const Slice& right_operand, std::string* new_value,
28 std::string* new_value, Logger* logger) const override;
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | merge_operator.cc | 24 merge_out->new_value.clear(); in FullMergeV2()
38 merge_out->new_value.reserve(merged.Size()); in FullMergeV2()
39 merged.Serialize(&(merge_out->new_value)); in FullMergeV2()
46 std::string* new_value, Logger* /*logger*/) const { in PartialMergeMulti() argument
48 assert(new_value); in PartialMergeMulti()
49 new_value->clear(); in PartialMergeMulti()
56 new_value->reserve(merged.Size()); in PartialMergeMulti()
57 merged.Serialize(new_value); in PartialMergeMulti()
|
| D | cassandra_compaction_filter.cc | 20 const Slice& existing_value, std::string* new_value, in FilterV2() argument
39 compacted.Serialize(new_value); in FilterV2()
|
| D | cassandra_compaction_filter.h | 34 const Slice& existing_value, std::string* new_value,
|
| /rocksdb-6.9/db/ |
| D | merge_operator.cc | 23 &merge_out->new_value, merge_in.logger); in FullMergeV2()
31 std::string* new_value, in PartialMergeMulti() argument
43 swap(temp_value, *new_value); in PartialMergeMulti()
44 temp_slice = Slice(*new_value); in PartialMergeMulti()
66 swap(temp_value, merge_out->new_value); in FullMergeV2()
67 temp_existing = Slice(merge_out->new_value); in FullMergeV2()
81 std::string* new_value, in PartialMerge() argument
83 return Merge(key, &left_operand, right_operand, new_value, logger); in PartialMerge()
|
| D | merge_test.cc | 42 std::string* new_value, Logger* logger) const override { in Merge() argument
43 assert(new_value->empty()); in Merge()
46 new_value->assign(value.data(), value.size()); in Merge()
54 new_value, in Merge()
60 std::string* new_value, in PartialMergeMulti() argument
62 assert(new_value->empty()); in PartialMergeMulti()
64 return mergeOperator_->PartialMergeMulti(key, operand_list, new_value, in PartialMergeMulti()
|
| /rocksdb-6.9/tools/advisor/advisor/ |
| D | db_config_optimizer.py | 22 new_value = None
25 new_value = chosen_sugg_val
49 new_value = int(old_value * mul + add)
50 return new_value
75 new_value = ConfigOptimizer.apply_action_on_value(
84 updated_config[sugg.option][NO_COL_FAMILY] = new_value
87 updated_config[sugg.option][col_fam] = new_value
98 new_value = ConfigOptimizer.apply_action_on_value(
103 updated_config[sugg.option][NO_COL_FAMILY] = new_value
115 new_value = ConfigOptimizer.apply_action_on_value(
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | merge_operator.h | 102 : new_value(_new_value), existing_operand(_existing_operand) {} in MergeOperationOutput()
105 std::string& new_value; member
193 std::string* new_value, Logger* logger) const;
244 const Slice& value, std::string* new_value,
253 const Slice& right_operand, std::string* new_value,
|
| 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()
|
| /rocksdb-6.9/examples/ |
| D | compaction_filter_example.cc | 15 merge_out->new_value.clear(); in FullMergeV2()
17 merge_out->new_value.assign(merge_in.existing_value->data(), in FullMergeV2()
24 merge_out->new_value.assign(m.data(), m.size()); in FullMergeV2()
36 std::string* new_value, bool* value_changed) const override { in Filter() argument
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.h | 270 MergeOperationOutput user_merge_out(merge_out->new_value, in FullMergeV2()
292 merge_out->new_value.assign(merge_out->existing_operand.data(), in FullMergeV2()
308 merge_out->new_value.append(ts_string, ts_len); in FullMergeV2()
315 std::string* new_value, Logger* logger) const in PartialMergeMulti() argument
332 assert(new_value); in PartialMergeMulti()
333 if (!user_merge_op_->PartialMergeMulti(key, operands_without_ts, new_value, in PartialMergeMulti()
349 new_value->append(ts_string, ts_len); in PartialMergeMulti()
|
| D | ttl_test.cc | 317 std::string* new_value, bool* value_changed) const override { in Filter() argument
318 assert(new_value != nullptr); in Filter()
342 *new_value = kNewValue_; in Filter()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_compaction_filter.cc | 85 std::string* new_value) const { in PrepareBlobOutput()
86 assert(new_value); in PrepareBlobOutput()
145 BlobIndex::EncodeBlob(new_value, new_blob_file_number, new_blob_offset, in PrepareBlobOutput()
|
| /rocksdb-6.9/third-party/folly/folly/ |
| D | Utility.h | 48 T exchange(T& obj, U&& new_value) { in exchange() argument
50 obj = std::forward<U>(new_value); in exchange()
|
| /rocksdb-6.9/utilities/compaction_filters/ |
| D | remove_emptyvalue_compactionfilter.h | 23 std::string* new_value,
|