kc3-lang/angle/src/libANGLE/renderer/vulkan/ResourceVk.cpp

• Show log

  Commit

• Hash : ed876984
  Author :
  Date : 2020-10-03T11:00:36
  

  Vulkan: functionally complete worker thread
  
  Working on enhancing worker thread to completely own primary command
  buffers. This will include not only processing SCBs from main thread
  into a primary, but also submitting those command buffers to the queue.
  
  The CommandProcessor is a vk::Context so it can handle errors in the
  worker thread. When the main thread submits tasks to the worker
  thread it also syncs any outstanding errors from the worker.
  
  Include asynchronousCommandProcessing feature that will control
  whether the worker thread task does it's work in parallel or not. If
  false, we wait for the thread to complete it's work before letting the
  main thread continue.  If true, the thread can execute in parallel with
  the main thread.
  
  Bug: b/154030730
  Bug: b/161912801
  Change-Id: I00f8f013d6cbb2af12a172c4f7927855db2f0ebf
  Reviewed-on: https://chromium-review.googlesource.com/c/angle/angle/+/2328992
  Commit-Queue: Courtney Goeltzenleuchter <courtneygo@google.com>
  Reviewed-by: Tim Van Patten <timvp@google.com>
  Reviewed-by: Jamie Madill <jmadill@chromium.org>
  

Download

• src/libANGLE/renderer/vulkan/ResourceVk.cpp

• //
  // Copyright 2017 The ANGLE Project Authors. All rights reserved.
  // Use of this source code is governed by a BSD-style license that can be
  // found in the LICENSE file.
  //
  // Resource:
  //    Resource lifetime tracking in the Vulkan back-end.
  //
  
  #include "libANGLE/renderer/vulkan/ResourceVk.h"
  
  #include "libANGLE/renderer/vulkan/ContextVk.h"
  
  namespace rx
  {
  namespace vk
  {
  // Resource implementation.
  Resource::Resource()
  {
      mUse.init();
  }
  
  Resource::Resource(Resource &&other) : Resource()
  {
      mUse = std::move(other.mUse);
  }
  
  Resource::~Resource()
  {
      mUse.release();
  }
  
  angle::Result Resource::finishRunningCommands(ContextVk *contextVk)
  {
      return contextVk->finishToSerial(mUse.getSerial());
  }
  
  angle::Result Resource::waitForIdle(ContextVk *contextVk, const char *debugMessage)
  {
      // If there are pending commands for the resource, flush them.
      if (usedInRecordedCommands())
      {
          ANGLE_TRY(contextVk->flushImpl(nullptr));
      }
  
      // Make sure the driver is done with the resource.
      if (usedInRunningCommands(contextVk->getLastCompletedQueueSerial()))
      {
          if (debugMessage)
          {
              ANGLE_PERF_WARNING(contextVk->getDebug(), GL_DEBUG_SEVERITY_HIGH, debugMessage);
          }
          ANGLE_TRY(finishRunningCommands(contextVk));
      }
  
      ASSERT(!isCurrentlyInUse(contextVk->getLastCompletedQueueSerial()));
  
      return angle::Result::Continue;
  }
  
  // SharedGarbage implementation.
  SharedGarbage::SharedGarbage() = default;
  
  SharedGarbage::SharedGarbage(SharedGarbage &&other)
  {
      *this = std::move(other);
  }
  
  SharedGarbage::SharedGarbage(SharedResourceUse &&use, std::vector<GarbageObject> &&garbage)
      : mLifetime(std::move(use)), mGarbage(std::move(garbage))
  {}
  
  SharedGarbage::~SharedGarbage() = default;
  
  SharedGarbage &SharedGarbage::operator=(SharedGarbage &&rhs)
  {
      std::swap(mLifetime, rhs.mLifetime);
      std::swap(mGarbage, rhs.mGarbage);
      return *this;
  }
  
  bool SharedGarbage::destroyIfComplete(RendererVk *renderer, Serial completedSerial)
  {
      if (mLifetime.isCurrentlyInUse(completedSerial))
          return false;
  
      for (GarbageObject &object : mGarbage)
      {
          object.destroy(renderer);
      }
  
      mLifetime.release();
  
      return true;
  }
  
  // ResourceUseList implementation.
  ResourceUseList::ResourceUseList()
  {
      constexpr size_t kDefaultResourceUseCount = 4096;
      mResourceUses.reserve(kDefaultResourceUseCount);
  }
  
  ResourceUseList::ResourceUseList(ResourceUseList &&other)
  {
      *this = std::move(other);
  }
  
  ResourceUseList::~ResourceUseList()
  {
      ASSERT(mResourceUses.empty());
  }
  
  ResourceUseList &ResourceUseList::operator=(ResourceUseList &&rhs)
  {
      std::swap(mResourceUses, rhs.mResourceUses);
      return *this;
  }
  
  void ResourceUseList::releaseResourceUses()
  {
      for (SharedResourceUse &use : mResourceUses)
      {
          use.release();
      }
  
      mResourceUses.clear();
  }
  
  void ResourceUseList::releaseResourceUsesAndUpdateSerials(Serial serial)
  {
      for (SharedResourceUse &use : mResourceUses)
      {
          use.releaseAndUpdateSerial(serial);
      }
  
      mResourceUses.clear();
  }
  }  // namespace vk
  }  // namespace rx
  

Download