Lines Matching refs:absorber_body

226 class absorber_body : WaitThrow<Conc,T> {  class
230 absorber_body(std::atomic<int> &my_cnt) : my_count(&my_cnt) { } in absorber_body() function in absorber_body
351 …typedef absorber_body<ItemType, tbb::flow::continue_msg, absorbThrowType, unlimited_type> parallel… in run_one_input_node_test()
592 typedef absorber_body<Item12, Item23, FType, Conc> TestBodyType; in run_function_node_test()
593 typedef absorber_body<Item23,tbb::flow::continue_msg, NType1, unlimited_type> SinkBodyType1; in run_function_node_test()
594 typedef absorber_body<Item23,tbb::flow::continue_msg, NType2, unlimited_type> SinkBodyType2; in run_function_node_test()
699 … typedef absorber_body<Item23Type0,tbb::flow::continue_msg, NType1, unlimited_type> SinkBodyType1; in run_multifunction_node_test()
700 … typedef absorber_body<Item23Type1,tbb::flow::continue_msg, NType2, unlimited_type> SinkBodyType2; in run_multifunction_node_test()
867 typedef absorber_body<tbb::flow::continue_msg,ItemType,CType,unlimited_type> ContBodyType; in run_continue_node_test()
868 typedef absorber_body<ItemType,tbb::flow::continue_msg, AType, unlimited_type> SinkBodyType; in run_continue_node_test()
988 …typedef absorber_body<BufferItemType,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBod… in run_buffer_queue_and_overwrite_node_test()
1122 …typedef absorber_body<BufferItemType,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBod… in run_sequencer_node_test()
1246 …typedef absorber_body<BufferItemType,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBod… in run_priority_queue_node_test()
1508 …typedef absorber_body<OutputTuple,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBodyTy… in run_join_node_test()
1633 …typedef absorber_body<BufferItemType,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBod… in run_limiter_node_test()
1746 …typedef absorber_body<ItemType0,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBodyType… in run_split_node_test()
1747 …typedef absorber_body<ItemType1,tbb::flow::continue_msg,SinkThrowType,unlimited_type> SinkBodyType… in run_split_node_test()
1882 …typedef absorber_body<typename TestNodeType::output_type,tbb::flow::continue_msg,SinkThrowType,unl… in run_indexer_node_test()