diff options
Diffstat (limited to 'queue_common.c')
| -rw-r--r-- | queue_common.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/queue_common.c b/queue_common.c index b9c2f99..717f6ab 100644 --- a/queue_common.c +++ b/queue_common.c @@ -8,7 +8,7 @@ * access to this should only be called in the main thread, this * is currently not thread safe as there's no need for it. */ -static LIST_HEAD(queue_head, mog_queue) all_queues; +static LIST_HEAD(all_queues); struct mog_queue *mog_queue_init(int queue_fd) { @@ -26,7 +26,7 @@ struct mog_queue *mog_queue_init(int queue_fd) q = &mfd->as.queue; q->queue_fd = queue_fd; memset(&q->thrpool, 0, sizeof(struct mog_thrpool)); - LIST_INSERT_HEAD(&all_queues, q, qbuddies); + list_add(&all_queues, &q->qbuddies); return q; } @@ -36,11 +36,11 @@ void mog_queue_stop(struct mog_queue *keep) struct mog_queue *queue, *tmp; struct mog_fd *mfd; - LIST_FOREACH_SAFE(queue, &all_queues, qbuddies, tmp) { + list_for_each_safe(&all_queues, queue, tmp, qbuddies) { /* keep is usually mog_notify_queue */ if (queue == keep) continue; - LIST_REMOVE(queue, qbuddies); + list_del(&queue->qbuddies); mog_thrpool_quit(&queue->thrpool, queue); mfd = mog_fd_of(queue); mog_fd_put(mfd); |