Lines Matching refs:bnode
83 B bnode(g); in TestBufferingNode() local
90 tbb::flow::make_edge(bnode, fnode); in TestBufferingNode()
91 … CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after make_edge"); in TestBufferingNode()
94 bnode.try_put(1); // will forward to the fnode in TestBufferingNode()
100 bnode.try_put(2); // should reverse the edge in TestBufferingNode()
102 utils::SpinWaitWhile([&] { return !bnode.my_successors.empty(); }); in TestBufferingNode()
105 …CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after forwarding m… in TestBufferingNode()
115 tbb::flow::remove_edge(bnode, fnode); in TestBufferingNode()
116 … CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after remove_edge"); in TestBufferingNode()
119 tbb::flow::make_edge(bnode, tbb::flow::input_port<0>(jnode)); // will spawn a task in TestBufferingNode()
121 …CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after attaching to… in TestBufferingNode()
123 bnode.try_put(1); // the edge should reverse in TestBufferingNode()
125 CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after reserving"); in TestBufferingNode()
129 CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after reset()"); in TestBufferingNode()
132 …CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after reset(rf_clear… in TestBufferingNode()
133 tbb::flow::make_edge(bnode, tbb::flow::input_port<0>(jnode)); // add edge again in TestBufferingNode()
135 bnode.try_put(1); // the edge should reverse in TestBufferingNode()
137 CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after reserving"); in TestBufferingNode()
140 CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has no successor after reset()"); in TestBufferingNode()
362 tbb::flow::broadcast_node<std::tuple<int> > bnode(g); in TestSimpleSuccessorArc() local
363 tbb::flow::make_edge(qj, bnode); in TestSimpleSuccessorArc()
383 tbb::flow::broadcast_node<my_tuple > bnode(g); in TestSimpleSuccessorArc() local
384 tbb::flow::make_edge(qj, bnode); in TestSimpleSuccessorArc()
665 tbb::flow::sequencer_node<int> bnode(g, seq_body()); in TestSequencerNode() local
671 tbb::flow::make_edge(bnode, fnode); in TestSequencerNode()
672 …CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after make_edge" ); in TestSequencerNode()
675 bnode.try_put(0); // will forward to the fnode in TestSequencerNode()
680 …CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after forwarding m… in TestSequencerNode()
685 tbb::flow::remove_edge(bnode, fnode); in TestSequencerNode()
686 … CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after remove_edge"); in TestSequencerNode()
688 tbb::flow::make_edge(bnode, tbb::flow::input_port<0>(jnode)); // will spawn a task in TestSequencerNode()
690 …CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after attaching to… in TestSequencerNode()
692 bnode.try_put(3); // the edge should reverse in TestSequencerNode()
694 CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after reserving"); in TestSequencerNode()
698 CHECK_MESSAGE( (!bnode.my_successors.empty()), "buffering node has no successor after reset()"); in TestSequencerNode()
701 …CHECK_MESSAGE( (bnode.my_successors.empty()), "buffering node has a successor after reset(rf_clear… in TestSequencerNode()