Merge pull request #1094 from KhronosGroup/khr_queue_flush

[khr_queue_flush] Add tests

Author: tomdeakin

CMakeLists.txt

@@ -152,6 +152,10 @@ add_cts_option(SYCL_CTS_ENABLE_KHR_WORK_ITEM_QUERIES_TESTS
     "Enable extension Khronos work_item_queries tests" OFF
     FORCE_ON ${SYCL_CTS_ENABLE_KHR_TESTS})
 
+add_cts_option(SYCL_CTS_ENABLE_KHR_QUEUE_FLUSH_TESTS
+    "Enable extension Khronos queue_flush tests" OFF
+    FORCE_ON ${SYCL_CTS_ENABLE_KHR_TESTS})
+
 # TODO: Deprecated - remove
 add_cts_option(SYCL_CTS_ENABLE_VERBOSE_LOG
     "Enable debug-level logs (deprecated)" OFF)

tests/extension/khr_queue_flush/CMakeLists.txt

@@ -0,0 +1,5 @@
+if(SYCL_CTS_ENABLE_KHR_QUEUE_FLUSH_TESTS)
+    file(GLOB test_cases_list *.cpp)
+
+    add_cts_test(${test_cases_list})
+endif()

tests/extension/khr_queue_flush/queue_flush.cpp

@@ -0,0 +1,56 @@
+/*******************************************************************************
+//
+//  SYCL 2020 Conformance Test Suite
+//
+//  Copyright (c) 2025 The Khronos Group Inc.
+//
+//  Licensed under the Apache License, Version 2.0 (the "License");
+//  you may not use this file except in compliance with the License.
+//  You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+//  Unless required by applicable law or agreed to in writing, software
+//  distributed under the License is distributed on an "AS IS" BASIS,
+//  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//  See the License for the specific language governing permissions and
+//  limitations under the License.
+//
+*******************************************************************************/
+
+#include "../../common/common.h"
+#include <future>
+
+namespace queue_flush::tests {
+
+TEST_CASE(
+    "the queue flush extension defines the "
+    "SYCL_KHR_QUEUE_FLUSH macro",
+    "[khr_queue_flush]") {
+#ifndef SYCL_KHR_QUEUE_FLUSH
+  static_assert(false, "SYCL_KHR_QUEUE_FLUSH is not defined");
+#endif
+}
+
+TEST_CASE("Flush and spin lock event", "[khr_queue_flush]") {
+  sycl::queue q;
+  auto e = q.single_task([] {});
+  q.khr_flush();
+  while (e.get_info<sycl::info::event::command_execution_status>() !=
+         sycl::info::event_command_status::complete) {
+  };
+}
+
+TEST_CASE("Flush and host task", "[khr_queue_flush]") {
+  sycl::queue q;
+  std::promise<void> promise;
+
+  q.submit([&](sycl::handler& cgh) {
+    cgh.host_task([&] { promise.get_future().wait(); });
+  });
+  q.khr_flush();
+  promise.set_value();
+  q.wait();
+}
+
+}  // namespace queue_flush::tests