Searched refs:pqueue (Results 1 – 10 of 10) sorted by relevance
67 struct padata_parallel_queue *pqueue; in padata_parallel_worker() local71 pqueue = container_of(parallel_work, in padata_parallel_worker()74 spin_lock(&pqueue->parallel.lock); in padata_parallel_worker()75 list_replace_init(&pqueue->parallel.list, &local_list); in padata_parallel_worker()76 spin_unlock(&pqueue->parallel.lock); in padata_parallel_worker()136 queue = per_cpu_ptr(pd->pqueue, target_cpu); in padata_do_parallel()183 next_queue = per_cpu_ptr(pd->pqueue, cpu); in padata_get_next()202 if (__this_cpu_read(pd->pqueue->cpu_index) == next_queue->cpu_index) { in padata_get_next()282 struct padata_parallel_queue *pqueue; in invoke_padata_reorder() local286 pqueue = container_of(work, struct padata_parallel_queue, reorder_work); in invoke_padata_reorder()[all …]
346 struct pending_queue *pqueue = &pqinfo->queue[qno]; in process_pending_queue() local353 spin_lock_bh(&pqueue->lock); in process_pending_queue()354 pentry = &pqueue->head[pqueue->front]; in process_pending_queue()356 spin_unlock_bh(&pqueue->lock); in process_pending_queue()364 spin_unlock_bh(&pqueue->lock); in process_pending_queue()377 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()381 spin_unlock_bh(&pqueue->lock); in process_pending_queue()391 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()395 spin_unlock_bh(&pqueue->lock); in process_pending_queue()402 spin_unlock_bh(&pqueue->lock); in process_pending_queue()[all …]
54 #define _init_queue(pqueue) \ argument56 INIT_LIST_HEAD(&((pqueue)->queue)); \57 spin_lock_init(&((pqueue)->lock)); \
35 void _rtw_init_queue(struct __queue *pqueue) in _rtw_init_queue() argument37 INIT_LIST_HEAD(&pqueue->queue); in _rtw_init_queue()38 spin_lock_init(&pqueue->lock); in _rtw_init_queue()
2872 struct __queue *pqueue; in enqueue_pending_xmitbuf() local2875 pqueue = &pxmitpriv->pending_xmitbuf_queue; in enqueue_pending_xmitbuf()2877 spin_lock_bh(&pqueue->lock); in enqueue_pending_xmitbuf()2879 list_add_tail(&pxmitbuf->list, get_list_head(pqueue)); in enqueue_pending_xmitbuf()2880 spin_unlock_bh(&pqueue->lock); in enqueue_pending_xmitbuf()2889 struct __queue *pqueue; in enqueue_pending_xmitbuf_to_head() local2891 pqueue = &pxmitpriv->pending_xmitbuf_queue; in enqueue_pending_xmitbuf_to_head()2893 spin_lock_bh(&pqueue->lock); in enqueue_pending_xmitbuf_to_head()2895 list_add(&pxmitbuf->list, get_list_head(pqueue)); in enqueue_pending_xmitbuf_to_head()2896 spin_unlock_bh(&pqueue->lock); in enqueue_pending_xmitbuf_to_head()[all …]
648 struct __queue *pqueue; in rtl8723bs_free_xmit_priv() local655 pqueue = &pxmitpriv->pending_xmitbuf_queue; in rtl8723bs_free_xmit_priv()656 phead = get_list_head(pqueue); in rtl8723bs_free_xmit_priv()659 spin_lock_bh(&pqueue->lock); in rtl8723bs_free_xmit_priv()660 if (!list_empty(&pqueue->queue)) { in rtl8723bs_free_xmit_priv()666 spin_unlock_bh(&pqueue->lock); in rtl8723bs_free_xmit_priv()
61 void _rtw_init_queue(struct __queue *pqueue) in _rtw_init_queue() argument63 INIT_LIST_HEAD(&(pqueue->queue)); in _rtw_init_queue()65 spin_lock_init(&(pqueue->lock)); in _rtw_init_queue()
69 void _rtw_init_queue(struct __queue *pqueue);
132 struct padata_parallel_queue __percpu *pqueue; member
111 extern void _rtw_init_queue(struct __queue *pqueue);
