//@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 namespace Test { namespace stdalgos { namespace Remove { namespace KE = Kokkos::Experimental; constexpr int match_value = 4; template struct UnifDist; template <> struct UnifDist { using dist_type = std::uniform_int_distribution; std::mt19937 m_gen; dist_type m_dist; UnifDist() : m_dist(-100, 100) { m_gen.seed(1034343); } int 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(match_value); } else if (name == "two-elements-a") { v_h(0) = static_cast(1); v_h(1) = static_cast(match_value); } else if (name == "two-elements-b") { v_h(0) = static_cast(match_value); v_h(1) = static_cast(-1); } else if (name == "small-a") { for (std::size_t i = 0; i < ext; ++i) { v_h(i) = static_cast(i + 1); } } else if (name == "small-b") { for (std::size_t i = 0; i < ext; ++i) { if (i % 2 == 0) { v_h(i) = static_cast(match_value); } else { v_h(i) = static_cast(-12); } } } else if (name == "medium" || name == "large") { UnifDist randObj; for (std::size_t i = 0; i < ext; ++i) { if (i % 8 == 0) { v_h(i) = static_cast(match_value); } else { 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 void verify_data(ViewTypeData view_data_h, ViewTypeTest view_test, MyItResult my_result) { // run std::remove auto std_result = std::remove(KE::begin(view_data_h), KE::end(view_data_h), match_value); // check that returned iterators are correct const std::size_t std_diff = std_result - KE::begin(view_data_h); const std::size_t my_diff = my_result - KE::begin(view_test); ASSERT_EQ(std_diff, my_diff); // check the actual data after algo has been applied auto view_test_h = create_host_space_copy(view_test); for (std::size_t i = 0; i < my_diff; ++i) { ASSERT_EQ(view_test_h(i), view_data_h[i]); // std::cout << "i= " << i << " " // << "mine: " << view_test_h(i) << " " // << "std: " << view_data_h(i) // << '\n'; } } std::string value_type_to_string(int) { return "int"; } std::string value_type_to_string(double) { return "double"; } template void run_single_scenario(const InfoType& scenario_info) { const auto name = std::get<0>(scenario_info); const std::size_t view_ext = std::get<1>(scenario_info); // std::cout << "remove: " << name << ", " << view_tag_to_string(Tag{}) << ", // " // << value_type_to_string(ValueType()) << std::endl; { auto view = create_view(Tag{}, view_ext, "remove_from"); fill_view(view, name); // make host copy BEFORE running algo auto data_h = create_host_space_copy(view); auto rit = KE::remove(exespace(), KE::begin(view), KE::end(view), (ValueType)match_value); verify_data(data_h, view, rit); } { auto view = create_view(Tag{}, view_ext, "remove_from"); fill_view(view, name); // make host copy BEFORE running algo auto data_h = create_host_space_copy(view); auto rit = KE::remove("label", exespace(), KE::begin(view), KE::end(view), (ValueType)match_value); verify_data(data_h, view, rit); } { auto view = create_view(Tag{}, view_ext, "remove_from"); fill_view(view, name); // make host copy BEFORE running algo auto data_h = create_host_space_copy(view); auto rit = KE::remove(exespace(), view, (ValueType)match_value); verify_data(data_h, view, rit); } { auto view = create_view(Tag{}, view_ext, "remove_from"); fill_view(view, name); // make host copy BEFORE running algo auto data_h = create_host_space_copy(view); auto rit = KE::remove("label", exespace(), view, (ValueType)match_value); verify_data(data_h, view, rit); } 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", 9}, {"small-b", 13}, {"medium", 13031}, {"large", 101513}}; for (const auto& it : scenarios) { run_single_scenario(it); } } TEST(std_algorithms_mod_seq_ops, remove) { run_all_scenarios(); run_all_scenarios(); } } // namespace Remove } // namespace stdalgos } // namespace Test