Searched refs:consumer_status (Results 1 – 1 of 1) sorted by relevance
300 auto consumer_status = in TEST_F() local302 ASSERT_FALSE(consumer_status.ok()); in TEST_F()303 ASSERT_EQ(consumer_status.error(), ETIMEDOUT); in TEST_F()317 consumer_status = consumer_queue_->Dequeue(kTimeoutMs, &slot, &mo, &fence); in TEST_F()318 ASSERT_TRUE(consumer_status.ok()); in TEST_F()321 auto consumer = consumer_status.take(); in TEST_F()538 auto consumer_status = in TEST_F() local540 EXPECT_TRUE(consumer_status.ok()); in TEST_F()541 auto consumer_buffer = consumer_status.take(); in TEST_F()851 pdx::Status<std::shared_ptr<ConsumerBuffer>> consumer_status; in TEST_F() local[all …]