Searched refs:IsDropped (Results 1 – 16 of 16) sorted by relevance
96 if (cfd->IsDropped()) { in GetLiveFiles()124 if (cfd->IsDropped()) { in GetLiveFiles()
300 if (cfd->IsDropped()) { in CheckIterationResult()315 if (cfd->IsDropped()) { in CheckIterationResult()400 assert(!cfd->IsDropped()); in LoadTables()492 if (cfd->IsDropped()) { in CheckIterationResult()
33 if (!cfd->IsDropped()) { in TakeNextColumnFamily()
57 if (!cfd->IsDropped()) { in TakeNextColumnFamily()
3666 if (last_writer->cfd->IsDropped()) { in ProcessManifestWrites()4556 if (cfd->IsDropped()) { in Recover()4612 if (cfd->IsDropped()) { in Recover()5125 if (cfd->IsDropped()) { in DumpManifest()5214 if (cfd->IsDropped()) { in WriteCurrentStateToManifest()5853 if (!cfd->IsDropped()) { in Recover()5903 if (cfd->IsDropped()) { in Recover()5927 if (cfd->IsDropped()) { in Recover()6029 if (cfd->IsDropped()) { in ReadAndApply()6080 !cfd->IsDropped()) { in ApplyOneVersionEditToBuilder()[all …]
502 if (s.ok() && !cfd->IsDropped()) { // commit new state in TryInstallMemtableFlushResults()708 if (cfds[i]->IsDropped()) { in InstallMemtableAtomicFlushResults()
314 bool IsDropped() const { return dropped_.load(std::memory_order_relaxed); } in IsDropped() function
228 if (s.ok() && cfd_->IsDropped()) { in Run()
1022 if (min_log_num > cfd->GetLogNumber() && !cfd->IsDropped()) { in PreComputeMinLogNumberWithUnflushedData()
63 bool dropped = cfd_->IsDropped(); in ~ColumnFamilyHandleImpl()
333 if (cfd->IsDropped()) { in ResumeImpl()1002 if (!c->IsDropped()) { in SetDBOptions()2446 if (cfd->IsDropped()) { in DropColumnFamilyImpl()2483 assert(cfd->IsDropped()); in DropColumnFamilyImpl()3669 if (cfd->IsDropped()) { in WriteOptionsFile()4115 if (cfd->IsDropped()) { in IngestExternalFiles()4195 if (cfd->IsDropped()) { in IngestExternalFiles()4223 if (!cfd->IsDropped()) { in IngestExternalFiles()4269 if (!cfd->IsDropped()) { in IngestExternalFiles()4354 assert(!cfd->IsDropped()); in CreateColumnFamilyWithImport()[all …]
474 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()515 if (!cfds[i]->IsDropped() && !mems.empty()) { in AtomicFlushMemTablesToOutputFiles()533 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()552 if (cfds[i]->IsDropped()) { in AtomicFlushMemTablesToOutputFiles()1731 if (cfd->IsDropped()) { in AtomicFlushMemTables()1823 if (cfd->IsDropped()) { in WaitUntilFlushWouldNotStallWrites()1899 if (cfds[i]->IsDropped()) { in WaitForFlushMemTables()2232 if (cfd->IsDropped() || !cfd->imm()->IsFlushPending()) { in BackgroundFlush()2615 if (!mutable_cf_options->disable_auto_compactions && !cfd->IsDropped()) { in BackgroundCompaction()
1197 if (cfd->IsDropped()) { in SelectColumnFamiliesForAtomicFlush()1270 if (cfd->IsDropped()) { in SwitchWAL()1337 if (cfd->IsDropped()) { in HandleWriteBufferFull()
586 if (loop_cfd->IsDropped() || loop_cfd == cfd_to_flush) { in FindMinPrepLogReferencedByMemTable()
517 if (cfd->IsDropped()) { in TryCatchUpWithPrimary()
911 while (status.ok() && !cfd->IsDropped() && c_iter->Valid()) { in ProcessKeyValueCompaction()1015 if (status.ok() && cfd->IsDropped()) { in ProcessKeyValueCompaction()