Loading libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp +6 −0 Original line number Diff line number Diff line Loading @@ -613,6 +613,12 @@ Status<size_t> ConsumerQueue::ImportBuffers() { std::unique_ptr<BufferConsumer> buffer_consumer = BufferConsumer::Import(std::move(buffer_handle_slot.first)); if (!buffer_consumer) { ALOGE("ConsumerQueue::ImportBuffers: Failed to import buffer: slot=%zu", buffer_handle_slot.second); last_error = ErrorStatus(EPIPE); continue; } // Setup ignore state before adding buffer to the queue. if (ignore_on_import_) { Loading libs/vr/libvrflinger/display_surface.cpp +3 −0 Original line number Diff line number Diff line Loading @@ -194,6 +194,7 @@ std::shared_ptr<ConsumerQueue> ApplicationDisplaySurface::GetQueue( "ApplicationDisplaySurface::GetQueue: surface_id=%d queue_id=%d", surface_id(), queue_id); std::lock_guard<std::mutex> autolock(lock_); auto search = consumer_queues_.find(queue_id); if (search != consumer_queues_.end()) return search->second; Loading @@ -202,6 +203,7 @@ std::shared_ptr<ConsumerQueue> ApplicationDisplaySurface::GetQueue( } std::vector<int32_t> ApplicationDisplaySurface::GetQueueIds() const { std::lock_guard<std::mutex> autolock(lock_); std::vector<int32_t> queue_ids; for (const auto& entry : consumer_queues_) queue_ids.push_back(entry.first); Loading Loading @@ -270,6 +272,7 @@ void ApplicationDisplaySurface::OnQueueEvent( } std::vector<int32_t> DirectDisplaySurface::GetQueueIds() const { std::lock_guard<std::mutex> autolock(lock_); std::vector<int32_t> queue_ids; if (direct_queue_) queue_ids.push_back(direct_queue_->id()); Loading libs/vr/libvrflinger/display_surface.h +1 −0 Original line number Diff line number Diff line Loading @@ -133,6 +133,7 @@ class ApplicationDisplaySurface : public DisplaySurface { void OnQueueEvent(const std::shared_ptr<ConsumerQueue>& consumer_queue, int events) override; // Accessed by both message dispatch thread and epoll event thread. std::unordered_map<int32_t, std::shared_ptr<ConsumerQueue>> consumer_queues_; }; Loading Loading
libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp +6 −0 Original line number Diff line number Diff line Loading @@ -613,6 +613,12 @@ Status<size_t> ConsumerQueue::ImportBuffers() { std::unique_ptr<BufferConsumer> buffer_consumer = BufferConsumer::Import(std::move(buffer_handle_slot.first)); if (!buffer_consumer) { ALOGE("ConsumerQueue::ImportBuffers: Failed to import buffer: slot=%zu", buffer_handle_slot.second); last_error = ErrorStatus(EPIPE); continue; } // Setup ignore state before adding buffer to the queue. if (ignore_on_import_) { Loading
libs/vr/libvrflinger/display_surface.cpp +3 −0 Original line number Diff line number Diff line Loading @@ -194,6 +194,7 @@ std::shared_ptr<ConsumerQueue> ApplicationDisplaySurface::GetQueue( "ApplicationDisplaySurface::GetQueue: surface_id=%d queue_id=%d", surface_id(), queue_id); std::lock_guard<std::mutex> autolock(lock_); auto search = consumer_queues_.find(queue_id); if (search != consumer_queues_.end()) return search->second; Loading @@ -202,6 +203,7 @@ std::shared_ptr<ConsumerQueue> ApplicationDisplaySurface::GetQueue( } std::vector<int32_t> ApplicationDisplaySurface::GetQueueIds() const { std::lock_guard<std::mutex> autolock(lock_); std::vector<int32_t> queue_ids; for (const auto& entry : consumer_queues_) queue_ids.push_back(entry.first); Loading Loading @@ -270,6 +272,7 @@ void ApplicationDisplaySurface::OnQueueEvent( } std::vector<int32_t> DirectDisplaySurface::GetQueueIds() const { std::lock_guard<std::mutex> autolock(lock_); std::vector<int32_t> queue_ids; if (direct_queue_) queue_ids.push_back(direct_queue_->id()); Loading
libs/vr/libvrflinger/display_surface.h +1 −0 Original line number Diff line number Diff line Loading @@ -133,6 +133,7 @@ class ApplicationDisplaySurface : public DisplaySurface { void OnQueueEvent(const std::shared_ptr<ConsumerQueue>& consumer_queue, int events) override; // Accessed by both message dispatch thread and epoll event thread. std::unordered_map<int32_t, std::shared_ptr<ConsumerQueue>> consumer_queues_; }; Loading