kc3-lang/angle/src/common/WorkerThread_unittest.cpp

• Show log

  Commit

• Hash : e6ac77d9
  Author :
  Date : 2023-02-27T16:13:29
  

  Tests: Enable RunLockStepThreads OpenGL/GLES backend support.
  
  Added "EGL_CONTEXT_VIRTUALIZATION_GROUP_ANGLE" attribute if display
  has "EGL_ANGLE_context_virtualization" extension enabled.
  
  Bug: angleproject:8032
  Change-Id: I482475950b9d8d63891c74fc832cc13d93921e21
  Reviewed-on: https://chromium-review.googlesource.com/c/angle/angle/+/4291436
  Reviewed-by: Charlie Lao <cclao@google.com>
  Reviewed-by: Shahbaz Youssefi <syoussefi@chromium.org>
  Commit-Queue: Igor Nazarov <i.nazarov@samsung.com>
  

Download

• src/common/WorkerThread_unittest.cpp

• //
  // Copyright 2016 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.
  //
  // WorkerThread_unittest:
  //   Simple tests for the worker thread class.
  
  #include <gtest/gtest.h>
  #include <array>
  
  #include "common/WorkerThread.h"
  
  using namespace angle;
  
  namespace
  {
  
  // Tests simple worker pool application.
  TEST(WorkerPoolTest, SimpleTask)
  {
      class TestTask : public Closure
      {
        public:
          void operator()() override { fired = true; }
  
          bool fired = false;
      };
  
      std::array<std::shared_ptr<WorkerThreadPool>, 2> pools = {
          {WorkerThreadPool::Create(1, ANGLEPlatformCurrent()),
           WorkerThreadPool::Create(0, ANGLEPlatformCurrent())}};
      for (auto &pool : pools)
      {
          std::array<std::shared_ptr<TestTask>, 4> tasks = {
              {std::make_shared<TestTask>(), std::make_shared<TestTask>(),
               std::make_shared<TestTask>(), std::make_shared<TestTask>()}};
          std::array<std::shared_ptr<WaitableEvent>, 4> waitables = {
              {pool->postWorkerTask(tasks[0]), pool->postWorkerTask(tasks[1]),
               pool->postWorkerTask(tasks[2]), pool->postWorkerTask(tasks[3])}};
  
          WaitableEvent::WaitMany(&waitables);
  
          for (const auto &task : tasks)
          {
              EXPECT_TRUE(task->fired);
          }
      }
  }
  
  }  // anonymous namespace
  

Download