Clear the queue */
| 478 | |
| 479 | /* Clear the queue */ |
| 480 | static void jobqueue_clear(jobqueue *jobqueue_p) { |
| 481 | |
| 482 | while(jobqueue_p->len) { |
| 483 | rm_free(jobqueue_pull(jobqueue_p)); |
| 484 | } |
| 485 | |
| 486 | jobqueue_p->front = NULL; |
| 487 | jobqueue_p->rear = NULL; |
| 488 | bsem_reset(jobqueue_p->has_jobs); |
| 489 | jobqueue_p->len = 0; |
| 490 | } |
| 491 | |
| 492 | /* Add (allocated) job to queue */ |
| 493 | static void jobqueue_push(jobqueue *jobqueue_p, struct job *newjob) { |
no test coverage detected