| /rocksdb-6.9/db/ |
| D | flush_job.cc | 102 cfd_(cfd), in FlushJob()
137 ThreadStatusUtil::SetColumnFamily(cfd_, cfd_->ioptions()->env, in ReportStartedFlush()
184 edit_->SetColumnFamily(cfd_->GetID()); in PickMemTable()
189 base_ = cfd_->current(); in PickMemTable()
202 cfd_->GetName().c_str()); in Run()
228 if (s.ok() && cfd_->IsDropped()) { in Run()
383 cfd_->int_tbl_prop_collector_factories(), cfd_->GetID(), in WriteLevel0Table()
387 cfd_->ioptions()->compression_opts, in WriteLevel0Table()
452 info->cf_id = cfd_->GetID(); in GetFlushJobInfo()
453 info->cf_name = cfd_->GetName(); in GetFlushJobInfo()
[all …]
|
| D | forward_iterator.cc | 40 : cfd_(cfd), in ForwardLevelIterator()
78 file_iter_ = cfd_->table_cache()->NewIterator( in Reset()
79 read_options_, *(cfd_->soptions()), cfd_->internal_comparator(), in Reset()
190 const ColumnFamilyData* const cfd_; member in ROCKSDB_NAMESPACE::ForwardLevelIterator
207 cfd_(cfd), in ForwardIterator()
621 sv_ = cfd_->GetReferencedSuperVersion(db_); in RebuildIterators()
651 read_options_, *cfd_->soptions(), cfd_->internal_comparator(), *l0, in RebuildIterators()
675 svnew = cfd_->GetReferencedSuperVersion(db_); in RenewIterators()
727 read_options_, *cfd_->soptions(), cfd_->internal_comparator(), in RenewIterators()
777 cfd_, read_options_, level_files, in BuildLevelIterators()
[all …]
|
| D | external_sst_file_ingestion_job.cc | 47 f.cf_id != cfd_->GetID()) { in Prepare()
202 SuperVersion* super_version = cfd_->GetSuperVersion(); in Run()
221 edit_.SetColumnFamily(cfd_->GetID()); in Run()
312 auto vstorage = cfd_->current()->storage_info(); in UpdateStats()
322 cfd_->internal_stats()->AddCFStats( in UpdateStats()
384 TableReaderOptions(*cfd_->ioptions(), in GetIngestedFileInfo()
545 auto* vstorage = cfd_->current()->storage_info(); in AssignLevelAndSeqnoForIngestedFile()
547 for (int lvl = 0; lvl < cfd_->NumberLevels(); lvl++) { in AssignLevelAndSeqnoForIngestedFile()
615 auto* vstorage = cfd_->current()->storage_info(); in CheckLevelForIngestedBehindFile()
617 int bottom_lvl = cfd_->NumberLevels() - 1; in CheckLevelForIngestedBehindFile()
[all …]
|
| D | internal_stats.cc | 618 auto* current = cfd_->current(); in HandleSsTables()
653 *value = cfd_->imm()->NumNotFlushed(); in HandleNumImmutableMemTable()
660 *value = cfd_->imm()->NumFlushed(); in HandleNumImmutableMemTableFlushed()
724 *value = cfd_->mem()->num_entries(); in HandleNumEntriesActiveMemTable()
740 *value = cfd_->mem()->num_deletes(); in HandleNumDeletesActiveMemTable()
761 cfd_->mem()->num_deletes() + cfd_->imm()->current()->GetTotalNumDeletes(); in HandleEstimateNumKeys()
788 *value = cfd_->GetNumLiveVersions(); in HandleNumLiveVersions()
814 *value = cfd_->GetTotalSstFilesSize(); in HandleTotalSstFilesSize()
820 *value = cfd_->GetLiveSstFilesSize(); in HandleLiveSstFilesSize()
882 cfd_->GetCurrentMutableCFOptions() in HandleEstimateOldestKeyTime()
[all …]
|
| D | arena_wrapped_db_iter.cc | 52 if (cfd_ == nullptr || db_impl_ == nullptr || !allow_refresh_) { in Refresh()
60 uint64_t cur_sv_number = cfd_->GetSuperVersionNumber(); in Refresh()
67 SuperVersion* sv = cfd_->GetReferencedSuperVersion(db_impl_); in Refresh()
71 Init(env, read_options_, *(cfd_->ioptions()), sv->mutable_cf_options, in Refresh()
73 cur_sv_number, read_callback_, db_impl_, cfd_, allow_blob_, in Refresh()
77 read_options_, cfd_, sv, &arena_, db_iter_->GetRangeDelAggregator(), in Refresh()
|
| D | compacted_db_impl.cc | 20 : DBImpl(options, dbname), cfd_(nullptr), version_(nullptr), in CompactedDBImpl()
93 cfd_ = reinterpret_cast<ColumnFamilyHandleImpl*>( in Init()
95 cfd_->InstallSuperVersion(&sv_context, &mutex_); in Init()
102 NewThreadStatusCfInfo(cfd_); in Init()
103 version_ = cfd_->GetSuperVersion()->current; in Init()
104 user_comparator_ = cfd_->user_comparator(); in Init()
|
| D | import_column_family_job.cc | 36 const auto ucmp = cfd_->internal_comparator().user_comparator(); in Prepare()
92 cfd_->ioptions()->cf_paths, f.fd.GetNumber(), f.fd.GetPathId()); in Prepare()
136 edit_.SetColumnFamily(cfd_->GetID()); in Run()
223 status = cfd_->ioptions()->table_factory->NewTableReader( in GetIngestedFileInfo()
224 TableReaderOptions(*cfd_->ioptions(), in GetIngestedFileInfo()
226 env_options_, cfd_->internal_comparator()), in GetIngestedFileInfo()
|
| D | version_set.cc | 751 assert(cfd_ != nullptr); in ~Version()
1415 assert(cfd_); in GetColumnFamilyMetaData()
1417 cf_meta->name = cfd_->GetName(); in GetColumnFamilyMetaData()
1710 cfd_(column_family_data), in Version()
1711 info_log_((cfd_ == nullptr) ? nullptr : cfd_->ioptions()->info_log), in Version()
1714 table_cache_((cfd_ == nullptr) ? nullptr : cfd_->table_cache()), in Version()
1718 (cfd_ == nullptr) ? nullptr : &cfd_->internal_comparator(), in Version()
1719 (cfd_ == nullptr) ? nullptr : cfd_->user_comparator(), in Version()
1720 cfd_ == nullptr ? 0 : cfd_->NumberLevels(), in Version()
1723 (cfd_ == nullptr || cfd_->current() == nullptr) in Version()
[all …]
|
| D | import_column_family_job.h | 30 cfd_(cfd), in ImportColumnFamilyJob()
62 ColumnFamilyData* cfd_; variable
|
| D | external_sst_file_ingestion_job.h | 79 cfd_(cfd), in ExternalSstFileIngestionJob()
164 ColumnFamilyData* cfd_; variable
|
| D | arena_wrapped_db_iter.h | 87 cfd_ = cfd; in StoreRefreshInfo()
96 ColumnFamilyData* cfd_ = nullptr; variable
|
| D | column_family.cc | 43 : cfd_(column_family_data), db_(db), mutex_(mutex) { in ColumnFamilyHandleImpl()
44 if (cfd_ != nullptr) { in ColumnFamilyHandleImpl()
45 cfd_->Ref(); in ColumnFamilyHandleImpl()
50 if (cfd_ != nullptr) { in ~ColumnFamilyHandleImpl()
52 for (auto& listener : cfd_->ioptions()->listeners) { in ~ColumnFamilyHandleImpl()
60 ColumnFamilyOptions initial_cf_options_copy = cfd_->initial_cf_options(); in ~ColumnFamilyHandleImpl()
63 bool dropped = cfd_->IsDropped(); in ~ColumnFamilyHandleImpl()
64 if (cfd_->UnrefAndTryDelete()) { in ~ColumnFamilyHandleImpl()
|
| D | db_iter.cc | 73 cfd_(cfd), in DBIter()
1157 if (db_impl_ != nullptr && cfd_ != nullptr) { in Seek()
1158 db_impl_->TraceIteratorSeek(cfd_->GetID(), target); in Seek()
1218 if (db_impl_ != nullptr && cfd_ != nullptr) { in SeekForPrev()
1219 db_impl_->TraceIteratorSeekForPrev(cfd_->GetID(), target); in SeekForPrev()
|
| D | column_family.h | 166 virtual ColumnFamilyData* cfd() const { return cfd_; } in cfd()
174 ColumnFamilyData* cfd_;
|
| D | flush_job.h | 106 ColumnFamilyData* cfd_; variable
|
| D | compacted_db_impl.h | 107 ColumnFamilyData* cfd_; variable
|
| D | forward_iterator.h | 120 ColumnFamilyData* const cfd_; variable
|
| D | internal_stats.h | 133 cfd_(cfd),
593 ColumnFamilyData* cfd_; variable
|
| D | db_iter.h | 336 ColumnFamilyData* cfd_; variable
|
| D | version_set.h | 674 ColumnFamilyData* cfd() const { return cfd_; } in cfd()
732 ColumnFamilyData* cfd_; // ColumnFamilyData to which this Version belongs variable
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction.cc | 68 cfd_ = input_version_->cfd(); in SetInputVersion()
70 cfd_->Ref(); in SetInputVersion()
72 edit_.SetColumnFamily(cfd_->GetID()); in SetInputVersion()
228 cfd_(nullptr), in Compaction()
277 if (cfd_ != nullptr) { in ~Compaction()
278 cfd_->UnrefAndTryDelete(); in ~Compaction()
366 const Comparator* user_cmp = cfd_->user_comparator(); in KeyNotExistsBeyondOutputLevel()
440 cfd_->compaction_picker()->ReleaseCompactionFiles(this, status); in ReleaseCompactionFiles()
516 if (!cfd_->ioptions()->compaction_filter_factory) { in CreateCompactionFilter()
523 context.column_family_id = cfd_->GetID(); in CreateCompactionFilter()
[all …]
|
| D | compaction_job_test.cc | 293 cfd_ = versions_->GetColumnFamilySet()->GetDefault(); in NewDB()
382 ColumnFamilyData* cfd_; member in ROCKSDB_NAMESPACE::CompactionJobTest
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 …]
|
| D | compaction.h | 122 ColumnFamilyData* column_family_data() const { return cfd_; } in column_family_data()
333 ColumnFamilyData* cfd_; variable
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 260 ColumnFamilyData* cfd = arg.cfd_; in FlushMemTablesToOutputFiles()
295 cfds.emplace_back(arg.cfd_); in AtomicFlushMemTablesToOutputFiles()
2249 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush()
2265 *reason = bg_flush_args[0].cfd_->GetFlushReason(); in BackgroundFlush()
2267 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush()
2269 arg.cfd_ = nullptr; in BackgroundFlush()
|
| D | db_impl.h | 1253 : cfd_(nullptr), max_memtable_id_(0), superversion_context_(nullptr) {} in BGFlushArg()
1256 : cfd_(cfd), in BGFlushArg()
1261 ColumnFamilyData* cfd_; member
|