Home
last modified time | relevance | path

Searched refs:storage_info (Results 1 – 21 of 21) sorted by relevance

/rocksdb-6.9/db/compaction/
Dcompaction_job_test.cc393 auto files = cfd->current()->storage_info()->LevelFiles(0); in TEST_F()
403 auto files = cfd->current()->storage_info()->LevelFiles(0); in TEST_F()
423 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
441 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
463 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
516 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
540 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
567 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
603 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
637 auto files = cfd_->current()->storage_info()->LevelFiles(0); in TEST_F()
[all …]
Dcompaction_job.cc404 assert(c->column_family_data()->current()->storage_info()->NumLevelFiles( in Prepare()
529 int base_level = v->storage_info()->base_level(); in GenSubcompactionBoundaries()
729 auto vstorage = cfd->current()->storage_info(); in Install()
/rocksdb-6.9/db/
Dforward_iterator.cc396 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in SeekInternal()
637 const auto* vstorage = sv_->current->storage_info(); in RebuildIterators()
698 const auto* vstorage = sv_->current->storage_info(); in RenewIterators()
700 const auto* vstorage_new = svnew->current->storage_info(); in RenewIterators()
784 const auto& l0_files = sv_->current->storage_info()->LevelFiles(0); in ResetIncompleteIterators()
881 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in DeleteCurrentIter()
913 const VersionStorageInfo* vstorage = sv_->current->storage_info(); in TEST_CheckDeletedIters()
Dinternal_stats.cc536 const auto* vstorage = cfd_->current()->storage_info(); in HandleNumFilesAtLevel()
552 const auto* vstorage = cfd_->current()->storage_info(); in HandleCompressionRatioAtLevelPrefix()
564 const auto* vstorage = cfd_->current()->storage_info(); in HandleLevelStats()
680 const auto* vstorage = cfd_->current()->storage_info(); in HandleCompactionPending()
756 const auto* vstorage = cfd_->current()->storage_info(); in HandleEstimateNumKeys()
807 const auto* vstorage = cfd_->current()->storage_info(); in HandleBaseLevel()
827 const auto* vstorage = cfd_->current()->storage_info(); in HandleEstimatePendingCompactionBytes()
841 const auto* vstorage = version->storage_info(); in HandleEstimateLiveDataSize()
1104 const VersionStorageInfo* vstorage = cfd_->current()->storage_info(); in DumpCFMapStats()
Dexternal_sst_file_ingestion_job.cc312 auto vstorage = cfd_->current()->storage_info(); in UpdateStats()
545 auto* vstorage = cfd_->current()->storage_info(); in AssignLevelAndSeqnoForIngestedFile()
615 auto* vstorage = cfd_->current()->storage_info(); in CheckLevelForIngestedBehindFile()
697 auto* vstorage = cfd_->current()->storage_info(); in IngestedFileFitInLevel()
Dcolumn_family.cc852 auto* vstorage = current_->storage_info(); in RecalculateWriteStallConditions()
1045 return compaction_picker_->NeedsCompaction(current_->storage_info()); in NeedsCompaction()
1054 GetName(), mutable_options, current_->storage_info(), log_buffer, in PickCompaction()
1095 auto* vstorage = super_version->current->storage_info(); in RangesOverlapWithMemtables()
1131 GetName(), mutable_cf_options, current_->storage_info(), input_level, in CompactRange()
1348 int base_level = current_->storage_info()->base_level(); in CalculateSSTWriteHint()
Dversion_set.cc1423 auto* vstorage = storage_info(); in GetColumnFamilyMetaData()
1725 : cfd_->current()->storage_info(), in Version()
3610 v->storage_info()->ComputeCompactionScore( in AppendVersion()
4584 builder->SaveTo(v->storage_info()); in Recover()
4878 auto* vstorage = current_version->storage_info(); in ReduceNumberOfLevels()
5135 builder->SaveTo(v->storage_info()); in DumpManifest()
5292 const auto* vstorage = v->storage_info(); in ApproximateSize()
5484 const auto* vstorage = v->storage_info(); in AddLiveFiles()
5748 VersionStorageInfo* storage_info = v->storage_info(); in GetTotalSstFilesSize() local
5914 builder->SaveTo(v->storage_info()); in Recover()
[all …]
Dversion_edit_handler.cc387 builder->SaveTo(v->storage_info()); in MaybeCreateVersion()
561 builder->SaveTo(version->storage_info()); in MaybeCreateVersion()
Dcompacted_db_impl.cc105 auto* vstorage = version_->storage_info(); in Init()
Dversion_builder.cc777 cfd->current()->storage_info(), cfd->ioptions()->info_log)), in BaseReferencedVersionBuilder()
786 v->storage_info(), cfd->ioptions()->info_log)), in BaseReferencedVersionBuilder()
Dcolumn_family_test.cc2565 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2744 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2809 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2813 VersionStorageInfo* vstorage1 = cfd1->current()->storage_info(); in TEST_P()
2885 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_P()
2889 VersionStorageInfo* vstorage1 = cfd1->current()->storage_info(); in TEST_P()
Dflush_job.cc264 auto vstorage = cfd_->current()->storage_info(); in Run()
Dversion_set_test.cc1918 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
1969 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
2018 VersionStorageInfo* vstorage = cfd->current()->storage_info(); in TEST_F()
Dversion_set.h683 VersionStorageInfo* storage_info() { return &storage_info_; } in storage_info() function
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc599 (cfd->current()->storage_info()->NumLevelFiles(0) >= in NotifyOnFlushBegin()
602 (cfd->current()->storage_info()->NumLevelFiles(0) >= in NotifyOnFlushBegin()
651 (cfd->current()->storage_info()->NumLevelFiles(0) >= in NotifyOnFlushCompleted()
654 (cfd->current()->storage_info()->NumLevelFiles(0) >= in NotifyOnFlushCompleted()
751 overlap = current_version->storage_info()->OverlapInLevel( in CompactRange()
1040 version->storage_info()->ComputeCompactionScore(*cfd->ioptions(), in CompactFilesImpl()
1289 auto* vstorage = cfd->current()->storage_info(); in ReFitLevel()
1840 const auto* vstorage = cfd->current()->storage_info(); in WaitUntilFlushWouldNotStallWrites()
2632 ->storage_info() in BackgroundCompaction()
2785 ->storage_info() in BackgroundCompaction()
[all …]
Ddb_impl_debug.cc21 return default_cf_handle_->cfd()->current()->storage_info()->NumLevelBytes(0); in TEST_GetLevel0TotalSize()
54 return cfd->current()->storage_info()->MaxNextLevelOverlappingBytes(); in TEST_MaxNextLevelOverlappingBytes()
66 cfd->current()->storage_info()->LevelFiles(level); in TEST_GetFilesMetaData()
Ddb_impl_experimental.cc36 auto vstorage = cfd->current()->storage_info(); in SuggestCompactRange()
71 const auto* vstorage = cfd->current()->storage_info(); in PromoteL0()
Ddb_impl_secondary.cc226 cfd->current()->storage_info()->LevelFiles(0); in RecoverLogFiles()
525 cfd->current()->storage_info()->LevelSummary(&tmp)); in TryCatchUpWithPrimary()
Ddb_impl.cc1137 const auto* vstorage = cfd->current()->storage_info(); in FindMinimumEmptyLevelFitting()
2748 cfd->current()->storage_info()->UpdateOldestSnapshot(oldest_snapshot); in ReleaseSnapshot()
2750 ->storage_info() in ReleaseSnapshot()
2769 cfd->current()->storage_info()->bottommost_files_mark_threshold()); in ReleaseSnapshot()
3215 auto* vstoreage = cfd->current()->storage_info(); in DeleteFile()
3270 auto* vstorage = input_version->storage_info(); in DeleteFilesInRanges()
4414 VersionStorageInfo* vstorage = sv->current->storage_info(); in VerifyChecksum()
Ddb_impl_open.cc1525 auto* vstorage = cfd->current()->storage_info(); in Open()
/rocksdb-6.9/tools/
Dldb_cmd.cc1896 if (default_cfd->current()->storage_info()->NumLevelFiles(i)) { in GetOldNumOfLevels()