216     void try_to_spawn_task_for_next_token(StageTask& spawner, d1::execution_data& ed) {  in try_to_spawn_task_for_next_token()  argument
227             spawner.spawn_stage_task(wakee, ed);  in try_to_spawn_task_for_next_token()
278     bool execute_filter(d1::execution_data& ed);
281     void try_spawn_stage_task(d1::execution_data& ed) {  in try_spawn_stage_task()  argument
285 …       r1::spawn( *alloc.new_object<stage_task>(ed, my_pipeline, alloc ), my_pipeline.my_context );  in try_spawn_stage_task()
318     void finalize(d1::execution_data& ed) {  in finalize()  argument
319         m_allocator.delete_object(this, ed);  in finalize()
322     task* execute(d1::execution_data& ed) override {  in execute()  argument
323         if(!execute_filter(ed)) {  in execute()
324             finalize(ed);  in execute()
329     task* cancel(d1::execution_data& ed) override {  in cancel()  argument
330         finalize(ed);  in cancel()
342     void spawn_stage_task(const task_info& info, d1::execution_data& ed) {  in spawn_stage_task()  argument
344         stage_task* clone = alloc.new_object<stage_task>(ed, my_pipeline, my_filter, info, alloc);  in spawn_stage_task()
349 bool stage_task::execute_filter(d1::execution_data& ed) {  in execute_filter()  argument
363                     try_spawn_stage_task(ed);  in execute_filter()
374             try_spawn_stage_task(ed);  in execute_filter()
386             my_filter->my_input_buffer->try_to_spawn_task_for_next_token(*this, ed);  in execute_filter()