diff options
Diffstat (limited to 'libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp')
| -rw-r--r-- | libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp | 18 |
1 files changed, 5 insertions, 13 deletions
diff --git a/libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp b/libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp index 1978f41983..a3479c1ca7 100644 --- a/libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp +++ b/libs/vr/libbufferhubqueue/buffer_hub_queue_client.cpp @@ -10,7 +10,6 @@ #include <pdx/default_transport/client_channel.h> #include <pdx/default_transport/client_channel_factory.h> #include <pdx/file_handle.h> -#include <private/dvr/bufferhub_rpc.h> #define RETRY_EINTR(fnc_call) \ ([&]() -> decltype(fnc_call) { \ @@ -106,7 +105,7 @@ Status<void> BufferHubQueue::ImportQueue() { status.GetErrorMessage().c_str()); return ErrorStatus(status.error()); } else { - SetupQueue(status.get().meta_size_bytes, status.get().id); + SetupQueue(status.get().producer_config.meta_size_bytes, status.get().id); return {}; } } @@ -396,9 +395,6 @@ Status<std::shared_ptr<BufferHubBuffer>> BufferHubQueue::Dequeue( return {std::move(buffer)}; } -ProducerQueue::ProducerQueue(size_t meta_size) - : ProducerQueue(meta_size, 0, 0, 0, 0) {} - ProducerQueue::ProducerQueue(LocalChannelHandle handle) : BASE(std::move(handle)) { auto status = ImportQueue(); @@ -409,14 +405,10 @@ ProducerQueue::ProducerQueue(LocalChannelHandle handle) } } -ProducerQueue::ProducerQueue(size_t meta_size, uint64_t usage_set_mask, - uint64_t usage_clear_mask, - uint64_t usage_deny_set_mask, - uint64_t usage_deny_clear_mask) +ProducerQueue::ProducerQueue(size_t meta_size, const UsagePolicy& usage) : BASE(BufferHubRPC::kClientPath) { - auto status = InvokeRemoteMethod<BufferHubRPC::CreateProducerQueue>( - meta_size, UsagePolicy{usage_set_mask, usage_clear_mask, - usage_deny_set_mask, usage_deny_clear_mask}); + auto status = + InvokeRemoteMethod<BufferHubRPC::CreateProducerQueue>(meta_size, usage); if (!status) { ALOGE("ProducerQueue::ProducerQueue: Failed to create producer queue: %s", status.GetErrorMessage().c_str()); @@ -424,7 +416,7 @@ ProducerQueue::ProducerQueue(size_t meta_size, uint64_t usage_set_mask, return; } - SetupQueue(status.get().meta_size_bytes, status.get().id); + SetupQueue(status.get().producer_config.meta_size_bytes, status.get().id); } Status<void> ProducerQueue::AllocateBuffer(uint32_t width, uint32_t height, |