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

Commit d6670778 authored by Greg Daniel's avatar Greg Daniel
Browse files

Make sure to close vulkan fd's in error cases 

In one set of the fixed cases we actually were never closing the
fd. In the other set we would crash with a fatal error. Now both
have been updated to handle the failures and correctly close the
fd to make sure it all works.

However, I don't think this is the route case of the leaking fds
from the bug since I don't believe we are seeing any of the
corresponding error messages in the logs.

Test: Manual running on phone and watching logs.
Bug: 187240173
Change-Id: I18babe91b0ec83ca63199f06d3d02ec10e8aea85
parent 894c5d3d

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();