Lines Matching refs:spq
131 BCMFASTPATH(spktq_enq)(struct spktq *spq, void *p) in BCMFASTPATH()
136 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
139 ASSERT_FP(!spktq_full(spq)); in BCMFASTPATH()
143 q = &spq->q; in BCMFASTPATH()
154 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
197 BCMFASTPATH(spktq_enq_head)(struct spktq *spq, void *p) in BCMFASTPATH()
202 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
205 ASSERT_FP(!spktq_full(spq)); in BCMFASTPATH()
209 q = &spq->q; in BCMFASTPATH()
219 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
264 BCMFASTPATH(spktq_deq)(struct spktq *spq) in BCMFASTPATH()
270 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
273 q = &spq->q; in BCMFASTPATH()
291 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
298 BCMFASTPATH(spktq_deq_virt)(struct spktq *spq) in BCMFASTPATH()
304 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
307 q = &spq->q; in BCMFASTPATH()
327 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
375 BCMFASTPATH(spktq_deq_tail)(struct spktq *spq) in BCMFASTPATH()
381 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
384 q = &spq->q; in BCMFASTPATH()
405 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
498 BCMFASTPATH(spktq_append)(struct spktq *spq, struct spktq *list) in BCMFASTPATH()
504 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
515 ASSERT_FP(!spktq_full(spq)); in BCMFASTPATH()
517 q = &spq->q; in BCMFASTPATH()
537 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
604 BCMFASTPATH(spktq_prepend)(struct spktq *spq, struct spktq *list) in BCMFASTPATH()
610 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in BCMFASTPATH()
621 ASSERT_FP(!spktq_full(spq)); in BCMFASTPATH()
623 q = &spq->q; in BCMFASTPATH()
649 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in BCMFASTPATH()
909 spktq_filter(struct spktq *spq, pktq_filter_t fltr, void* fltr_ctx, in spktq_filter() argument
917 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_filter()
920 q = &spq->q; in spktq_filter()
924 (void)HND_PKTQ_MUTEX_RELEASE(&spq->mutex); in spktq_filter()
939 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_filter()
959 spktq_enq(spq, p); in spktq_filter()
1008 spktq_init(struct spktq *spq, uint max_pkts) in spktq_init() argument
1010 bzero(spq, sizeof(struct spktq)); in spktq_init()
1012 if (HND_PKTQ_MUTEX_CREATE("spktq", &spq->mutex) != OSL_EXT_SUCCESS) in spktq_init()
1015 spq->q.max_pkts = (uint16)max_pkts; in spktq_init()
1021 spktq_init_list(struct spktq *spq, uint max_pkts, void *head, void *tail, uint16 n_pkts) in spktq_init_list() argument
1023 if (HND_PKTQ_MUTEX_CREATE("spktq", &spq->mutex) != OSL_EXT_SUCCESS) in spktq_init_list()
1028 spq->q.head = head; in spktq_init_list()
1029 spq->q.tail = tail; in spktq_init_list()
1030 spq->q.max_pkts = (uint16)max_pkts; in spktq_init_list()
1031 spq->q.n_pkts = n_pkts; in spktq_init_list()
1032 spq->q.stall_count = 0; in spktq_init_list()
1033 spq->q.dequeue_count = 0; in spktq_init_list()
1049 spktq_deinit(struct spktq *spq) in spktq_deinit() argument
1051 BCM_REFERENCE(spq); in spktq_deinit()
1052 if (HND_PKTQ_MUTEX_DELETE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_deinit()
1204 spktq_peek(struct spktq *spq) in spktq_peek() argument
1209 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_peek()
1212 if (spq->q.n_pkts == 0) in spktq_peek()
1215 p = spq->q.head; in spktq_peek()
1219 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_peek()
1241 spktq_flush_ext(osl_t *osh, struct spktq *spq, bool dir, in spktq_flush_ext() argument
1249 while ((pkt = spktq_deq(spq)) != NULL) { in spktq_flush_ext()
1281 spktq_cb(void *spq) in spktq_cb() argument
1285 cbinfop->cb(cbinfop->arg, spq); in spktq_cb()
1495 spktq_avail(struct spktq *spq) in spktq_avail() argument
1500 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_avail()
1503 ret = spq->q.max_pkts - spq->q.n_pkts; in spktq_avail()
1506 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_avail()
1531 spktq_full(struct spktq *spq) in spktq_full() argument
1536 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_full()
1539 ret = spq->q.n_pkts >= spq->q.max_pkts; in spktq_full()
1542 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_full()