Tests for queue empty oneAPI extension

CMakeLists.txt

@@ -55,6 +55,9 @@ add_cts_option(SYCL_CTS_ENABLE_EXT_ONEAPI_MEMCPY2D_TESTS
 add_cts_option(SYCL_CTS_ENABLE_EXT_ONEAPI_WEAK_OBJECT_TESTS
     "Enable extension oneAPI weak_object tests" OFF)
 
+add_cts_option(SYCL_CTS_ENABLE_EXT_ONEAPI_QUEUE_EMPTY
+    "Enable extension oneAPI queue_empty tests" OFF)
+
 add_cts_option(SYCL_CTS_ENABLE_EXT_ONEAPI_DISCARD_QUEUE_EVENTS_TESTS
     "Enable extension oneAPI discard_queue_events tests" OFF)
 

tests/extension/oneapi_queue_empty/CMakeLists.txt

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

tests/extension/oneapi_queue_empty/queue_empty_ext_test.cpp

@@ -0,0 +1,120 @@
+/*******************************************************************************
+//
+//  SYCL 2020 Conformance Test Suite
+//
+//  Copyright (c) 2023 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"
+
+namespace queue_empty::tests {
+constexpr size_t buf_size = 10;
+constexpr size_t iter_num = 10000000;
+
+template <size_t iter_num, typename AccT>
+class Kernel {
+  AccT array_acc;
+
+ public:
+  Kernel(AccT acc) : array_acc(acc) {}
+  void operator()() const {
+    for (size_t i = 0; i < iter_num; i++) {
+      int val = sycl::sqrt(float(i));
+      array_acc[val % array_acc.size()] = i;
+    }
+  }
+};
+
+TEST_CASE(
+    "Test for \"Queue empty\" extension, check extension functionality"
+    "when no commands are submitted to the queue",
+    "[oneapi_queue_empty]") {
+#ifndef SYCL_EXT_ONEAPI_QUEUE_EMPTY
+  SKIP("SYCL_EXT_ONEAPI_QUEUE_EMPTY is not defined");
+#else
+  auto queue = sycl_cts::util::get_cts_object::queue();
+  auto is_empty = queue.ext_oneapi_empty();
+  CHECK(std::is_same_v<decltype(is_empty), bool>);
+  CHECK(is_empty);
+#endif
+}
+
+TEST_CASE(
+    "Test for \"Queue empty\" extension, check extension functionality"
+    "after commands are submitted to the queue, test 1",
+    "[oneapi_queue_empty]") {
+#ifndef SYCL_EXT_ONEAPI_QUEUE_EMPTY
+  SKIP("SYCL_EXT_ONEAPI_QUEUE_EMPTY is not defined");
+#else
+  auto queue = sycl_cts::util::get_cts_object::queue();
+
+  sycl::buffer<size_t, 1> array_buf(buf_size);
+
+  auto e = queue.submit([&](sycl::handler& cgh) {
+    auto array_acc = sycl::accessor(array_buf, cgh, sycl::write_only);
+    cgh.single_task(Kernel<iter_num, decltype(array_acc)>(array_acc));
+  });
+
+  bool is_empty = queue.ext_oneapi_empty();
+  if (e.get_info<sycl::info::event::command_execution_status>() !=
+      sycl::info::event_command_status::complete) {
+    CHECK(!is_empty);
+  }
+
+  queue.wait();
+
+  is_empty = queue.ext_oneapi_empty();
+  CHECK(is_empty);
+#endif
+}
+
+TEST_CASE(
+    "Test for \"Queue empty\" extension, check extension functionality"
+    "after commands are submitted to the queue, test 2",
+    "[oneapi_queue_empty]") {
+#ifndef SYCL_EXT_ONEAPI_QUEUE_EMPTY
+  SKIP("SYCL_EXT_ONEAPI_QUEUE_EMPTY is not defined");
+#else
+  auto queue = sycl_cts::util::get_cts_object::queue();
+
+  size_t array[buf_size];
+  sycl::buffer<size_t, 1> array_buf(array, buf_size);
+
+  auto Ea = queue.submit([&](sycl::handler& cgh) {
+    auto array_acc = sycl::accessor(array_buf, cgh, sycl::write_only);
+    cgh.single_task(Kernel<iter_num, decltype(array_acc)>(array_acc));
+  });
+
+  auto Eb = queue.submit([&](sycl::handler& cgh) {
+    cgh.depends_on(Ea);
+    auto array_acc = sycl::accessor(array_buf, cgh, sycl::write_only);
+    cgh.single_task(Kernel<iter_num, decltype(array_acc)>(array_acc));
+  });
+
+  Ea.wait();
+
+  bool is_empty = queue.ext_oneapi_empty();
+  if (Eb.get_info<sycl::info::event::command_execution_status>() !=
+      sycl::info::event_command_status::complete) {
+    CHECK(!is_empty);
+  }
+
+  Eb.wait();
+
+  is_empty = queue.ext_oneapi_empty();
+  CHECK(is_empty);
+#endif
+}
+}  // namespace queue_empty::tests