Lines Matching refs:taskgroup
1537 kmp_taskgroup_t *taskgroup = taskdata->td_taskgroup; in __kmp_invoke_task() local
1538 if ((taskgroup && taskgroup->cancel_request) || in __kmp_invoke_task()
1546 ((taskgroup && taskgroup->cancel_request) ? ompt_cancel_taskgroup in __kmp_invoke_task()
2521 kmp_taskgroup_t *taskgroup = taskdata->td_taskgroup; in __kmpc_end_taskgroup() local
2541 KMP_DEBUG_ASSERT(taskgroup != NULL); in __kmpc_end_taskgroup()
2571 RCAST(std::atomic<kmp_uint32> *, &(taskgroup->count)), 0U); in __kmpc_end_taskgroup()
2572 while (KMP_ATOMIC_LD_ACQ(&taskgroup->count) != 0) { in __kmpc_end_taskgroup()
2593 KMP_DEBUG_ASSERT(taskgroup->count == 0); in __kmpc_end_taskgroup()
2595 if (taskgroup->reduce_data != NULL && in __kmpc_end_taskgroup()
2596 !taskgroup->gomp_data) { // need to reduce? in __kmpc_end_taskgroup()
2600 kmp_taskred_data_t *arr = (kmp_taskred_data_t *)taskgroup->reduce_data; in __kmpc_end_taskgroup()
2610 __kmp_task_reduction_fini(thread, taskgroup); in __kmpc_end_taskgroup()
2619 __kmp_task_reduction_clean(thread, taskgroup); in __kmpc_end_taskgroup()
2628 __kmp_task_reduction_fini(thread, taskgroup); in __kmpc_end_taskgroup()
2637 __kmp_task_reduction_clean(thread, taskgroup); in __kmpc_end_taskgroup()
2641 __kmp_task_reduction_fini(thread, taskgroup); in __kmpc_end_taskgroup()
2645 taskdata->td_taskgroup = taskgroup->parent; in __kmpc_end_taskgroup()
2646 __kmp_thread_free(thread, taskgroup); in __kmpc_end_taskgroup()