//@HEADER // ************************************************************************ // // Kokkos v. 4.0 // Copyright (2022) National Technology & Engineering // Solutions of Sandia, LLC (NTESS). // // Under the terms of Contract DE-NA0003525 with NTESS, // the U.S. Government retains certain rights in this software. // // Part of Kokkos, under the Apache License v2.0 with LLVM Exceptions. // See https://kokkos.org/LICENSE for license information. // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception // //@HEADER #include #include #include "std_algorithms/Kokkos_AdjacentFind.hpp" #include namespace Test { namespace stdalgos { namespace AdjacentFind { namespace KE = Kokkos::Experimental; // impl is here for std because it is only avail from c++>=17 template auto my_unique_copy(InputIterator first, InputIterator last, OutputIterator result, BinaryPredicate pred) { if (first != last) { typename OutputIterator::value_type t(*first); *result = t; ++result; while (++first != last) { if (!pred(t, *first)) { t = *first; *result = t; ++result; } } } return result; } template auto my_unique_copy(InputIterator first, InputIterator last, OutputIterator result) { using value_type = typename OutputIterator::value_type; using func_t = IsEqualFunctor; return my_unique_copy(first, last, result, func_t()); } template struct UnifDist; template <> struct UnifDist { using dist_type = std::uniform_int_distribution; std::mt19937 m_gen; dist_type m_dist; // make bounds tight so that it is likely we get // consecutive equal elements UnifDist() : m_dist(2, 8) { m_gen.seed(345823); } int operator()() { return m_dist(m_gen); } }; template <> struct UnifDist { using dist_type = std::uniform_real_distribution; std::mt19937 m_gen; dist_type m_dist; // make bounds tight so that it is likely we get // consecutive equal elements UnifDist() : m_dist(2, 8) { m_gen.seed(345823); } double operator()() { return m_dist(m_gen); } }; template void fill_view(ViewType dest_view, const std::string& name) { using value_type = typename ViewType::value_type; using exe_space = typename ViewType::execution_space; const std::size_t ext = dest_view.extent(0); using aux_view_t = Kokkos::View; aux_view_t aux_view("aux_view", ext); auto v_h = create_mirror_view(Kokkos::HostSpace(), aux_view); if (name == "empty") { // no op } else if (name == "one-element-a") { v_h(0) = static_cast(1); } else if (name == "one-element-b") { v_h(0) = static_cast(2); } else if (name == "two-elements-a") { v_h(0) = static_cast(1); v_h(1) = static_cast(2); } else if (name == "two-elements-b") { v_h(0) = static_cast(2); v_h(1) = static_cast(-1); } else if (name == "small-a") { v_h(0) = static_cast(0); v_h(1) = static_cast(1); v_h(2) = static_cast(2); v_h(3) = static_cast(3); v_h(4) = static_cast(2); v_h(5) = static_cast(5); v_h(6) = static_cast(4); v_h(7) = static_cast(4); v_h(8) = static_cast(5); v_h(9) = static_cast(6); v_h(10) = static_cast(6); } else if (name == "small-b") { v_h(0) = static_cast(1); v_h(1) = static_cast(1); v_h(2) = static_cast(1); v_h(3) = static_cast(2); v_h(4) = static_cast(3); v_h(5) = static_cast(4); v_h(6) = static_cast(4); v_h(7) = static_cast(4); v_h(8) = static_cast(5); v_h(9) = static_cast(6); v_h(10) = static_cast(8); v_h(11) = static_cast(9); v_h(12) = static_cast(8); } else if (name == "medium") { // beginning just contains increasing values for (std::size_t i = 0; i < 1000; ++i) { v_h(i) = static_cast(i); } // then use random UnifDist randObj; for (std::size_t i = 1000; i < ext; ++i) { v_h(i) = randObj(); } } else if (name == "large-a") { // put equal elements at the end for (std::size_t i = 0; i < ext; ++i) { v_h(i) = static_cast(i); } v_h(ext - 3) = static_cast(44); v_h(ext - 2) = static_cast(44); v_h(ext - 1) = static_cast(44); } else if (name == "large-b") { UnifDist randObj; for (std::size_t i = 0; i < ext; ++i) { v_h(i) = randObj(); } } else { throw std::runtime_error("invalid choice"); } Kokkos::deep_copy(aux_view, v_h); CopyFunctor F1(aux_view, dest_view); Kokkos::parallel_for("copy", dest_view.extent(0), F1); } template IteratorType my_std_adjacent_find(IteratorType first, IteratorType last, BinaryPredicate p) { if (first == last) { return last; } IteratorType next = first; ++next; for (; next != last; ++next, ++first) { if (p(*first, *next)) { return first; } } return last; } template IteratorType my_std_adjacent_find(IteratorType first, IteratorType last) { using value_type = typename IteratorType::value_type; return my_std_adjacent_find(first, last, IsEqualFunctor()); } std::string value_type_to_string(int) { return "int"; } std::string value_type_to_string(double) { return "double"; } template void print_scenario_details(const std::string& name) { std::cout << "adjacent_find: default predicate: " << name << ", " << view_tag_to_string(Tag{}) << " " << value_type_to_string(ValueType()) << '\n'; } template void print_scenario_details(const std::string& name, Predicate pred) { (void)pred; std::cout << "adjacent_find: custom predicate: " << name << ", " << view_tag_to_string(Tag{}) << " " << value_type_to_string(ValueType()) << '\n'; } template void verify(DiffType my_diff, ViewType view, Args... args) { auto view_dc = create_deep_copyable_compatible_clone(view); auto view_h = create_mirror_view_and_copy(Kokkos::HostSpace(), view_dc); auto std_r = my_std_adjacent_find(KE::cbegin(view_h), KE::cend(view_h), args...); const auto std_diff = std_r - KE::cbegin(view_h); ASSERT_EQ(my_diff, std_diff); } template void run_single_scenario(const InfoType& scenario_info, Args... args) { const auto name = std::get<0>(scenario_info); const std::size_t view_ext = std::get<1>(scenario_info); // print_scenario_details(name, args...); auto view = create_view(Tag{}, view_ext, "adjacent_find_view"); fill_view(view, name); { auto res_it = KE::adjacent_find(exespace(), KE::cbegin(view), KE::cend(view), args...); const auto my_diff = res_it - KE::cbegin(view); verify(my_diff, view, args...); } { auto res_it = KE::adjacent_find("label", exespace(), KE::cbegin(view), KE::cend(view), args...); const auto my_diff = res_it - KE::cbegin(view); verify(my_diff, view, args...); } { auto res_it = KE::adjacent_find(exespace(), view, args...); const auto my_diff = res_it - KE::begin(view); verify(my_diff, view, args...); } { auto res_it = KE::adjacent_find("label", exespace(), view, args...); const auto my_diff = res_it - KE::begin(view); verify(my_diff, view, args...); } Kokkos::fence(); } template void run_all_scenarios() { const std::map scenarios = { {"empty", 0}, {"one-element-a", 1}, {"one-element-b", 1}, {"two-elements-a", 2}, {"two-elements-b", 2}, {"small-a", 11}, {"small-b", 13}, {"medium", 21103}, {"large-a", 101513}, {"large-b", 100111}}; for (const auto& it : scenarios) { run_single_scenario(it); using func_t = IsEqualFunctor; run_single_scenario(it, func_t()); } } TEST(std_algorithms_nonmod_seq_ops, adjacent_find) { run_all_scenarios(); run_all_scenarios(); run_all_scenarios(); } } // namespace AdjacentFind } // namespace stdalgos } // namespace Test