Lines Matching refs:curr_queue

299                                            kmpc_task_queue_t *curr_queue,  in __kmp_aux_dump_task_queue_tree()  argument
304 kmpc_task_queue_t *queue = curr_queue; in __kmp_aux_dump_task_queue_tree()
306 if (curr_queue == NULL) in __kmp_aux_dump_task_queue_tree()
314 __kmp_printf("%p", curr_queue); in __kmp_aux_dump_task_queue_tree()
318 tq->tq_curr_thunk[i]->th.th_shareds->sv_queue == curr_queue) { in __kmp_aux_dump_task_queue_tree()
331 qs = curr_queue->tq_tail; in __kmp_aux_dump_task_queue_tree()
333 for (count = 0; count < curr_queue->tq_nfull; ++count) { in __kmp_aux_dump_task_queue_tree()
334 __kmp_printf("%p ", curr_queue->tq_queue[qs].qs_thunk); in __kmp_aux_dump_task_queue_tree()
335 qs = (qs + 1) % curr_queue->tq_nslots; in __kmp_aux_dump_task_queue_tree()
342 if (curr_queue->tq_first_child) { in __kmp_aux_dump_task_queue_tree()
349 if (curr_queue->tq_first_child) { in __kmp_aux_dump_task_queue_tree()
350 for (queue = CCAST(kmpc_task_queue_t *, curr_queue->tq_first_child); in __kmp_aux_dump_task_queue_tree()
837 kmpc_task_queue_t *curr_queue) { in __kmp_find_task_in_descendant_queue() argument
839 kmpc_task_queue_t *queue = curr_queue; in __kmp_find_task_in_descendant_queue()
841 if (curr_queue->tq_first_child != NULL) { in __kmp_find_task_in_descendant_queue()
842 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
847 queue = CCAST(kmpc_task_queue_t *, curr_queue->tq_first_child); in __kmp_find_task_in_descendant_queue()
849 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
858 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
867 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
877 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
891 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
901 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
906 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
921 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_task_in_descendant_queue()
932 kmpc_task_queue_t *curr_queue) { in __kmp_find_task_in_ancestor_queue() argument
938 if (curr_queue->tq.tq_parent != NULL) { in __kmp_find_task_in_ancestor_queue()
939 queue = curr_queue->tq.tq_parent; in __kmp_find_task_in_ancestor_queue()
1104 kmp_taskq_t *tq, kmp_int32 global_tid, kmpc_task_queue_t *curr_queue) { in __kmp_find_and_remove_finished_child_taskq() argument
1105 kmpc_task_queue_t *queue = curr_queue; in __kmp_find_and_remove_finished_child_taskq()
1107 if (curr_queue->tq_first_child != NULL) { in __kmp_find_and_remove_finished_child_taskq()
1108 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_and_remove_finished_child_taskq()
1113 queue = CCAST(kmpc_task_queue_t *, curr_queue->tq_first_child); in __kmp_find_and_remove_finished_child_taskq()
1115 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_and_remove_finished_child_taskq()
1157 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_and_remove_finished_child_taskq()
1172 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmp_find_and_remove_finished_child_taskq()
1309 kmpc_task_queue_t *new_queue, *curr_queue; in __kmpc_taskq() local
1444 curr_queue = tq->tq_curr_thunk[tid]->th.th_shareds->sv_queue; in __kmpc_taskq()
1445 new_queue->tq.tq_parent = curr_queue; in __kmpc_taskq()
1454 __kmp_acquire_lock(&curr_queue->tq_link_lck, global_tid); in __kmpc_taskq()
1461 CCAST(struct kmpc_task_queue_t *, curr_queue->tq_first_child); in __kmpc_taskq()
1463 if (curr_queue->tq_first_child != NULL) in __kmpc_taskq()
1464 curr_queue->tq_first_child->tq_prev_child = new_queue; in __kmpc_taskq()
1466 curr_queue->tq_first_child = new_queue; in __kmpc_taskq()
1468 __kmp_release_lock(&curr_queue->tq_link_lck, global_tid); in __kmpc_taskq()