Lines Matching refs:list
86 MemTableList* list, const MutableCFOptions& mutable_cf_options, in Mock_InstallMemtableFlushResults() argument
121 std::list<std::unique_ptr<FlushJobInfo>> flush_jobs_info; in Mock_InstallMemtableFlushResults()
122 Status s = list->TryInstallMemtableFlushResults( in Mock_InstallMemtableFlushResults()
190 MemTableList list(1, 0, 0); in TEST_F() local
192 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
193 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
194 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
197 list.PickMemtablesToFlush(nullptr /* memtable_id */, &mems); in TEST_F()
201 list.current()->Unref(&to_delete); in TEST_F()
210 MemTableList list(min_write_buffer_number_to_merge, in TEST_F() local
223 bool found = list.current()->Get( in TEST_F()
271 list.Add(mem, &to_delete); in TEST_F()
285 list.Add(mem2, &to_delete); in TEST_F()
289 found = list.current()->Get( in TEST_F()
295 found = list.current()->Get( in TEST_F()
302 found = list.current()->Get( in TEST_F()
309 found = list.current()->Get( in TEST_F()
314 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
316 list.current()->Unref(&to_delete); in TEST_F()
327 MemTableList list(min_write_buffer_number_to_merge, in TEST_F() local
340 bool found = list.current()->Get( in TEST_F()
377 list.Add(mem, &to_delete); in TEST_F()
382 found = list.current()->Get(LookupKey("key1", seq), &value, in TEST_F()
388 found = list.current()->Get(LookupKey("key2", seq), &value, in TEST_F()
397 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
401 s = Mock_InstallMemtableFlushResults(&list, mutable_cf_options, to_flush, in TEST_F()
404 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
405 ASSERT_EQ(1, list.NumFlushed()); in TEST_F()
410 found = list.current()->Get(LookupKey("key1", seq), &value, in TEST_F()
416 found = list.current()->Get(LookupKey("key2", seq), &value, in TEST_F()
423 found = list.current()->GetFromHistory( in TEST_F()
429 found = list.current()->GetFromHistory( in TEST_F()
445 list.Add(mem2, &to_delete); in TEST_F()
449 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
453 s = Mock_InstallMemtableFlushResults(&list, mutable_cf_options, to_flush, in TEST_F()
456 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
457 ASSERT_EQ(2, list.NumFlushed()); in TEST_F()
465 list.Add(mem3, &to_delete); in TEST_F()
466 ASSERT_EQ(1, list.NumNotFlushed()); in TEST_F()
467 ASSERT_EQ(1, list.NumFlushed()); in TEST_F()
472 found = list.current()->Get(LookupKey("key1", seq), &value, in TEST_F()
478 found = list.current()->Get(LookupKey("key2", seq), &value, in TEST_F()
484 found = list.current()->Get(LookupKey("key3", seq), &value, in TEST_F()
491 found = list.current()->GetFromHistory( in TEST_F()
497 found = list.current()->GetFromHistory( in TEST_F()
505 found = list.current()->Get(LookupKey("key2", seq), &value, in TEST_F()
511 list.current()->Unref(&to_delete); in TEST_F()
535 MemTableList list(min_write_buffer_number_to_merge, in TEST_F() local
562 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
563 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
565 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
569 list.FlushRequested(); in TEST_F()
570 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
571 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
574 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
576 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
577 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
580 list.FlushRequested(); in TEST_F()
582 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
583 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
586 list.Add(tables[0], &to_delete); in TEST_F()
587 list.Add(tables[1], &to_delete); in TEST_F()
588 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
594 ASSERT_TRUE(list.IsFlushPending()); in TEST_F()
595 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
598 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
600 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
601 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
602 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
605 list.RollbackMemtableFlush(to_flush, 0); in TEST_F()
606 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
607 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
611 list.Add(tables[2], &to_delete); in TEST_F()
614 ASSERT_TRUE(list.IsFlushPending()); in TEST_F()
615 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
619 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
621 ASSERT_EQ(3, list.NumNotFlushed()); in TEST_F()
622 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
623 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
627 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush2); in TEST_F()
629 ASSERT_EQ(3, list.NumNotFlushed()); in TEST_F()
630 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
631 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
634 list.Add(tables[3], &to_delete); in TEST_F()
635 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
636 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
640 list.FlushRequested(); in TEST_F()
641 ASSERT_TRUE(list.IsFlushPending()); in TEST_F()
642 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
645 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush2); in TEST_F()
647 ASSERT_EQ(4, list.NumNotFlushed()); in TEST_F()
648 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
649 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
652 list.RollbackMemtableFlush(to_flush, 0); in TEST_F()
653 ASSERT_TRUE(list.IsFlushPending()); in TEST_F()
654 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
658 list.Add(tables[4], &to_delete); in TEST_F()
659 ASSERT_EQ(5, list.NumNotFlushed()); in TEST_F()
661 ASSERT_TRUE(list.IsFlushPending()); in TEST_F()
662 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
666 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush); in TEST_F()
669 ASSERT_EQ(5, list.NumNotFlushed()); in TEST_F()
670 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
671 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
675 list.PickMemtablesToFlush(nullptr /* memtable_id */, &to_flush3); in TEST_F()
677 ASSERT_EQ(5, list.NumNotFlushed()); in TEST_F()
678 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
679 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
682 s = Mock_InstallMemtableFlushResults(&list, mutable_cf_options, to_flush, in TEST_F()
691 ASSERT_EQ(2, list.NumNotFlushed()); in TEST_F()
695 ASSERT_EQ(num_in_history, list.NumFlushed()); in TEST_F()
696 ASSERT_EQ(5 - list.NumNotFlushed() - num_in_history, to_delete.size()); in TEST_F()
699 list.FlushRequested(); in TEST_F()
700 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
701 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
705 &list, mutable_cf_options, to_flush2, &to_delete); in TEST_F()
710 ASSERT_EQ(0, list.NumNotFlushed()); in TEST_F()
714 ASSERT_EQ(num_in_history, list.NumFlushed()); in TEST_F()
715 ASSERT_EQ(5 - list.NumNotFlushed() - num_in_history, to_delete.size()); in TEST_F()
727 list.Add(tables[5], &to_delete); in TEST_F()
728 ASSERT_EQ(1, list.NumNotFlushed()); in TEST_F()
729 ASSERT_EQ(5, list.GetLatestMemTableID()); in TEST_F()
734 list.FlushRequested(); in TEST_F()
735 ASSERT_TRUE(list.HasFlushRequested()); in TEST_F()
736 list.PickMemtablesToFlush(&memtable_id, &to_flush4); in TEST_F()
738 ASSERT_EQ(1, list.NumNotFlushed()); in TEST_F()
739 ASSERT_TRUE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
740 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
741 ASSERT_FALSE(list.HasFlushRequested()); in TEST_F()
746 list.FlushRequested(); in TEST_F()
747 list.PickMemtablesToFlush(&memtable_id, &to_flush4); in TEST_F()
749 ASSERT_EQ(1, list.NumNotFlushed()); in TEST_F()
750 ASSERT_FALSE(list.imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
751 ASSERT_FALSE(list.IsFlushPending()); in TEST_F()
754 list.current()->Unref(&to_delete); in TEST_F()
836 auto* list = lists[i]; in TEST_F() local
837 ASSERT_FALSE(list->IsFlushPending()); in TEST_F()
838 ASSERT_FALSE(list->imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
839 list->PickMemtablesToFlush(nullptr /* memtable_id */, &flush_candidates[i]); in TEST_F()
844 auto* list = lists[i]; in TEST_F() local
845 list->FlushRequested(); in TEST_F()
846 ASSERT_FALSE(list->IsFlushPending()); in TEST_F()
847 ASSERT_FALSE(list->imm_flush_needed.load(std::memory_order_acquire)); in TEST_F()
902 for (auto list : lists) { in TEST_F() local
903 list->current()->Unref(&to_delete); in TEST_F()
904 delete list; in TEST_F()