Function ng_queue_rw

lib/ff_ng_base.c:2019–2044

* Queue a packet to be picked up later by someone else. * If the queue could be run now, add node to the queue handler's worklist. */

 * If the queue could be run now, add node to the queue handler's worklist.
 */
static __inline void
ng_queue_rw(node_p node, item_p  item, int rw)
{
    struct ng_queue *ngq = &node->nd_input_queue;
    if (rw == NGQRW_W)
        NGI_SET_WRITER(item);
    else
        NGI_SET_READER(item);
    item->depth = 1;

    NG_QUEUE_LOCK(ngq);
    /* Set OP_PENDING flag and enqueue the item. */
    atomic_set_int(&ngq->q_flags, OP_PENDING);
    STAILQ_INSERT_TAIL(&ngq->queue, item, el_next);

    CTR5(KTR_NET, "%20s: node [%x] (%p) queued item %p as %s", __func__,
        node->nd_ID, node, item, rw ? "WRITER" : "READER" );

    /*
     * We can take the worklist lock with the node locked
     * BUT NOT THE REVERSE!
     */
    if (NEXT_QUEUED_ITEM_CAN_PROCEED(ngq))
        ng_worklist_add(node);
    NG_QUEUE_UNLOCK(ngq);
}

/* Acquire reader lock on node. If node is busy, queue the packet. */
static __inline item_p