Searched refs:dst_table (Results 1 – 1 of 1) sorted by relevance
355 void check_concurrent_merge( SrcTableType& start_data, DstTableType& dst_table, in check_concurrent_merge() argument358 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() argument388 …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() local415 …utils::NativeParallelFor(num_threads, [&](std::size_t index) { dst_table.merge(src_tables[index]);… in test_concurrent_merge()[all …]