Lines Matching refs:queue_
29 EXPECT_TRUE(queue_.empty()); in SetUp()
34 EXPECT_TRUE(queue_.empty()); in TearDown()
37 BlockingQueue<int> queue_; member in bluetooth::common::__anon53bea4160110::BlockingQueueTest
41 EXPECT_TRUE(queue_.empty()); in TEST_F()
46 queue_.push(data); in TEST_F()
47 EXPECT_FALSE(queue_.empty()); in TEST_F()
48 EXPECT_EQ(queue_.take(), data); in TEST_F()
49 EXPECT_TRUE(queue_.empty()); in TEST_F()
54 queue_.push(data); in TEST_F()
55 EXPECT_FALSE(queue_.empty()); in TEST_F()
56 EXPECT_EQ(queue_.take(), data); in TEST_F()
57 EXPECT_TRUE(queue_.empty()); in TEST_F()
63 queue_.push(data); in TEST_F()
65 EXPECT_FALSE(queue_.empty()); in TEST_F()
67 EXPECT_EQ(queue_.take(), data); in TEST_F()
69 EXPECT_TRUE(queue_.empty()); in TEST_F()
74 queue_.push(data); in TEST_F()
76 EXPECT_FALSE(queue_.empty()); in TEST_F()
77 queue_.clear(); in TEST_F()
78 EXPECT_TRUE(queue_.empty()); in TEST_F()
83 std::thread waiter_thread([this, data] { EXPECT_EQ(queue_.take(), data); }); in TEST_F()
84 queue_.push(data); in TEST_F()
86 EXPECT_TRUE(queue_.empty()); in TEST_F()
90 EXPECT_FALSE(queue_.wait_to_take(std::chrono::milliseconds(3))); in TEST_F()
95 queue_.push(data); in TEST_F()
96 EXPECT_TRUE(queue_.wait_to_take(std::chrono::milliseconds(3))); in TEST_F()
97 queue_.clear(); in TEST_F()
102 …std::thread waiter_thread([this] { EXPECT_TRUE(queue_.wait_to_take(std::chrono::milliseconds(3)));… in TEST_F()
103 queue_.push(data); in TEST_F()
105 queue_.clear(); in TEST_F()
111 EXPECT_EQ(queue_.take(), data); in TEST_F()
115 queue_.push(data); in TEST_F()
118 EXPECT_TRUE(queue_.empty()); in TEST_F()
124 EXPECT_TRUE(queue_.empty()); in SetUp()
129 EXPECT_TRUE(queue_.empty()); in TearDown()
132 BlockingQueue<std::vector<uint8_t>> queue_; member in bluetooth::common::__anon53bea4160110::VectorBlockingQueueTest
137 queue_.push(data); in TEST_F()
138 EXPECT_FALSE(queue_.empty()); in TEST_F()
139 EXPECT_EQ(queue_.take(), data); in TEST_F()
140 EXPECT_TRUE(queue_.empty()); in TEST_F()