Lines Matching refs:pktq
523 void cfpkt_queue(struct cfpktq *pktq, struct cfpkt *pkt, unsigned short prio)
525 atomic_inc(&pktq->count);
526 spin_lock(&pktq->lock);
527 skb_queue_tail(&pktq->head, pkt_to_skb(pkt));
528 spin_unlock(&pktq->lock);
533 struct cfpkt *cfpkt_qpeek(struct cfpktq *pktq)
536 spin_lock(&pktq->lock);
537 tmp = skb_to_pkt(skb_peek(&pktq->head));
538 spin_unlock(&pktq->lock);
543 struct cfpkt *cfpkt_dequeue(struct cfpktq *pktq)
546 spin_lock(&pktq->lock);
547 pkt = skb_to_pkt(skb_dequeue(&pktq->head));
549 atomic_dec(&pktq->count);
550 caif_assert(atomic_read(&pktq->count) >= 0);
552 spin_unlock(&pktq->lock);
557 int cfpkt_qcount(struct cfpktq *pktq)
559 return atomic_read(&pktq->count);