37     friend void parallel_pipeline(d1::task_group_context&, std::size_t, const d1::filter_node&);
41     pipeline(d1::task_group_context& cxt, std::size_t max_token) :  in pipeline()
54     void add_filter( d1::base_filter& );
57     void fill_pipeline(const d1::filter_node& root) {  in fill_pipeline()
71     friend void set_end_of_input(d1::base_filter& bf);
76     d1::base_filter* first_filter;
79     d1::base_filter* last_filter;
87     d1::wait_context wait_ctx;
114     friend void set_end_of_input(d1::base_filter& bf);
216     void try_to_spawn_task_for_next_token(StageTask& spawner, d1::execution_data& ed) {  in try_to_spawn_task_for_next_token()
268 class stage_task : public d1::task, public task_info {
272     d1::base_filter* my_filter;
273     d1::small_object_allocator m_allocator;
278     bool execute_filter(d1::execution_data& ed);
281     void try_spawn_stage_task(d1::execution_data& ed) {  in try_spawn_stage_task()
284             d1::small_object_allocator alloc{};  in try_spawn_stage_task()
293     stage_task(pipeline& pipeline, d1::small_object_allocator& alloc ) :  in stage_task()
303 …stage_task(pipeline& pipeline, d1::base_filter* filter, const task_info& info, d1::small_object_al…  in stage_task()
318     void finalize(d1::execution_data& ed) {  in finalize()
322     task* execute(d1::execution_data& ed) override {  in execute()
329     task* cancel(d1::execution_data& ed) override {  in cancel()
342     void spawn_stage_task(const task_info& info, d1::execution_data& ed) {  in spawn_stage_task()
343         d1::small_object_allocator alloc{};  in spawn_stage_task()
349 bool stage_task::execute_filter(d1::execution_data& ed) {  in execute_filter()
415         d1::base_filter* f = first_filter;  in ~pipeline()
426 void pipeline::add_filter( d1::base_filter& new_fitler ) {  in add_filter()
427 …__TBB_ASSERT( new_fitler.next_filter_in_pipeline==d1::base_filter::not_in_pipeline(), "filter alre…  in add_filter()
446 void __TBB_EXPORTED_FUNC parallel_pipeline(d1::task_group_context& cxt, std::size_t max_token, cons…  in parallel_pipeline()
451     d1::small_object_allocator alloc{};  in parallel_pipeline()
458 void __TBB_EXPORTED_FUNC set_end_of_input(d1::base_filter& bf) {  in set_end_of_input()