Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 3ba62b4a authored by TreeHugger Robot's avatar TreeHugger Robot Committed by Automerger Merge Worker
Browse files

Merge "Make sure to close vulkan fd's in error cases" into sc-dev am: d2a3454d 

Original change: https://googleplex-android-review.googlesource.com/c/platform/frameworks/base/+/14921129

Change-Id: I1d40b716095cb884d5f0412517e47ea37de59da0
parents 4d260389 d2a3454d

libs/hwui/renderthread/VulkanManager.cpp

+36 −22
Original line number Diff line number Diff line
@@ -425,9 +425,11 @@ Frame VulkanManager::dequeueNextBuffer(VulkanSurface* surface) { 
                semaphoreInfo.flags = 0;

                VkSemaphore semaphore;

                VkResult err = mCreateSemaphore(mDevice, &semaphoreInfo, nullptr, &semaphore);

                LOG_ALWAYS_FATAL_IF(VK_SUCCESS != err, "Failed to create import semaphore, err: %d",

                                    err);



                if (err != VK_SUCCESS) {

                    ALOGE("Failed to create import semaphore, err: %d", err);

                    close(fence_clone);

                    sync_wait(bufferInfo->dequeue_fence, -1 /* forever */);

                } else {

                    VkImportSemaphoreFdInfoKHR importInfo;

                    importInfo.sType = VK_STRUCTURE_TYPE_IMPORT_SEMAPHORE_FD_INFO_KHR;

                    importInfo.pNext = nullptr;
@@ -437,18 +439,27 @@ Frame VulkanManager::dequeueNextBuffer(VulkanSurface* surface) { 
                    importInfo.fd = fence_clone;



                    err = mImportSemaphoreFdKHR(mDevice, &importInfo);

                LOG_ALWAYS_FATAL_IF(VK_SUCCESS != err, "Failed to import semaphore, err: %d", err);



                    if (err != VK_SUCCESS) {

                        ALOGE("Failed to import semaphore, err: %d", err);

                        mDestroySemaphore(mDevice, semaphore, nullptr);

                        close(fence_clone);

                        sync_wait(bufferInfo->dequeue_fence, -1 /* forever */);

                    } else {

                        GrBackendSemaphore backendSemaphore;

                        backendSemaphore.initVulkan(semaphore);

                        // Skia will take ownership of the VkSemaphore and delete it once the wait

                        // has finished. The VkSemaphore also owns the imported fd, so it will

                        // close the fd when it is deleted.

                        bufferInfo->skSurface->wait(1, &backendSemaphore);

                // The following flush blocks the GPU immediately instead of waiting for other

                // drawing ops. It seems dequeue_fence is not respected otherwise.

                        // The following flush blocks the GPU immediately instead of waiting for

                        // other drawing ops. It seems dequeue_fence is not respected otherwise.

                        // TODO: remove the flush after finding why backendSemaphore is not working.

                        bufferInfo->skSurface->flushAndSubmit();

                    }

                }

            }

        }

    }



    int bufferAge = (mSwapBehavior == SwapBehavior::Discard) ? 0 : surface->getCurrentBuffersAge();

    return Frame(surface->logicalWidth(), surface->logicalHeight(), bufferAge);
@@ -621,6 +632,7 @@ status_t VulkanManager::fenceWait(int fence, GrDirectContext* grContext) { 
    VkSemaphore semaphore;

    VkResult err = mCreateSemaphore(mDevice, &semaphoreInfo, nullptr, &semaphore);

    if (VK_SUCCESS != err) {

        close(fenceFd);

        ALOGE("Failed to create import semaphore, err: %d", err);

        return UNKNOWN_ERROR;

    }
@@ -635,6 +647,7 @@ status_t VulkanManager::fenceWait(int fence, GrDirectContext* grContext) { 
    err = mImportSemaphoreFdKHR(mDevice, &importInfo);

    if (VK_SUCCESS != err) {

        mDestroySemaphore(mDevice, semaphore, nullptr);

        close(fenceFd);

        ALOGE("Failed to import semaphore, err: %d", err);

        return UNKNOWN_ERROR;

    }
@@ -642,7 +655,8 @@ status_t VulkanManager::fenceWait(int fence, GrDirectContext* grContext) { 
    GrBackendSemaphore beSemaphore;

    beSemaphore.initVulkan(semaphore);



    // Skia takes ownership of the semaphore and will delete it once the wait has finished.

    // Skia will take ownership of the VkSemaphore and delete it once the wait has finished. The

    // VkSemaphore also owns the imported fd, so it will close the fd when it is deleted.

    grContext->wait(1, &beSemaphore);

    grContext->flushAndSubmit();