Lines Matching refs:new_queue
434 kmpc_task_queue_t *new_queue; in __kmp_alloc_taskq() local
446 new_queue = tq->tq_freelist; in __kmp_alloc_taskq()
449 KMP_DEBUG_ASSERT(new_queue->tq_flags & TQF_DEALLOCATED); in __kmp_alloc_taskq()
451 new_queue->tq_flags = 0; in __kmp_alloc_taskq()
457 new_queue = (kmpc_task_queue_t *)__kmp_taskq_allocate( in __kmp_alloc_taskq()
459 new_queue->tq_flags = 0; in __kmp_alloc_taskq()
468 new_queue->tq_thunk_space = (kmpc_thunk_t *)pt; in __kmp_alloc_taskq()
473 new_queue->tq_free_thunks = (kmpc_thunk_t *)pt; in __kmp_alloc_taskq()
492 __kmp_init_lock(&new_queue->tq_link_lck); in __kmp_alloc_taskq()
493 __kmp_init_lock(&new_queue->tq_free_thunks_lck); in __kmp_alloc_taskq()
494 __kmp_init_lock(&new_queue->tq_queue_lck); in __kmp_alloc_taskq()
500 new_queue->tq_queue = in __kmp_alloc_taskq()
518 shared_var_array[i].ai_data->sv_queue = new_queue; in __kmp_alloc_taskq()
520 new_queue->tq_shareds = shared_var_array; in __kmp_alloc_taskq()
526 new_queue->tq_th_thunks = in __kmp_alloc_taskq()
528 new_queue->tq_nproc = nproc; in __kmp_alloc_taskq()
531 new_queue->tq_th_thunks[i].ai_data = 0; in __kmp_alloc_taskq()
534 return new_queue; in __kmp_alloc_taskq()
1309 kmpc_task_queue_t *new_queue, *curr_queue; in __kmpc_taskq() local
1387 new_queue = __kmp_alloc_taskq(tq, in_parallel, nslots, nthunks, nshareds, in __kmpc_taskq()
1392 new_queue->tq_flags = flags & TQF_INTERFACE_FLAGS; in __kmpc_taskq()
1395 new_queue->tq_tasknum_queuing = 0; in __kmpc_taskq()
1396 new_queue->tq_tasknum_serving = 0; in __kmpc_taskq()
1397 new_queue->tq_flags |= TQF_PARALLEL_CONTEXT; in __kmpc_taskq()
1400 new_queue->tq_taskq_slot = NULL; in __kmpc_taskq()
1401 new_queue->tq_nslots = nslots; in __kmpc_taskq()
1402 new_queue->tq_hiwat = HIGH_WATER_MARK(nslots); in __kmpc_taskq()
1403 new_queue->tq_nfull = 0; in __kmpc_taskq()
1404 new_queue->tq_head = 0; in __kmpc_taskq()
1405 new_queue->tq_tail = 0; in __kmpc_taskq()
1406 new_queue->tq_loc = loc; in __kmpc_taskq()
1408 if ((new_queue->tq_flags & TQF_IS_ORDERED) && in_parallel) { in __kmpc_taskq()
1410 new_queue->tq_tasknum_serving = 1; in __kmpc_taskq()
1420 *shareds = CCAST(kmpc_shared_vars_t *, new_queue->tq_shareds[0].ai_data); in __kmpc_taskq()
1424 new_taskq_thunk->th_flags = new_queue->tq_flags | TQF_TASKQ_TASK; in __kmpc_taskq()
1437 new_queue->tq.tq_parent = NULL; in __kmpc_taskq()
1438 new_queue->tq_first_child = NULL; in __kmpc_taskq()
1439 new_queue->tq_next_child = NULL; in __kmpc_taskq()
1440 new_queue->tq_prev_child = NULL; in __kmpc_taskq()
1441 new_queue->tq_ref_count = 1; in __kmpc_taskq()
1442 tq->tq_root = new_queue; in __kmpc_taskq()
1445 new_queue->tq.tq_parent = curr_queue; in __kmpc_taskq()
1446 new_queue->tq_first_child = NULL; in __kmpc_taskq()
1447 new_queue->tq_prev_child = NULL; in __kmpc_taskq()
1448 new_queue->tq_ref_count = in __kmpc_taskq()
1452 global_tid, new_queue, new_queue->tq_ref_count)); in __kmpc_taskq()
1460 new_queue->tq_next_child = 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()
1478 new_queue->tq.tq_parent = NULL; in __kmpc_taskq()
1479 new_queue->tq_first_child = NULL; in __kmpc_taskq()
1480 new_queue->tq_next_child = NULL; in __kmpc_taskq()
1481 new_queue->tq_prev_child = NULL; in __kmpc_taskq()
1482 new_queue->tq_ref_count = 1; in __kmpc_taskq()
1491 ("After TaskQ at %p Creation on (%d):\n", new_queue, global_tid)); in __kmpc_taskq()
1493 KF_TRACE(25, ("After Serial TaskQ at %p Creation on (%d):\n", new_queue, in __kmpc_taskq()
1497 KF_DUMP(25, __kmp_dump_task_queue(tq, new_queue, global_tid)); in __kmpc_taskq()
1505 __kmp_push_workshare(global_tid, ct_taskq, new_queue->tq_loc); in __kmpc_taskq()