diff --git a/test/Jamfile.v2 b/test/Jamfile.v2 index 8cf8e40c..8d985b65 100644 --- a/test/Jamfile.v2 +++ b/test/Jamfile.v2 @@ -191,6 +191,7 @@ local CFOA_TESTS = equality_tests fwd_tests exception_insert_tests + exception_erase_tests ; for local test in $(CFOA_TESTS) diff --git a/test/cfoa/exception_erase_tests.cpp b/test/cfoa/exception_erase_tests.cpp new file mode 100644 index 00000000..ac4e8c3a --- /dev/null +++ b/test/cfoa/exception_erase_tests.cpp @@ -0,0 +1,294 @@ +// Copyright (C) 2023 Christian Mazakas +// Distributed under the Boost Software License, Version 1.0. (See accompanying +// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) + +#include "exception_helpers.hpp" + +#include + +#include + +namespace { + test::seed_t initialize_seed(3202923); + + struct lvalue_eraser_type + { + template void operator()(std::vector& values, X& x) + { + std::atomic num_erased{0}; + auto const old_size = x.size(); + + auto const old_dc = +raii::default_constructor; + auto const old_cc = +raii::copy_constructor; + auto const old_mc = +raii::move_constructor; + + auto const old_d = +raii::destructor; + + BOOST_TEST_EQ(raii::default_constructor + raii::copy_constructor + + raii::move_constructor, + raii::destructor + 2 * x.size()); + + enable_exceptions(); + thread_runner(values, [&values, &num_erased, &x](boost::span) { + for (auto const& k : values) { + try { + auto count = x.erase(k.first); + num_erased += count; + BOOST_TEST_LE(count, 1u); + BOOST_TEST_GE(count, 0u); + } catch (...) { + } + } + }); + disable_exceptions(); + + BOOST_TEST_EQ(raii::default_constructor, old_dc); + BOOST_TEST_EQ(raii::copy_constructor, old_cc); + BOOST_TEST_EQ(raii::move_constructor, old_mc); + + BOOST_TEST_EQ(raii::destructor, old_d + 2 * old_size); + + BOOST_TEST_EQ(x.size(), 0u); + BOOST_TEST(x.empty()); + BOOST_TEST_EQ(num_erased, old_size); + } + } lvalue_eraser; + + struct lvalue_eraser_if_type + { + template void operator()(std::vector& values, X& x) + { + using value_type = typename X::value_type; + + std::atomic num_erased{0}; + + auto const old_size = x.size(); + + auto const old_dc = +raii::default_constructor; + auto const old_cc = +raii::copy_constructor; + auto const old_mc = +raii::move_constructor; + + auto const old_d = +raii::destructor; + + auto max = 0; + x.visit_all([&max](value_type const& v) { + if (v.second.x_ > max) { + max = v.second.x_; + } + }); + + auto threshold = max / 2; + + auto expected_erasures = 0u; + x.visit_all([&expected_erasures, threshold](value_type const& v) { + if (v.second.x_ > threshold) { + ++expected_erasures; + } + }); + + enable_exceptions(); + thread_runner(values, [&num_erased, &x, threshold](boost::span s) { + for (auto const& k : s) { + try { + auto count = x.erase_if(k.first, + [threshold](value_type& v) { return v.second.x_ > threshold; }); + num_erased += count; + BOOST_TEST_LE(count, 1u); + BOOST_TEST_GE(count, 0u); + } catch (...) { + } + } + }); + disable_exceptions(); + + BOOST_TEST_LE(num_erased, expected_erasures); + BOOST_TEST_EQ(x.size(), old_size - num_erased); + + BOOST_TEST_EQ(raii::default_constructor, old_dc); + BOOST_TEST_EQ(raii::copy_constructor, old_cc); + BOOST_TEST_EQ(raii::move_constructor, old_mc); + + BOOST_TEST_EQ(raii::destructor, old_d + 2 * num_erased); + } + } lvalue_eraser_if; + + struct erase_if_type + { + template void operator()(std::vector& values, X& x) + { + using value_type = typename X::value_type; + + std::atomic num_erased{0}; + + auto const old_size = x.size(); + + auto const old_dc = +raii::default_constructor; + auto const old_cc = +raii::copy_constructor; + auto const old_mc = +raii::move_constructor; + + auto const old_d = +raii::destructor; + + auto max = 0; + x.visit_all([&max](value_type const& v) { + if (v.second.x_ > max) { + max = v.second.x_; + } + }); + + auto threshold = max / 2; + + auto expected_erasures = 0u; + x.visit_all([&expected_erasures, threshold](value_type const& v) { + if (v.second.x_ > threshold) { + ++expected_erasures; + } + }); + + enable_exceptions(); + thread_runner( + values, [&num_erased, &x, threshold](boost::span /* s */) { + for (std::size_t i = 0; i < 128; ++i) { + try { + auto count = x.erase_if([threshold](value_type& v) { + static std::atomic c{0}; + auto t = ++c; + if (should_throw && (t % throw_threshold == 0)) { + throw exception_tag{}; + } + + return v.second.x_ > threshold; + }); + + num_erased += count; + } catch (...) { + } + } + }); + disable_exceptions(); + + BOOST_TEST_GT(num_erased, 0u); + + BOOST_TEST_EQ(raii::default_constructor, old_dc); + BOOST_TEST_EQ(raii::copy_constructor, old_cc); + BOOST_TEST_EQ(raii::move_constructor, old_mc); + + BOOST_TEST_EQ(raii::destructor, old_d + 2 * (old_size - x.size())); + } + } erase_if; + + struct free_fn_erase_if_type + { + template void operator()(std::vector& values, X& x) + { + using value_type = typename X::value_type; + + std::atomic num_erased{0}; + + auto const old_size = x.size(); + + auto const old_dc = +raii::default_constructor; + auto const old_cc = +raii::copy_constructor; + auto const old_mc = +raii::move_constructor; + + auto const old_d = +raii::destructor; + + auto max = 0; + x.visit_all([&max](value_type const& v) { + if (v.second.x_ > max) { + max = v.second.x_; + } + }); + + auto threshold = max / 2; + + auto expected_erasures = 0u; + x.visit_all([&expected_erasures, threshold](value_type const& v) { + if (v.second.x_ > threshold) { + ++expected_erasures; + } + }); + + enable_exceptions(); + thread_runner( + values, [&num_erased, &x, threshold](boost::span /* s */) { + for (std::size_t i = 0; i < 128; ++i) { + try { + auto count = + boost::unordered::erase_if(x, [threshold](value_type& v) { + static std::atomic c{0}; + auto t = ++c; + if (should_throw && (t % throw_threshold == 0)) { + throw exception_tag{}; + } + + return v.second.x_ > threshold; + }); + + num_erased += count; + } catch (...) { + } + } + }); + disable_exceptions(); + + BOOST_TEST_GT(num_erased, 0u); + BOOST_TEST_LE(num_erased, expected_erasures); + + BOOST_TEST_EQ(raii::default_constructor, old_dc); + BOOST_TEST_EQ(raii::copy_constructor, old_cc); + BOOST_TEST_EQ(raii::move_constructor, old_mc); + + BOOST_TEST_EQ(raii::destructor, old_d + 2 * (old_size - x.size())); + } + } free_fn_erase_if; + + template + void erase(X*, G gen, F eraser, test::random_generator rg) + { + auto values = make_random_values(1024 * 16, [&] { return gen(rg); }); + auto reference_map = + boost::unordered_flat_map(values.begin(), values.end()); + raii::reset_counts(); + + { + X x; + + x.insert(values.begin(), values.end()); + + BOOST_TEST_EQ(x.size(), reference_map.size()); + + using value_type = typename X::value_type; + BOOST_TEST_EQ(x.size(), x.visit_all([&](value_type const& kv) { + BOOST_TEST(reference_map.contains(kv.first)); + if (rg == test::sequential) { + BOOST_TEST_EQ(kv.second, reference_map[kv.first]); + } + })); + + eraser(values, x); + test_fuzzy_matches_reference(x, reference_map, rg); + } + + check_raii_counts(); + } + + boost::unordered::concurrent_flat_map > >* map; + +} // namespace + +using test::default_generator; +using test::limited_range; +using test::sequential; + +// clang-format off +UNORDERED_TEST( + erase, + ((map)) + ((exception_value_type_generator)(exception_init_type_generator)) + ((lvalue_eraser)(lvalue_eraser_if)(erase_if)(free_fn_erase_if)) + ((default_generator)(sequential)(limited_range))) + +// clang-format on + +RUN_TESTS() diff --git a/test/cfoa/exception_helpers.hpp b/test/cfoa/exception_helpers.hpp index 0fd63833..0645ff21 100644 --- a/test/cfoa/exception_helpers.hpp +++ b/test/cfoa/exception_helpers.hpp @@ -28,7 +28,7 @@ static std::size_t const num_threads = std::atomic_bool should_throw{false}; -constexpr std::uint32_t threshold = 2500; +constexpr std::uint32_t throw_threshold = 2500; void enable_exceptions() { should_throw = true; } void disable_exceptions() { should_throw = false; } @@ -45,8 +45,8 @@ struct stateful_hash void throw_helper() const { - ++c; - if (should_throw && (c % threshold == 0)) { + auto n = ++c; + if (should_throw && (n % throw_threshold == 0)) { throw exception_tag{}; } } @@ -95,8 +95,8 @@ struct stateful_key_equal void throw_helper() const { - ++c; - if (should_throw && (c % threshold == 0)) { + auto n = ++c; + if (should_throw && (n % throw_threshold == 0)) { throw exception_tag{}; } } @@ -143,8 +143,8 @@ template struct stateful_allocator void throw_helper() const { - ++c; - if (should_throw && (c % threshold == 0)) { + auto n = ++c; + if (should_throw && (n % 10 == 0)) { throw exception_tag{}; } } @@ -189,8 +189,8 @@ struct raii static std::atomic c; void throw_helper() const { - ++c; - if (should_throw && (c % threshold == 0)) { + auto n = ++c; + if (should_throw && (n % throw_threshold == 0)) { throw exception_tag{}; } }