Lines Matching refs:spq

101 spktq_enq(struct spktq *spq, void *p)  in spktq_enq()  argument
106 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_enq()
109 ASSERT(!spktq_full(spq)); in spktq_enq()
113 q = &spq->q; in spktq_enq()
124 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_enq()
167 spktq_enq_head(struct spktq *spq, void *p) in spktq_enq_head() argument
172 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_enq_head()
175 ASSERT(!spktq_full(spq)); in spktq_enq_head()
179 q = &spq->q; in spktq_enq_head()
189 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_enq_head()
234 spktq_deq(struct spktq *spq) in spktq_deq() argument
240 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_deq()
243 q = &spq->q; in spktq_deq()
261 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_deq()
309 spktq_deq_tail(struct spktq *spq) in spktq_deq_tail() argument
315 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_deq_tail()
318 q = &spq->q; in spktq_deq_tail()
339 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_deq_tail()
432 spktq_append(struct spktq *spq, struct spktq *list) in spktq_append() argument
438 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_append()
449 ASSERT(!spktq_full(spq)); in spktq_append()
451 q = &spq->q; in spktq_append()
471 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_append()
538 spktq_prepend(struct spktq *spq, struct spktq *list) in spktq_prepend() argument
544 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_prepend()
555 ASSERT(!spktq_full(spq)); in spktq_prepend()
557 q = &spq->q; in spktq_prepend()
583 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_prepend()
843 spktq_filter(struct spktq *spq, pktq_filter_t fltr, void* fltr_ctx, in spktq_filter() argument
851 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_filter()
854 q = &spq->q; in spktq_filter()
858 (void)HND_PKTQ_MUTEX_RELEASE(&spq->mutex); in spktq_filter()
873 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_filter()
893 spktq_enq(spq, p); in spktq_filter()
942 spktq_init(struct spktq *spq, int max_pkts) in spktq_init() argument
944 bzero(spq, sizeof(struct spktq)); in spktq_init()
946 if (HND_PKTQ_MUTEX_CREATE("spktq", &spq->mutex) != OSL_EXT_SUCCESS) in spktq_init()
949 spq->q.max_pkts = (uint16)max_pkts; in spktq_init()
965 spktq_deinit(struct spktq *spq) in spktq_deinit() argument
967 BCM_REFERENCE(spq); in spktq_deinit()
968 if (HND_PKTQ_MUTEX_DELETE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_deinit()
1120 spktq_peek(struct spktq *spq) in spktq_peek() argument
1125 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_peek()
1128 if (spq->q.n_pkts == 0) in spktq_peek()
1131 p = spq->q.head; in spktq_peek()
1135 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_peek()
1157 spktq_flush(osl_t *osh, struct spktq *spq, bool dir) in spktq_flush() argument
1164 while ((p = spktq_deq(spq)) != NULL) { in spktq_flush()
1371 spktq_avail(struct spktq *spq) in spktq_avail() argument
1376 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_avail()
1379 ret = spq->q.max_pkts - spq->q.n_pkts; in spktq_avail()
1382 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_avail()
1407 spktq_full(struct spktq *spq) in spktq_full() argument
1412 if (HND_PKTQ_MUTEX_ACQUIRE(&spq->mutex, OSL_EXT_TIME_FOREVER) != OSL_EXT_SUCCESS) in spktq_full()
1415 ret = spq->q.n_pkts >= spq->q.max_pkts; in spktq_full()
1418 if (HND_PKTQ_MUTEX_RELEASE(&spq->mutex) != OSL_EXT_SUCCESS) in spktq_full()