Searched refs:tag_queue (Results 1 – 1 of 1) sorted by relevance
71 tbb::flow::queue_node<int> tag_queue(g); in test() local72 tbb::flow::make_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()79 tbb::flow::make_edge(recreate_tag, tag_queue); in test()82 for(int t = 1; t<=maxTag; ++t) tag_queue.try_put(t); in test()99 CHECK_MESSAGE( (tag_queue.try_get(j)), "not enough tags in queue"); in test()103 CHECK_MESSAGE( (!tag_queue.try_get(j)), "Extra tags in recirculation queue"); in test()109 tbb::flow::remove_edge(tag_queue, tbb::flow::input_port<0>(*my_input_join)); in test()