355 void check_concurrent_merge( SrcTableType& start_data, DstTableType& dst_table,  in check_concurrent_merge()  argument
358     REQUIRE_MESSAGE(dst_table.size() == start_data.size() * src_tables.size(),  in check_concurrent_merge()
362         REQUIRE_MESSAGE(dst_table.count(Value<DstTableType>::key(it)) ==  in check_concurrent_merge()
373 void check_concurrent_merge( SrcTableType& start_data, DstTableType& dst_table,  in check_concurrent_merge()  argument
388 …REQUIRE_MESSAGE((expected_result.size() == dst_table.size() && start_data.size() == dst_table.size…  in check_concurrent_merge()
392         if (dst_table.contains(Value<SrcTableType>::key(it)) &&  in check_concurrent_merge()
395             dst_table.unsafe_extract(Value<SrcTableType>::key(it));  in check_concurrent_merge()
402 …REQUIRE_MESSAGE((dst_table.empty() && start_data.empty()), "Merge: Some elements were not merged");  in check_concurrent_merge()
409         DstTableType dst_table;  in test_concurrent_merge()  local
415 …utils::NativeParallelFor(num_threads, [&](std::size_t index) { dst_table.merge(src_tables[index]);…  in test_concurrent_merge()
417         check_concurrent_merge(table_data, dst_table, src_tables,  in test_concurrent_merge()