Home
last modified time | relevance | path

Searched refs:cfd (Results 1 – 25 of 71) sorted by relevance

123

/rocksdb-6.9/db/
Dversion_edit_handler.cc100 (void)cfd; in Initialize()
131 assert(cfd != nullptr); in OnColumnFamilyAdd()
132 *cfd = nullptr; in OnColumnFamilyAdd()
157 *cfd = tmp_cfd; in OnColumnFamilyAdd()
170 *cfd = nullptr; in OnColumnFamilyDrop()
180 *cfd = tmp_cfd; in OnColumnFamilyDrop()
191 *cfd = nullptr; in OnNonCfOperation()
210 *cfd = tmp_cfd; in OnNonCfOperation()
352 return cfd; in CreateCfAndInit()
424 if (cfd != nullptr) { in ExtractInfoFromVersionEdit()
[all …]
Dflush_scheduler.cc14 void FlushScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork() argument
18 assert(checking_set_.count(cfd) == 0); in ScheduleWork()
19 checking_set_.insert(cfd); in ScheduleWork()
22 cfd->Ref(); in ScheduleWork()
45 ColumnFamilyData* cfd = node->column_family; in TakeNextColumnFamily() local
51 auto iter = checking_set_.find(cfd); in TakeNextColumnFamily()
57 if (!cfd->IsDropped()) { in TakeNextColumnFamily()
59 return cfd; in TakeNextColumnFamily()
63 cfd->UnrefAndTryDelete(); in TakeNextColumnFamily()
79 ColumnFamilyData* cfd; in Clear() local
[all …]
Dtrim_history_scheduler.cc14 void TrimHistoryScheduler::ScheduleWork(ColumnFamilyData* cfd) { in ScheduleWork() argument
16 cfd->Ref(); in ScheduleWork()
17 cfds_.push_back(cfd); in ScheduleWork()
27 ColumnFamilyData* cfd = cfds_.back(); in TakeNextColumnFamily() local
33 if (!cfd->IsDropped()) { in TakeNextColumnFamily()
35 return cfd; in TakeNextColumnFamily()
37 cfd->UnrefAndTryDelete(); in TakeNextColumnFamily()
47 ColumnFamilyData* cfd; in Clear() local
48 while ((cfd = TakeNextColumnFamily()) != nullptr) { in Clear()
49 cfd->UnrefAndTryDelete(); in Clear()
Drepair.cc124 cf_name_to_opts_[cfd.name] = cfd.options; in Repairer()
154 ColumnFamilyData* cfd; in AddColumnFamily() local
155 cfd = nullptr; in AddColumnFamily()
369 cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(), in ConvertLogToTable()
401 MemTable* mem = cfd->mem(); in ConvertLogToTable()
432 cfd->internal_comparator(), cfd->int_tbl_prop_collector_factories(), in ConvertLogToTable()
433 cfd->GetID(), cfd->GetName(), {}, kMaxSequenceNumber, in ConvertLogToTable()
508 ColumnFamilyData* cfd = nullptr; in ScanTable() local
574 auto* cfd = in AddTables() local
580 edit.SetColumnFamily(cfd->GetID()); in AddTables()
[all …]
Dflush_job_test.cc155 auto new_mem = cfd->ConstructNewMemtable(*cfd->GetLatestMutableCFOptions(), in TEST_F()
212 cfd->imm()->Add(new_mem, &to_delete); in TEST_F()
259 MemTable* mem = cfd->ConstructNewMemtable(*cfd->GetLatestMutableCFOptions(), in TEST_F()
276 cfd->imm()->Add(mem, &to_delete); in TEST_F()
320 all_cfds.push_back(cfd); in TEST_F()
332 for (auto cfd : all_cfds) { in TEST_F() local
346 cfd->imm()->Add(mem, &to_delete); in TEST_F()
356 for (auto cfd : all_cfds) { in TEST_F() local
359 dbname_, cfd, db_options_, *cfd->GetLatestMutableCFOptions(), in TEST_F()
392 for (auto cfd : all_cfds) { in TEST_F() local
[all …]
Dversion_set.cc3489 cfd(_cfd), in ManifestWriter()
3826 curr_state[cfd->GetID()] = {cfd->GetLogNumber()}; in ProcessManifestWrites()
4127 if (cfd == nullptr || !cfd->IsDropped()) { in LogAndApply()
4167 (void)cfd; in LogAndApplyHelper()
4618 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
4946 if (cfd->IsDropped() || !cfd->initialized()) { in GetLiveFilesChecksumInfo()
5140 cfd->GetName().c_str(), cfd->GetID()); in DumpManifest()
5652 if (cfd->IsDropped() || !cfd->initialized()) { in GetLiveFilesMetaData()
5932 cfd->GetName().c_str(), cfd->GetID(), cfd->GetLogNumber()); in Recover()
5965 if (cfd != nullptr && !cfd->IsDropped()) { in ReadAndApply()
[all …]
Ddb_flush_test.cc91 auto* cfd = in TEST_F() local
93 ->cfd(); in TEST_F()
98 auto current_before = cfd->current(); in TEST_F()
99 int refs_before = cfd->current()->TEST_refs(); in TEST_F()
114 ASSERT_EQ(current_before, cfd->current()); in TEST_F()
338 auto* cfd = static_cast<ColumnFamilyHandleImpl*>(handles_[1])->cfd(); in TEST_F() local
382 auto* cfd = in TEST_F() local
384 ->cfd(); in TEST_F()
468 ASSERT_TRUE(cfh->cfd()->mem()->IsEmpty()); in TEST_P()
557 ASSERT_TRUE(cfh->cfd()->mem()->IsEmpty()); in TEST_P()
[all …]
Dversion_edit_handler.h50 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);
71 ColumnFamilyData* cfd,
74 Status LoadTables(ColumnFamilyData* cfd,
93 Status ExtractInfoFromVersionEdit(ColumnFamilyData* cfd,
116 Status MaybeCreateVersion(const VersionEdit& edit, ColumnFamilyData* cfd,
Ddb_filesnapshot.cc95 for (auto cfd : *versions_->GetColumnFamilySet()) { in GetLiveFiles()
96 if (cfd->IsDropped()) { in GetLiveFiles()
99 cfd->Ref(); in GetLiveFiles()
101 status = FlushMemTable(cfd, FlushOptions(), FlushReason::kGetLiveFiles); in GetLiveFiles()
105 cfd->UnrefAndTryDelete(); in GetLiveFiles()
123 for (auto cfd : *versions_->GetColumnFamilySet()) { in GetLiveFiles()
124 if (cfd->IsDropped()) { in GetLiveFiles()
127 cfd->current()->AddLiveFiles(&live); in GetLiveFiles()
Dcolumn_family_test.cc531 void RecalculateWriteStallConditions(ColumnFamilyData* cfd, in RecalculateWriteStallConditions() argument
537 cfd->RecalculateWriteStallConditions(mutable_cf_options); in RecalculateWriteStallConditions()
2562 ColumnFamilyData* cfd = in TEST_P() local
2576 RecalculateWriteStallConditions(cfd, mutable_cf_options); in TEST_P()
2581 RecalculateWriteStallConditions(cfd, mutable_cf_options); in TEST_P()
2588 RecalculateWriteStallConditions(cfd, mutable_cf_options); in TEST_P()
2595 RecalculateWriteStallConditions(cfd, mutable_cf_options); in TEST_P()
2601 RecalculateWriteStallConditions(cfd, mutable_cf_options); in TEST_P()
2741 ColumnFamilyData* cfd = in TEST_P() local
2807 ColumnFamilyData* cfd = in TEST_P() local
[all …]
Dcolumn_family.cc87 return cfd()->GetName(); in GetName()
94 *desc = ColumnFamilyDescriptor(cfd()->GetName(), cfd()->GetLatestCFOptions()); in GetDescriptor()
103 return cfd()->user_comparator(); in GetComparator()
439 if (cfd->Unref()) { in Cleanup()
440 delete cfd; in Cleanup()
446 cfd = new_cfd; in Init()
450 cfd->Ref(); in Init()
1453 assert(cfd != nullptr); in GetColumnFamily()
1454 return cfd; in GetColumnFamily()
1500 for (auto cfd = dummy_cfd_->next_; cfd != dummy_cfd_; cfd = cfd->next_) { in FreeDeadColumnFamilies() local
[all …]
Darena_wrapped_db_iter.cc40 ColumnFamilyData* cfd, bool allow_blob, in Init() argument
46 read_callback, db_impl, cfd, allow_blob); in Init()
92 ReadCallback* read_callback, DBImpl* db_impl, ColumnFamilyData* cfd, in NewArenaWrappedDbIterator() argument
97 db_impl, cfd, allow_blob, allow_refresh); in NewArenaWrappedDbIterator()
98 if (db_impl != nullptr && cfd != nullptr && allow_refresh) { in NewArenaWrappedDbIterator()
99 iter->StoreRefreshInfo(read_options, db_impl, cfd, read_callback, in NewArenaWrappedDbIterator()
Dversion_builder.cc774 ColumnFamilyData* cfd) in BaseReferencedVersionBuilder() argument
776 cfd->current()->version_set()->file_options(), cfd->table_cache(), in BaseReferencedVersionBuilder()
777 cfd->current()->storage_info(), cfd->ioptions()->info_log)), in BaseReferencedVersionBuilder()
778 version_(cfd->current()) { in BaseReferencedVersionBuilder()
783 ColumnFamilyData* cfd, Version* v) in BaseReferencedVersionBuilder() argument
785 cfd->current()->version_set()->file_options(), cfd->table_cache(), in BaseReferencedVersionBuilder()
786 v->storage_info(), cfd->ioptions()->info_log)), in BaseReferencedVersionBuilder()
788 assert(version_ != cfd->current()); in BaseReferencedVersionBuilder()
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc46 ColumnFamilyData* cfd; in TEST_MaxNextLevelOverlappingBytes() local
48 cfd = default_cf_handle_->cfd(); in TEST_MaxNextLevelOverlappingBytes()
51 cfd = cfh->cfd(); in TEST_MaxNextLevelOverlappingBytes()
61 auto cfd = cfh->cfd(); in TEST_GetFilesMetaData() local
89 cfd = default_cf_handle_->cfd(); in TEST_CompactRange()
92 cfd = cfh->cfd(); in TEST_CompactRange()
108 cfd = default_cf_handle_->cfd(); in TEST_SwitchMemtable()
132 cfd = default_cf_handle_->cfd(); in TEST_FlushMemTable()
135 cfd = cfhi->cfd(); in TEST_FlushMemTable()
153 cfd = default_cf_handle_->cfd(); in TEST_WaitForFlushMemTable()
[all …]
Ddb_impl_compaction_flush.cc46 (void)cfd; in EnoughRoomForCompaction()
631 (void)cfd; in NotifyOnFlushBegin()
672 (void)cfd; in NotifyOnFlushCompleted()
682 auto cfd = cfh->cfd(); in CompactRange() local
1211 (void)cfd; in NotifyOnCompactionBegin()
1252 (void)cfd; in NotifyOnCompactionCompleted()
1436 manual.cfd = cfd; in RunManualCompaction()
2064 cfd->Ref(); in AddToCompactionQueue()
2075 return cfd; in PopFirstFromCompactionQueue()
2109 return cfd; in PickCompactionFromQueue()
[all …]
Ddb_impl.cc876 ColumnFamilyData* cfd = cfh->cfd(); in TablesRangeTombstoneSummary() local
1319 cfd = default_cf_handle_->cfd(); in NewInternalIterator()
1322 cfd = cfh->cfd(); in NewInternalIterator()
1536 auto cfd = cfh->cfd(); in GetImpl() local
1723 auto cfd = cfh->cfd(); in MultiGet() local
2432 auto cfd = cfh->cfd(); in DropColumnFamilyImpl() local
2542 auto cfd = cfh->cfd(); in NewIterator() local
2781 auto cfd = cfh->cfd(); in GetPropertiesOfAllTables() local
2803 auto cfd = cfh->cfd(); in GetPropertiesOfTablesInRange() local
3104 auto cfd = cfh->cfd(); in GetApproximateSizes() local
[all …]
Ddb_impl_secondary.cc219 if (cfd == nullptr) { in RecoverLogFiles()
250 cfd->imm()->Add(cfd->mem(), &job_context->memtables_to_free); in RecoverLogFiles()
273 if (cfd == nullptr) { in RecoverLogFiles()
326 ColumnFamilyData* cfd = cfh->cfd(); in GetImpl() local
392 auto cfd = cfh->cfd(); in NewIterator() local
411 assert(nullptr != cfd); in NewIteratorImpl()
451 ColumnFamilyData* cfd = static_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators() local
517 if (cfd->IsDropped()) { in TryCatchUpWithPrimary()
542 cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(), in TryCatchUpWithPrimary()
622 auto cfd = in OpenAsSecondary() local
[all …]
Ddb_impl_open.cc569 cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(), in Recover()
739 cf_name_id_map.insert(std::make_pair(cfd->GetName(), cfd->GetID())); in RecoverLogFiles()
741 std::make_pair(cfd->GetID(), cfd->GetLogNumber())); in RecoverLogFiles()
967 status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit); in RecoverLogFiles()
975 cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(), in RecoverLogFiles()
1078 status = WriteLevel0TableForRecovery(job_id, cfd, cfd->mem(), edit); in RecoverLogFiles()
1085 cfd->CreateNewMemtable(*cfd->GetLatestMutableCFOptions(), in RecoverLogFiles()
1114 cfds.push_back(cfd); in RecoverLogFiles()
1247 cfd->int_tbl_prop_collector_factories(), cfd->GetID(), cfd->GetName(), in WriteLevel0TableForRecovery()
1446 auto cfd = in Open() local
[all …]
Ddb_impl_readonly.cc39 auto cfd = cfh->cfd(); in Get() local
46 SuperVersion* super_version = cfd->GetSuperVersion(); in Get()
74 auto cfd = cfh->cfd(); in NewIterator() local
75 SuperVersion* super_version = cfd->GetSuperVersion()->Ref(); in NewIterator()
113 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators() local
114 auto* sv = cfd->GetSuperVersion()->Ref(); in NewIterators()
173 auto cfd = in OpenForReadOnly() local
175 if (cfd == nullptr) { in OpenForReadOnly()
183 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in OpenForReadOnly()
185 cfd->InstallSuperVersion(&sv_context, &impl->mutex_); in OpenForReadOnly()
[all …]
Ddb_impl_experimental.cc26 auto cfd = cfh->cfd(); in SuggestCompactRange() local
36 auto vstorage = cfd->current()->storage_info(); in SuggestCompactRange()
48 vstorage->ComputeCompactionScore(*cfd->ioptions(), in SuggestCompactRange()
49 *cfd->GetLatestMutableCFOptions()); in SuggestCompactRange()
50 SchedulePendingCompaction(cfd); in SuggestCompactRange()
70 auto* cfd = static_cast<ColumnFamilyHandleImpl*>(column_family)->cfd(); in PromoteL0() local
71 const auto* vstorage = cfd->current()->storage_info(); in PromoteL0()
82 const InternalKeyComparator* icmp = &cfd->internal_comparator(); in PromoteL0()
125 edit.SetColumnFamily(cfd->GetID()); in PromoteL0()
136 status = versions_->LogAndApply(cfd, *cfd->GetLatestMutableCFOptions(), in PromoteL0()
[all …]
Ddb_impl_write.cc1200 if (cfd->imm()->NumNotFlushed() != 0 || !cfd->mem()->IsEmpty() || in SelectColumnFamiliesForAtomicFlush()
1211 for (auto cfd : cfds) { in AssignAtomicFlushSeq() local
1285 cfd->Ref(); in SwitchWAL()
1364 cfd->Ref(); in HandleWriteBufferFull()
1546 for (auto& cfd : cfds) { in TrimMemtableHistory() local
1548 cfd->imm()->TrimHistory(&to_delete, cfd->mem()->ApproximateMemoryUsage()); in TrimMemtableHistory()
1559 cfd = nullptr; in TrimMemtableHistory()
1570 cfd->Ref(); in ScheduleFlushes()
1586 for (auto& cfd : cfds) { in ScheduleFlushes() local
1591 cfd = nullptr; in ScheduleFlushes()
[all …]
Ddb_impl.h886 Status TEST_FlushMemTable(ColumnFamilyData* cfd,
1054 void NotifyOnMemTableSealed(ColumnFamilyData* cfd,
1256 : cfd_(cfd), in BGFlushArg()
1280 ColumnFamilyData* cfd; member
1448 Status WaitForFlushMemTable(ColumnFamilyData* cfd,
1621 void AddToCompactionQueue(ColumnFamilyData* cfd);
1664 bool HaveManualCompaction(ColumnFamilyData* cfd);
1676 ColumnFamilyData* cfd, uint64_t num,
1708 ColumnFamilyData* cfd; member
1725 cfd(static_cast<ColumnFamilyHandleImpl*>(cf)->cfd()), in MultiGetColumnFamilyData()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc342 ThreadStatusUtil::SetColumnFamily(cfd, cfd->ioptions()->env, in CompactionJob()
355 ThreadStatusUtil::SetColumnFamily(cfd, cfd->ioptions()->env, in ReportStartedCompaction()
440 auto* cfd = c->column_family_data(); in GenSubcompactionBoundaries() local
823 cfd->ioptions()->compaction_filter; in ProcessKeyValueCompaction()
869 env_, cfd->user_comparator(), cfd->ioptions()->merge_operator, in ProcessKeyValueCompaction()
1015 if (status.ok() && cfd->IsDropped()) { in ProcessKeyValueCompaction()
1383 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, in FinishCompactionOutputFile()
1474 cfd->ioptions()->listeners, dbname_, cfd->GetName(), fname, job_id_, in OpenCompactionOutputFile()
1494 event_logger_, cfd->ioptions()->listeners, dbname_, cfd->GetName(), in OpenCompactionOutputFile()
1546 cfd->internal_comparator(), cfd->int_tbl_prop_collector_factories(), in OpenCompactionOutputFile()
[all …]
/rocksdb-6.9/monitoring/
Dthread_status_util.cc35 void ThreadStatusUtil::SetColumnFamily(const ColumnFamilyData* cfd, in SetColumnFamily() argument
42 if (cfd != nullptr && enable_thread_tracking) { in SetColumnFamily()
43 thread_updater_local_cache_->SetColumnFamilyInfoKey(cfd); in SetColumnFamily()
120 const ColumnFamilyData* cfd, in NewColumnFamilyInfo() argument
128 thread_updater_local_cache_->NewColumnFamilyInfo(db, db->GetName(), cfd, in NewColumnFamilyInfo()
133 void ThreadStatusUtil::EraseColumnFamilyInfo(const ColumnFamilyData* cfd) { in EraseColumnFamilyInfo() argument
137 thread_updater_local_cache_->EraseColumnFamilyInfo(cfd); in EraseColumnFamilyInfo()
Dthread_status_updater_debug.cc22 auto* cfd = reinterpret_cast<ColumnFamilyHandleImpl*>(handle)->cfd(); in TEST_VerifyColumnFamilyInfoMap() local
23 auto iter __attribute__((__unused__)) = cf_info_map_.find(cfd); in TEST_VerifyColumnFamilyInfoMap()
26 assert(iter->second.cf_name == cfd->GetName()); in TEST_VerifyColumnFamilyInfoMap()

123