Lines Matching refs:rtask

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 spawn
603                 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);
899             return rtask;