Searched refs:pq_queue (Results 1 – 1 of 1) sorted by relevance
69 static stream_t **pq_queue; variable229 swap((void **)&pq_queue[k], (void **)&pq_queue[k / 2]); in heap_up()247 swap((void **)&pq_queue[k], (void **)&pq_queue[j]); in heap_down()262 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1)); in pqueue_init()270 pq_queue[++pq_N] = source; in pqueue_insert()271 heap_up(pq_queue, pq_N, coll_flags); in pqueue_insert()277 swap((void **)&pq_queue[1], (void **)&pq_queue[pq_N]); in pqueue_head()278 heap_down(pq_queue, 1, pq_N - 1, coll_flags); in pqueue_head()279 return (pq_queue[pq_N--]); in pqueue_head()