Lines Matching refs:dst_table
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()