248         CHECK_MESSAGE( (std::get<N-1>(my_ports).try_put(my_type())), "Error putting to successor");  in issue_tuple_element()
258         CHECK_MESSAGE( (std::get<0>(my_ports).try_put(my_type())), "Error putting to successor");  in issue_tuple_element()
286         CHECK_MESSAGE( (s), "sequencer item out of range (== 0)");  in operator ()()
389 …CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception flag in flow::graph no…  in run_one_input_node_test()
390             CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "canceled flag not set");  in run_one_input_node_test()
391             CHECK_MESSAGE( (src_cnt <= g_NumItems), "Too many input_node items emitted");  in run_one_input_node_test()
392             CHECK_MESSAGE( (sink_cnt <= src_cnt), "Too many input_node items received");  in run_one_input_node_test()
395 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_input_node_test()
396             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_input_node_test()
397             CHECK_MESSAGE( (src_cnt == g_NumItems), "Incorrect # input_node items emitted");  in run_one_input_node_test()
398             CHECK_MESSAGE( (sink_cnt == src_cnt), "Incorrect # input_node items received");  in run_one_input_node_test()
403         CHECK_MESSAGE( (!g.exception_thrown()), "Reset didn't clear exception_thrown()");  in run_one_input_node_test()
404         CHECK_MESSAGE( (!g.is_cancelled()), "Reset didn't clear is_cancelled()");  in run_one_input_node_test()
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()
428     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Some items leaked in test");  in test_input_node()
438     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Some items leaked in test");  in test_input_node()
537 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_functype_node_test()
538 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_functype_node_test()
539             CHECK_MESSAGE( (ib0_cnt + ib1_cnt <= 2*g_NumItems), "Too many items sent by inputs");  in run_one_functype_node_test()
540             CHECK_MESSAGE( (ib0_cnt + ib1_cnt >= t_cnt), "Too many items received by test node");  in run_one_functype_node_test()
541             CHECK_MESSAGE( (nb0_cnt + nb1_cnt <= t_cnt*2), "Too many items received by sink nodes");  in run_one_functype_node_test()
544 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_functype_node_test()
545             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_functype_node_test()
546 …         CHECK_MESSAGE( (ib0_cnt + ib1_cnt == 2*g_NumItems), "Missing invocations of input_nodes");  in run_one_functype_node_test()
547             CHECK_MESSAGE( (t_cnt == 2*g_NumItems), "Not all items reached test node");  in run_one_functype_node_test()
548 …CHECK_MESSAGE( (nb0_cnt == 2*g_NumItems && nb1_cnt == 2*g_NumItems), "Missing items in absorbers");  in run_one_functype_node_test()
552 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType0>(input0).count_value()),"Reset input …  in run_one_functype_node_test()
553 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType1>(input1).count_value()),"Reset input …  in run_one_functype_node_test()
554 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te…  in run_one_functype_node_test()
555 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType0>(sink0).count_value()),"Reset sink 0 f…  in run_one_functype_node_test()
556 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType1>(sink1).count_value()),"Reset sink 1 f…  in run_one_functype_node_test()
640     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Some items leaked in test");  in test_function_node()
747     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Some items leaked in test");  in test_multifunction_node()
835 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_continue_node_test()
836 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_continue_node_test()
837             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_continue_node_test()
838             CHECK_MESSAGE( (ib_cnt >= t_cnt), "Too many items received by test node");  in run_one_continue_node_test()
839             CHECK_MESSAGE( (nb_cnt <= t_cnt), "Too many items received by sink nodes");  in run_one_continue_node_test()
842 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_continue_node_test()
843             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_continue_node_test()
844             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_continue_node_test()
845             CHECK_MESSAGE( (t_cnt == g_NumItems), "Not all items reached test node");  in run_one_continue_node_test()
846             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_continue_node_test()
850         CHECK_MESSAGE( (0 == (int)test_count), "Atomic wasn't reset properly");  in run_one_continue_node_test()
851 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_continue_node_test()
852 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<TestNodeBodyType>(node_to_test).count_value()),"Reset te…  in run_one_continue_node_test()
853 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_continue_node_test()
902 … CHECK_MESSAGE( (!CheckType<double>::check_type_counter), "Dropped objects in continue_node test");  in test_continue_node()
949 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_buffer_node_test()
950 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_buffer_node_test()
951             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_buffer_node_test()
952             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_buffer_node_test()
955 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_buffer_node_test()
956             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_buffer_node_test()
957             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_buffer_node_test()
958             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_buffer_node_test()
967             CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty");  in run_one_buffer_node_test()
975 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_buffer_node_test()
976 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_buffer_node_test()
1083 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_sequencer_node_test()
1084 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_sequencer_node_test()
1085             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_sequencer_node_test()
1086             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_sequencer_node_test()
1089 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_sequencer_node_test()
1090             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_sequencer_node_test()
1091             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_sequencer_node_test()
1092             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_sequencer_node_test()
1108 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_sequencer_node_test()
1109 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_sequencer_node_test()
1154     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Dropped objects in sequencer_node test");  in test_sequencer_node()
1206 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_priority_queue_node_test()
1207 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_priority_queue_node_test()
1208             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_priority_queue_node_test()
1209             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_priority_queue_node_test()
1212 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_priority_queue_node_test()
1213             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_priority_queue_node_test()
1214             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_node");  in run_one_priority_queue_node_test()
1215             CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in run_one_priority_queue_node_test()
1232 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_priority_queue_node_test()
1233 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_priority_queue_node_test()
1275 …CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Dropped objects in priority_queue_node test…  in test_priority_queue_node()
1351 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in execute_test()
1352 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in execute_test()
1353 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs");  in execute_test()
1354 …CHECK_MESSAGE( (nb_cnt <= ((ib0_cnt < ib1_cnt) ? ib0_cnt : ib1_cnt)), "Too many items received by …  in execute_test()
1357 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in execute_test()
1358                 CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in execute_test()
1365 …        CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0");  // this one  in execute_test()
1366                 CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1");  in execute_test()
1367                 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in execute_test()
1384 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail…  in execute_test()
1385 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail…  in execute_test()
1387 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in execute_test()
1461 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in execute_test()
1462 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in execute_test()
1463 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs");  in execute_test()
1464 …CHECK_MESSAGE( (nb_cnt <= ((ib0_cnt < ib1_cnt) ? ib0_cnt : ib1_cnt)), "Too many items received by …  in execute_test()
1467 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in execute_test()
1468                 CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in execute_test()
1469                 CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0");  in execute_test()
1470                 CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1");  in execute_test()
1471                 CHECK_MESSAGE( (nb_cnt == g_NumItems), "Missing items in absorbers");  in execute_test()
1488 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail…  in execute_test()
1489 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail…  in execute_test()
1491 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in execute_test()
1541     CHECK_MESSAGE( (!CheckType<int>::check_type_counter), "Dropped items in test");  in test_join_node()
1590 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_limiter_node_test()
1591 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_limiter_node_test()
1592             CHECK_MESSAGE( (ib_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_limiter_node_test()
1593             CHECK_MESSAGE( (nb_cnt <= ib_cnt), "Too many items received by sink nodes");  in run_one_limiter_node_test()
1596 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_limiter_node_test()
1597             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_limiter_node_test()
1600             CHECK_MESSAGE( (ib_cnt == g_NumThreads + 2), "Missing invocations of input_node");  in run_one_limiter_node_test()
1601             CHECK_MESSAGE( (nb_cnt == g_NumThreads + 1), "Missing items in absorbers");  in run_one_limiter_node_test()
1611             CHECK_MESSAGE( (!node_to_test.try_get(tmp)), "node not empty");  in run_one_limiter_node_test()
1619 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputNodeBodyType>(input).count_value()),"Reset input fa…  in run_one_limiter_node_test()
1620 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkNodeBodyType>(sink).count_value()),"Reset sink faile…  in run_one_limiter_node_test()
1717 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_split_node_test()
1718 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_split_node_test()
1719             CHECK_MESSAGE( (ib_cnt <= 2*g_NumItems), "Too many items sent by input");  in run_one_split_node_test()
1720 …          CHECK_MESSAGE( (nb0_cnt + nb1_cnt <= ib_cnt*2), "Too many items received by sink nodes");  in run_one_split_node_test()
1723 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_split_node_test()
1724             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_split_node_test()
1725             CHECK_MESSAGE( (ib_cnt == g_NumItems), "Missing invocations of input_nodes");  in run_one_split_node_test()
1726 …    CHECK_MESSAGE( (nb0_cnt == g_NumItems && nb1_cnt == g_NumItems), "Missing items in absorbers");  in run_one_split_node_test()
1730 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType>(input).count_value()),"Reset input failed…  in run_one_split_node_test()
1731 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType0>(sink0).count_value()),"Reset sink 0 faile…  in run_one_split_node_test()
1732 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType1>(sink1).count_value()),"Reset sink 1 faile…  in run_one_split_node_test()
1835 … CHECK_MESSAGE( (g.exception_thrown() || okayNoExceptionsCaught), "Exception not caught by graph");  in run_one_indexer_node_test()
1836 …CHECK_MESSAGE( (g.is_cancelled() || okayNoExceptionsCaught), "Cancellation not signalled in graph"…  in run_one_indexer_node_test()
1837 … CHECK_MESSAGE( (ib0_cnt <= g_NumItems && ib1_cnt <= g_NumItems), "Too many items sent by inputs");  in run_one_indexer_node_test()
1838             CHECK_MESSAGE( (nb_cnt <= ib0_cnt + ib1_cnt), "Too many items received by sink nodes");  in run_one_indexer_node_test()
1841 …CHECK_MESSAGE( (!g.exception_thrown()), "Exception flag in flow::graph set but no throw occurred");  in run_one_indexer_node_test()
1842             CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag set but no throw occurred");  in run_one_indexer_node_test()
1843             CHECK_MESSAGE( (ib0_cnt == g_NumItems), "Missing invocations of input_node0");  in run_one_indexer_node_test()
1844             CHECK_MESSAGE( (ib1_cnt == g_NumItems), "Missing invocations of input_node1");  in run_one_indexer_node_test()
1845             CHECK_MESSAGE( (nb_cnt == 2*g_NumItems), "Missing items in absorbers");  in run_one_indexer_node_test()
1862 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType0>(input0).count_value()),"Reset input fail…  in run_one_indexer_node_test()
1863 …CHECK_MESSAGE( (0 == tbb::flow::copy_body<InputBodyType1>(input1).count_value()),"Reset input fail…  in run_one_indexer_node_test()
1865 … CHECK_MESSAGE( (0 == tbb::flow::copy_body<SinkBodyType>(sink).count_value()),"Reset sink failed");  in run_one_indexer_node_test()
1927         CHECK_MESSAGE( (false), "Exception not thrown by invalid access");  in operator ()()
1950     CHECK_MESSAGE( (!g.exception_thrown()), "exception_thrown flag already set");  in test_flow_graph_exception0()
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()
1963 …CHECK_MESSAGE( (nExceptions > 0), "Exception caught, but no body signaled exception being thrown");  in test_flow_graph_exception0()
1965     CHECK_MESSAGE( (g.exception_thrown()), "Exception not intercepted");  in test_flow_graph_exception0()
1967     CHECK_MESSAGE( (g.is_cancelled()), "Exception cancellation not signaled");  in test_flow_graph_exception0()
1973         CHECK_MESSAGE( (false), "Second exception thrown but no task executing");  in test_flow_graph_exception0()
1975 …  CHECK_MESSAGE( (nExceptions == 0), "body signaled exception being thrown, but no body executed");  in test_flow_graph_exception0()
1976     CHECK_MESSAGE( (!g.exception_thrown()), "exception_thrown flag not reset");  in test_flow_graph_exception0()
1977     CHECK_MESSAGE( (!g.is_cancelled()), "canceled flag not reset");  in test_flow_graph_exception0()