Searched refs:start_data (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()361 for (auto it : start_data) { in check_concurrent_merge()363 start_data.count(Value<SrcTableType>::key(it)) * src_tables.size(), in check_concurrent_merge()373 void check_concurrent_merge( SrcTableType& start_data, DstTableType& dst_table, in check_concurrent_merge() argument378 for (auto it : start_data) { in check_concurrent_merge()388 …REQUIRE_MESSAGE((expected_result.size() == dst_table.size() && start_data.size() == dst_table.size… in check_concurrent_merge()393 start_data.contains(Value<DstTableType>::key(it))) in check_concurrent_merge()396 start_data.unsafe_extract(Value<DstTableType>::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()