Function ng_flush_input_queue

lib/ff_ng_base.c:2178–2204

Purge node queue. Called on node shutdown. */

/* Purge node queue. Called on node shutdown. */
static void
ng_flush_input_queue(node_p node)
{
    struct ng_queue *ngq = &node->nd_input_queue;
    item_p item;

    NG_QUEUE_LOCK(ngq);
    while ((item = STAILQ_FIRST(&ngq->queue)) != NULL) {
        STAILQ_REMOVE_HEAD(&ngq->queue, el_next);
        if (STAILQ_EMPTY(&ngq->queue))
            atomic_clear_int(&ngq->q_flags, OP_PENDING);
        NG_QUEUE_UNLOCK(ngq);

        /* If the item is supplying a callback, call it with an error */
        if (item->apply != NULL) {
            if (item->depth == 1)
                item->apply->error = ENOENT;
            if (refcount_release(&item->apply->refs)) {
                (*item->apply->apply)(item->apply->context,
                    item->apply->error);
            }
        }
        NG_FREE_ITEM(item);
        NG_QUEUE_LOCK(ngq);
    }
    NG_QUEUE_UNLOCK(ngq);
}
#endif

/***********************************************************************