Lines Matching defs:pq_queue
69 static stream_t **pq_queue;
229 swap((void **)&pq_queue[k], (void **)&pq_queue[k / 2]);
247 swap((void **)&pq_queue[k], (void **)&pq_queue[j]);
262 pq_queue = safe_realloc(NULL, sizeof (stream_t *) * (max_size + 1));
270 pq_queue[++pq_N] = source;
271 heap_up(pq_queue, pq_N, coll_flags);
277 swap((void **)&pq_queue[1], (void **)&pq_queue[pq_N]);
278 heap_down(pq_queue, 1, pq_N - 1, coll_flags);
279 return (pq_queue[pq_N--]);