Lines Matching refs:cfd
14 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()
25 Node* node = new Node{cfd, head_.load(std::memory_order_relaxed)}; 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
80 while ((cfd = TakeNextColumnFamily()) != nullptr) { in Clear()
81 cfd->UnrefAndTryDelete(); in Clear()