Home
last modified time | relevance | path

Searched refs:compaction_queue_ (Results 1 – 3 of 3) sorted by relevance

/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc2065 compaction_queue_.push_back(cfd); in AddToCompactionQueue()
2070 assert(!compaction_queue_.empty()); in PopFirstFromCompactionQueue()
2071 auto cfd = *compaction_queue_.begin(); in PopFirstFromCompactionQueue()
2072 compaction_queue_.pop_front(); in PopFirstFromCompactionQueue()
2088 assert(!compaction_queue_.empty()); in PickCompactionFromQueue()
2092 while (!compaction_queue_.empty()) { in PickCompactionFromQueue()
2093 auto first_cfd = *compaction_queue_.begin(); in PickCompactionFromQueue()
2094 compaction_queue_.pop_front(); in PickCompactionFromQueue()
2107 compaction_queue_.push_front(*iter); in PickCompactionFromQueue()
2579 } else if (!is_prepicked && !compaction_queue_.empty()) { in BackgroundCompaction()
Ddb_impl.h1928 std::deque<ColumnFamilyData*> compaction_queue_; variable
Ddb_impl.cc488 while (!compaction_queue_.empty()) { in CloseHelper()