Lines Matching full:notifier
160 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
166 EXPECT_TRUE(notifier.enqueueRequired(pel->id())); in TEST_F()
167 EXPECT_TRUE(notifier.notifyRequired(pel->id())); in TEST_F()
170 EXPECT_FALSE(notifier.enqueueRequired(42)); in TEST_F()
171 EXPECT_FALSE(notifier.notifyRequired(42)); in TEST_F()
177 EXPECT_FALSE(notifier.enqueueRequired(pel->id())); in TEST_F()
178 EXPECT_FALSE(notifier.notifyRequired(pel->id())); in TEST_F()
184 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
196 EXPECT_FALSE(notifier.enqueueRequired(pel->id())); in TEST_F()
203 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
215 EXPECT_TRUE(notifier.enqueueRequired(pel->id())); in TEST_F()
218 EXPECT_TRUE(notifier.notifyRequired(pel->id())); in TEST_F()
224 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
236 EXPECT_TRUE(notifier.enqueueRequired(pel->id())); in TEST_F()
241 EXPECT_FALSE(notifier.enqueueRequired(pel->id())); in TEST_F()
248 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
256 EXPECT_TRUE(notifier.notifyRequired(pel->id())); in TEST_F()
261 EXPECT_FALSE(notifier.notifyRequired(pel->id())); in TEST_F()
274 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
276 ASSERT_EQ(notifier.queueSize(), 10); in TEST_F()
278 // Now add 10 more after the notifier is watching in TEST_F()
285 ASSERT_EQ(notifier.queueSize(), 20); in TEST_F()
293 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
299 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
307 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
323 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
329 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
338 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
355 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
361 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
369 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
393 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
400 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
410 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
413 // Test that all commands fail and notifier will give up
418 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
438 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
449 EXPECT_EQ(notifier.queueSize(), 2); in TEST_F()
458 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
501 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
513 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
520 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
530 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
536 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
542 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
551 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
559 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
576 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
581 EXPECT_EQ(notifier.queueSize(), 2); in TEST_F()
588 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
591 notifier.ackPEL(id1); in TEST_F()
592 notifier.ackPEL(id2); in TEST_F()
607 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
623 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
634 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
637 notifier.setHostFull(id); in TEST_F()
640 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
652 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
659 EXPECT_EQ(notifier.queueSize(), 2); in TEST_F()
667 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
670 notifier.setHostFull(id); in TEST_F()
684 EXPECT_EQ(notifier.queueSize(), 2); in TEST_F()
687 notifier.ackPEL(id); in TEST_F()
693 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
703 HostNotifier notifier{repo1, dataIface, std::move(hostIface)}; in TEST_F() local
714 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
717 notifier.setBadPEL(id); in TEST_F()
720 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
732 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
742 HostNotifier notifier{repo1, dataIface, std::move(hostIface1)}; in TEST_F() local
744 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
761 HostNotifier notifier{repo, dataIface, std::move(hostIface)}; in TEST_F() local
768 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
776 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()
782 EXPECT_EQ(notifier.queueSize(), 1); in TEST_F()
793 HostNotifier notifier{repo1, dataIface, std::move(hostIface1)}; in TEST_F() local
795 EXPECT_EQ(notifier.queueSize(), 0); in TEST_F()