| /oneTBB/test/tbb/ |
| H A D | test_tagged_msg.cpp | 66 CHECK_MESSAGE( (*(wip.value()) == 23), "Error in wip value"); in TestWrapper() 105 CHECK_MESSAGE( (i == 42), "Assignment to i failed"); in TestWrapper() 128 CHECK_MESSAGE( (is_a<int>(i)), "wrong type for i ( == int)"); in RunTests() 134 CHECK_MESSAGE( (ref_i == 3), "ref_i got wrong value"); in RunTests() 139 CHECK_MESSAGE( ( z == 3), "Error retrieving value from i"); in RunTests() 142 CHECK_MESSAGE( (j.tag() == 2), "Error retrieving tag for j"); in RunTests() 144 CHECK_MESSAGE( (j.tag() == 10), "Error updating tag for j"); in RunTests() 148 CHECK_MESSAGE( (k.tag() == 'b'), "Error updating char tag"); in RunTests() 190 CHECK_MESSAGE( ((int)(*ctip) == 0), "ctip incorrect"); in RunTests() 217 CHECK_MESSAGE( (false), "Bad cast"); in RunTests() [all …]
|
| H A D | test_priority_queue_node.cpp | 76 CHECK_MESSAGE(v < prev, ""); in operator ()() 124 CHECK_MESSAGE( v == T(3), "" ); in test_reservation() 129 CHECK_MESSAGE( v == T(3), "" ); in test_reservation() 135 CHECK_MESSAGE( v == T(2), "" ); in test_reservation() 178 CHECK_MESSAGE(j == i, ""); in test_parallel() 223 CHECK_MESSAGE(j == i, ""); in test_parallel() 271 CHECK_MESSAGE( i == j, "" ); in test_serial() 286 CHECK_MESSAGE( i == j, "" ); in test_serial() 302 CHECK_MESSAGE( j == 1, "" ); in test_serial() 314 CHECK_MESSAGE( i == j, "" ); in test_serial() [all …]
|
| H A D | test_queue_node.cpp | 75 CHECK_MESSAGE( msg == true, "" ); in operator ()() 214 CHECK_MESSAGE( v == T(1), "" ); in test_reservation() 219 CHECK_MESSAGE( v == T(1), "" ); in test_reservation() 225 CHECK_MESSAGE( v == T(2), "" ); in test_reservation() 230 CHECK_MESSAGE( v == T(3), "" ); in test_reservation() 235 CHECK_MESSAGE( v == T(3), "" ); in test_reservation() 389 CHECK_MESSAGE( i == j, "" ); in test_serial() 407 CHECK_MESSAGE( i == j, "" ); in test_serial() 423 CHECK_MESSAGE( j == 1, "" ); in test_serial() 437 CHECK_MESSAGE( i == j, "" ); in test_serial() [all …]
|
| H A D | test_buffer_node.cpp | 55 CHECK_MESSAGE( msg == true, "" ); in operator ()() 183 CHECK_MESSAGE( vsum == T(6), ""); in test_reservation() 224 CHECK_MESSAGE( j == bogus_value, "" ); in test_parallel() 236 CHECK_MESSAGE( j == bogus_value, "" ); in test_parallel() 247 CHECK_MESSAGE( j == bogus_value, "" ); in test_parallel() 266 CHECK_MESSAGE( j == bogus_value, "" ); in test_parallel() 338 CHECK_MESSAGE( msg == true, "" ); in test_serial() 358 CHECK_MESSAGE( msg == true, "" ); in test_serial() 381 CHECK_MESSAGE( j == 1, "" ); in test_serial() 390 CHECK_MESSAGE( msg == true, "" ); in test_serial() [all …]
|
| H A D | test_flow_graph_whitebox.cpp | 271 CHECK_MESSAGE( (!fnode0.my_queue), "node should have no queue"); in TestFunctionNode() 297 CHECK_MESSAGE( (fnode1.my_queue), "node should have no queue"); in TestFunctionNode() 480 CHECK_MESSAGE( (ln.my_threshold == 1), "error in my_threshold"); in TestLimiterNode() 515 CHECK_MESSAGE( (ln.my_threshold == 1), "error in my_threshold"); in TestLimiterNode() 527 CHECK_MESSAGE( (out_int == 4), "input incorrect (4)"); in TestLimiterNode() 602 CHECK_MESSAGE((my_test(mf)), "fail cancel group test"); in TestMultifunctionNode() 648 CHECK_MESSAGE( (!on.my_successors.empty()), "edge not added"); in TestScalarNode() 908 CHECK_MESSAGE((b == b2), "Assignment should make iterators equal"); 918 CHECK_MESSAGE((g.begin() == g.end()), "Starting graph is empty"); 943 CHECK_MESSAGE((tmp == -1), "Value should not be altered"); [all …]
|
| H A D | test_sequencer_node.cpp | 209 CHECK_MESSAGE( j == bogus_value, "" ); in test_parallel() 240 CHECK_MESSAGE( i == j, "" ); in test_parallel() 285 CHECK_MESSAGE( msg == true, "" ); in test_serial() 293 CHECK_MESSAGE( i == j, "" ); in test_serial() 307 CHECK_MESSAGE( msg == true, "" ); in test_serial() 313 CHECK_MESSAGE( i == j, "" ); in test_serial() 332 CHECK_MESSAGE( msg == true, "" ); in test_serial() 338 CHECK_MESSAGE( i == j, "" ); in test_serial() 354 CHECK_MESSAGE( j == N, "" ); in test_serial() 374 CHECK_MESSAGE( i == j, "" ); in test_serial() [all …]
|
| H A D | test_write_once_node.cpp | 50 CHECK_MESSAGE( n.is_valid() == false, "" ); in simple_read_write_tests() 57 CHECK_MESSAGE( v0 == R(N+1), "" ); in simple_read_write_tests() 67 CHECK_MESSAGE( int(c) == 1, "" ); in simple_read_write_tests() 76 CHECK_MESSAGE( result == true, "" ); in simple_read_write_tests() 88 CHECK_MESSAGE( R(1) == v2, "" ); in simple_read_write_tests() 93 CHECK_MESSAGE( int(c) == 1, "" ); in simple_read_write_tests() 101 CHECK_MESSAGE( int(c) == 1, "" ); in simple_read_write_tests() 104 CHECK_MESSAGE( n.is_valid() == false, "" ); in simple_read_write_tests() 122 CHECK_MESSAGE( v1 == R(-1), "" ); in operator ()() 158 CHECK_MESSAGE( int(c) == 1, "" ); in parallel_read_write_tests() [all …]
|
| H A D | test_overwrite_node.cpp | 48 CHECK_MESSAGE( n.is_valid() == false, "" ); in simple_read_write_tests() 49 CHECK_MESSAGE( n.try_get( v0 ) == false, "" ); in simple_read_write_tests() 54 CHECK_MESSAGE( v0 == R(N), "" ); in simple_read_write_tests() 63 CHECK_MESSAGE( n.try_put( v1 ), "" ); in simple_read_write_tests() 67 CHECK_MESSAGE( n.try_get( v2 ), "" ); in simple_read_write_tests() 68 CHECK_MESSAGE( v1 == v2, "" ); in simple_read_write_tests() 73 CHECK_MESSAGE( int(c) == N+t%2, "" ); in simple_read_write_tests() 78 CHECK_MESSAGE( n.try_put( R(0) ), "" ); in simple_read_write_tests() 81 CHECK_MESSAGE( int(c) == N+t%2, "" ); in simple_read_write_tests() 84 CHECK_MESSAGE( n.is_valid() == false, "" ); in simple_read_write_tests() [all …]
|
| H A D | test_eh_flow_graph.cpp | 286 CHECK_MESSAGE( (s), "sequencer item out of range (== 0)"); in operator ()() 407 CHECK_MESSAGE( (src_cnt == 0), "input_node count not reset"); in run_one_input_node_test() 408 CHECK_MESSAGE( (sink_cnt == 0), "sink_node count not reset"); in run_one_input_node_test() 850 CHECK_MESSAGE( (0 == (int)test_count), "Atomic wasn't reset properly"); in run_one_continue_node_test() 967 CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty"); in run_one_buffer_node_test() 1611 CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty"); in run_one_limiter_node_test() 1927 CHECK_MESSAGE( (false), "Exception not thrown by invalid access"); in operator ()() 1951 CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag already set"); in test_flow_graph_exception0() 1955 CHECK_MESSAGE( (false), "Exception not thrown"); in test_flow_graph_exception0() 1965 CHECK_MESSAGE( (g.exception_thrown()), "Exception not intercepted"); in test_flow_graph_exception0() [all …]
|
| H A D | test_limiter_node.cpp | 52 CHECK_MESSAGE( next_value++ == v, "" ); in try_put_task() 141 CHECK_MESSAGE( c == N*num_threads, "" ); in test_puts_with_decrements() 142 CHECK_MESSAGE( r.my_count == N*num_threads, "" ); in test_puts_with_decrements() 167 CHECK_MESSAGE( c == i, "" ); in test_parallel() 218 CHECK_MESSAGE( msg == true, "" ); in test_serial() 296 CHECK_MESSAGE( (emit_sum == receive_sum), "sums do not match"); in test_multifunction_to_limiter() 308 CHECK_MESSAGE( (emit_sum == receive_sum), "sums do not match"); in test_multifunction_to_limiter() 395 CHECK_MESSAGE( actual == expected[m++], "" ); in test_decrementer() 404 CHECK_MESSAGE( limit2.decrementer().try_put( -decrement_value ), in test_decrementer() 407 CHECK_MESSAGE( limit2.decrementer().try_put( -decrement_value ), in test_decrementer() [all …]
|
| H A D | test_composite_node.cpp | 80 CHECK_MESSAGE( ( &std::get<N>(tuple1) == &std::get<N>(tuple2)), "ports not set correctly"); in compare_refs() 88 CHECK_MESSAGE( (&std::get<0>(tuple1) == &std::get<0>(tuple2)), "port 0 not correctly set"); in compare_refs() 117 …CHECK_MESSAGE( (&tbb::flow::input_port<0>(t) == &t.f1), "f1 not bound to input port 0 in composite… in test_tiny() 118 …CHECK_MESSAGE( (&tbb::flow::output_port<0>(t) == &t.f2), "f2 not bound to output port 0 in composi… in test_tiny() 143 CHECK_MESSAGE( ( i == 1), "item did not go through graph"); in test_tiny() 145 CHECK_MESSAGE( ( !j), "unexpected item in graph"); in test_tiny() 159 CHECK_MESSAGE( ( i == 2), "item did not go through graph after removal of edge"); in test_tiny() 161 CHECK_MESSAGE( ( !j), "unexpected item in graph after removal of edge"); in test_tiny() 254 …CHECK_MESSAGE( (result == sum_total), "the sum from the graph does not match the calculated value"… in test_adder() 335 CHECK_MESSAGE( (out == 8*i), "output from outer_node not correct"); in test_nested_adder() [all …]
|
| H A D | test_parallel_pipeline.cpp | 64 CHECK_MESSAGE(false, "Ran out of buffers, p:"<< concurrency); in fetchNextBuffer() 193 CHECK_MESSAGE(!middle_my_id(t), "bad id value, p:" << concurrency); in operator ()() 194 CHECK_MESSAGE(!middle_is_ready(t), "Already ready, p:" << concurrency ); in operator ()() 272 CHECK_MESSAGE(output_my_id(c), "unset id value, p:" << concurrency); in operator ()() 273 CHECK_MESSAGE(output_is_ready(c), "not yet ready, p:" << concurrency); in operator ()() 298 CHECK_MESSAGE(output_my_id(*c), "unset id value, p:" << concurrency); in operator ()() 393 CHECK_MESSAGE(!filter_node_count, "invalid filter_node counter"); in run_function_spec() 414 CHECK_MESSAGE(!filter_node_count, "filter_node objects leaked"); in run_function_spec() 482 CHECK_MESSAGE(filter_node_count==cnt+5, "filter node accounting error?"); in run_filter_set() 593 CHECK_MESSAGE(!filter_node_count, "invalid filter_node counter"); in run_function() [all …]
|
| H A D | test_async_node.cpp | 122 CHECK_MESSAGE( ( result == true), "attempted to cancel graph twice" ); in operator ()() 170 CHECK_MESSAGE( ( g.is_cancelled() == true), "task group not canceled" ); in test_reset() 187 CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" ); in test_reset() 193 CHECK_MESSAGE( int(async_body_exec_count) == int(b2.my_async_body_exec_count), in test_reset() 208 CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" ); in test_reset() 227 CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" ); in test_reset() 246 CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" ); in test_reset() 266 CHECK_MESSAGE( ( g.is_cancelled() == false), "task group not canceled" ); in test_reset() 570 CHECK_MESSAGE( (async_body_exec_count == overall_message_count), in run() 574 CHECK_MESSAGE( (end_body_exec_count == overall_message_count), in run() [all …]
|
| H A D | test_task_group.cpp | 467 CHECK_MESSAGE( e.what(), "Empty what() string" ); in LaunchChildrenWithFunctor() 471 } catch( ... ) { CHECK_MESSAGE( false, "Unknown exception" ); } in LaunchChildrenWithFunctor() 473 CHECK_MESSAGE(false, "No exception in the child task group"); in LaunchChildrenWithFunctor() 521 CHECK_MESSAGE( false, "Unexpected exception" ); in TestExceptionHandling1() 539 CHECK_MESSAGE( e.what(), "Empty what() string" ); in TestExceptionHandling2() 542 } catch( ... ) { CHECK_MESSAGE( false, "Unknown exception" ); } in TestExceptionHandling2() 562 CHECK_MESSAGE( false, "Unexpected exception" ); in TestExceptionHandling3() 600 CHECK_MESSAGE( e.what(), "Error message is absent" ); in TestMissingWait() 1042 CHECK_MESSAGE( 1076 CHECK_MESSAGE( in run_cancellation_use_case() [all …]
|
| H A D | test_input_node.cpp | 136 CHECK_MESSAGE( v == 1, "" ); in test_single_dest() 150 CHECK_MESSAGE( v == 1, "" ); in test_single_dest() 179 CHECK_MESSAGE( v == 1, "" ); in test_reset() 191 CHECK_MESSAGE( v == 1, "" ); in test_reset() 201 CHECK_MESSAGE( v == 0, "" ); in test_reset() 211 CHECK_MESSAGE( v == 0, "" ); in test_reset() 220 CHECK_MESSAGE( v == 1, "" ); in test_reset() 228 CHECK_MESSAGE( v == 0, "" ); in test_reset() 236 CHECK_MESSAGE( v == 1, "" ); in test_reset() 246 CHECK_MESSAGE( v == 0, "" ); in test_reset() [all …]
|
| H A D | test_broadcast_node.cpp | 97 CHECK_MESSAGE( b.try_put( (T)n ), "" ); in test_serial_broadcasts() 102 CHECK_MESSAGE( (*receivers[r])[n] == 1, "" ); in test_serial_broadcasts() 106 CHECK_MESSAGE( b.try_put( (T)0 ), "" ); in test_serial_broadcasts() 108 CHECK_MESSAGE( (*receivers[0])[0] == 1, "" ); in test_serial_broadcasts() 124 CHECK_MESSAGE( my_b.try_put( (T)n ), "" ); in operator ()() 145 CHECK_MESSAGE( (int)(*receivers[r])[n] == p, "" ); in run_parallel_broadcasts() 149 CHECK_MESSAGE( b.try_put( (T)0 ), "" ); in run_parallel_broadcasts() 151 CHECK_MESSAGE( (int)(*receivers[r])[0] == p, "" ); in run_parallel_broadcasts() 188 CHECK_MESSAGE( (!q0.try_get(j)), "extra value in queue"); in test_resets() 199 CHECK_MESSAGE( (!q0.try_get(j)), "edge between nodes not removed"); in test_resets() [all …]
|
| /oneTBB/test/conformance/ |
| H A D | conformance_limiter_node.cpp | 113 CHECK_MESSAGE(limit.decrementer().try_put( -threshold ), // close limiter's gate 120 CHECK_MESSAGE(( !limit.try_put( m )), "Limiter node's gate is not closed." ); 125 CHECK_MESSAGE(actual == expected[m++], "" ); 134 CHECK_MESSAGE(limit2.decrementer().try_put( -decrement_value ), 137 CHECK_MESSAGE(limit2.decrementer().try_put( -decrement_value ), 143 CHECK_MESSAGE(actual == expected2[m++], "" ); 151 CHECK_MESSAGE(limit3.decrementer().try_put( -decrement_value3 ), 160 CHECK_MESSAGE(actual == m++, "Not all messages have been processed." ); 171 CHECK_MESSAGE(limit4.decrementer().try_put(oneapi::tbb::flow::continue_msg()), 176 CHECK_MESSAGE(m == threshold4, "Not all messages have been accepted." ); [all …]
|
| H A D | conformance_task_group.cpp | 64 CHECK_MESSAGE(run == true, "Delayed task should be completed when task_group::wait exits"); 66 CHECK_MESSAGE(h == nullptr, "Delayed task can be executed only once"); 84 CHECK_MESSAGE(run == true, "Delayed task should be completed when task_group::wait exits"); 86 CHECK_MESSAGE(h == nullptr, "Delayed task can be executed only once"); 97 CHECK_MESSAGE(empty, "default constructed task_handle should be empty"); 112 CHECK_MESSAGE(empty, "default constructed task_handle should be empty"); 113 CHECK_MESSAGE(h == nullptr, "default constructed task_handle should be empty"); 114 CHECK_MESSAGE(nullptr == h, "default constructed task_handle should be empty"); 231 CHECK_MESSAGE( in run_cancellation_use_case() 237 CHECK_MESSAGE( in run_cancellation_use_case() [all …]
|
| H A D | conformance_split_node.cpp | 52 CHECK_MESSAGE((oneapi::tbb::flow::output_port<0>(testing_node).try_get(tmp1) == false 54 CHECK_MESSAGE((oneapi::tbb::flow::output_port<1>(testing_node).try_get(tmp2) == false 56 CHECK_MESSAGE((oneapi::tbb::flow::output_port<2>(testing_node).try_get(tmp3) == false 77 CHECK_MESSAGE((testing_node.try_put(my_tuple)), "`try_put()' must always returns `true'"); 83 CHECK_MESSAGE((values1.size() == 1), "Descendant of the node must receive one message."); 84 CHECK_MESSAGE((values2.size() == 1), "Descendant of the node must receive one message."); 85 CHECK_MESSAGE((values3.size() == 1), "Descendant of the node must receive one message."); 86 CHECK_MESSAGE((values1[0] == 1), "Descendant of the node needs to be receive N messages"); 87 CHECK_MESSAGE((values2[0] == 1.5f), "Descendant of the node must receive one message."); 88 CHECK_MESSAGE((values3[0] == 2), "Descendant of the node must receive one message."); [all …]
|
| H A D | conformance_graph.cpp | 36 CHECK_MESSAGE((flag == false), "Should be false"); in test_continue_node_rf_reset_protocol() 42 CHECK_MESSAGE((flag == false), "Internal number of predecessors reinitialized"); in test_continue_node_rf_reset_protocol() 46 CHECK_MESSAGE((flag == true), "Should be true"); in test_continue_node_rf_reset_protocol() 65 CHECK_MESSAGE((node.try_get(tmp) == false), "Should be false"); in test_input_node_rf_reset_protocol() 79 CHECK_MESSAGE((counting_body.execute_count == 0), "Body should not be executed"); in test_functional_nodes_rf_reset_protocol() 83 CHECK_MESSAGE((counting_body.execute_count == 1), "Body should be executed"); in test_functional_nodes_rf_reset_protocol() 93 CHECK_MESSAGE((tmp == -1), "Value should not be updated"); in test_buffering_nodes_rf_reset_protocol() 101 CHECK_MESSAGE((tmp == -1), "Value should not be updated"); in test_buffering_nodes_rf_reset_protocol() 114 CHECK_MESSAGE((counting_body.execute_count == 1), "Body should be executed"); in test_nodes_with_body_rf_reset_bodies() 158 CHECK_MESSAGE((!testing_node.try_get(tmp)), "All buffers must be emptied"); in test_join_node_rf_reset_protocol() [all …]
|
| H A D | conformance_overwrite_node.cpp | 40 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message"); 41 CHECK_MESSAGE((tmp == 1), "Descendant needs to receive a correct value"); 46 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Descendant needs to receive a message"); 47 CHECK_MESSAGE((tmp == 2), "Descendant needs to receive a correct value"); 83 CHECK_MESSAGE((!testing_node.is_valid()), "Constructed node has invalid internal buffer item"); 84 …CHECK_MESSAGE((!testing_node.try_get(tmp)), "Gets from the node are non-destructive, but the first… 93 CHECK_MESSAGE((!testing_node.is_valid()), "Constructed node has invalid internal buffer item"); 97 CHECK_MESSAGE((testing_node.is_valid()), "Buffer must be valid after try_put call"); 101 …CHECK_MESSAGE((!testing_node.is_valid()), "call `clear` invalidates the value held in the buffer."…
|
| H A D | conformance_indexer_node.cpp | 50 …CHECK_MESSAGE((values.size() == 3), std::string("Descendant of the node must receive 3 messages.")… 53 … CHECK_MESSAGE((value.cast_to<int>() == 6), "Value passed is the actual one received."); 55 … CHECK_MESSAGE((value.cast_to<float>() == 1.5), "Value passed is the actual one received."); 57 … CHECK_MESSAGE((value.cast_to<input_msg>() == 1), "Value passed is the actual one received."); 85 … CHECK_MESSAGE((testing_node.try_get(tmp) == false), "Value should be discarded after rejection"); 106 CHECK_MESSAGE((v.is_a<int>()), "Expected to int" ); in __anon3412adbc0402() 107 … CHECK_MESSAGE((oneapi::tbb::flow::cast_to<int>(v) == 6), "Expected to receive 6" ); in __anon3412adbc0402() 109 CHECK_MESSAGE((v.is_a<float>()), "Expected to float" ); in __anon3412adbc0402() 110 … CHECK_MESSAGE((oneapi::tbb::flow::cast_to<float>(v) == 1.5), "Expected to receive 1.5" ); in __anon3412adbc0402() 112 CHECK_MESSAGE((v.is_a<input_msg>()), "Expected to float" ); in __anon3412adbc0402() [all …]
|
| H A D | conformance_flowgraph.h | 423 CHECK_MESSAGE((produce_messages<Node, InputType>(testing_node) == true), in test_body_exec() 462 CHECK_MESSAGE((tmp == 1), "try_get after rejection should set value"); in test_buffering() 469 CHECK_MESSAGE((tmp == -1), "try_get after rejection should not alter passed value"); in test_buffering() 489 CHECK_MESSAGE(expected == messages_received, "For correct execution of test"); in test_forwarding() 496 CHECK_MESSAGE((values[0] == expected), "Value passed is the actual one received."); in test_forwarding() 528 CHECK_MESSAGE((values1[0] == 0), "Value passed is the actual one received"); in test_forwarding_single_push() 529 CHECK_MESSAGE((values3[0] == 1), "Value passed is the actual one received"); in test_forwarding_single_push() 532 CHECK_MESSAGE((values1[0] == 0), "Value passed is the actual one received"); in test_forwarding_single_push() 534 CHECK_MESSAGE((values2[0] == 0), "Value passed is the actual one received"); in test_forwarding_single_push() 568 CHECK_MESSAGE((fun2.copy_count + 1 < b2.copy_count), "constructor should copy bodies"); in test_copy_ctor() [all …]
|
| H A D | conformance_priority_queue_node.cpp | 68 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 69 CHECK_MESSAGE((tmp == 1), "Values should get sorted"); 70 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 71 CHECK_MESSAGE((tmp == 2), "Values should get sorted"); 72 CHECK_MESSAGE((testing_node.try_get(tmp)), "Get should succeed"); 73 CHECK_MESSAGE((tmp == 3), "Values should get sorted");
|
| H A D | conformance_join_node.cpp | 111 CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::graph_node, 114 CHECK_MESSAGE((std::is_base_of<oneapi::tbb::flow::sender<my_input_tuple>, 153 CHECK_MESSAGE((get_values(q_node).size() == 0), 158 CHECK_MESSAGE((get_values(q_node).size() == 0), 164 CHECK_MESSAGE((get_values(q_node).size() == 1), 169 CHECK_MESSAGE((get_values(q_node).size() == 1), 173 CHECK_MESSAGE((get_values(q_node).size() == 1), 177 CHECK_MESSAGE((get_values(q_node).size() == 0), 227 CHECK_MESSAGE((testing_node.try_get(tmp)), "Mapped keys should match.\ 248 CHECK_MESSAGE((testing_node.try_get(tmp) == true), "Mapped keys should match"); [all …]
|