Lines Matching refs:g
61 tbb::flow::graph g; in TestSplitNode() local
62 snode_type snode(g); in TestSplitNode()
63 tbb::flow::function_node<int> rcvr(g,tbb::flow::unlimited, receiverBody<int>()); in TestSplitNode()
70 g.wait_for_all(); in TestSplitNode()
71 g.reset(); in TestSplitNode()
73 g.reset(tbb::flow::rf_clear_edges); in TestSplitNode()
82 tbb::flow::graph g; in TestBufferingNode() local
83 B bnode(g); in TestBufferingNode()
84 …tbb::flow::function_node<int,int,tbb::flow::rejecting> fnode(g, tbb::flow::serial, serial_fn_body<… in TestBufferingNode()
95 g.wait_for_all(); in TestBufferingNode()
118 tbb::flow::join_node<std::tuple<int,int>,tbb::flow::reserving> jnode(g); in TestBufferingNode()
120 g.wait_for_all(); in TestBufferingNode()
124 g.wait_for_all(); in TestBufferingNode()
127 g.wait_for_all(); in TestBufferingNode()
128 g.reset(); // should be in forward direction again in TestBufferingNode()
131 g.reset(tbb::flow::rf_clear_edges); in TestBufferingNode()
136 g.wait_for_all(); in TestBufferingNode()
139 g.reset(tbb::flow::rf_clear_edges); in TestBufferingNode()
143 g.wait_for_all(); in TestBufferingNode()
150 tbb::flow::graph g; in TestContinueNode() local
151 … tbb::flow::function_node<int> fnode0(g, tbb::flow::serial, serial_fn_body<int>(serial_fn_state0)); in TestContinueNode()
152 tbb::flow::continue_node<int> cnode(g, /*number_of_predecessors*/ 1, in TestContinueNode()
154 … tbb::flow::function_node<int> fnode1(g, tbb::flow::serial, serial_fn_body<int>(serial_fn_state1)); in TestContinueNode()
172 g.wait_for_all(); in TestContinueNode()
183 g.reset(); // should still be the same in TestContinueNode()
188 g.wait_for_all(); in TestContinueNode()
192 g.reset(tbb::flow::rf_clear_edges); // should be in forward direction again in TestContinueNode()
235 tbb::flow::graph g; in TestFunctionNode() local
236 tbb::flow::queue_node<int> qnode0(g); in TestFunctionNode()
237 …tbb::flow::function_node<int,int, tbb::flow::rejecting > fnode0(g, tbb::flow::serial, serial_fn_… in TestFunctionNode()
238 …tbb::flow::function_node<int,int/*, tbb::flow::queueing*/> fnode1(g, tbb::flow::serial, serial_fn_… in TestFunctionNode()
240 tbb::flow::queue_node<int> qnode1(g); in TestFunctionNode()
247 g.wait_for_all(); in TestFunctionNode()
258 g.wait_for_all(); in TestFunctionNode()
267 g.reset(); // attach to the current arena in TestFunctionNode()
276 g.wait_for_all(); in TestFunctionNode()
287 g.reset(); // should reverse the edge from the input to the function node. in TestFunctionNode()
303 g.wait_for_all(); in TestFunctionNode()
304 g.reset(); // should reverse the edge from the input to the function node. in TestFunctionNode()
314 g.reset(); // attach to the current arena in TestFunctionNode()
324 g.wait_for_all(); in TestFunctionNode()
333 g.my_context->cancel_group_execution(); in TestFunctionNode()
337 g.reset(tbb::flow::rf_clear_edges); in TestFunctionNode()
358 tbb::flow::graph g; in TestSimpleSuccessorArc() local
361 tbb::flow::join_node<std::tuple<int>, JNODE_TYPE> qj(g); in TestSimpleSuccessorArc()
362 tbb::flow::broadcast_node<std::tuple<int> > bnode(g); in TestSimpleSuccessorArc()
365 g.reset(); in TestSimpleSuccessorArc()
367 g.reset(tbb::flow::rf_clear_edges); in TestSimpleSuccessorArc()
375 tbb::flow::graph g; in TestSimpleSuccessorArc() local
379 tbb::flow::join_node<my_tuple, tbb::flow::tag_matching> qj(g, in TestSimpleSuccessorArc()
383 tbb::flow::broadcast_node<my_tuple > bnode(g); in TestSimpleSuccessorArc()
386 g.reset(); in TestSimpleSuccessorArc()
388 g.reset(tbb::flow::rf_clear_edges); in TestSimpleSuccessorArc()
395 tbb::flow::graph g; in TestJoinNode() local
404 tbb::flow::join_node<std::tuple<int,int>, tbb::flow::reserving> rj(g); in TestJoinNode()
405 tbb::flow::queue_node<int> q0(g); in TestJoinNode()
406 tbb::flow::queue_node<int> q1(g); in TestJoinNode()
410 g.wait_for_all(); // quiesce in TestJoinNode()
413 g.reset(); in TestJoinNode()
417 g.wait_for_all(); // quiesce in TestJoinNode()
420 g.reset(); in TestJoinNode()
425 g.wait_for_all(); // quiesce in TestJoinNode()
428 g.reset(tbb::flow::rf_clear_edges); in TestJoinNode()
475 tbb::flow::graph g; in TestLimiterNode() local
477 typename limiter_node_type<DecrementerType>::type ln(g,1); in TestLimiterNode()
481 tbb::flow::queue_node<int> inq(g); in TestLimiterNode()
482 tbb::flow::queue_node<int> outq(g); in TestLimiterNode()
483 tbb::flow::broadcast_node<dtype> bn(g); in TestLimiterNode()
489 g.wait_for_all(); in TestLimiterNode()
493 g.wait_for_all(); in TestLimiterNode()
497 g.wait_for_all(); in TestLimiterNode()
501 g.wait_for_all(); in TestLimiterNode()
503 g.wait_for_all(); in TestLimiterNode()
505 g.reset(); in TestLimiterNode()
508 g.wait_for_all(); in TestLimiterNode()
513 g.reset(tbb::flow::rf_clear_edges); in TestLimiterNode()
525 g.wait_for_all(); in TestLimiterNode()
529 g.wait_for_all(); in TestLimiterNode()
573 tbb::flow::graph g; in TestMultifunctionNode() local
574 multinode_type mf(g, tbb::flow::serial, mf_body<multinode_type>(serial_fn_state0)); in TestMultifunctionNode()
575 tbb::flow::queue_node<int> qin(g); in TestMultifunctionNode()
576 tbb::flow::queue_node<int> qodd_out(g); in TestMultifunctionNode()
577 tbb::flow::queue_node<int> qeven_out(g); in TestMultifunctionNode()
581 g.wait_for_all(); in TestMultifunctionNode()
587 g.reset(); // attach to the current arena in TestMultifunctionNode()
591 g.wait_for_all(); in TestMultifunctionNode()
596 g.my_context->cancel_group_execution(); in TestMultifunctionNode()
606 g.reset(tbb::flow::rf_clear_edges); in TestMultifunctionNode()
612 g.reset(); in TestMultifunctionNode()
624 tbb::flow::graph g; in TestIndexerNode() local
626 indexernode_type inode(g); in TestIndexerNode()
628 tbb::flow::queue_node<indexernode_type::output_type> qout(g); in TestIndexerNode()
630 g.wait_for_all(); in TestIndexerNode()
632 g.reset(); in TestIndexerNode()
634 g.reset(tbb::flow::rf_clear_edges); in TestIndexerNode()
642 tbb::flow::graph g; in TestScalarNode() local
643 Node on(g); in TestScalarNode()
644 tbb::flow::queue_node<int> qout(g); in TestScalarNode()
647 g.wait_for_all(); in TestScalarNode()
649 g.reset(); in TestScalarNode()
651 g.reset(tbb::flow::rf_clear_edges); in TestScalarNode()
664 tbb::flow::graph g; in TestSequencerNode() local
665 tbb::flow::sequencer_node<int> bnode(g, seq_body()); in TestSequencerNode()
667 … tbb::flow::function_node<int> fnode(g, tbb::flow::serial, serial_fn_body<int>(serial_fn_state0)); in TestSequencerNode()
676 g.wait_for_all(); in TestSequencerNode()
687 tbb::flow::join_node<std::tuple<int,int>,tbb::flow::reserving> jnode(g); in TestSequencerNode()
689 g.wait_for_all(); in TestSequencerNode()
693 g.wait_for_all(); in TestSequencerNode()
696 g.wait_for_all(); in TestSequencerNode()
697 g.reset(); // should be in forward direction again in TestSequencerNode()
700 g.reset(tbb::flow::rf_clear_edges); // should be in forward direction again in TestSequencerNode()
704 g.wait_for_all(); in TestSequencerNode()
721 tbb::flow::graph g; in TestInputNode() local
722 tbb::flow::input_node<int> in(g, snode_body(4)); in TestInputNode()
724 tbb::flow::queue_node<int> qin(g); in TestInputNode()
725 tbb::flow::join_node<std::tuple<int,int>, tbb::flow::reserving> jn(g); in TestInputNode()
726 tbb::flow::queue_node<std::tuple<int,int> > qout(g); in TestInputNode()
733 g.wait_for_all(); in TestInputNode()
734 g.reset(); in TestInputNode()
736 g.wait_for_all(); in TestInputNode()
737 g.reset(tbb::flow::rf_clear_edges); in TestInputNode()
742 g.wait_for_all(); in TestInputNode()
746 g.wait_for_all(); in TestInputNode()
748 g.reset(); in TestInputNode()
845 tbb::flow::graph g; variable
847 tbb::flow::input_node<int> src(g, [&](tbb::flow_control& fc) { fc.stop(); return 0;}); in __anon8a33875c0a02()
848 deactivate_graph(g);
861 tbb::flow::graph g; variable
863 tbb::flow::continue_node<int> c(g, [](const tbb::flow::continue_msg&){ return 1; }); in __anon8a33875c0b02()
865 … tbb::flow::function_node<int, int> f(g, tbb::flow::serial, serial_fn_body<int>(serial_fn_state0));
868 g.wait_for_all();
870 deactivate_graph(g);
878 tbb::flow::graph g; variable
880 tbb::flow::queue_node<int> q(g);
882 tbb::flow::overwrite_node<int> on(g);
885 g.wait_for_all();
887 deactivate_graph(g);
898 tbb::flow::graph g; variable
901 tbb::flow::graph::iterator b = g.begin();
902 tbb::flow::graph::iterator b2 = g.begin();
916 const graph g; variable
917 CHECK_MESSAGE((g.cbegin() == g.cend()), "Starting graph is empty");
918 CHECK_MESSAGE((g.begin() == g.end()), "Starting graph is empty");
929 graph g; variable
931 continue_node<int> c(g, [](const continue_msg&){ return 1; }); in __anon8a33875c0c02()
932 buffer_node<int> b(g);
936 deactivate_graph(g);
939 g.wait_for_all();
952 graph g; variable
955 function_node<int, int, lightweight> f1(g, unlimited, body);
958 function_node<int, int> f2(g, unlimited, body2);
960 buffer_node<int> b(g);
966 g.wait_for_all();