Implementation of frontier primitive from SYGraph

cpp/oneapi/dal/backend/common.hpp

@@ -523,6 +523,11 @@ inline std::int64_t device_max_sg_size(const sycl::queue& q) {
     return dal::detail::integral_cast<std::int64_t>(*result_iter);
 }
 
+inline std::int64_t device_max_sg_count(const sycl::queue& q) {
+    const auto res = q.get_device().template get_info<sycl::info::device::max_num_sub_groups>();
+    return dal::detail::integral_cast<std::int64_t>(res);
+}
+
 inline std::int64_t propose_wg_size(const sycl::queue& q) {
     // TODO: a temporary solution that limits work item count used on the device.
     // Needs to change to more smart logic in the future.

cpp/oneapi/dal/backend/primitives/BUILD

@@ -37,6 +37,7 @@ dal_collect_modules(
         "lapack",
         "optimizers",
         "objective_function",
+        "frontier",
         "placement",
         "reduction",
         "regression",
@@ -88,6 +89,7 @@ dal_collect_test_suites(
         "lapack",
         "optimizers",
         "objective_function",
+        "frontier",
         "placement",
         "reduction",
         "regression",

cpp/oneapi/dal/backend/primitives/frontier.hpp

@@ -0,0 +1,3 @@
+#include "oneapi/dal/backend/primitives/frontier/frontier.hpp"
+#include "oneapi/dal/backend/primitives/frontier/advance.hpp"
+#include "oneapi/dal/backend/primitives/frontier/graph.hpp"

cpp/oneapi/dal/backend/primitives/frontier/BUILD

@@ -0,0 +1,44 @@
+package(default_visibility = ["//visibility:public"])
+load("@onedal//dev/bazel:dal.bzl",
+    "dal_module",
+    "dal_test_suite",
+)
+
+dal_module (
+    name = "frontier",
+    auto = True,
+    dal_deps = [
+        "@onedal//cpp/oneapi/dal/backend/primitives:common",
+        "@onedal//cpp/oneapi/dal/backend/primitives:blas",
+        "@onedal//cpp/oneapi/dal/backend/primitives/optimizers",
+        "@onedal//cpp/oneapi/dal/backend/primitives:sparse_blas",
+    ],
+)
+
+dal_test_suite (
+    name = "tests",
+    framework = "catch2",
+    compile_as = [ "dpc++" ],
+    private = True,
+    srcs = glob([
+        "test/*_dpc.cpp",
+    ], exclude=[
+        "test/*perf*.cpp",
+    ]),
+    dal_deps = [
+        ":frontier",
+    ],
+)
+
+dal_test_suite(
+    name = "perf_tests",
+    framework = "catch2",
+    compile_as = [ "dpc++" ],
+    private = True,
+    srcs = glob([
+        "test/*perf_dpc.cpp",
+    ]),
+    dal_deps = [
+        ":frontier",
+    ],
+)