Lines Matching refs:cfd
48 for (auto cfd : *versions_->GetColumnFamilySet()) { in Recover()
49 auto* mutable_cf_options = cfd->GetLatestMutableCFOptions(); in Recover()
56 default_cf_internal_stats_ = default_cf_handle_->cfd()->internal_stats(); in Recover()
217 ColumnFamilyData* cfd = in RecoverLogFiles() local
219 if (cfd == nullptr) { in RecoverLogFiles()
222 if (cfds_changed->count(cfd) == 0) { in RecoverLogFiles()
223 cfds_changed->insert(cfd); in RecoverLogFiles()
226 cfd->current()->storage_info()->LevelFiles(0); in RecoverLogFiles()
237 if (cfd_to_current_log_.count(cfd) > 0) { in RecoverLogFiles()
238 curr_log_num = cfd_to_current_log_[cfd]; in RecoverLogFiles()
243 if (!cfd->mem()->IsEmpty() && (curr_log_num == port::kMaxUint64 || in RecoverLogFiles()
246 *cfd->GetLatestMutableCFOptions(); in RecoverLogFiles()
248 cfd->ConstructNewMemtable(mutable_cf_options, seq_of_batch); in RecoverLogFiles()
249 cfd->mem()->SetNextLogNumber(log_number); in RecoverLogFiles()
250 cfd->imm()->Add(cfd->mem(), &job_context->memtables_to_free); in RecoverLogFiles()
252 cfd->SetMemtable(new_mem); in RecoverLogFiles()
271 ColumnFamilyData* cfd = in RecoverLogFiles() local
273 if (cfd == nullptr) { in RecoverLogFiles()
277 cfd_to_current_log_.find(cfd); in RecoverLogFiles()
279 cfd_to_current_log_.insert({cfd, log_number}); in RecoverLogFiles()
326 ColumnFamilyData* cfd = cfh->cfd(); in GetImpl() local
334 SuperVersion* super_version = GetAndRefSuperVersion(cfd); in GetImpl()
358 ReturnAndCleanupSuperVersion(cfd, super_version); in GetImpl()
370 ReturnAndCleanupSuperVersion(cfd, super_version); in GetImpl()
392 auto cfd = cfh->cfd(); in NewIterator() local
403 result = NewIteratorImpl(read_options, cfd, snapshot, read_callback); in NewIterator()
409 const ReadOptions& read_options, ColumnFamilyData* cfd, in NewIteratorImpl() argument
411 assert(nullptr != cfd); in NewIteratorImpl()
412 SuperVersion* super_version = cfd->GetReferencedSuperVersion(this); in NewIteratorImpl()
414 env_, read_options, *cfd->ioptions(), super_version->mutable_cf_options, in NewIteratorImpl()
419 NewInternalIterator(read_options, cfd, super_version, db_iter->GetArena(), in NewIteratorImpl()
451 ColumnFamilyData* cfd = static_cast<ColumnFamilyHandleImpl*>(cfh)->cfd(); in NewIterators() local
453 NewIteratorImpl(read_options, cfd, read_seq, read_callback)); in NewIterators()
516 for (ColumnFamilyData* cfd : cfds_changed) { in TryCatchUpWithPrimary()
517 if (cfd->IsDropped()) { in TryCatchUpWithPrimary()
519 cfd->GetName().c_str()); in TryCatchUpWithPrimary()
524 "[%s] Level summary: %s\n", cfd->GetName().c_str(), in TryCatchUpWithPrimary()
525 cfd->current()->storage_info()->LevelSummary(&tmp)); in TryCatchUpWithPrimary()
541 for (auto cfd : cfds_changed) { in TryCatchUpWithPrimary() local
542 cfd->imm()->RemoveOldMemTables(cfd->GetLogNumber(), in TryCatchUpWithPrimary()
545 cfd->InstallSuperVersion(&sv_context, &mutex_); in TryCatchUpWithPrimary()
622 auto cfd = in OpenAsSecondary() local
624 if (nullptr == cfd) { in OpenAsSecondary()
628 handles->push_back(new ColumnFamilyHandleImpl(cfd, impl, &impl->mutex_)); in OpenAsSecondary()
633 for (auto cfd : *impl->versions_->GetColumnFamilySet()) { in OpenAsSecondary()
635 cfd->InstallSuperVersion(&sv_context, &impl->mutex_); in OpenAsSecondary()
644 reinterpret_cast<ColumnFamilyHandleImpl*>(h)->cfd()); in OpenAsSecondary()