From 99a263ff20e6b2bbeddbbbc4e0a1acbec1d5dd79 Mon Sep 17 00:00:00 2001 From: Holger Hans Peter Freyther Date: Fri, 26 Mar 2010 09:20:22 +0100 Subject: write_queue: Add a method to clear the queue. --- src/write_queue.c | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src/write_queue.c') diff --git a/src/write_queue.c b/src/write_queue.c index 7d908b4c..a0ac2d6f 100644 --- a/src/write_queue.c +++ b/src/write_queue.c @@ -72,3 +72,14 @@ int write_queue_enqueue(struct write_queue *queue, struct msgb *data) return 0; } + +void write_queue_clear(struct write_queue *queue) +{ + while (!llist_empty(&queue->msg_queue)) { + struct msgb *msg = msgb_dequeue(&queue->msg_queue); + msgb_free(msg); + } + + queue->current_length = 0; + queue->bfd.when &= ~BSC_FD_WRITE; +} -- cgit v1.2.3