Searched refs:rtask (Results 1 – 2 of 2) sorted by relevance
413 graph_task* rtask = nullptr;416 if (was_empty) rtask = my_join->decrement_port_count(false);418 rtask = SUCCESSFULLY_ENQUEUED;419 current->bypass_t = rtask;598 graph_task* rtask = nullptr;601 rtask = my_join->increment_key_count((*(this->get_key_func()))(v)); // may spawn603 if(!rtask) rtask = SUCCESSFULLY_ENQUEUED;605 return rtask;880 graph_task* rtask = nullptr;889 rtask = allocator.new_object<task_type>(this->graph_ref, allocator, *my_node);[all …]
1969 … graph_task* rtask = allocator.new_object<task_type>( my_graph, allocator, *this ); in forward_task() local1971 spawn_in_graph_arena(graph_reference(), *rtask); in forward_task()2092 graph_task* rtask = my_successors.try_put_task(t); in try_put_task() local2093 if ( !rtask ) { // try_put_task failed. in try_put_task()2099 rtask = allocator.new_object<task_type>(my_graph, allocator, *this); in try_put_task()2118 return rtask; in try_put_task()3119 graph_task* rtask = my_successors.try_put_task(v); in try_put_task_impl() local3120 if (!rtask) rtask = SUCCESSFULLY_ENQUEUED; in try_put_task_impl()3121 return rtask; in try_put_task_impl()