HomeSort by relevance Sort by last modified time
    Searched refs:consumer_queue_ (Results 1 - 3 of 3) sorted by null

  /frameworks/native/libs/vr/libbufferhubqueue/tests/
buffer_hub_queue-test.cpp 41 consumer_queue_ = producer_queue_->CreateConsumerQueue();
42 return consumer_queue_ != nullptr;
85 std::unique_ptr<ConsumerQueue> consumer_queue_; member in class:android::dvr::__anon46399::BufferHubQueueTest
113 auto c1_status = consumer_queue_->Dequeue(kTimeoutMs, &slot, &mo, &fence);
141 ASSERT_EQ(consumer_queue_->count(), 0U);
143 ASSERT_EQ(consumer_queue_->capacity(), i);
146 auto status = consumer_queue_->Dequeue(kNoTimeout, &slot, &mo, &fence);
149 ASSERT_EQ(consumer_queue_->capacity(), i + 1);
158 consumer_queue_->Dequeue(kNoTimeout, &slot, &mo, &fence);
174 consumer_status = consumer_queue_->Dequeue(kTimeoutMs, &slot, &mo, &fence)
    [all...]
  /frameworks/native/libs/vr/libdvr/
dvr_buffer_queue_internal.h 72 int id() const { return consumer_queue_->id(); }
73 int event_fd() const { return consumer_queue_->queue_fd(); }
74 size_t capacity() const { return consumer_queue_->capacity(); }
90 std::shared_ptr<ConsumerQueue> consumer_queue_; member in struct:DvrReadBufferQueue
dvr_buffer_queue.cpp 325 : consumer_queue_(consumer_queue) {}
329 consumer_queue_->CreateConsumerQueue();
333 "from producer queue: queue_id=%d.", consumer_queue_->id());
348 consumer_queue_->Dequeue(timeout, &slot, out_meta, &acquire_fence);
391 if (read_buffer->read_buffer->id() != consumer_queue_->GetBufferId(slot)) {
392 if (consumer_queue_->GetBufferId(slot) > 0) {
398 consumer_queue_->id(), read_buffer->read_buffer->id(),
399 static_cast<int>(slot), consumer_queue_->GetBufferId(slot));
405 consumer_queue_->id(), read_buffer->read_buffer->id(),
429 consumer_queue_->SetBufferAvailableCallback(nullptr)
    [all...]

Completed in 216 milliseconds