Searched refs:pqueue (Results 1 – 9 of 9) sorted by relevance
231 struct otx2_cpt_pending_queue *pqueue, in process_request() argument260 spin_lock_bh(&pqueue->lock); in process_request()261 pentry = get_free_pending_entry(pqueue, pqueue->qlen); in process_request()264 spin_unlock_bh(&pqueue->lock); in process_request()266 spin_lock_bh(&pqueue->lock); in process_request()267 pentry = get_free_pending_entry(pqueue, pqueue->qlen); in process_request()281 pqueue->pending_count > (pqueue->qlen - CPT_IQ_STOP_MARGIN)) { in process_request()286 pqueue->pending_count++; in process_request()331 spin_unlock_bh(&pqueue->lock); in process_request()337 spin_unlock_bh(&pqueue->lock); in process_request()[all …]
176 kfree(lfs->lf[i].pqueue.head); in free_pending_queues()177 lfs->lf[i].pqueue.head = NULL; in free_pending_queues()189 lfs->lf[i].pqueue.qlen = OTX2_CPT_INST_QLEN_MSGS; in alloc_pending_queues()190 size = lfs->lf[i].pqueue.qlen * in alloc_pending_queues()193 lfs->lf[i].pqueue.head = kzalloc(size, GFP_KERNEL); in alloc_pending_queues()194 if (!lfs->lf[i].pqueue.head) { in alloc_pending_queues()200 spin_lock_init(&lfs->lf[i].pqueue.lock); in alloc_pending_queues()
93 struct otx2_cpt_pending_queue pqueue; /* Pending queue */ member
298 struct otx_cpt_pending_queue *pqueue, in process_request() argument324 spin_lock_bh(&pqueue->lock); in process_request()325 pentry = get_free_pending_entry(pqueue, pqueue->qlen); in process_request()328 spin_unlock_bh(&pqueue->lock); in process_request()330 spin_lock_bh(&pqueue->lock); in process_request()331 pentry = get_free_pending_entry(pqueue, pqueue->qlen); in process_request()336 spin_unlock_bh(&pqueue->lock); in process_request()346 pqueue->pending_count > (pqueue->qlen - CPT_IQ_STOP_MARGIN)) { in process_request()351 pqueue->pending_count++; in process_request()394 spin_unlock_bh(&pqueue->lock); in process_request()[all …]
329 struct pending_queue *pqueue = &pqinfo->queue[qno]; in process_pending_queue() local336 spin_lock_bh(&pqueue->lock); in process_pending_queue()337 pentry = &pqueue->head[pqueue->front]; in process_pending_queue()339 spin_unlock_bh(&pqueue->lock); in process_pending_queue()347 spin_unlock_bh(&pqueue->lock); in process_pending_queue()360 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()364 spin_unlock_bh(&pqueue->lock); in process_pending_queue()374 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()378 spin_unlock_bh(&pqueue->lock); in process_pending_queue()385 spin_unlock_bh(&pqueue->lock); in process_pending_queue()[all …]
41 #define _init_queue(pqueue) \ argument43 INIT_LIST_HEAD(&((pqueue)->queue)); \44 spin_lock_init(&((pqueue)->lock)); \
2379 struct __queue *pqueue; in enqueue_pending_xmitbuf() local2382 pqueue = &pxmitpriv->pending_xmitbuf_queue; in enqueue_pending_xmitbuf()2384 spin_lock_bh(&pqueue->lock); in enqueue_pending_xmitbuf()2386 list_add_tail(&pxmitbuf->list, get_list_head(pqueue)); in enqueue_pending_xmitbuf()2387 spin_unlock_bh(&pqueue->lock); in enqueue_pending_xmitbuf()2394 struct __queue *pqueue; in enqueue_pending_xmitbuf_to_head() local2396 pqueue = &pxmitpriv->pending_xmitbuf_queue; in enqueue_pending_xmitbuf_to_head()2398 spin_lock_bh(&pqueue->lock); in enqueue_pending_xmitbuf_to_head()2400 list_add(&pxmitbuf->list, get_list_head(pqueue)); in enqueue_pending_xmitbuf_to_head()2401 spin_unlock_bh(&pqueue->lock); in enqueue_pending_xmitbuf_to_head()[all …]
565 struct __queue *pqueue; in rtl8723bs_free_xmit_priv() local571 pqueue = &pxmitpriv->pending_xmitbuf_queue; in rtl8723bs_free_xmit_priv()572 phead = get_list_head(pqueue); in rtl8723bs_free_xmit_priv()575 spin_lock_bh(&pqueue->lock); in rtl8723bs_free_xmit_priv()576 if (!list_empty(&pqueue->queue)) { in rtl8723bs_free_xmit_priv()582 spin_unlock_bh(&pqueue->lock); in rtl8723bs_free_xmit_priv()
74 extern void _rtw_init_queue(struct __queue *pqueue);