Home
last modified time | relevance | path

Searched defs:cfd (Results 1 – 25 of 50) sorted by relevance

12

/rocksdb-6.9/db/
Dversion_edit_handler.cc51 ColumnFamilyData* cfd = nullptr; in Iterate() local
96 ColumnFamilyData* cfd = in Initialize() local
109 ColumnFamilyData** cfd) { in ApplyVersionEdit()
126 ColumnFamilyData** cfd) { in OnColumnFamilyAdd()
164 ColumnFamilyData** cfd) { in OnColumnFamilyDrop()
185 ColumnFamilyData** cfd) { in OnNonCfOperation()
342 ColumnFamilyData* cfd = version_set_->CreateColumnFamily(cf_options, &edit); in CreateCfAndInit() local
377 ColumnFamilyData* cfd, in MaybeCreateVersion()
396 Status VersionEditHandler::LoadTables(ColumnFamilyData* cfd, in LoadTables()
421 Status VersionEditHandler::ExtractInfoFromVersionEdit(ColumnFamilyData* cfd, in ExtractInfoFromVersionEdit()
[all …]
Dtrim_history_scheduler.cc14 void TrimHistoryScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork()
27 ColumnFamilyData* cfd = cfds_.back(); in TakeNextColumnFamily() local
47 ColumnFamilyData* cfd; in Clear() local
Dflush_scheduler.cc14 void FlushScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork()
45 ColumnFamilyData* cfd = node->column_family; in TakeNextColumnFamily() local
79 ColumnFamilyData* cfd; in Clear() local
Dflush_job_test.cc133 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F() local
154 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F() local
255 ColumnFamilyData* cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F() local
332 for (auto cfd : all_cfds) { in TEST_F() local
356 for (auto cfd : all_cfds) { in TEST_F() local
392 for (auto cfd : all_cfds) { in TEST_F() local
428 auto cfd = versions_->GetColumnFamilySet()->GetDefault(); in TEST_F() local
Darena_wrapped_db_iter.cc40 ColumnFamilyData* cfd, bool allow_blob, in Init()
92 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd, in NewArenaWrappedDbIterator()
Drepair.cc123 for (const auto& cfd : column_families) { in Repairer() local
154 ColumnFamilyData* cfd; in AddColumnFamily() local
508 ColumnFamilyData* cfd = nullptr; in ScanTable() local
574 auto* cfd = in AddTables() local
633 [](const ColumnFamilyDescriptor& cfd) { in GetDefaultCFOptions()
Dcolumn_family.h166 virtual ColumnFamilyData* cfd() const { return cfd_; } in cfd() function
191 virtual ColumnFamilyData* cfd() const override { return internal_cfd_; } in cfd() function
201 ColumnFamilyData* cfd; member
626 explicit iterator(ColumnFamilyData* cfd) in iterator()
Dimport_column_family_job.h23 ImportColumnFamilyJob(Env* env, VersionSet* versions, ColumnFamilyData* cfd, in ImportColumnFamilyJob()
Dcolumn_family.cc1424 auto cfd = column_family_data_.begin()->second; in ~ColumnFamilySet() local
1452 auto cfd = GetColumnFamily(cfd_iter->second); in GetColumnFamily() local
1500 for (auto cfd = dummy_cfd_->next_; cfd != dummy_cfd_; cfd = cfd->next_) { in FreeDeadColumnFamilies() local
1505 for (auto cfd : to_delete) { in FreeDeadColumnFamilies() local
1512 void ColumnFamilySet::RemoveColumnFamily(ColumnFamilyData* cfd) { in RemoveColumnFamily()
Ddb_iter.cc42 ColumnFamilyData* cfd, bool allow_blob) in DBIter()
1381 ColumnFamilyData* cfd, bool allow_blob) { in NewDBIterator()
Darena_wrapped_db_iter.h83 ColumnFamilyData* cfd, ReadCallback* read_callback, in StoreRefreshInfo()
Ddb_flush_test.cc91 auto* cfd = in TEST_F() local
338 auto* cfd = static_cast<ColumnFamilyHandleImpl*>(handles_[1])->cfd(); in TEST_F() local
382 auto* cfd = in TEST_F() local
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc260 ColumnFamilyData* cfd = arg.cfd_; in FlushMemTablesToOutputFiles() local
299 for (const auto cfd : cfds) { in AtomicFlushMemTablesToOutputFiles() local
318 auto cfd = cfds[i]; in AtomicFlushMemTablesToOutputFiles() local
682 auto cfd = cfh->cfd(); in CompactRange() local
1569 for (const auto cfd : cfds) { in GenerateFlushRequest() local
1739 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1752 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1760 for (auto cfd : cfds) { in AtomicFlushMemTables() local
1786 for (auto* cfd : cfds) { in AtomicFlushMemTables() local
2091 ColumnFamilyData* cfd = nullptr; in PickCompactionFromQueue() local
[all …]
Ddb_impl_debug.cc46 ColumnFamilyData* cfd; in TEST_MaxNextLevelOverlappingBytes() local
61 auto cfd = cfh->cfd(); in TEST_GetFilesMetaData() local
87 ColumnFamilyData* cfd; in TEST_CompactRange() local
104 Status DBImpl::TEST_SwitchMemtable(ColumnFamilyData* cfd) { in TEST_SwitchMemtable()
130 ColumnFamilyData* cfd; in TEST_FlushMemTable() local
140 Status DBImpl::TEST_FlushMemTable(ColumnFamilyData* cfd, in TEST_FlushMemTable()
151 ColumnFamilyData* cfd; in TEST_WaitForFlushMemTable() local
Ddb_impl.cc1317 ColumnFamilyData* cfd; in NewInternalIterator() local
2359 auto* cfd = in CreateColumnFamilyImpl() local
2367 auto* cfd = in CreateColumnFamilyImpl() local
2672 auto* cfd = in NewIterators() local
3063 auto* cfd = in GetColumnFamilyHandleUnlocked() local
4045 auto* cfd = in IngestExternalFiles() local
4056 auto* cfd = in IngestExternalFiles() local
4113 auto* cfd = in IngestExternalFiles() local
4193 auto* cfd = in IngestExternalFiles() local
4221 auto* cfd = in IngestExternalFiles() local
[all …]
Ddb_impl_secondary.cc217 ColumnFamilyData* cfd = in RecoverLogFiles() local
271 ColumnFamilyData* cfd = in RecoverLogFiles() local
326 ColumnFamilyData* cfd = cfh->cfd(); in GetImpl() local
392 auto cfd = cfh->cfd(); in NewIterator() local
409 const ReadOptions& read_options, ColumnFamilyData* cfd, in NewIteratorImpl()
451 ColumnFamilyData* cfd = static_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators() local
541 for (auto cfd : cfds_changed) { in TryCatchUpWithPrimary() local
622 auto cfd = in OpenAsSecondary() local
Ddb_impl_readonly.cc39 auto cfd = cfh->cfd(); in Get() local
74 auto cfd = cfh->cfd(); in NewIterator() local
113 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators() local
173 auto cfd = in OpenForReadOnly() local
Ddb_impl_experimental.cc26 auto cfd = cfh->cfd(); in SuggestCompactRange() local
70 auto* cfd = static_cast<ColumnFamilyHandleImpl*>(column_family)->cfd(); in PromoteL0() local
Ddb_impl_write.cc1211 for (auto cfd : cfds) { in AssignAtomicFlushSeq() local
1284 for (const auto cfd : cfds) { in SwitchWAL() local
1300 for (auto cfd : cfds) { in SwitchWAL() local
1360 for (const auto cfd : cfds) { in HandleWriteBufferFull() local
1379 for (const auto cfd : cfds) { in HandleWriteBufferFull() local
1546 for (auto& cfd : cfds) { in TrimMemtableHistory() local
1569 for (auto cfd : cfds) { in ScheduleFlushes() local
1586 for (auto& cfd : cfds) { in ScheduleFlushes() local
1634 Status DBImpl::SwitchMemtable(ColumnFamilyData* cfd, WriteContext* context) { in SwitchMemtable()
Ddb_impl_open.cc196 for (auto& cfd : column_families) { in ValidateOptions() local
957 ColumnFamilyData* cfd; in RecoverLogFiles() local
1192 Status DBImpl::WriteLevel0TableForRecovery(int job_id, ColumnFamilyData* cfd, in WriteLevel0TableForRecovery()
1446 auto cfd = in Open() local
/rocksdb-6.9/monitoring/
Dthread_status_util.cc35 void ThreadStatusUtil::SetColumnFamily(const ColumnFamilyData* cfd, in SetColumnFamily()
120 const ColumnFamilyData* cfd, in NewColumnFamilyInfo()
133 void ThreadStatusUtil::EraseColumnFamilyInfo(const ColumnFamilyData* cfd) { in EraseColumnFamilyInfo()
Dthread_status_updater_debug.cc22 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(handle)->cfd(); in TEST_VerifyColumnFamilyInfoMap() local
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc341 const auto* cfd = compact_->compaction->column_family_data(); in CompactionJob() local
354 const auto* cfd = compact_->compaction->column_family_data(); in ReportStartedCompaction() local
440 auto* cfd = c->column_family_data(); in GenSubcompactionBoundaries() local
633 ColumnFamilyData* cfd = compact_->compaction->column_family_data(); in Run() local
717 ColumnFamilyData* cfd = compact_->compaction->column_family_data(); in Install() local
818 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in ProcessKeyValueCompaction() local
1131 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in FinishCompactionOutputFile() local
1471 ColumnFamilyData* cfd = sub_compact->compaction->column_family_data(); in OpenCompactionOutputFile() local
1686 ColumnFamilyData* cfd = compaction->column_family_data(); in LogCompaction() local
/rocksdb-6.9/utilities/transactions/
Dtransaction_util.cc28 auto cfd = cfh->cfd(); in CheckKeyForConflicts() local
Dwrite_unprepared_txn_db.cc225 ColumnFamilyDescriptor cfd; in Initialize() local
457 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(column_family)->cfd(); in NewIterator() local

12