| /rocksdb-6.9/examples/ |
| D | options_file_example.cc | 54 std::unique_ptr<CompactionFilter> compaction_filter; in main() local
55 compaction_filter.reset(new DummyCompactionFilter()); in main()
57 cf_descs[0].options.compaction_filter = compaction_filter.get(); in main()
100 assert(loaded_cf_descs[0].options.compaction_filter == nullptr); in main()
101 loaded_cf_descs[0].options.compaction_filter = compaction_filter.get(); in main()
|
| D | compaction_filter_example.cc | 71 options.compaction_filter = &filter; in main()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator_test.cc | 276 CompactionFilter* compaction_filter = nullptr, in RunTest() argument
280 last_committed_seq, merge_operator, compaction_filter, in RunTest()
921 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F() local
930 nullptr /*merge_operator*/, compaction_filter.get()); in TEST_F()
934 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F() local
942 compaction_filter.get()); in TEST_F()
949 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F() local
954 2 /*last_committed_seq*/, merge_op.get(), compaction_filter.get()); in TEST_F()
960 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F() local
968 compaction_filter.get()); in TEST_F()
|
| D | compaction_iterator.h | 70 const CompactionFilter* compaction_filter = nullptr,
85 const CompactionFilter* compaction_filter = nullptr,
|
| D | compaction_iterator.cc | 40 const CompactionFilter* compaction_filter, in CompactionIterator() argument
51 compaction_filter, shutting_down, preserve_deletes_seqnum, in CompactionIterator()
62 const CompactionFilter* compaction_filter, in CompactionIterator() argument
78 compaction_filter_(compaction_filter), in CompactionIterator()
|
| D | compaction_job.cc | 822 const CompactionFilter* compaction_filter = in ProcessKeyValueCompaction() local
823 cfd->ioptions()->compaction_filter; in ProcessKeyValueCompaction()
825 if (compaction_filter == nullptr) { in ProcessKeyValueCompaction()
828 compaction_filter = compaction_filter_from_factory.get(); in ProcessKeyValueCompaction()
830 if (compaction_filter != nullptr && !compaction_filter->IgnoreSnapshots()) { in ProcessKeyValueCompaction()
870 compaction_filter, db_options_.info_log.get(), in ProcessKeyValueCompaction()
897 &range_del_agg, sub_compact->compaction, compaction_filter, in ProcessKeyValueCompaction()
|
| /rocksdb-6.9/java/rocksjni/ |
| D | remove_emptyvalue_compactionfilterjni.cc | 18 auto* compaction_filter = in Java_org_rocksdb_RemoveEmptyValueCompactionFilter_createNewRemoveEmptyValueCompactionFilter0() local
22 return reinterpret_cast<jlong>(compaction_filter); in Java_org_rocksdb_RemoveEmptyValueCompactionFilter_createNewRemoveEmptyValueCompactionFilter0()
|
| D | cassandra_compactionfilterjni.cc | 19 auto* compaction_filter = in Java_org_rocksdb_CassandraCompactionFilter_createNewCassandraCompactionFilter0() local
23 return reinterpret_cast<jlong>(compaction_filter); in Java_org_rocksdb_CassandraCompactionFilter_createNewCassandraCompactionFilter0()
|
| /rocksdb-6.9/utilities/ttl/ |
| D | db_ttl_impl.cc | 21 if (options->compaction_filter) { in SanitizeOptions()
22 options->compaction_filter = in SanitizeOptions()
23 new TtlCompactionFilter(ttl, env, options->compaction_filter); in SanitizeOptions()
52 delete default_options.compaction_filter; in Close()
|
| D | ttl_test.cc.d | 2 utilities/ttl/ttl_test.cc include/rocksdb/compaction_filter.h \
|
| /rocksdb-6.9/db/ |
| D | manual_compaction_test.cc | 100 options.compaction_filter = new DestroyAllCompactionFilter(); in TEST_F()
118 delete options.compaction_filter; in TEST_F()
189 options.compaction_filter = filter; in TEST_F()
|
| D | merge_helper.cc | 24 const CompactionFilter* compaction_filter, in MergeHelper() argument
33 compaction_filter_(compaction_filter), in MergeHelper()
|
| D | manual_compaction_test.cc.d | 13 include/rocksdb/statistics.h include/rocksdb/compaction_filter.h \
|
| D | c.cc.d | 13 include/rocksdb/statistics.h include/rocksdb/compaction_filter.h \
|
| D | merge_helper.h | 33 const CompactionFilter* compaction_filter, Logger* logger,
|
| /rocksdb-6.9/options/ |
| D | options_test.cc | 864 delete new_cf_opts.compaction_filter; in TEST_F()
885 if (base_opt.compaction_filter) { in TEST_F()
886 delete base_opt.compaction_filter; in TEST_F()
1487 auto* tmp_compaction_filter = base_cf_opt->compaction_filter; in VerifyCFPointerTypedOptions()
1489 base_cf_opt->compaction_filter = nullptr; in VerifyCFPointerTypedOptions()
1494 base_cf_opt->compaction_filter = tmp_compaction_filter; in VerifyCFPointerTypedOptions()
1653 if (base_cf_opts[c].compaction_filter) { in TEST_F()
1654 delete base_cf_opts[c].compaction_filter; in TEST_F()
1881 opts.compaction_filter = test::RandomCompactionFilter(&rnd); in TEST_F()
1888 delete opts.compaction_filter; in TEST_F()
[all …]
|
| D | cf_options.cc | 31 compaction_filter(cf_options.compaction_filter), in ImmutableCFOptions()
|
| D | options_settable_test.cc | 354 {offset_of(&ColumnFamilyOptions::compaction_filter), in TEST_F()
404 options->compaction_filter = nullptr; in TEST_F()
|
| D | options.cc | 121 compaction_filter ? compaction_filter->Name() : "None"); in Dump()
|
| D | options_helper.cc.d | 29 include/rocksdb/compaction_filter.h include/rocksdb/convenience.h \
|
| D | options.cc.d | 27 util/string_util.h include/rocksdb/compaction_filter.h \
|
| /rocksdb-6.9/test_util/ |
| D | testutil.cc | 383 if (cf_opt->compaction_filter) { in RandomInitCFOptions()
384 delete cf_opt->compaction_filter; in RandomInitCFOptions()
386 cf_opt->compaction_filter = RandomCompactionFilter(rnd); in RandomInitCFOptions()
|
| /rocksdb-6.9/utilities/compaction_filters/ |
| D | remove_emptyvalue_compactionfilter.cc.d | 7 include/rocksdb/compaction_filter.h
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | cassandra_compaction_filter.cc.d | 5 include/rocksdb/compaction_filter.h \
|
| /rocksdb-6.9/utilities/options/ |
| D | options_util_test.cc | 90 if (cf_opts[i].compaction_filter) { in TEST_F()
91 delete cf_opts[i].compaction_filter; in TEST_F()
|