Searched refs:pq_queue (Results 1 – 1 of 1) sorted by relevance
67 static stream_t **pq_queue; variable227 swap((void **)&pq_queue[k], (void **)&pq_queue[k / 2]); in heap_up()245 swap((void **)&pq_queue[k], (void **)&pq_queue[j]); in heap_down()260 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1)); in pqueue_init()268 pq_queue[++pq_N] = source; in pqueue_insert()269 heap_up(pq_queue, pq_N, coll_flags); in pqueue_insert()275 swap((void **)&pq_queue[1], (void **)&pq_queue[pq_N]); in pqueue_head()276 heap_down(pq_queue, 1, pq_N - 1, coll_flags); in pqueue_head()277 return (pq_queue[pq_N--]); in pqueue_head()