Lines Matching refs:g
357 tbb::flow::graph g; in run_one_input_node_test() local
366 tbb::flow::input_node<ItemType> sn(g, src_body_type(input_body_count)); in run_one_input_node_test()
368 tbb::flow::function_node<ItemType> parallel_fn(g,tbb::flow::unlimited,ab2); in run_one_input_node_test()
375 g.wait_for_all(); in run_one_input_node_test()
381 g.wait_for_all(); in run_one_input_node_test()
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()
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()
400 g.reset(); // resets the body of the input_node and the absorb_nodes. 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()
486 tbb::flow::graph g; in run_one_functype_node_test() local
501 InputNodeType input0(g, InputNodeBodyType0(input0_count)); in run_one_functype_node_test()
502 InputNodeType input1(g, InputNodeBodyType1(input1_count)); in run_one_functype_node_test()
503 TestNodeType node_to_test(g, Conc, TestNodeBodyType(test_count)); in run_one_functype_node_test()
504 SinkNodeType0 sink0(g,tbb::flow::unlimited,SinkNodeBodyType0(sink0_count)); in run_one_functype_node_test()
505 SinkNodeType1 sink1(g,tbb::flow::unlimited,SinkNodeBodyType1(sink1_count)); in run_one_functype_node_test()
520 g.wait_for_all(); in run_one_functype_node_test()
527 g.wait_for_all(); in run_one_functype_node_test()
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()
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()
550 g.reset(); // resets the body of the input_nodes, test_node and the absorb_nodes. in run_one_functype_node_test()
795 tbb::flow::graph g; in run_one_continue_node_test() local
806 InputNodeType input(g, InputNodeBodyType(input_count)); in run_one_continue_node_test()
807 TTestNodeType node_to_test(g, TestNodeBodyType(test_count)); in run_one_continue_node_test()
808 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_continue_node_test()
809 tbb::flow::broadcast_node<tbb::flow::continue_msg> b1(g), b2(g), b3(g); in run_one_continue_node_test()
821 g.wait_for_all(); in run_one_continue_node_test()
827 g.wait_for_all(); in run_one_continue_node_test()
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()
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()
848 g.reset(); // resets the body of the input_nodes, test_node and the absorb_nodes. in run_one_continue_node_test()
916 tbb::flow::graph g; in run_one_buffer_node_test() local
926 InputNodeType input(g, InputNodeBodyType(input_count)); in run_one_buffer_node_test()
927 TestNodeType node_to_test(g); in run_one_buffer_node_test()
928 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_buffer_node_test()
936 g.wait_for_all(); in run_one_buffer_node_test()
942 g.wait_for_all(); in run_one_buffer_node_test()
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()
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()
963 g.wait_for_all(); in run_one_buffer_node_test()
964 g.reset(); in run_one_buffer_node_test()
969 g.wait_for_all(); in run_one_buffer_node_test()
972 g.reset(); in run_one_buffer_node_test()
1050 tbb::flow::graph g; in run_one_sequencer_node_test() local
1060 InputNodeType input(g, InputNodeBodyType(input_count)); in run_one_sequencer_node_test()
1061 TestNodeType node_to_test(g,SeqBodyType()); in run_one_sequencer_node_test()
1062 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_sequencer_node_test()
1070 g.wait_for_all(); in run_one_sequencer_node_test()
1076 g.wait_for_all(); in run_one_sequencer_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()
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()
1098 g.wait_for_all(); in run_one_sequencer_node_test()
1099 g.reset(); in run_one_sequencer_node_test()
1102 g.wait_for_all(); in run_one_sequencer_node_test()
1105 g.reset(); in run_one_sequencer_node_test()
1170 tbb::flow::graph g; in run_one_priority_queue_node_test() local
1180 InputNodeType input(g, InputNodeBodyType(input_count)); in run_one_priority_queue_node_test()
1182 TestNodeType node_to_test(g); in run_one_priority_queue_node_test()
1184 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_priority_queue_node_test()
1193 g.wait_for_all(); in run_one_priority_queue_node_test()
1199 g.wait_for_all(); in run_one_priority_queue_node_test()
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()
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()
1222 g.wait_for_all(); in run_one_priority_queue_node_test()
1223 g.reset(); in run_one_priority_queue_node_test()
1226 g.wait_for_all(); in run_one_priority_queue_node_test()
1229 g.reset(); in run_one_priority_queue_node_test()
1313 tbb::flow::graph g; in execute_test() local
1323 InputType0 input0(g, InputBodyType0(input0_count)); in execute_test()
1324 InputType1 input1(g, InputBodyType1(input1_count)); in execute_test()
1325 TestJoinType node_to_test(g); in execute_test()
1326 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in execute_test()
1336 g.wait_for_all(); in execute_test()
1343 g.wait_for_all(); in execute_test()
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()
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()
1373 g.wait_for_all(); in execute_test()
1374 g.reset(); in execute_test()
1377 g.wait_for_all(); in execute_test()
1380 g.wait_for_all(); in execute_test()
1381 g.reset(); in execute_test()
1422 tbb::flow::graph g; in execute_test() local
1433 InputType0 input0(g, InputBodyType0(input0_count, 2)); in execute_test()
1434 InputType1 input1(g, InputBodyType1(input1_count, 3)); in execute_test()
1435 …TestJoinType node_to_test(g, tag_func<ItemType0>(ItemType0(2)), tag_func<ItemType1>(ItemType1(3))); in execute_test()
1436 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in execute_test()
1446 g.wait_for_all(); in execute_test()
1453 g.wait_for_all(); 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()
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()
1477 g.wait_for_all(); // have to wait for the graph to stop again.... in execute_test()
1478 g.reset(); // resets the body of the input_nodes, test_node and the absorb_nodes. in execute_test()
1481 g.wait_for_all(); // have to wait for the graph to stop again.... in execute_test()
1484 g.wait_for_all(); in execute_test()
1485 g.reset(); in execute_test()
1557 tbb::flow::graph g; in run_one_limiter_node_test() local
1567 InputNodeType input(g, InputNodeBodyType(input_count)); in run_one_limiter_node_test()
1568 TestNodeType node_to_test(g,g_NumThreads + 1); in run_one_limiter_node_test()
1569 SinkNodeType sink(g,tbb::flow::unlimited,SinkNodeBodyType(sink_count)); in run_one_limiter_node_test()
1577 g.wait_for_all(); in run_one_limiter_node_test()
1583 g.wait_for_all(); in run_one_limiter_node_test()
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()
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()
1607 g.wait_for_all(); in run_one_limiter_node_test()
1608 g.reset(); in run_one_limiter_node_test()
1613 g.wait_for_all(); in run_one_limiter_node_test()
1616 g.reset(); in run_one_limiter_node_test()
1678 tbb::flow::graph g; in run_one_split_node_test() local
1690 InputType input(g, InputBodyType(input_count)); in run_one_split_node_test()
1691 TestSplitType node_to_test(g); in run_one_split_node_test()
1692 SinkType0 sink0(g,tbb::flow::unlimited,SinkBodyType0(sink0_count)); in run_one_split_node_test()
1693 SinkType1 sink1(g,tbb::flow::unlimited,SinkBodyType1(sink1_count)); in run_one_split_node_test()
1703 g.wait_for_all(); in run_one_split_node_test()
1709 g.wait_for_all(); in run_one_split_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()
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()
1728 g.reset(); // resets the body of the input_nodes and the absorb_nodes. in run_one_split_node_test()
1796 tbb::flow::graph g; in run_one_indexer_node_test() local
1807 InputType0 input0(g, InputBodyType0(input0_count)); in run_one_indexer_node_test()
1808 InputType1 input1(g, InputBodyType1(input1_count)); in run_one_indexer_node_test()
1809 TestNodeType node_to_test(g); in run_one_indexer_node_test()
1810 SinkType sink(g,tbb::flow::unlimited,SinkBodyType(sink_count)); in run_one_indexer_node_test()
1820 g.wait_for_all(); in run_one_indexer_node_test()
1827 g.wait_for_all(); in run_one_indexer_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()
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()
1851 g.wait_for_all(); in run_one_indexer_node_test()
1852 g.reset(); in run_one_indexer_node_test()
1855 g.wait_for_all(); in run_one_indexer_node_test()
1858 g.wait_for_all(); in run_one_indexer_node_test()
1859 g.reset(); in run_one_indexer_node_test()
1942 tbb::flow::graph g; in test_flow_graph_exception0() local
1943 tbb::flow::broadcast_node<tbb::flow::continue_msg> start(g); in test_flow_graph_exception0()
1944 tbb::flow::continue_node<tbb::flow::continue_msg> fooNode(g, f); in test_flow_graph_exception0()
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()
1954 g.wait_for_all(); 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()
1970 g.wait_for_all(); // context still signalled canceled, my_exception still set. 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()