| 3640 | does not need to lock NODE. */ |
| 3641 | |
| 3642 | static void |
| 3643 | queue_insert (struct merge_node_queue *queue, struct merge_node *node) |
| 3644 | { |
| 3645 | pthread_mutex_lock (&queue->mutex); |
| 3646 | heap_insert (queue->priority_queue, node); |
| 3647 | node->queued = true; |
| 3648 | pthread_cond_signal (&queue->cond); |
| 3649 | pthread_mutex_unlock (&queue->mutex); |
| 3650 | } |
| 3651 | |
| 3652 | /* Pop the top node off the priority QUEUE, lock the node, return it. */ |
| 3653 |
no test coverage detected