Add DaydreamVR native libraries and services
Upstreaming the main VR system components from master-dreamos-dev
into goog/master.
Bug: None
Test: `m -j32` succeeds. Sailfish boots and basic_vr sample app works
Change-Id: I853015872afc443aecee10411ef2d6b79184d051
diff --git a/libs/vr/libbufferhub/include/private/dvr/buffer_hub_client.h b/libs/vr/libbufferhub/include/private/dvr/buffer_hub_client.h
new file mode 100644
index 0000000..b6ff5b6
--- /dev/null
+++ b/libs/vr/libbufferhub/include/private/dvr/buffer_hub_client.h
@@ -0,0 +1,313 @@
+#ifndef ANDROID_DVR_BUFFER_HUB_CLIENT_H_
+#define ANDROID_DVR_BUFFER_HUB_CLIENT_H_
+
+#include <hardware/gralloc.h>
+#include <pdx/channel_handle.h>
+#include <pdx/client.h>
+#include <pdx/file_handle.h>
+#include <pdx/status.h>
+
+#include <vector>
+
+#include <private/dvr/ion_buffer.h>
+
+namespace android {
+namespace dvr {
+
+class BufferHubBuffer : public pdx::Client {
+ public:
+ using LocalHandle = pdx::LocalHandle;
+ using LocalChannelHandle = pdx::LocalChannelHandle;
+ template <typename T>
+ using Status = pdx::Status<T>;
+
+ // Create a new consumer channel that is attached to the producer. Returns
+ // a file descriptor for the new channel or a negative error code.
+ Status<LocalChannelHandle> CreateConsumer();
+
+ // Polls the fd for |timeout_ms| milliseconds (-1 for infinity).
+ int Poll(int timeout_ms);
+
+ // Locks the area specified by (x, y, width, height) for a specific usage. If
+ // the usage is software then |addr| will be updated to point to the address
+ // of the buffer in virtual memory. The caller should only access/modify the
+ // pixels in the specified area. anything else is undefined behavior.
+ int Lock(int usage, int x, int y, int width, int height, void** addr,
+ size_t index);
+
+ // Must be called after Lock() when the caller has finished changing the
+ // buffer.
+ int Unlock(size_t index);
+
+ // Helper for when index is 0.
+ int Lock(int usage, int x, int y, int width, int height, void** addr) {
+ return Lock(usage, x, y, width, height, addr, 0);
+ }
+
+ // Helper for when index is 0.
+ int Unlock() { return Unlock(0); }
+
+ // Gets a blob buffer that was created with BufferProducer::CreateBlob.
+ // Locking and Unlocking is handled internally. There's no need to Unlock
+ // after calling this method.
+ int GetBlobReadWritePointer(size_t size, void** addr);
+
+ // Gets a blob buffer that was created with BufferProducer::CreateBlob.
+ // Locking and Unlocking is handled internally. There's no need to Unlock
+ // after calling this method.
+ int GetBlobReadOnlyPointer(size_t size, void** addr);
+
+ // Returns a dup'd file descriptor for accessing the blob shared memory. The
+ // caller takes ownership of the file descriptor and must close it or pass on
+ // ownership. Some GPU API extensions can take file descriptors to bind shared
+ // memory gralloc buffers to GPU buffer objects.
+ LocalHandle GetBlobFd() const {
+ // Current GPU vendor puts the buffer allocation in one FD. If we change GPU
+ // vendors and this is the wrong fd, late-latching and EDS will very clearly
+ // stop working and we will need to correct this. The alternative is to use
+ // a GL context in the pose service to allocate this buffer or to use the
+ // ION API directly instead of gralloc.
+ return LocalHandle(dup(native_handle()->data[0]));
+ }
+
+ using Client::event_fd;
+ native_handle_t* native_handle() const {
+ return const_cast<native_handle_t*>(slices_[0].handle());
+ }
+ // If index is greater than or equal to slice_count(), the result is
+ // undefined.
+ native_handle_t* native_handle(size_t index) const {
+ return const_cast<native_handle_t*>(slices_[index].handle());
+ }
+
+ IonBuffer* buffer() { return &slices_[0]; }
+ // If index is greater than or equal to slice_count(), the result is
+ // undefined.
+ IonBuffer* slice(size_t index) { return &slices_[index]; }
+
+ int slice_count() const { return static_cast<int>(slices_.size()); }
+ int id() const { return id_; }
+
+ // The following methods return settings of the first buffer. Currently,
+ // it is only possible to create multi-buffer BufferHubBuffers with the same
+ // settings.
+ int width() const { return slices_[0].width(); }
+ int height() const { return slices_[0].height(); }
+ int stride() const { return slices_[0].stride(); }
+ int format() const { return slices_[0].format(); }
+ int usage() const { return slices_[0].usage(); }
+
+ protected:
+ explicit BufferHubBuffer(LocalChannelHandle channel);
+ explicit BufferHubBuffer(const std::string& endpoint_path);
+ virtual ~BufferHubBuffer();
+
+ // Initialization helper.
+ int ImportBuffer();
+
+ private:
+ BufferHubBuffer(const BufferHubBuffer&) = delete;
+ void operator=(const BufferHubBuffer&) = delete;
+
+ // Global id for the buffer that is consistent across processes. It is meant
+ // for logging and debugging purposes only and should not be used for lookup
+ // or any other functional purpose as a security precaution.
+ int id_;
+
+ // A BufferHubBuffer may contain multiple slices of IonBuffers with same
+ // configurations.
+ std::vector<IonBuffer> slices_;
+};
+
+// This represents a writable buffer. Calling Post notifies all clients and
+// makes the buffer read-only. Call Gain to acquire write access. A buffer
+// may have many consumers.
+//
+// The user of BufferProducer is responsible with making sure that the Post() is
+// done with the correct metadata type and size. The user is also responsible
+// for making sure that remote ends (BufferConsumers) are also using the correct
+// metadata when acquiring the buffer. The API guarantees that a Post() with a
+// metadata of wrong size will fail. However, it currently does not do any
+// type checking.
+// The API also assumes that metadata is a serializable type (plain old data).
+class BufferProducer : public pdx::ClientBase<BufferProducer, BufferHubBuffer> {
+ public:
+ // Create a buffer designed to hold arbitrary bytes that can be read and
+ // written from CPU, GPU and DSP. The buffer is mapped uncached so that CPU
+ // reads and writes are predictable.
+ static std::unique_ptr<BufferProducer> CreateUncachedBlob(size_t size);
+
+ // Creates a persistent uncached buffer with the given name and access.
+ static std::unique_ptr<BufferProducer> CreatePersistentUncachedBlob(
+ const std::string& name, int user_id, int group_id, size_t size);
+
+ // Imports a bufferhub producer channel, assuming ownership of its handle.
+ static std::unique_ptr<BufferProducer> Import(LocalChannelHandle channel);
+ static std::unique_ptr<BufferProducer> Import(
+ Status<LocalChannelHandle> status);
+
+ // Post this buffer, passing |ready_fence| to the consumers. The bytes in
+ // |meta| are passed unaltered to the consumers. The producer must not modify
+ // the buffer until it is re-gained.
+ // This returns zero or a negative unix error code.
+ int Post(const LocalHandle& ready_fence, const void* meta,
+ size_t meta_size_bytes);
+
+ template <typename Meta,
+ typename = typename std::enable_if<std::is_void<Meta>::value>::type>
+ int Post(const LocalHandle& ready_fence) {
+ return Post(ready_fence, nullptr, 0);
+ }
+ template <typename Meta, typename = typename std::enable_if<
+ !std::is_void<Meta>::value>::type>
+ int Post(const LocalHandle& ready_fence, const Meta& meta) {
+ return Post(ready_fence, &meta, sizeof(meta));
+ }
+
+ // Attempt to re-gain the buffer for writing. If |release_fence| is valid, it
+ // must be waited on before using the buffer. If it is not valid then the
+ // buffer is free for immediate use. This call will only succeed if the buffer
+ // is in the released state.
+ // This returns zero or a negative unix error code.
+ int Gain(LocalHandle* release_fence);
+
+ // Asynchronously marks a released buffer as gained. This method is similar to
+ // the synchronous version above, except that it does not wait for BufferHub
+ // to acknowledge success or failure, nor does it transfer a release fence to
+ // the client. This version may be used in situations where a release fence is
+ // not needed. Because of the asynchronous nature of the underlying message,
+ // no error is returned if this method is called when the buffer is in an
+ // incorrect state. Returns zero if sending the message succeeded, or a
+ // negative errno code otherwise.
+ int GainAsync();
+
+ // Attaches the producer to |name| so that it becomes a persistent buffer that
+ // may be retrieved by name at a later time. This may be used in cases where a
+ // shared memory buffer should persist across the life of the producer process
+ // (i.e. the buffer may be held by clients across a service restart). The
+ // buffer may be associated with a user and/or group id to restrict access to
+ // the buffer. If user_id or group_id is -1 then checks for the respective id
+ // are disabled. If user_id or group_id is 0 then the respective id of the
+ // calling process is used instead.
+ int MakePersistent(const std::string& name, int user_id, int group_id);
+
+ // Removes the persistence of the producer.
+ int RemovePersistence();
+
+ private:
+ friend BASE;
+
+ // Constructors are automatically exposed through BufferProducer::Create(...)
+ // static template methods inherited from ClientBase, which take the same
+ // arguments as the constructors.
+
+ // Constructs a buffer with the given geometry and parameters.
+ BufferProducer(int width, int height, int format, int usage,
+ size_t metadata_size = 0, size_t slice_count = 1);
+
+ // Constructs a persistent buffer with the given geometry and parameters and
+ // binds it to |name| in one shot. If a persistent buffer with the same name
+ // and settings already exists and matches the given geometry and parameters,
+ // that buffer is connected to this client instead of creating a new buffer.
+ // If the name matches but the geometry or settings do not match then
+ // construction fails and BufferProducer::Create() returns nullptr.
+ //
+ // Access to the persistent buffer may be restricted by |user_id| and/or
+ // |group_id|; these settings are established only when the buffer is first
+ // created and cannot be changed. A user or group id of -1 disables checks for
+ // that respective id. A user or group id of 0 is substituted with the
+ // effective user or group id of the calling process.
+ BufferProducer(const std::string& name, int user_id, int group_id, int width,
+ int height, int format, int usage, size_t metadata_size = 0,
+ size_t slice_count = 1);
+
+ // Constructs a blob (flat) buffer with the given usage flags.
+ BufferProducer(int usage, size_t size);
+
+ // Constructs a persistent blob (flat) buffer and binds it to |name|.
+ BufferProducer(const std::string& name, int user_id, int group_id, int usage,
+ size_t size);
+
+ // Constructs a channel to persistent buffer by name only. The buffer must
+ // have been previously created or made persistent.
+ explicit BufferProducer(const std::string& name);
+
+ // Imports the given file handle to a producer channel, taking ownership.
+ explicit BufferProducer(LocalChannelHandle channel);
+};
+
+// This is a connection to a producer buffer, which can be located in another
+// application. When that buffer is Post()ed, this fd will be signaled and
+// Acquire allows read access. The user is responsible for making sure that
+// Acquire is called with the correct metadata structure. The only guarantee the
+// API currently provides is that an Acquire() with metadata of the wrong size
+// will fail.
+class BufferConsumer : public pdx::ClientBase<BufferConsumer, BufferHubBuffer> {
+ public:
+ // This call assumes ownership of |fd|.
+ static std::unique_ptr<BufferConsumer> Import(LocalChannelHandle channel);
+ static std::unique_ptr<BufferConsumer> Import(
+ Status<LocalChannelHandle> status);
+
+ // Attempt to retrieve a post event from buffer hub. If successful,
+ // |ready_fence| will be set to a fence to wait on until the buffer is ready.
+ // This call will only succeed after the fd is signalled. This call may be
+ // performed as an alternative to the Acquire() with metadata. In such cases
+ // the metadata is not read.
+ //
+ // This returns zero or negative unix error code.
+ int Acquire(LocalHandle* ready_fence);
+
+ // Attempt to retrieve a post event from buffer hub. If successful,
+ // |ready_fence| is set to a fence signaling that the contents of the buffer
+ // are available. This call will only succeed if the buffer is in the posted
+ // state.
+ // Returns zero on success, or a negative errno code otherwise.
+ int Acquire(LocalHandle* ready_fence, void* meta, size_t meta_size_bytes);
+
+ // Attempt to retrieve a post event from buffer hub. If successful,
+ // |ready_fence| is set to a fence to wait on until the buffer is ready. This
+ // call will only succeed after the fd is signaled. This returns zero or a
+ // negative unix error code.
+ template <typename Meta>
+ int Acquire(LocalHandle* ready_fence, Meta* meta) {
+ return Acquire(ready_fence, meta, sizeof(*meta));
+ }
+
+ // This should be called after a successful Acquire call. If the fence is
+ // valid the fence determines the buffer usage, otherwise the buffer is
+ // released immediately.
+ // This returns zero or a negative unix error code.
+ int Release(const LocalHandle& release_fence);
+
+ // Asynchronously releases a buffer. Similar to the synchronous version above,
+ // except that it does not wait for BufferHub to reply with success or error,
+ // nor does it transfer a release fence. This version may be used in
+ // situations where a release fence is not needed. Because of the asynchronous
+ // nature of the underlying message, no error is returned if this method is
+ // called when the buffer is in an incorrect state. Returns zero if sending
+ // the message succeeded, or a negative errno code otherwise.
+ int ReleaseAsync();
+
+ // May be called after or instead of Acquire to indicate that the consumer
+ // does not need to access the buffer this cycle. This returns zero or a
+ // negative unix error code.
+ int Discard();
+
+ // When set, this consumer is no longer notified when this buffer is
+ // available. The system behaves as if Discard() is immediately called
+ // whenever the buffer is posted. If ignore is set to true while a buffer is
+ // pending, it will act as if Discard() was also called.
+ // This returns zero or a negative unix error code.
+ int SetIgnore(bool ignore);
+
+ private:
+ friend BASE;
+
+ explicit BufferConsumer(LocalChannelHandle channel);
+};
+
+} // namespace dvr
+} // namespace android
+
+#endif // ANDROID_DVR_BUFFER_HUB_CLIENT_H_
diff --git a/libs/vr/libbufferhub/include/private/dvr/bufferhub_rpc.h b/libs/vr/libbufferhub/include/private/dvr/bufferhub_rpc.h
new file mode 100644
index 0000000..ed11551
--- /dev/null
+++ b/libs/vr/libbufferhub/include/private/dvr/bufferhub_rpc.h
@@ -0,0 +1,214 @@
+#ifndef ANDROID_DVR_BUFFERHUB_RPC_H_
+#define ANDROID_DVR_BUFFERHUB_RPC_H_
+
+#include <cutils/native_handle.h>
+#include <gui/BufferQueueDefs.h>
+#include <sys/types.h>
+
+#include <pdx/channel_handle.h>
+#include <pdx/file_handle.h>
+#include <pdx/rpc/remote_method.h>
+#include <pdx/rpc/serializable.h>
+#include <private/dvr/ion_buffer.h>
+
+namespace android {
+namespace dvr {
+
+template <typename FileHandleType>
+class NativeBufferHandle {
+ public:
+ NativeBufferHandle() { Clear(); }
+ NativeBufferHandle(const IonBuffer& buffer, int id)
+ : id_(id),
+ stride_(buffer.stride()),
+ width_(buffer.width()),
+ height_(buffer.height()),
+ format_(buffer.format()),
+ usage_(buffer.usage()) {
+ // Populate the fd and int vectors: native_handle->data[] is an array of fds
+ // followed by an array of opaque ints.
+ const int fd_count = buffer.handle()->numFds;
+ const int int_count = buffer.handle()->numInts;
+ for (int i = 0; i < fd_count; i++) {
+ fds_.emplace_back(FileHandleType::AsDuplicate(buffer.handle()->data[i]));
+ }
+ for (int i = 0; i < int_count; i++) {
+ opaque_ints_.push_back(buffer.handle()->data[fd_count + i]);
+ }
+ }
+ NativeBufferHandle(NativeBufferHandle&& other) = default;
+
+ // Imports the native handle into the given IonBuffer instance.
+ int Import(IonBuffer* buffer) {
+ // This is annoying, but we need to convert the vector of FileHandles into a
+ // vector of ints for the Import API.
+ std::vector<int> fd_ints;
+ for (const auto& fd : fds_)
+ fd_ints.push_back(fd.Get());
+
+ const int ret = buffer->Import(fd_ints.data(), fd_ints.size(),
+ opaque_ints_.data(), opaque_ints_.size(),
+ width_, height_, stride_, format_, usage_);
+ if (ret < 0)
+ return ret;
+
+ // Import succeeded, release the file handles which are now owned by the
+ // IonBuffer and clear members.
+ for (auto& fd : fds_)
+ fd.Release();
+ opaque_ints_.clear();
+ Clear();
+
+ return 0;
+ }
+
+ int id() const { return id_; }
+ size_t IntCount() const { return opaque_ints_.size(); }
+ size_t FdCount() const { return fds_.size(); }
+
+ private:
+ int id_;
+ int stride_;
+ int width_;
+ int height_;
+ int format_;
+ int usage_;
+ std::vector<int> opaque_ints_;
+ std::vector<FileHandleType> fds_;
+
+ void Clear() { id_ = stride_ = width_ = height_ = format_ = usage_ = -1; }
+
+ PDX_SERIALIZABLE_MEMBERS(NativeBufferHandle<FileHandleType>, id_, stride_,
+ width_, height_, format_, usage_, opaque_ints_,
+ fds_);
+
+ NativeBufferHandle(const NativeBufferHandle&) = delete;
+ void operator=(const NativeBufferHandle&) = delete;
+};
+
+template <typename FileHandleType>
+class FenceHandle {
+ public:
+ FenceHandle() = default;
+ explicit FenceHandle(int fence) : fence_{fence} {}
+ explicit FenceHandle(FileHandleType&& fence) : fence_{std::move(fence)} {}
+ FenceHandle(FenceHandle&&) = default;
+ FenceHandle& operator=(FenceHandle&&) = default;
+
+ explicit operator bool() const { return fence_.IsValid(); }
+
+ const FileHandleType& get() const { fence_; }
+ FileHandleType&& take() { return std::move(fence_); }
+
+ int get_fd() const { return fence_.Get(); }
+ void close() { fence_.Close(); }
+
+ FenceHandle<pdx::BorrowedHandle> borrow() const {
+ return FenceHandle<pdx::BorrowedHandle>(fence_.Borrow());
+ }
+
+ private:
+ FileHandleType fence_;
+
+ PDX_SERIALIZABLE_MEMBERS(FenceHandle<FileHandleType>, fence_);
+
+ FenceHandle(const FenceHandle&) = delete;
+ void operator=(const FenceHandle&) = delete;
+};
+
+using LocalFence = FenceHandle<pdx::LocalHandle>;
+using BorrowedFence = FenceHandle<pdx::BorrowedHandle>;
+
+// BufferHub Service RPC interface. Defines the endpoints, op codes, and method
+// type signatures supported by bufferhubd.
+struct BufferHubRPC {
+ // Service path.
+ static constexpr char kClientPath[] = "system/buffer_hub/client";
+
+ // |BufferHubQueue| will keep track of at most this value of buffers.
+ // Attempts at runtime to increase the number of buffers past this
+ // will fail. Note that the value is in sync with |android::BufferQueue|, so
+ // that slot id can be shared between |android::dvr::BufferHubQueueProducer|
+ // and |android::BufferQueueProducer| which both implements the same
+ // interface: |android::IGraphicBufferProducer|.
+ static constexpr size_t kMaxQueueCapacity =
+ android::BufferQueueDefs::NUM_BUFFER_SLOTS;
+
+ // Op codes.
+ enum {
+ kOpCreateBuffer = 0,
+ kOpCreatePersistentBuffer,
+ kOpGetPersistentBuffer,
+ kOpGetBuffer,
+ kOpGetBuffers,
+ kOpNewConsumer,
+ kOpProducerMakePersistent,
+ kOpProducerRemovePersistence,
+ kOpProducerPost,
+ kOpProducerGain,
+ kOpConsumerAcquire,
+ kOpConsumerRelease,
+ kOpConsumerSetIgnore,
+ kOpCreateProducerQueue,
+ kOpCreateConsumerQueue,
+ kOpProducerQueueAllocateBuffers,
+ kOpProducerQueueDetachBuffer,
+ kOpConsumerQueueImportBuffers,
+ };
+
+ // Aliases.
+ using MetaData = pdx::rpc::BufferWrapper<std::uint8_t*>;
+ using LocalChannelHandle = pdx::LocalChannelHandle;
+ using LocalHandle = pdx::LocalHandle;
+ using Void = pdx::rpc::Void;
+
+ // Methods.
+ PDX_REMOTE_METHOD(CreateBuffer, kOpCreateBuffer,
+ int(int width, int height, int format, int usage,
+ size_t meta_size_bytes, size_t slice_count));
+ PDX_REMOTE_METHOD(CreatePersistentBuffer, kOpCreatePersistentBuffer,
+ int(const std::string& name, int user_id, int group_id,
+ int width, int height, int format, int usage,
+ size_t meta_size_bytes, size_t slice_count));
+ PDX_REMOTE_METHOD(GetPersistentBuffer, kOpGetPersistentBuffer,
+ int(const std::string& name));
+ PDX_REMOTE_METHOD(GetBuffer, kOpGetBuffer,
+ NativeBufferHandle<LocalHandle>(unsigned index));
+ PDX_REMOTE_METHOD(GetBuffers, kOpGetBuffers,
+ std::vector<NativeBufferHandle<LocalHandle>>(Void));
+ PDX_REMOTE_METHOD(NewConsumer, kOpNewConsumer, LocalChannelHandle(Void));
+ PDX_REMOTE_METHOD(ProducerMakePersistent, kOpProducerMakePersistent,
+ int(const std::string& name, int user_id, int group_id));
+ PDX_REMOTE_METHOD(ProducerRemovePersistence, kOpProducerRemovePersistence,
+ int(Void));
+ PDX_REMOTE_METHOD(ProducerPost, kOpProducerPost,
+ int(LocalFence acquire_fence, MetaData));
+ PDX_REMOTE_METHOD(ProducerGain, kOpProducerGain, LocalFence(Void));
+ PDX_REMOTE_METHOD(ConsumerAcquire, kOpConsumerAcquire,
+ std::pair<LocalFence, MetaData>(std::size_t metadata_size));
+ PDX_REMOTE_METHOD(ConsumerRelease, kOpConsumerRelease,
+ int(LocalFence release_fence));
+ PDX_REMOTE_METHOD(ConsumerSetIgnore, kOpConsumerSetIgnore, int(bool ignore));
+
+ // Buffer Queue Methods.
+ PDX_REMOTE_METHOD(CreateProducerQueue, kOpCreateProducerQueue,
+ int(size_t meta_size_bytes, int usage_set_mask,
+ int usage_clear_mask, int usage_deny_set_mask,
+ int usage_deny_clear_mask));
+ PDX_REMOTE_METHOD(CreateConsumerQueue, kOpCreateConsumerQueue,
+ std::pair<LocalChannelHandle, size_t>(Void));
+ PDX_REMOTE_METHOD(ProducerQueueAllocateBuffers,
+ kOpProducerQueueAllocateBuffers,
+ std::vector<std::pair<LocalChannelHandle, size_t>>(
+ int width, int height, int format, int usage,
+ size_t slice_count, size_t buffer_count));
+ PDX_REMOTE_METHOD(ProducerQueueDetachBuffer, kOpProducerQueueDetachBuffer,
+ int(size_t slot));
+ PDX_REMOTE_METHOD(ConsumerQueueImportBuffers, kOpConsumerQueueImportBuffers,
+ std::vector<std::pair<LocalChannelHandle, size_t>>(Void));
+};
+
+} // namespace dvr
+} // namespace android
+
+#endif // ANDROID_DVR_BUFFERHUB_RPC_H_
diff --git a/libs/vr/libbufferhub/include/private/dvr/ion_buffer.h b/libs/vr/libbufferhub/include/private/dvr/ion_buffer.h
new file mode 100644
index 0000000..8125c54
--- /dev/null
+++ b/libs/vr/libbufferhub/include/private/dvr/ion_buffer.h
@@ -0,0 +1,108 @@
+#ifndef ANDROID_DVR_ION_BUFFER_H_
+#define ANDROID_DVR_ION_BUFFER_H_
+
+#include <hardware/gralloc.h>
+
+namespace android {
+namespace dvr {
+
+// IonBuffer is an abstraction of Ion/Gralloc buffers.
+class IonBuffer {
+ public:
+ IonBuffer();
+ IonBuffer(int width, int height, int format, int usage);
+ IonBuffer(buffer_handle_t handle, int width, int height, int stride,
+ int format, int usage);
+ IonBuffer(buffer_handle_t handle, int width, int height, int layer_count,
+ int stride, int layer_stride, int format, int usage);
+ ~IonBuffer();
+
+ IonBuffer(IonBuffer&& other);
+ IonBuffer& operator=(IonBuffer&& other);
+
+ // Frees the underlying native handle and leaves the instance initialized to
+ // empty.
+ void FreeHandle();
+
+ // Allocates a new native handle with the given parameters, freeing the
+ // previous native handle if necessary. Returns 0 on success or a negative
+ // errno code otherwise. If allocation fails the previous native handle is
+ // left intact.
+ int Alloc(int width, int height, int format, int usage);
+
+ // Resets the underlying native handle and parameters, freeing the previous
+ // native handle if necessary.
+ void Reset(buffer_handle_t handle, int width, int height, int stride,
+ int format, int usage);
+
+ // Like Reset but also registers the native handle, which is necessary for
+ // native handles received over IPC. Returns 0 on success or a negative errno
+ // code otherwise. If import fails the previous native handle is left intact.
+ int Import(buffer_handle_t handle, int width, int height, int stride,
+ int format, int usage);
+
+ // Like Reset but imports a native handle from raw fd and int arrays. Returns
+ // 0 on success or a negative errno code otherwise. If import fails the
+ // previous native handle is left intact.
+ int Import(const int* fd_array, int fd_count, const int* int_array,
+ int int_count, int width, int height, int stride, int format,
+ int usage);
+
+ // Duplicates the native handle underlying |other| and then imports it. This
+ // is useful for creating multiple, independent views of the same Ion/Gralloc
+ // buffer. Returns 0 on success or a negative errno code otherwise. If
+ // duplication or import fail the previous native handle is left intact.
+ int Duplicate(const IonBuffer* other);
+
+ int Lock(int usage, int x, int y, int width, int height, void** address);
+ int LockYUV(int usage, int x, int y, int width, int height,
+ struct android_ycbcr* yuv);
+ int Unlock();
+
+ buffer_handle_t handle() const { return handle_; }
+ int width() const { return width_; }
+ int height() const { return height_; }
+ int layer_count() const { return layer_count_; }
+ int stride() const { return stride_; }
+ int layer_stride() const { return layer_stride_; }
+ int format() const { return format_; }
+ int usage() const { return usage_; }
+
+ static gralloc_module_t const* GetGrallocModule() {
+ GrallocInit();
+ return gralloc_module_;
+ }
+
+ static alloc_device_t* GetGrallocDevice() {
+ GrallocInit();
+ return gralloc_device_;
+ }
+
+ private:
+ buffer_handle_t handle_;
+ int width_;
+ int height_;
+ int layer_count_;
+ int stride_;
+ int layer_stride_;
+ int format_;
+ int usage_;
+ bool locked_;
+ bool needs_unregister_;
+
+ void Replace(buffer_handle_t handle, int width, int height, int layer_count,
+ int stride, int layer_stride, int format, int usage,
+ bool needs_unregister);
+
+ static void GrallocInit();
+ static gralloc_module_t const* gralloc_module_;
+ static alloc_device_t* gralloc_device_;
+
+ IonBuffer(const IonBuffer&) = delete;
+ void operator=(const IonBuffer&) = delete;
+};
+
+} // namespace dvr
+} // namespace android
+
+#endif // ANDROID_DVR_ION_BUFFER_H_
diff --git a/libs/vr/libbufferhub/include/private/dvr/native_buffer.h b/libs/vr/libbufferhub/include/private/dvr/native_buffer.h
new file mode 100644
index 0000000..f6c24d9
--- /dev/null
+++ b/libs/vr/libbufferhub/include/private/dvr/native_buffer.h
@@ -0,0 +1,226 @@
+#ifndef ANDROID_DVR_NATIVE_BUFFER_H_
+#define ANDROID_DVR_NATIVE_BUFFER_H_
+
+#include <EGL/egl.h>
+#include <EGL/eglext.h>
+#include <android/native_window.h>
+#include <base/logging.h>
+#include <cutils/log.h>
+#include <system/window.h>
+#include <ui/ANativeObjectBase.h>
+#include <utils/RefBase.h>
+
+#include <private/dvr/buffer_hub_client.h>
+
+namespace android {
+namespace dvr {
+
+// ANativeWindowBuffer is the abstraction Android HALs and frameworks use to
+// pass around hardware graphics buffers. The following classes implement this
+// abstraction with different DVR backing buffers, all of which provide
+// different semantics on top of ion/gralloc buffers.
+
+// An implementation of ANativeWindowBuffer backed by an IonBuffer.
+class NativeBuffer
+ : public android::ANativeObjectBase<ANativeWindowBuffer, NativeBuffer,
+ android::LightRefBase<NativeBuffer>> {
+ public:
+ static constexpr int kEmptyFence = -1;
+
+ explicit NativeBuffer(const std::shared_ptr<IonBuffer>& buffer)
+ : BASE(), buffer_(buffer), fence_(kEmptyFence) {
+ ANativeWindowBuffer::width = buffer->width();
+ ANativeWindowBuffer::height = buffer->height();
+ ANativeWindowBuffer::stride = buffer->stride();
+ ANativeWindowBuffer::format = buffer->format();
+ ANativeWindowBuffer::usage = buffer->usage();
+ handle = buffer_->handle();
+ }
+
+ virtual ~NativeBuffer() {}
+
+ std::shared_ptr<IonBuffer> buffer() { return buffer_; }
+ int fence() const { return fence_.Get(); }
+
+ void SetFence(int fence) { fence_.Reset(fence); }
+
+ private:
+ friend class android::LightRefBase<NativeBuffer>;
+
+ std::shared_ptr<IonBuffer> buffer_;
+ pdx::LocalHandle fence_;
+
+ NativeBuffer(const NativeBuffer&) = delete;
+ void operator=(NativeBuffer&) = delete;
+};
+
+// NativeBufferProducerSlice is an implementation of ANativeWindowBuffer backed
+// by a buffer slice of a BufferProducer.
+class NativeBufferProducerSlice
+ : public android::ANativeObjectBase<
+ ANativeWindowBuffer, NativeBufferProducerSlice,
+ android::LightRefBase<NativeBufferProducerSlice>> {
+ public:
+ NativeBufferProducerSlice(const std::shared_ptr<BufferProducer>& buffer,
+ int buffer_index)
+ : BASE(), buffer_(buffer) {
+ ANativeWindowBuffer::width = buffer_->width();
+ ANativeWindowBuffer::height = buffer_->height();
+ ANativeWindowBuffer::stride = buffer_->stride();
+ ANativeWindowBuffer::format = buffer_->format();
+ ANativeWindowBuffer::usage = buffer_->usage();
+ handle = buffer_->native_handle(buffer_index);
+ }
+
+ virtual ~NativeBufferProducerSlice() {}
+
+ private:
+ friend class android::LightRefBase<NativeBufferProducerSlice>;
+
+ std::shared_ptr<BufferProducer> buffer_;
+
+ NativeBufferProducerSlice(const NativeBufferProducerSlice&) = delete;
+ void operator=(NativeBufferProducerSlice&) = delete;
+};
+
+// NativeBufferProducer is an implementation of ANativeWindowBuffer backed by a
+// BufferProducer.
+class NativeBufferProducer : public android::ANativeObjectBase<
+ ANativeWindowBuffer, NativeBufferProducer,
+ android::LightRefBase<NativeBufferProducer>> {
+ public:
+ static constexpr int kEmptyFence = -1;
+
+ NativeBufferProducer(const std::shared_ptr<BufferProducer>& buffer,
+ EGLDisplay display, uint32_t surface_buffer_index)
+ : BASE(),
+ buffer_(buffer),
+ surface_buffer_index_(surface_buffer_index),
+ display_(display) {
+ ANativeWindowBuffer::width = buffer_->width();
+ ANativeWindowBuffer::height = buffer_->height();
+ ANativeWindowBuffer::stride = buffer_->stride();
+ ANativeWindowBuffer::format = buffer_->format();
+ ANativeWindowBuffer::usage = buffer_->usage();
+ handle = buffer_->native_handle();
+ for (int i = 0; i < buffer->slice_count(); ++i) {
+ // display == null means don't create an EGL image. This is used by our
+ // Vulkan code.
+ slices_.push_back(new NativeBufferProducerSlice(buffer, i));
+ if (display_ != nullptr) {
+ egl_images_.push_back(eglCreateImageKHR(
+ display_, EGL_NO_CONTEXT, EGL_NATIVE_BUFFER_ANDROID,
+ static_cast<ANativeWindowBuffer*>(slices_.back().get()), nullptr));
+ if (egl_images_.back() == EGL_NO_IMAGE_KHR) {
+ ALOGE("NativeBufferProducer: eglCreateImageKHR failed");
+ }
+ }
+ }
+ }
+
+ explicit NativeBufferProducer(const std::shared_ptr<BufferProducer>& buffer)
+ : NativeBufferProducer(buffer, nullptr, 0) {}
+
+ virtual ~NativeBufferProducer() {
+ for (EGLImageKHR egl_image : egl_images_) {
+ if (egl_image != EGL_NO_IMAGE_KHR)
+ eglDestroyImageKHR(display_, egl_image);
+ }
+ }
+
+ EGLImageKHR image_khr(int index) const { return egl_images_[index]; }
+ std::shared_ptr<BufferProducer> buffer() const { return buffer_; }
+ int release_fence() const { return release_fence_.Get(); }
+ uint32_t surface_buffer_index() const { return surface_buffer_index_; }
+
+ // Return the release fence, passing ownership to the caller.
+ pdx::LocalHandle ClaimReleaseFence() { return std::move(release_fence_); }
+
+ // Post the buffer consumer, closing the acquire and release fences.
+ int Post(int acquire_fence, uint64_t sequence) {
+ release_fence_.Close();
+ return buffer_->Post(pdx::LocalHandle(acquire_fence), sequence);
+ }
+
+ // Gain the buffer producer, closing the previous release fence if valid.
+ int Gain() { return buffer_->Gain(&release_fence_); }
+
+ // Asynchronously gain the buffer, closing the previous release fence.
+ int GainAsync() {
+ release_fence_.Close();
+ return buffer_->GainAsync();
+ }
+
+ private:
+ friend class android::LightRefBase<NativeBufferProducer>;
+
+ std::shared_ptr<BufferProducer> buffer_;
+ pdx::LocalHandle release_fence_;
+ std::vector<android::sp<NativeBufferProducerSlice>> slices_;
+ std::vector<EGLImageKHR> egl_images_;
+ uint32_t surface_buffer_index_;
+ EGLDisplay display_;
+
+ NativeBufferProducer(const NativeBufferProducer&) = delete;
+ void operator=(NativeBufferProducer&) = delete;
+};
+
+// NativeBufferConsumer is an implementation of ANativeWindowBuffer backed by a
+// BufferConsumer.
+class NativeBufferConsumer : public android::ANativeObjectBase<
+ ANativeWindowBuffer, NativeBufferConsumer,
+ android::LightRefBase<NativeBufferConsumer>> {
+ public:
+ static constexpr int kEmptyFence = -1;
+
+ explicit NativeBufferConsumer(const std::shared_ptr<BufferConsumer>& buffer,
+ int index)
+ : BASE(), buffer_(buffer), acquire_fence_(kEmptyFence), sequence_(0) {
+ ANativeWindowBuffer::width = buffer_->width();
+ ANativeWindowBuffer::height = buffer_->height();
+ ANativeWindowBuffer::stride = buffer_->stride();
+ ANativeWindowBuffer::format = buffer_->format();
+ ANativeWindowBuffer::usage = buffer_->usage();
+ CHECK(buffer_->slice_count() > index);
+ handle = buffer_->slice(index)->handle();
+ }
+
+ explicit NativeBufferConsumer(const std::shared_ptr<BufferConsumer>& buffer)
+ : NativeBufferConsumer(buffer, 0) {}
+
+ virtual ~NativeBufferConsumer() {}
+
+ std::shared_ptr<BufferConsumer> buffer() const { return buffer_; }
+ int acquire_fence() const { return acquire_fence_.Get(); }
+ uint64_t sequence() const { return sequence_; }
+
+ // Return the acquire fence, passing ownership to the caller.
+ pdx::LocalHandle ClaimAcquireFence() { return std::move(acquire_fence_); }
+
+ // Acquire the underlying buffer consumer, closing the previous acquire fence
+ // if valid.
+ int Acquire() { return buffer_->Acquire(&acquire_fence_, &sequence_); }
+
+ // Release the buffer consumer, closing the acquire and release fences if
+ // valid.
+ int Release(int release_fence) {
+ acquire_fence_.Close();
+ sequence_ = 0;
+ return buffer_->Release(pdx::LocalHandle(release_fence));
+ }
+
+ private:
+ friend class android::LightRefBase<NativeBufferConsumer>;
+
+ std::shared_ptr<BufferConsumer> buffer_;
+ pdx::LocalHandle acquire_fence_;
+ uint64_t sequence_;
+
+ NativeBufferConsumer(const NativeBufferConsumer&) = delete;
+ void operator=(NativeBufferConsumer&) = delete;
+};
+
+} // namespace dvr
+} // namespace android
+
+#endif // ANDROID_DVR_NATIVE_BUFFER_H_