| /rocksdb-6.9/utilities/cassandra/ |
| D | merge_operator.cc.d | 1 utilities/cassandra/merge_operator.cc.d \
2 utilities/cassandra/merge_operator.o: \
3 utilities/cassandra/merge_operator.cc \
4 utilities/cassandra/merge_operator.h include/rocksdb/merge_operator.h \
|
| D | cassandra_functional_test.cc.d | 65 include/rocksdb/merge_operator.h include/rocksdb/utilities/db_ttl.h \
68 utilities/cassandra/merge_operator.h utilities/cassandra/test_utils.h \
|
| D | format.cc.d | 3 include/rocksdb/merge_operator.h include/rocksdb/slice.h \
|
| D | cassandra_row_merge_test.cc.d | 7 utilities/cassandra/format.h include/rocksdb/merge_operator.h \
|
| D | cassandra_compaction_filter.cc.d | 8 include/rocksdb/merge_operator.h test_util/testharness.h \
|
| D | cassandra_format_test.cc.d | 7 include/rocksdb/merge_operator.h utilities/cassandra/serialize.h \
|
| D | test_utils.cc.d | 6 utilities/cassandra/format.h include/rocksdb/merge_operator.h \
|
| /rocksdb-6.9/db/ |
| D | merge_operator.cc.d | 1 db/merge_operator.cc.d db/merge_operator.o: db/merge_operator.cc \
2 include/rocksdb/merge_operator.h include/rocksdb/slice.h \
|
| D | db_merge_operator_test.cc | 85 options.merge_operator = in TEST_F()
138 options.merge_operator.reset(new TestPutOperator()); in TEST_F()
151 options.merge_operator.reset(new TestPutOperator()); in TEST_F()
167 options.merge_operator.reset(new TestPutOperator()); in TEST_F()
223 options.merge_operator = MergeOperators::CreateStringAppendTESTOperator(); in TEST_P()
305 options.merge_operator = merge_hook; in TEST_P()
374 options.merge_operator = MergeOperators::CreateMaxOperator(); in TEST_P()
430 options.merge_operator = MergeOperators::CreateStringAppendOperator(); in TEST_F()
488 options.merge_operator = MergeOperators::CreateStringAppendOperator(); in TEST_F()
603 options.merge_operator = MergeOperators::CreateMaxOperator(); in TEST_P()
|
| D | memtable.cc | 60 merge_operator(ioptions.merge_operator), in ImmutableMemTableOptions()
604 const MergeOperator* merge_operator; member
631 const MergeOperator* merge_operator = s->merge_operator; in SaveValue() local
694 merge_operator, s->key->user_key(), &v, in SaveValue()
732 merge_operator, s->key->user_key(), nullptr, in SaveValue()
743 if (!merge_operator) { in SaveValue()
757 if (s->do_merge && merge_operator->ShouldMerge( in SaveValue()
760 merge_operator, s->key->user_key(), nullptr, in SaveValue()
858 saver.merge_operator = moptions_.merge_operator; in GetFromTable()
|
| D | merge_helper.cc | 51 Status MergeHelper::TimedFullMerge(const MergeOperator* merge_operator, in TimedFullMerge() argument
58 assert(merge_operator != nullptr); in TimedFullMerge()
82 success = merge_operator->FullMergeV2(merge_in, &merge_out); in TimedFullMerge()
|
| D | db_iter_test.cc | 695 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
735 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
1342 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
1370 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
1395 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
1420 options.merge_operator = MergeOperators::CreateFromStringId("stringappend"); in TEST_F()
2339 options.merge_operator = nullptr; in TEST_F()
2393 options.merge_operator = nullptr; in TEST_F()
2420 options.merge_operator = nullptr; in TEST_F()
2451 options.merge_operator = nullptr; in TEST_F()
[all …]
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index_internal.cc | 249 const MergeOperator* merge_operator; in GetFromBatch() local
253 merge_operator = cfh->cfd()->ioptions()->merge_operator; in GetFromBatch()
263 if (merge_operator) { in GetFromBatch()
264 *s = MergeHelper::TimedFullMerge(merge_operator, key, &entry_value, in GetFromBatch()
|
| D | write_batch_with_index.cc | 898 const MergeOperator* merge_operator = in GetFromBatchAndDB() local
899 cfh->cfd()->ioptions()->merge_operator; in GetFromBatchAndDB()
911 if (merge_operator) { in GetFromBatchAndDB()
913 s = MergeHelper::TimedFullMerge(merge_operator, key, merge_data, in GetFromBatchAndDB()
1003 const MergeOperator* merge_operator = cfh->cfd()->ioptions()->merge_operator; in MultiGetFromBatchAndDB() local
1024 if (merge_operator) { in MultiGetFromBatchAndDB()
1026 merge_operator, *key.key, merge_data, in MultiGetFromBatchAndDB()
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 232 cf_descs.back().options.merge_operator.reset( in TEST_F()
259 cf_descs[0].options.merge_operator; in TEST_F()
262 cf_descs[0].options.merge_operator.reset(); in TEST_F()
266 cf_descs[0].options.merge_operator.reset(new DummyMergeOperator()); in TEST_F()
270 cf_descs[0].options.merge_operator = merge_op; in TEST_F()
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 42 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument
50 merge_operator_(merge_operator), in GetContext()
75 const Comparator* ucmp, const MergeOperator* merge_operator, Logger* logger, in GetContext() argument
81 : GetContext(ucmp, merge_operator, logger, statistics, init_state, user_key, in GetContext()
|
| D | get_context.h | 88 GetContext(const Comparator* ucmp, const MergeOperator* merge_operator,
97 GetContext(const Comparator* ucmp, const MergeOperator* merge_operator,
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 30 if (options->merge_operator) { in SanitizeOptions()
31 options->merge_operator.reset( in SanitizeOptions()
32 new TtlMergeOperator(options->merge_operator, env)); in SanitizeOptions()
|
| /rocksdb-6.9/options/ |
| D | options_test.cc | 368 ASSERT_EQ(kMoName, std::string(new_cf_opt.merge_operator->Name())); in TEST_F()
1452 auto* merge_operator = dynamic_cast<test::ChanglingMergeOperator*>( in VerifyCFPointerTypedOptions() local
1453 base_cf_opt->merge_operator.get()); in VerifyCFPointerTypedOptions()
1454 if (merge_operator != nullptr) { in VerifyCFPointerTypedOptions()
1455 name_buffer = merge_operator->Name(); in VerifyCFPointerTypedOptions()
1457 merge_operator->SetName("some-other-name"); in VerifyCFPointerTypedOptions()
1461 merge_operator->SetName(name_buffer); in VerifyCFPointerTypedOptions()
1848 opts.merge_operator.reset(test::RandomMergeOperator(&rnd)); in TEST_F()
1858 opts.merge_operator.reset(test::RandomMergeOperator(&rnd)); in TEST_F()
1868 opts.merge_operator = nullptr; in TEST_F()
|
| D | cf_options.cc | 30 merge_operator(cf_options.merge_operator.get()), in ImmutableCFOptions()
|
| /rocksdb-6.9/utilities/merge_operators/ |
| D | max.cc.d | 2 utilities/merge_operators/max.cc include/rocksdb/merge_operator.h \
|
| D | put.cc.d | 4 include/rocksdb/merge_operator.h utilities/merge_operators.h
|
| D | sortlist.cc.d | 4 utilities/merge_operators/sortlist.h include/rocksdb/merge_operator.h \
|
| /rocksdb-6.9/utilities/merge_operators/string_append/ |
| D | stringappend2.cc.d | 5 include/rocksdb/merge_operator.h include/rocksdb/slice.h \
|
| D | stringappend.cc.d | 5 include/rocksdb/merge_operator.h include/rocksdb/slice.h \
|