Searched refs:consumer_queue_ (Results 1 – 3 of 3) sorted by relevance
| /frameworks/native/libs/vr/libbufferhubqueue/tests/ |
| D | buffer_hub_queue-test.cpp | 43 consumer_queue_ = producer_queue_->CreateConsumerQueue(); in CreateConsumerQueue()
44 return consumer_queue_ != nullptr; in CreateConsumerQueue()
87 std::unique_ptr<ConsumerQueue> consumer_queue_; member in android::dvr::__anonba5096350111::BufferHubQueueTest
115 auto c1_status = consumer_queue_->Dequeue(kTimeoutMs, &slot, &mo, &fence); in TEST_F()
165 consumer_queue_->Dequeue(kTimeoutMs, &consumer_slot, &mo, &fence); in TEST_F()
284 ASSERT_EQ(consumer_queue_->count(), 0U); in TEST_F()
286 ASSERT_EQ(consumer_queue_->capacity(), i); in TEST_F()
289 auto status = consumer_queue_->Dequeue(kNoTimeout, &slot, &mo, &fence); in TEST_F()
292 ASSERT_EQ(consumer_queue_->capacity(), i + 1); in TEST_F()
301 consumer_queue_->Dequeue(kNoTimeout, &slot, &mo, &fence); in TEST_F()
[all …]
|
| /frameworks/native/libs/vr/libdvr/ |
| D | dvr_buffer_queue.cpp | 325 : consumer_queue_(consumer_queue) {} in DvrReadBufferQueue()
329 consumer_queue_->CreateConsumerQueue(); in CreateReadQueue()
333 "from producer queue: queue_id=%d.", consumer_queue_->id()); in CreateReadQueue()
348 consumer_queue_->Dequeue(timeout, &slot, out_meta, &acquire_fence); in AcquireBuffer()
391 if (read_buffer->read_buffer->id() != consumer_queue_->GetBufferId(slot)) { in ReleaseBuffer()
392 if (consumer_queue_->GetBufferId(slot) > 0) { in ReleaseBuffer()
398 consumer_queue_->id(), read_buffer->read_buffer->id(), in ReleaseBuffer()
399 static_cast<int>(slot), consumer_queue_->GetBufferId(slot)); in ReleaseBuffer()
405 consumer_queue_->id(), read_buffer->read_buffer->id(), in ReleaseBuffer()
429 consumer_queue_->SetBufferAvailableCallback(nullptr); in SetBufferAvailableCallback()
[all …]
|
| D | dvr_buffer_queue_internal.h | 72 int id() const { return consumer_queue_->id(); } in id()
73 int event_fd() const { return consumer_queue_->queue_fd(); } in event_fd()
74 size_t capacity() const { return consumer_queue_->capacity(); } in capacity()
90 std::shared_ptr<ConsumerQueue> consumer_queue_;
|