diff options
Diffstat (limited to 'libs/ui/Gralloc2.cpp')
| -rw-r--r-- | libs/ui/Gralloc2.cpp | 248 |
1 files changed, 248 insertions, 0 deletions
diff --git a/libs/ui/Gralloc2.cpp b/libs/ui/Gralloc2.cpp new file mode 100644 index 0000000000..75f568657d --- /dev/null +++ b/libs/ui/Gralloc2.cpp @@ -0,0 +1,248 @@ +/* + * Copyright 2016 The Android Open Source Project + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#define LOG_TAG "Gralloc2" + +#include <ui/Gralloc2.h> + +#include <log/log.h> +#pragma clang diagnostic push +#pragma clang diagnostic ignored "-Wzero-length-array" +#include <sync/sync.h> +#pragma clang diagnostic pop + +namespace android { + +namespace Gralloc2 { + +static constexpr Error kTransactionError = Error::NO_RESOURCES; + +Mapper::Mapper() +{ + mMapper = IMapper::getService(); + if (mMapper != nullptr && mMapper->isRemote()) { + LOG_ALWAYS_FATAL("gralloc-mapper must be in passthrough mode"); + } +} + +Error Mapper::createDescriptor( + const IMapper::BufferDescriptorInfo& descriptorInfo, + BufferDescriptor* outDescriptor) const +{ + Error error; + auto ret = mMapper->createDescriptor(descriptorInfo, + [&](const auto& tmpError, const auto& tmpDescriptor) + { + error = tmpError; + if (error != Error::NONE) { + return; + } + + *outDescriptor = tmpDescriptor; + }); + + return (ret.isOk()) ? error : kTransactionError; +} + +Error Mapper::importBuffer(const hardware::hidl_handle& rawHandle, + buffer_handle_t* outBufferHandle) const +{ + Error error; + auto ret = mMapper->importBuffer(rawHandle, + [&](const auto& tmpError, const auto& tmpBuffer) + { + error = tmpError; + if (error != Error::NONE) { + return; + } + + *outBufferHandle = static_cast<buffer_handle_t>(tmpBuffer); + }); + + return (ret.isOk()) ? error : kTransactionError; +} + +void Mapper::freeBuffer(buffer_handle_t bufferHandle) const +{ + auto buffer = const_cast<native_handle_t*>(bufferHandle); + auto ret = mMapper->freeBuffer(buffer); + + auto error = (ret.isOk()) ? static_cast<Error>(ret) : kTransactionError; + ALOGE_IF(error != Error::NONE, "freeBuffer(%p) failed with %d", + buffer, error); +} + +Error Mapper::lock(buffer_handle_t bufferHandle, uint64_t usage, + const IMapper::Rect& accessRegion, + int acquireFence, void** outData) const +{ + auto buffer = const_cast<native_handle_t*>(bufferHandle); + + // put acquireFence in a hidl_handle + hardware::hidl_handle acquireFenceHandle; + NATIVE_HANDLE_DECLARE_STORAGE(acquireFenceStorage, 1, 0); + if (acquireFence >= 0) { + auto h = native_handle_init(acquireFenceStorage, 1, 0); + h->data[0] = acquireFence; + acquireFenceHandle = h; + } + + Error error; + auto ret = mMapper->lock(buffer, usage, accessRegion, acquireFenceHandle, + [&](const auto& tmpError, const auto& tmpData) + { + error = tmpError; + if (error != Error::NONE) { + return; + } + + *outData = tmpData; + }); + + // we own acquireFence even on errors + if (acquireFence >= 0) { + close(acquireFence); + } + + return (ret.isOk()) ? error : kTransactionError; +} + +Error Mapper::lock(buffer_handle_t bufferHandle, uint64_t usage, + const IMapper::Rect& accessRegion, + int acquireFence, YCbCrLayout* outLayout) const +{ + auto buffer = const_cast<native_handle_t*>(bufferHandle); + + // put acquireFence in a hidl_handle + hardware::hidl_handle acquireFenceHandle; + NATIVE_HANDLE_DECLARE_STORAGE(acquireFenceStorage, 1, 0); + if (acquireFence >= 0) { + auto h = native_handle_init(acquireFenceStorage, 1, 0); + h->data[0] = acquireFence; + acquireFenceHandle = h; + } + + Error error; + auto ret = mMapper->lockYCbCr(buffer, usage, accessRegion, + acquireFenceHandle, + [&](const auto& tmpError, const auto& tmpLayout) + { + error = tmpError; + if (error != Error::NONE) { + return; + } + + *outLayout = tmpLayout; + }); + + // we own acquireFence even on errors + if (acquireFence >= 0) { + close(acquireFence); + } + + return (ret.isOk()) ? error : kTransactionError; +} + +int Mapper::unlock(buffer_handle_t bufferHandle) const +{ + auto buffer = const_cast<native_handle_t*>(bufferHandle); + + int releaseFence = -1; + Error error; + auto ret = mMapper->unlock(buffer, + [&](const auto& tmpError, const auto& tmpReleaseFence) + { + error = tmpError; + if (error != Error::NONE) { + return; + } + + auto fenceHandle = tmpReleaseFence.getNativeHandle(); + if (fenceHandle && fenceHandle->numFds == 1) { + int fd = dup(fenceHandle->data[0]); + if (fd >= 0) { + releaseFence = fd; + } else { + ALOGD("failed to dup unlock release fence"); + sync_wait(fenceHandle->data[0], -1); + } + } + }); + + if (!ret.isOk()) { + error = kTransactionError; + } + + if (error != Error::NONE) { + ALOGE("unlock(%p) failed with %d", buffer, error); + } + + return releaseFence; +} + +Allocator::Allocator(const Mapper& mapper) + : mMapper(mapper) +{ + if (mMapper.valid()) { + mAllocator = IAllocator::getService(); + } +} + +std::string Allocator::dumpDebugInfo() const +{ + std::string debugInfo; + + mAllocator->dumpDebugInfo([&](const auto& tmpDebugInfo) { + debugInfo = tmpDebugInfo.c_str(); + }); + + return debugInfo; +} + +Error Allocator::allocate(BufferDescriptor descriptor, uint32_t count, + uint32_t* outStride, buffer_handle_t* outBufferHandles) const +{ + Error error; + auto ret = mAllocator->allocate(descriptor, count, + [&](const auto& tmpError, const auto& tmpStride, + const auto& tmpBuffers) { + error = tmpError; + if (tmpError != Error::NONE) { + return; + } + + // import buffers + for (uint32_t i = 0; i < count; i++) { + error = mMapper.importBuffer(tmpBuffers[i], + &outBufferHandles[i]); + if (error != Error::NONE) { + for (uint32_t j = 0; j < i; j++) { + mMapper.freeBuffer(outBufferHandles[j]); + outBufferHandles[j] = nullptr; + } + return; + } + } + + *outStride = tmpStride; + }); + + return (ret.isOk()) ? error : kTransactionError; +} + +} // namespace Gralloc2 + +} // namespace android |