Home
last modified time | relevance | path

Searched refs:mutable_cf_options (Results 1 – 25 of 47) sorted by relevance

12

/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc38 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickTTLCompaction() argument
40 assert(mutable_cf_options.ttl > 0); in PickTTLCompaction()
71 if (current_time > mutable_cf_options.ttl) { in PickTTLCompaction()
76 creation_time >= (current_time - mutable_cf_options.ttl)) { in PickTTLCompaction()
121 if (mutable_cf_options.compaction_options_fifo.allow_compaction && in PickSizeCompaction()
135 mutable_cf_options in PickSizeCompaction()
139 mutable_cf_options.max_compaction_bytes, &comp_inputs)) { in PickSizeCompaction()
141 vstorage, ioptions_, mutable_cf_options, {comp_inputs}, 0, in PickSizeCompaction()
144 0 /* output path ID */, mutable_cf_options.compression, in PickSizeCompaction()
158 mutable_cf_options.compaction_options_fifo.max_table_files_size); in PickSizeCompaction()
[all …]
Dcompaction_picker_level.cc51 const MutableCFOptions& mutable_cf_options, in LevelCompactionBuilder() argument
58 mutable_cf_options_(mutable_cf_options), in LevelCompactionBuilder()
121 const MutableCFOptions& mutable_cf_options,
410 const MutableCFOptions& mutable_cf_options, int level) { in GetPathId() argument
422 level_size = mutable_cf_options.max_bytes_for_level_base; in GetPathId()
440 level_size * mutable_cf_options.max_bytes_for_level_multiplier); in GetPathId()
443 level_size * mutable_cf_options.max_bytes_for_level_multiplier * in GetPathId()
444 mutable_cf_options.MaxBytesMultiplerAdditional(cur_level)); in GetPathId()
551 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickCompaction() argument
555 log_buffer, mutable_cf_options, ioptions_); in PickCompaction()
Dcompaction_picker.cc131 return mutable_cf_options.compression; in GetCompressionType()
351 GetCompressionType(ioptions_, vstorage, mutable_cf_options, in CompactFiles()
359 vstorage, ioptions_, mutable_cf_options, input_files, output_level, in CompactFiles()
486 const uint64_t limit = mutable_cf_options.max_compaction_bytes; in SetupOtherInputs()
629 vstorage, ioptions_, mutable_cf_options, std::move(inputs), in CompactRange()
631 MaxFileSizeForLevel(mutable_cf_options, output_level, in CompactRange()
635 GetCompressionType(ioptions_, vstorage, mutable_cf_options, in CompactRange()
672 const uint64_t limit = mutable_cf_options.max_compaction_bytes; in CompactRange()
783 MaxFileSizeForLevel(mutable_cf_options, output_level, in CompactRange()
786 mutable_cf_options.max_compaction_bytes, in CompactRange()
[all …]
Dcompaction_picker_fifo.h23 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
28 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
43 const MutableCFOptions& mutable_cf_options,
48 const MutableCFOptions& mutable_cf_options,
Dcompaction_picker.h58 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
74 const std::string& cf_name, const MutableCFOptions& mutable_cf_options,
115 const MutableCFOptions& mutable_cf_options,
184 const MutableCFOptions& mutable_cf_options,
304 const MutableCFOptions& mutable_cf_options,
Dcompaction_picker_universal.cc37 const MutableCFOptions& mutable_cf_options, in UniversalCompactionBuilder() argument
44 mutable_cf_options_(mutable_cf_options), in UniversalCompactionBuilder()
124 const MutableCFOptions& mutable_cf_options);
129 const MutableCFOptions& mutable_cf_options,
280 const std::string& cf_name, const MutableCFOptions& mutable_cf_options, in PickCompaction() argument
284 mutable_cf_options, vstorage, this, in PickCompaction()
329 const MutableCFOptions& mutable_cf_options) { in CalculateSortedRuns() argument
343 if (mutable_cf_options.compaction_options_universal.allow_trivial_move == in CalculateSortedRuns()
527 const MutableCFOptions& mutable_cf_options, uint64_t file_size) { in GetPathId() argument
545 (100 - mutable_cf_options.compaction_options_universal.size_ratio) / 100; in GetPathId()
Dcompaction_job.h101 Status Install(const MutableCFOptions& mutable_cf_options);
130 Status InstallCompactionResults(const MutableCFOptions& mutable_cf_options);
/rocksdb-6.9/db/
Dcolumn_family.cc817 const MutableCFOptions& mutable_cf_options) { in GetWriteStallConditionAndCause() argument
820 } else if (!mutable_cf_options.disable_auto_compactions && in GetWriteStallConditionAndCause()
823 } else if (!mutable_cf_options.disable_auto_compactions && in GetWriteStallConditionAndCause()
833 } else if (!mutable_cf_options.disable_auto_compactions && in GetWriteStallConditionAndCause()
849 const MutableCFOptions& mutable_cf_options) { in RecalculateWriteStallConditions() argument
875 mutable_cf_options.max_write_buffer_number); in RecalculateWriteStallConditions()
910 mutable_cf_options.max_write_buffer_number, in RecalculateWriteStallConditions()
1228 const MutableCFOptions& mutable_cf_options) { in InstallSuperVersion() argument
1231 new_superversion->mutable_cf_options = mutable_cf_options; in InstallSuperVersion()
1238 RecalculateWriteStallConditions(mutable_cf_options); in InstallSuperVersion()
[all …]
Dcolumn_family_test.cc532 const MutableCFOptions& mutable_cf_options) { in RecalculateWriteStallConditions() argument
2569 mutable_cf_options.level0_slowdown_writes_trigger = 20; in TEST_P()
2570 mutable_cf_options.level0_stop_writes_trigger = 10000; in TEST_P()
2573 mutable_cf_options.disable_auto_compactions = false; in TEST_P()
2701 mutable_cf_options.disable_auto_compactions = true; in TEST_P()
2722 mutable_cf_options.disable_auto_compactions = false; in TEST_P()
2750 mutable_cf_options.level0_slowdown_writes_trigger = 36; in TEST_P()
2751 mutable_cf_options.level0_stop_writes_trigger = 50; in TEST_P()
2787 mutable_cf_options.level0_stop_writes_trigger = 30; in TEST_P()
2817 mutable_cf_options.level0_stop_writes_trigger = 10000; in TEST_P()
[all …]
Darena_wrapped_db_iter.cc35 const MutableCFOptions& mutable_cf_options, in Init() argument
43 db_iter_ = new (mem) DBIter(env, read_options, cf_options, mutable_cf_options, in Init()
71 Init(env, read_options_, *(cfd_->ioptions()), sv->mutable_cf_options, in Refresh()
72 latest_seq, sv->mutable_cf_options.max_sequential_skip_in_iterations, in Refresh()
90 const MutableCFOptions& mutable_cf_options, const SequenceNumber& sequence, in NewArenaWrappedDbIterator() argument
95 iter->Init(env, read_options, cf_options, mutable_cf_options, sequence, in NewArenaWrappedDbIterator()
Ddb_iter_test.cc239 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
253 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
286 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
313 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
346 env_, ro, cf_options, mutable_cf_options, BytewiseComparator(), in TEST_F()
663 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
737 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
968 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
1451 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
1641 MutableCFOptions mutable_cf_options = MutableCFOptions(options); in TEST_F() local
[all …]
Dcolumn_family.h205 MutableCFOptions mutable_cf_options; member
333 return &(super_version_->mutable_cf_options); in GetCurrentMutableCFOptions()
378 MemTable* ConstructNewMemtable(const MutableCFOptions& mutable_cf_options,
380 void CreateNewMemtable(const MutableCFOptions& mutable_cf_options,
414 Compaction* CompactRange(const MutableCFOptions& mutable_cf_options,
459 const MutableCFOptions& mutable_cf_options);
480 const MutableCFOptions& mutable_cf_options);
488 const MutableCFOptions& mutable_cf_options);
Dmemtable.cc45 const MutableCFOptions& mutable_cf_options) in ImmutableMemTableOptions() argument
46 : arena_block_size(mutable_cf_options.arena_block_size), in ImmutableMemTableOptions()
49 static_cast<double>(mutable_cf_options.write_buffer_size) * in ImmutableMemTableOptions()
50 mutable_cf_options.memtable_prefix_bloom_size_ratio) * in ImmutableMemTableOptions()
54 mutable_cf_options.memtable_whole_key_filtering), in ImmutableMemTableOptions()
58 max_successive_merges(mutable_cf_options.max_successive_merges), in ImmutableMemTableOptions()
65 const MutableCFOptions& mutable_cf_options, in MemTable() argument
69 moptions_(ioptions, mutable_cf_options), in MemTable()
79 mutable_cf_options.memtable_huge_page_size), in MemTable()
90 write_buffer_size_(mutable_cf_options.write_buffer_size), in MemTable()
[all …]
Dmemtable_list_test.cc86 MemTableList* list, const MutableCFOptions& mutable_cf_options, in Mock_InstallMemtableFlushResults() argument
123 cfd, mutable_cf_options, m, &dummy_prep_tracker, &versions, &mutex, in Mock_InstallMemtableFlushResults()
400 MutableCFOptions mutable_cf_options(options); in TEST_F() local
401 s = Mock_InstallMemtableFlushResults(&list, mutable_cf_options, to_flush, in TEST_F()
542 MutableCFOptions mutable_cf_options(options); in TEST_F() local
544 MemTable* mem = new MemTable(cmp, ioptions, mutable_cf_options, &wb, in TEST_F()
705 &list, mutable_cf_options, to_flush2, &to_delete); in TEST_F()
906 for (auto& mutable_cf_options : mutable_cf_options_list) { in TEST_F() local
907 if (mutable_cf_options != nullptr) { in TEST_F()
908 delete mutable_cf_options; in TEST_F()
[all …]
Dversion_set.h148 const MutableCFOptions& mutable_cf_options);
152 const MutableCFOptions& mutable_cf_options);
620 void PrepareApply(const MutableCFOptions& mutable_cf_options,
751 MutableCFOptions mutable_cf_options, uint64_t version_number = 0);
833 const MutableCFOptions& mutable_cf_options, VersionEdit* edit,
840 mutable_cf_options_list.emplace_back(&mutable_cf_options);
852 const MutableCFOptions& mutable_cf_options,
859 mutable_cf_options_list.emplace_back(&mutable_cf_options);
Darena_wrapped_db_iter.h74 const MutableCFOptions& mutable_cf_options,
110 const MutableCFOptions& mutable_cf_options, const SequenceNumber& sequence,
Dbuilder.cc71 const MutableCFOptions& mutable_cf_options, const FileOptions& file_options, in BuildTable() argument
140 ioptions, mutable_cf_options, internal_comparator, in BuildTable()
239 mutable_cf_options.prefix_extractor.get(), nullptr, in BuildTable()
Dversion_set.cc1707 const MutableCFOptions mutable_cf_options, in Version() argument
1732 mutable_cf_options_(mutable_cf_options), in Version()
2075 const MutableCFOptions& mutable_cf_options, in PrepareApply() argument
2240 const MutableCFOptions& mutable_cf_options) { in EstimateCompactionBytesNeeded() argument
2350 const MutableCFOptions& mutable_cf_options) { in ComputeCompactionScore() argument
2393 if (mutable_cf_options.ttl > 0) { in ComputeCompactionScore()
2443 if (mutable_cf_options.ttl > 0) { in ComputeCompactionScore()
2450 EstimateCompactionBytesNeeded(mutable_cf_options); in ComputeCompactionScore()
3481 const MutableCFOptions mutable_cf_options; member
3490 mutable_cf_options(cf_options), in ManifestWriter()
[all …]
Dforward_iterator.cc208 prefix_extractor_(current_sv->mutable_cf_options.prefix_extractor.get()), in ForwardIterator()
653 sv_->mutable_cf_options.prefix_extractor.get(), in RebuildIterators()
730 svnew->mutable_cf_options.prefix_extractor.get(), in RenewIterators()
778 sv_->mutable_cf_options.prefix_extractor.get())); in BuildLevelIterators()
794 sv_->mutable_cf_options.prefix_extractor.get(), in ResetIncompleteIterators()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc156 &event_logger_, mutable_cf_options.report_bg_io_stats, in FlushMemTableToOutputFile()
200 mutable_cf_options); in FlushMemTableToOutputFile()
222 NotifyOnFlushCompleted(cfd, mutable_cf_options, in FlushMemTableToOutputFile()
600 mutable_cf_options.level0_slowdown_writes_trigger); in NotifyOnFlushBegin()
603 mutable_cf_options.level0_stop_writes_trigger); in NotifyOnFlushBegin()
633 (void)mutable_cf_options; in NotifyOnFlushBegin()
655 mutable_cf_options.level0_stop_writes_trigger); in NotifyOnFlushCompleted()
673 (void)mutable_cf_options; in NotifyOnFlushCompleted()
1032 c->mutable_cf_options()->paranoid_file_checks, in CompactFilesImpl()
1357 ->mutable_cf_options.level0_stop_writes_trigger; in Level0StopWriteTrigger()
[all …]
Ddb_impl_readonly.cc84 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIterator()
86 super_version->mutable_cf_options.max_sequential_skip_in_iterations, in NewIterator()
116 env_, read_options, *cfd->ioptions(), sv->mutable_cf_options, read_seq, in NewIterators()
117 sv->mutable_cf_options.max_sequential_skip_in_iterations, in NewIterators()
Ddb_impl_secondary.cc49 auto* mutable_cf_options = cfd->GetLatestMutableCFOptions(); in Recover() local
50 max_total_in_memory_state_ += mutable_cf_options->write_buffer_size * in Recover()
51 mutable_cf_options->max_write_buffer_number; in Recover()
245 const MutableCFOptions mutable_cf_options = in RecoverLogFiles() local
248 cfd->ConstructNewMemtable(mutable_cf_options, seq_of_batch); in RecoverLogFiles()
414 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIteratorImpl()
416 super_version->mutable_cf_options.max_sequential_skip_in_iterations, in NewIteratorImpl()
Ddb_impl_open.cc456 MutableCFOptions mutable_cf_options(options); in Recover() local
459 mutable_cf_options, &edit, &mutex_, nullptr, in Recover()
488 auto* mutable_cf_options = cfd->GetLatestMutableCFOptions(); in Recover() local
489 max_total_in_memory_state_ += mutable_cf_options->write_buffer_size * in Recover()
490 mutable_cf_options->max_write_buffer_number; in Recover()
1214 const MutableCFOptions mutable_cf_options = in WriteLevel0TableForRecovery() local
1244 dbname_, env_, fs_.get(), *cfd->ioptions(), mutable_cf_options, in WriteLevel0TableForRecovery()
1249 GetCompressionFlush(*cfd->ioptions(), mutable_cf_options), in WriteLevel0TableForRecovery()
1250 mutable_cf_options.sample_for_compression, in WriteLevel0TableForRecovery()
/rocksdb-6.9/options/
Doptions_helper.cc154 const MutableCFOptions& mutable_cf_options) { in BuildColumnFamilyOptions() argument
164 mutable_cf_options.memtable_whole_key_filtering; in BuildColumnFamilyOptions()
168 mutable_cf_options.inplace_update_num_locks; in BuildColumnFamilyOptions()
173 mutable_cf_options.disable_auto_compactions; in BuildColumnFamilyOptions()
183 mutable_cf_options.level0_stop_writes_trigger; in BuildColumnFamilyOptions()
187 mutable_cf_options.target_file_size_multiplier; in BuildColumnFamilyOptions()
189 mutable_cf_options.max_bytes_for_level_base; in BuildColumnFamilyOptions()
192 cf_opts.ttl = mutable_cf_options.ttl; in BuildColumnFamilyOptions()
194 mutable_cf_options.periodic_compaction_seconds; in BuildColumnFamilyOptions()
204 mutable_cf_options.compaction_options_universal; in BuildColumnFamilyOptions()
[all …]
/rocksdb-6.9/table/
Dsst_file_writer.cc35 mutable_cf_options(options), in Rep()
47 MutableCFOptions mutable_cf_options; member
205 compression_type = r->mutable_cf_options.compression; in Open()
209 r->mutable_cf_options.sample_for_compression; in Open()
241 r->ioptions, r->mutable_cf_options, r->internal_comparator, in Open()

12