| /rocksdb-6.9/db/ |
| D | column_family.h | 41 class ColumnFamilyData; variable
174 ColumnFamilyData* cfd_;
201 ColumnFamilyData* cfd;
267 class ColumnFamilyData {
269 ~ColumnFamilyData();
564 ColumnFamilyData* next_;
565 ColumnFamilyData* prev_;
644 ColumnFamilyData* current_;
686 friend class ColumnFamilyData;
702 ColumnFamilyData* dummy_cfd_;
[all …]
|
| D | column_family.cc | 485 ColumnFamilyData::ColumnFamilyData( in ColumnFamilyData() function in ROCKSDB_NAMESPACE::ColumnFamilyData
590 ColumnFamilyData::~ColumnFamilyData() { in ~ColumnFamilyData()
675 void ColumnFamilyData::SetDropped() { in SetDropped()
1035 void ColumnFamilyData::CreateNewMemtable( in CreateNewMemtable()
1124 Compaction* ColumnFamilyData::CompactRange( in CompactRange()
1282 Status ColumnFamilyData::ValidateOptions( in ValidateOptions()
1320 Status ColumnFamilyData::SetOptions( in SetOptions()
1362 Status ColumnFamilyData::AddDirectories( in AddDirectories()
1404 dummy_cfd_(new ColumnFamilyData( in ColumnFamilySet()
1479 ColumnFamilyData* new_cfd = new ColumnFamilyData( in CreateColumnFamily()
[all …]
|
| D | version_edit_handler.h | 50 Status ApplyVersionEdit(VersionEdit& edit, ColumnFamilyData** cfd);
52 Status OnColumnFamilyAdd(VersionEdit& edit, ColumnFamilyData** cfd);
54 Status OnColumnFamilyDrop(VersionEdit& edit, ColumnFamilyData** cfd);
56 Status OnNonCfOperation(VersionEdit& edit, ColumnFamilyData** cfd);
65 ColumnFamilyData* CreateCfAndInit(const ColumnFamilyOptions& cf_options,
68 virtual ColumnFamilyData* DestroyCfAndCleanup(const VersionEdit& edit);
71 ColumnFamilyData* cfd,
74 Status LoadTables(ColumnFamilyData* cfd,
93 Status ExtractInfoFromVersionEdit(ColumnFamilyData* cfd,
115 ColumnFamilyData* DestroyCfAndCleanup(const VersionEdit& edit) override;
[all …]
|
| D | version_edit_handler.cc | 51 ColumnFamilyData* cfd = nullptr; in Iterate()
96 ColumnFamilyData* cfd = in Initialize()
109 ColumnFamilyData** cfd) { in ApplyVersionEdit()
126 ColumnFamilyData** cfd) { in OnColumnFamilyAdd()
142 ColumnFamilyData* tmp_cfd = nullptr; in OnColumnFamilyAdd()
171 ColumnFamilyData* tmp_cfd = nullptr; in OnColumnFamilyDrop()
198 ColumnFamilyData* tmp_cfd = nullptr; in OnNonCfOperation()
340 ColumnFamilyData* VersionEditHandler::CreateCfAndInit( in CreateCfAndInit()
355 ColumnFamilyData* VersionEditHandler::DestroyCfAndCleanup( in DestroyCfAndCleanup()
365 ColumnFamilyData* ret = in DestroyCfAndCleanup()
[all …]
|
| D | flush_scheduler.h | 16 class ColumnFamilyData; variable
28 void ScheduleWork(ColumnFamilyData* cfd);
32 ColumnFamilyData* TakeNextColumnFamily();
43 ColumnFamilyData* column_family;
50 std::set<ColumnFamilyData*> checking_set_;
|
| D | version_set.h | 674 ColumnFamilyData* cfd() const { return cfd_; } in cfd()
832 ColumnFamilyData* column_family_data,
837 autovector<ColumnFamilyData*> cfds;
851 ColumnFamilyData* column_family_data,
856 autovector<ColumnFamilyData*> cfds;
870 const autovector<ColumnFamilyData*>& cfds,
1014 const ColumnFamilyData* cfd_to_skip) const { in PreComputeMinLogNumberWithUnflushedData()
1144 Status ExtractInfoFromVersionEdit(ColumnFamilyData* cfd,
1213 Status LogAndApplyHelper(ColumnFamilyData* cfd, VersionBuilder* b,
1234 std::unordered_set<ColumnFamilyData*>* cfds_changed);
[all …]
|
| D | trim_history_scheduler.h | 15 class ColumnFamilyData; variable
27 void ScheduleWork(ColumnFamilyData* cfd);
31 ColumnFamilyData* TakeNextColumnFamily();
40 autovector<ColumnFamilyData*> cfds_;
|
| D | trim_history_scheduler.cc | 14 void TrimHistoryScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork()
21 ColumnFamilyData* TrimHistoryScheduler::TakeNextColumnFamily() { in TakeNextColumnFamily()
27 ColumnFamilyData* cfd = cfds_.back(); in TakeNextColumnFamily()
47 ColumnFamilyData* cfd; in Clear()
|
| D | flush_scheduler.cc | 14 void FlushScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork()
36 ColumnFamilyData* FlushScheduler::TakeNextColumnFamily() { in TakeNextColumnFamily()
45 ColumnFamilyData* cfd = node->column_family; in TakeNextColumnFamily()
79 ColumnFamilyData* cfd; in Clear()
|
| D | arena_wrapped_db_iter.h | 77 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd,
83 ColumnFamilyData* cfd, ReadCallback* read_callback, in StoreRefreshInfo()
96 ColumnFamilyData* cfd_ = nullptr;
113 ColumnFamilyData* cfd = nullptr, bool allow_blob = false,
|
| D | version_builder.h | 25 class ColumnFamilyData; variable
54 explicit BaseReferencedVersionBuilder(ColumnFamilyData* cfd);
55 BaseReferencedVersionBuilder(ColumnFamilyData* cfd, Version* v);
|
| D | memtable_list.h | 30 class ColumnFamilyData; variable
138 const autovector<ColumnFamilyData*>& cfds,
264 ColumnFamilyData* cfd, const MutableCFOptions& mutable_cf_options,
378 const autovector<ColumnFamilyData*>& cfds,
421 const autovector<ColumnFamilyData*>& cfds,
|
| D | forward_iterator.h | 25 class ColumnFamilyData; variable
55 ColumnFamilyData* cfd, SuperVersion* current_sv = nullptr);
120 ColumnFamilyData* const cfd_;
|
| D | import_column_family_job.h | 23 ImportColumnFamilyJob(Env* env, VersionSet* versions, ColumnFamilyData* cfd, in ImportColumnFamilyJob()
62 ColumnFamilyData* cfd_;
|
| D | db_iter.h | 119 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd,
336 ColumnFamilyData* cfd_;
354 ColumnFamilyData* cfd = nullptr, bool allow_blob = false);
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl.h | 886 Status TEST_FlushMemTable(ColumnFamilyData* cfd,
1261 ColumnFamilyData* cfd_;
1280 ColumnFamilyData* cfd;
1456 const autovector<ColumnFamilyData*>& cfds,
1621 void AddToCompactionQueue(ColumnFamilyData* cfd);
1622 ColumnFamilyData* PopFirstFromCompactionQueue();
1626 ColumnFamilyData* PickCompactionFromQueue(
1664 bool HaveManualCompaction(ColumnFamilyData* cfd);
1676 ColumnFamilyData* cfd, uint64_t num,
1708 ColumnFamilyData* cfd;
[all …]
|
| D | db_impl_compaction_flush.cc | 260 ColumnFamilyData* cfd = arg.cfd_; in FlushMemTablesToOutputFiles()
293 autovector<ColumnFamilyData*> cfds; in AtomicFlushMemTablesToOutputFiles()
704 autovector<ColumnFamilyData*> cfds; in CompactRange()
1400 autovector<ColumnFamilyData*> cfds; in Flush()
1617 ColumnFamilyData* cfd_stats = in FlushMemTable()
1675 autovector<ColumnFamilyData*> cfds; in FlushMemTable()
1715 autovector<ColumnFamilyData*> cfds; in AtomicFlushMemTables()
2091 ColumnFamilyData* cfd = nullptr; in PickCompactionFromQueue()
2118 ColumnFamilyData* cfd = iter.first; in SchedulePendingFlush()
2249 ColumnFamilyData* cfd = arg.cfd_; in BackgroundFlush()
[all …]
|
| D | db_impl_debug.cc | 46 ColumnFamilyData* cfd; in TEST_MaxNextLevelOverlappingBytes()
87 ColumnFamilyData* cfd; in TEST_CompactRange()
104 Status DBImpl::TEST_SwitchMemtable(ColumnFamilyData* cfd) { in TEST_SwitchMemtable()
130 ColumnFamilyData* cfd; in TEST_FlushMemTable()
140 Status DBImpl::TEST_FlushMemTable(ColumnFamilyData* cfd, in TEST_FlushMemTable()
146 const autovector<ColumnFamilyData*>& cfds, const FlushOptions& flush_opts) { in TEST_AtomicFlushMemTables()
151 ColumnFamilyData* cfd; in TEST_WaitForFlushMemTable()
|
| D | db_impl_secondary.cc | 60 std::unordered_set<ColumnFamilyData*> cfds_changed; in Recover()
78 std::unordered_set<ColumnFamilyData*>* cfds_changed, in FindAndRecoverLogFiles()
176 std::unordered_set<ColumnFamilyData*>* cfds_changed, in RecoverLogFiles()
217 ColumnFamilyData* cfd = in RecoverLogFiles()
271 ColumnFamilyData* cfd = in RecoverLogFiles()
276 std::unordered_map<ColumnFamilyData*, uint64_t>::iterator iter = in RecoverLogFiles()
326 ColumnFamilyData* cfd = cfh->cfd(); in GetImpl()
409 const ReadOptions& read_options, ColumnFamilyData* cfd, in NewIteratorImpl()
451 ColumnFamilyData* cfd = static_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators()
507 std::unordered_set<ColumnFamilyData*> cfds_changed; in TryCatchUpWithPrimary()
[all …]
|
| D | db_impl_write.cc | 1195 autovector<ColumnFamilyData*>* cfds) { in SelectColumnFamiliesForAtomicFlush()
1265 autovector<ColumnFamilyData*> cfds; in SwitchWAL()
1329 autovector<ColumnFamilyData*> cfds; in HandleWriteBufferFull()
1333 ColumnFamilyData* cfd_picked = nullptr; in HandleWriteBufferFull()
1508 ColumnFamilyData* cfd_stats = in MaybeFlushStatsCF()
1512 for (ColumnFamilyData* cfd : *cfds) { in MaybeFlushStatsCF()
1540 autovector<ColumnFamilyData*> cfds; in TrimMemtableHistory()
1541 ColumnFamilyData* tmp_cfd; in TrimMemtableHistory()
1566 autovector<ColumnFamilyData*> cfds; in ScheduleFlushes()
1574 ColumnFamilyData* tmp_cfd; in ScheduleFlushes()
[all …]
|
| D | db_impl_secondary.h | 97 ColumnFamilyData* cfd,
309 std::unordered_set<ColumnFamilyData*>* cfds_changed,
316 std::unordered_set<ColumnFamilyData*>* cfds_changed,
328 std::unordered_map<ColumnFamilyData*, uint64_t> cfd_to_current_log_;
|
| D | db_impl.cc | 326 autovector<ColumnFamilyData*> cfds; in ResumeImpl()
416 autovector<ColumnFamilyData*> cfds; in CancelAllBackgroundWork()
876 ColumnFamilyData* cfd = cfh->cfd(); in TablesRangeTombstoneSummary()
1317 ColumnFamilyData* cfd; in NewInternalIterator()
1888 ColumnFamilyData* cfd = node->cfd; in MultiCFSnapshot()
2721 for (const ColumnFamilyData* t : list) { in CfdListContains()
3079 ColumnFamilyData* cfd = cfh->cfd(); in GetApproximateMemTableStats()
3189 ColumnFamilyData* cfd; in DeleteFile()
3262 ColumnFamilyData* cfd = cfh->cfd(); in DeleteFilesInRanges()
4399 std::vector<ColumnFamilyData*> cfd_list; in VerifyChecksum()
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | thread_status_util.cc | 35 void ThreadStatusUtil::SetColumnFamily(const ColumnFamilyData* cfd, in SetColumnFamily()
120 const ColumnFamilyData* cfd, in NewColumnFamilyInfo()
133 void ThreadStatusUtil::EraseColumnFamilyInfo(const ColumnFamilyData* cfd) { in EraseColumnFamilyInfo()
174 void ThreadStatusUtil::SetColumnFamily(const ColumnFamilyData* /*cfd*/,
189 const ColumnFamilyData* /*cfd*/,
193 void ThreadStatusUtil::EraseColumnFamilyInfo(const ColumnFamilyData* /*cfd*/) {}
|
| D | thread_status_util.h | 17 class ColumnFamilyData; variable
42 static void NewColumnFamilyInfo(const DB* db, const ColumnFamilyData* cfd,
48 static void EraseColumnFamilyInfo(const ColumnFamilyData* cfd);
57 static void SetColumnFamily(const ColumnFamilyData* cfd, const Env* env,
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction.h | 64 class ColumnFamilyData; variable
122 ColumnFamilyData* column_family_data() const { return cfd_; } in column_family_data()
333 ColumnFamilyData* cfd_;
|