Home
last modified time | relevance | path

Searched refs:being_compacted (Results 1 – 15 of 15) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_picker_universal.cc81 bool being_compacted; member
333 f->being_compacted); in CalculateSortedRuns()
338 bool being_compacted = false; in CalculateSortedRuns() local
345 if (f->being_compacted) { in CalculateSortedRuns()
346 being_compacted = f->being_compacted; in CalculateSortedRuns()
355 assert(is_first || f->being_compacted == being_compacted); in CalculateSortedRuns()
358 being_compacted = f->being_compacted; in CalculateSortedRuns()
364 being_compacted); in CalculateSortedRuns()
593 if (!sr->being_compacted) { in PickCompactionToReduceSortedRuns()
784 if (!sr->being_compacted) { in PickCompactionToReduceSizeAmp()
[all …]
Dcompaction_picker_test.cc523 file_map_[2].first->being_compacted = true; in TEST_F()
553 file_map_[5].first->being_compacted = true; in TEST_F()
579 file_map_[5].first->being_compacted = true; in TEST_F()
609 file_map_[2].first->being_compacted = true; in TEST_F()
828 vstorage_->LevelFiles(2)[3]->being_compacted = true; in TEST_F()
1075 file_map_[1U].first->being_compacted = true; in TEST_F()
1122 file_map_[6U].first->being_compacted = true; in TEST_F()
1153 file_map_[4u].first->being_compacted = true; in TEST_F()
1215 file_map_[4u].first->being_compacted = true; in TEST_F()
1608 file_map_[1U].first->being_compacted = true; in TEST_F()
[all …]
Dcompaction_picker_level.cc136 assert(!level_file.second->being_compacted); in PickExpiredTtlFiles()
172 assert(!level_file.second->being_compacted); in PickFilesMarkedForPeriodicCompaction()
265 assert(!level_and_file.second->being_compacted); in SetupInitialFiles()
487 if (f->being_compacted) { in PickFileToCompact()
538 level_files[0]->being_compacted) { in PickIntraL0Compaction()
Dcompaction_picker.cc49 if (level_files[start]->being_compacted) { in FindIntraL0Compaction()
76 if (level_files[limit]->being_compacted || in FindIntraL0Compaction()
324 if (files[i]->being_compacted) { in AreFilesInCompaction()
905 if (current_files[f].being_compacted) { in SanitizeCompactionInputFilesForAllLevels()
949 if (next_lv_file.being_compacted) { in SanitizeCompactionInputFilesForAllLevels()
1010 if (file_meta.being_compacted) { in SanitizeCompactionInputFiles()
1070 assert(!level_file.second->being_compacted); in PickFilesMarkedForCompaction()
Dcompaction.cc392 assert(mark_as_compacted ? !inputs_[i][j]->being_compacted in MarkFilesBeingCompacted()
393 : inputs_[i][j]->being_compacted); in MarkFilesBeingCompacted()
394 inputs_[i][j]->being_compacted = mark_as_compacted; in MarkFilesBeingCompacted()
/rocksdb-6.9/include/rocksdb/
Dmetadata.h62 being_compacted(false), in SstFileMetaData()
85 being_compacted(_being_compacted), in SstFileMetaData()
108 bool being_compacted; // true if the file is currently being compacted. member
/rocksdb-6.9/db/
Dinternal_stats.cc87 int num_files, int being_compacted, in PrepareLevelStats() argument
96 (*level_stats)[LevelStatType::COMPACTED_FILES] = being_compacted; in PrepareLevelStats()
172 int num_files, int being_compacted, double total_file_size, in PrintLevelStats() argument
176 PrepareLevelStats(&level_stats, num_files, being_compacted, total_file_size, in PrintLevelStats()
1122 if (f->being_compacted) { in DumpCFMapStats()
Dversion_set.cc1445 file->being_compacted, file->oldest_blob_file_number, in GetColumnFamilyMetaData()
2335 if (!f->being_compacted) { in GetExpiredTtlFilesCount()
2368 if (!f->being_compacted) { in ComputeCompactionScore()
2378 if (!files_[i].empty() && !files_[i][0]->being_compacted) { in ComputeCompactionScore()
2416 if (!f->being_compacted) { in ComputeCompactionScore()
2469 if (!f->being_compacted && f->marked_for_compaction) { in ComputeFilesMarkedForCompaction()
2491 if (!f->being_compacted) { in ComputeExpiredTtlFiles()
2527 if (!f->being_compacted) { in ComputeFilesMarkedForPeriodicCompaction()
2840 if (!level_and_file.second->being_compacted && in ComputeBottommostFilesMarkedForCompaction()
3155 static_cast<int>(f->being_compacted)); in LevelFileSummary()
[all …]
Dversion_edit.h121 bool being_compacted = false; // Is this file undergoing compaction? member
/rocksdb-6.9/db/db_impl/
Ddb_impl_experimental.cc93 if (f->being_compacted) { in PromoteL0()
Ddb_impl.cc3204 if (metadata->being_compacted) { in DeleteFile()
3299 if (level_file->being_compacted) { in DeleteFilesInRanges()
3313 level_file->being_compacted = true; in DeleteFilesInRanges()
3330 deleted_file->being_compacted = false; in DeleteFilesInRanges()
/rocksdb-6.9/examples/
Dcompact_files_example.cc94 if (file.being_compacted) { in PickCompaction()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_test_base.cc1404 if (files[random_file_index].being_compacted) { in TestCompactFiles()
1412 !files[random_file_index - 1].being_compacted) { in TestCompactFiles()
1416 !files[random_file_index + 1].being_compacted) { in TestCompactFiles()
/rocksdb-6.9/java/rocksjni/
Dportal.h7007 static_cast<jboolean>(live_file_meta_data->being_compacted), in fromCppLiveFileMetaData()
7105 static_cast<jboolean>(sst_file_meta_data->being_compacted), in fromCppSstFileMetaData()
/rocksdb-6.9/
DHISTORY.md93 …lyMetaData() and Compaction::MarkFilesBeingCompacted() for access to being_compacted (#6056). The …