Vulkan: need to serialize access to mFenceRecycler

src/libANGLE/renderer/vulkan/RendererVk.cpp

@@ -512,7 +512,10 @@ void RendererVk::onDestroy()
 
     mOneOffCommandPool.destroy(mDevice);
 
-    mFenceRecycler.destroy(mDevice);
+    {
+        std::lock_guard<std::mutex> lock(mFenceRecyclerMutex);
+        mFenceRecycler.destroy(mDevice);
+    }
 
     mPipelineLayoutCache.destroy(mDevice);
     mDescriptorSetLayoutCache.destroy(mDevice);
@@ -2205,19 +2208,27 @@ VkResult RendererVk::queuePresent(egl::ContextPriority priority,
 angle::Result RendererVk::newSharedFence(vk::Context *context,
                                          vk::Shared<vk::Fence> *sharedFenceOut)
 {
+    bool gotRecycledFence = false;
     vk::Fence fence;
-    if (mFenceRecycler.empty())
+    {
+        std::lock_guard<std::mutex> lock(mFenceRecyclerMutex);
+        if (!mFenceRecycler.empty())
+        {
+            mFenceRecycler.fetch(&fence);
+            gotRecycledFence = true;
+        }
+    }
+    if (gotRecycledFence)
+    {
+        ANGLE_VK_TRY(context, fence.reset(mDevice));
+    }
+    else
     {
         VkFenceCreateInfo fenceCreateInfo = {};
         fenceCreateInfo.sType             = VK_STRUCTURE_TYPE_FENCE_CREATE_INFO;
         fenceCreateInfo.flags             = 0;
         ANGLE_VK_TRY(context, fence.init(mDevice, fenceCreateInfo));
     }
-    else
-    {
-        mFenceRecycler.fetch(&fence);
-        ANGLE_VK_TRY(context, fence.reset(mDevice));
-    }
     sharedFenceOut->assign(mDevice, std::move(fence));
     return angle::Result::Continue;
 }

src/libANGLE/renderer/vulkan/RendererVk.h

@@ -200,6 +200,7 @@ class RendererVk : angle::NonCopyable
     angle::Result newSharedFence(vk::Context *context, vk::Shared<vk::Fence> *sharedFenceOut);
     inline void resetSharedFence(vk::Shared<vk::Fence> *sharedFenceIn)
     {
+        std::lock_guard<std::mutex> lock(mFenceRecyclerMutex);
         sharedFenceIn->resetAndRecycle(&mFenceRecycler);
     }
 
@@ -336,6 +337,7 @@ class RendererVk : angle::NonCopyable
 
     bool mDeviceLost;
 
+    std::mutex mFenceRecyclerMutex;
     vk::Recycler<vk::Fence> mFenceRecycler;
 
     std::mutex mGarbageMutex;