From ebd9d98fd7a2c08f57b1187a7b9efafbfbb63fe7 Mon Sep 17 00:00:00 2001 From: Matthias Schiffer Date: Fri, 2 Mar 2012 20:12:59 +0100 Subject: Delete pending tasks for deleted peers --- src/queue.c | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'src/queue.c') diff --git a/src/queue.c b/src/queue.c index 87ca255..e0e25e1 100644 --- a/src/queue.c +++ b/src/queue.c @@ -87,3 +87,17 @@ int fastd_queue_timeout(fastd_queue *queue) { else return (int)diff_msec; } + +void fastd_queue_filter(fastd_queue *queue, bool (*pred)(void*, void*), void *extra) { + fastd_queue_entry **entry; + for (entry = &queue->head; *entry; ) { + if (!pred((*entry)->data, extra)) { + fastd_queue_entry *cur = *entry; + *entry = cur->next; + free(cur); + } + else { + entry = &(*entry)->next; + } + } +} -- cgit v1.2.3