Lines Matching refs:make_edge
135 tbb::flow::make_edge( lim, r ); in test_puts_with_decrements()
136 tbb::flow::make_edge(s, lim.decrementer()); in test_puts_with_decrements()
162 tbb::flow::make_edge( lim, r ); in test_parallel()
196 tbb::flow::make_edge( lim, r ); in test_serial()
210 tbb::flow::make_edge( lim, r ); in test_serial()
211 tbb::flow::make_edge(s, lim.decrementer()); in test_serial()
288 tbb::flow::make_edge(tbb::flow::output_port<LIMITER_OUTPUT>(mf_node), lim_node); in test_multifunction_to_limiter()
289 tbb::flow::make_edge(tbb::flow::output_port<DECREMENT_OUTPUT>(mf_node), lim_node.decrementer()); in test_multifunction_to_limiter()
290 tbb::flow::make_edge(lim_node, fn_node); in test_multifunction_to_limiter()
291 tbb::flow::make_edge(fn_node, mf_node); in test_multifunction_to_limiter()
317 tbb::flow::make_edge(ln, qn); in test_continue_msg_reception()
342 make_edge(input_queue, limit); in test_reserve_release_messages()
343 make_edge(limit, output_queue); in test_reserve_release_messages()
344 make_edge(broad,limit.decrementer()); in test_reserve_release_messages()
359 tbb::flow::make_edge(limit, output_queue); //putting the successor back in test_reserve_release_messages()
380 make_edge(limit, queue); in test_decrementer()
401 make_edge(limit2, queue); in test_decrementer()
419 make_edge(limit3, queue); in test_decrementer()
443 tbb::flow::make_edge(bn, ln); in test_try_put_without_successors()
457 tbb::flow::make_edge(ln, fn); in test_try_put_without_successors()
527 tbb::flow::make_edge(input, blockingNode); in test_decrement_while_try_put_task()
528 tbb::flow::make_edge(blockingNode, processing); in test_decrement_while_try_put_task()
529 tbb::flow::make_edge(processing, blockingNode.decrementer()); in test_decrement_while_try_put_task()
619 tbb::flow::make_edge( input_node, func );