Lines Matching refs:pqueue
333 struct pending_queue *pqueue = &pqinfo->queue[qno]; in process_pending_queue() local
340 spin_lock_bh(&pqueue->lock); in process_pending_queue()
341 pentry = &pqueue->head[pqueue->front]; in process_pending_queue()
343 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
351 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
364 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()
368 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
378 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()
382 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
389 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
397 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()
399 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
418 struct pending_queue *pqueue = NULL; in process_request() local
480 pqueue = &cptvf->pqinfo.queue[queue]; in process_request()
482 if (atomic64_read(&pqueue->pending_count) > PENDING_THOLD) { in process_request()
488 spin_lock_bh(&pqueue->lock); in process_request()
489 pentry = get_free_pending_entry(pqueue, cptvf->pqinfo.qlen); in process_request()
491 spin_unlock_bh(&pqueue->lock); in process_request()
499 queue, pqueue->rear, pqueue->front); in process_request()
510 atomic64_inc(&pqueue->pending_count); in process_request()
529 spin_unlock_bh(&pqueue->lock); in process_request()