Home
last modified time | relevance | path

Searched refs:CompactionReason (Results 1 – 22 of 22) sorted by relevance

/rocksdb-6.9/java/src/main/java/org/rocksdb/
DCompactionReason.java8 public enum CompactionReason { enum
85 CompactionReason(final byte value) { in CompactionReason() method in CompactionReason
105 static CompactionReason fromValue(final byte value) { in fromValue()
106 for (final CompactionReason compactionReason : CompactionReason.values()) { in fromValue()
DCompactionJobInfo.java114 public CompactionReason compactionReason() { in compactionReason()
115 return CompactionReason.fromValue(compactionReason(nativeHandle_)); in compactionReason()
/rocksdb-6.9/db/compaction/
Dcompaction_picker_level.cc115 CompactionReason compaction_reason_ = CompactionReason::kUnknown;
216 compaction_reason_ = CompactionReason::kLevelL0FilesNum; in SetupInitialFiles()
219 compaction_reason_ = CompactionReason::kLevelMaxLevelSize; in SetupInitialFiles()
236 compaction_reason_ = CompactionReason::kLevelL0FilesNum; in SetupInitialFiles()
254 compaction_reason_ = CompactionReason::kFilesMarkedForCompaction; in SetupInitialFiles()
278 compaction_reason_ = CompactionReason::kBottommostFiles; in SetupInitialFiles()
287 compaction_reason_ = CompactionReason::kTtl; in SetupInitialFiles()
296 compaction_reason_ = CompactionReason::kPeriodicCompaction; in SetupInitialFiles()
Dcompaction_picker_universal.cc98 CompactionReason compaction_reason);
472 c->compaction_reason() != CompactionReason::kPeriodicCompaction) { in PickCompaction()
740 CompactionReason compaction_reason; in PickCompactionToReduceSortedRuns()
742 compaction_reason = CompactionReason::kUniversalSizeRatio; in PickCompactionToReduceSortedRuns()
744 compaction_reason = CompactionReason::kUniversalSortedRunNum; in PickCompactionToReduceSortedRuns()
847 CompactionReason::kUniversalSizeAmplification); in PickCompactionToReduceSizeAmp()
965 CompactionReason::kFilesMarkedForCompaction); in PickDeleteTriggeredCompaction()
969 size_t start_index, CompactionReason compaction_reason) { in PickCompactionToOldest()
997 if (compaction_reason == CompactionReason::kPeriodicCompaction) { in PickCompactionToOldest()
1000 CompactionReason::kUniversalSizeAmplification) { in PickCompactionToOldest()
[all …]
Dcompaction_job.cc66 case CompactionReason::kUnknown: in GetCompactionReasonString()
68 case CompactionReason::kLevelL0FilesNum: in GetCompactionReasonString()
70 case CompactionReason::kLevelMaxLevelSize: in GetCompactionReasonString()
74 case CompactionReason::kUniversalSizeRatio: in GetCompactionReasonString()
78 case CompactionReason::kFIFOMaxSize: in GetCompactionReasonString()
82 case CompactionReason::kFIFOTtl: in GetCompactionReasonString()
84 case CompactionReason::kManualCompaction: in GetCompactionReasonString()
88 case CompactionReason::kBottommostFiles: in GetCompactionReasonString()
90 case CompactionReason::kTtl: in GetCompactionReasonString()
92 case CompactionReason::kFlush: in GetCompactionReasonString()
[all …]
Dcompaction.h81 CompactionReason compaction_reason = CompactionReason::kUnknown);
284 CompactionReason compaction_reason() { return compaction_reason_; } in compaction_reason()
378 CompactionReason compaction_reason_;
Dcompaction_picker_fifo.cc106 /* is deletion compaction */ true, CompactionReason::kFIFOTtl); in PickTTLCompaction()
148 CompactionReason::kFIFOReduceNumFiles); in PickSizeCompaction()
195 /* is deletion compaction */ true, CompactionReason::kFIFOMaxSize); in PickSizeCompaction()
Dcompaction.cc217 CompactionReason _compaction_reason) in Compaction()
243 compaction_reason_ = CompactionReason::kManualCompaction; in Compaction()
Dcompaction_picker_test.cc1669 ASSERT_EQ(CompactionReason::kLevelL0FilesNum, in TEST_F()
1699 ASSERT_EQ(CompactionReason::kLevelL0FilesNum, in TEST_F()
1731 ASSERT_EQ(CompactionReason::kLevelL0FilesNum, in TEST_F()
/rocksdb-6.9/db/
Dinternal_stats.h174 int counts[static_cast<int>(CompactionReason::kNumOfReasons)];
189 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in CompactionStats()
195 explicit CompactionStats(CompactionReason reason, int c) in CompactionStats()
208 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in CompactionStats()
234 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in CompactionStats()
255 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons);
275 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in Clear()
296 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in Add()
317 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in Subtract()
649 explicit CompactionStats(CompactionReason /*reason*/, int /*c*/) {} in CompactionStats()
Dlistener_test.cc514 std::vector<CompactionReason> compaction_reasons_;
542 CompactionReason::kLevelL0FilesNum); in TEST_F()
566 ASSERT_EQ(compaction_reason, CompactionReason::kLevelMaxLevelSize); in TEST_F()
580 ASSERT_EQ(compaction_reason, CompactionReason::kManualCompaction); in TEST_F()
612 ASSERT_EQ(compaction_reason, CompactionReason::kUniversalSizeRatio); in TEST_F()
630 ASSERT_EQ(compaction_reason, CompactionReason::kUniversalSizeAmplification); in TEST_F()
642 ASSERT_EQ(compaction_reason, CompactionReason::kManualCompaction); in TEST_F()
671 ASSERT_EQ(compaction_reason, CompactionReason::kFIFOMaxSize); in TEST_F()
Ddb_compaction_test.cc96 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in OnCompactionCompleted()
103 int k = static_cast<int>(CompactionReason::kExternalSstIngestion); in OnExternalFileIngested()
108 int k = static_cast<int>(CompactionReason::kFlush); in OnFlushCompleted()
112 int NumberOfCompactions(CompactionReason reason) const { in NumberOfCompactions()
113 int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in NumberOfCompactions()
232 const int num_of_reasons = static_cast<int>(CompactionReason::kNumOfReasons); in VerifyCompactionStats()
3498 CompactionReason::kBottommostFiles); in TEST_F()
3668 if (compaction_reason == CompactionReason::kTtl) { in TEST_F()
3899 if (compaction_reason == CompactionReason::kPeriodicCompaction) { in TEST_F()
3970 if (compaction_reason == CompactionReason::kPeriodicCompaction) { in TEST_F()
[all …]
Dcompact_files_test.cc397 CompactionReason::kManualCompaction); in TEST_F()
Dflush_job.cc436 InternalStats::CompactionStats stats(CompactionReason::kFlush, 1); in WriteLevel0Table()
Ddb_universal_compaction_test.cc404 CompactionReason::kUniversalSizeAmplification) { in TEST_P()
484 if (c->compaction_reason() == CompactionReason::kUniversalSizeRatio) { in TEST_P()
2197 CompactionReason::kPeriodicCompaction); in TEST_F()
Dexternal_sst_file_ingestion_job.cc280 InternalStats::CompactionStats stats(CompactionReason::kExternalSstIngestion, 1); in UpdateStats()
Ddb_test2.cc1338 ASSERT_EQ(ci.compaction_reason, CompactionReason::kLevelL0FilesNum); in OnCompactionBegin()
1345 ASSERT_EQ(ci.compaction_reason, CompactionReason::kLevelL0FilesNum); in OnCompactionCompleted()
/rocksdb-6.9/java/rocksjni/
Dportal.h6762 case ROCKSDB_NAMESPACE::CompactionReason::kUnknown: in toJavaCompactionReason()
6764 case ROCKSDB_NAMESPACE::CompactionReason::kLevelL0FilesNum: in toJavaCompactionReason()
6774 case ROCKSDB_NAMESPACE::CompactionReason::kFIFOMaxSize: in toJavaCompactionReason()
6778 case ROCKSDB_NAMESPACE::CompactionReason::kFIFOTtl: in toJavaCompactionReason()
6786 case ROCKSDB_NAMESPACE::CompactionReason::kTtl: in toJavaCompactionReason()
6788 case ROCKSDB_NAMESPACE::CompactionReason::kFlush: in toJavaCompactionReason()
6803 return ROCKSDB_NAMESPACE::CompactionReason::kUnknown; in toCppCompactionReason()
6819 return ROCKSDB_NAMESPACE::CompactionReason::kFIFOTtl; in toCppCompactionReason()
6827 return ROCKSDB_NAMESPACE::CompactionReason::kTtl; in toCppCompactionReason()
6829 return ROCKSDB_NAMESPACE::CompactionReason::kFlush; in toCppCompactionReason()
[all …]
/rocksdb-6.9/include/rocksdb/
Dlistener.h62 enum class CompactionReason : int { enum
251 CompactionReason compaction_reason;
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DCompactionJobInfoTest.java95 .isEqualTo(CompactionReason.kUnknown); in compactionReason()
/rocksdb-6.9/java/
DCMakeLists.txt123 src/main/java/org/rocksdb/CompactionReason.java
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc1278 InternalStats::CompactionStats stats(CompactionReason::kFlush, 1); in WriteLevel0TableForRecovery()