Lines Matching refs:pqueue
346 struct pending_queue *pqueue = &pqinfo->queue[qno]; in process_pending_queue() local
353 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()
410 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()
412 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
431 struct pending_queue *pqueue = NULL; in process_request() local
495 pqueue = &cptvf->pqinfo.queue[queue]; in process_request()
497 if (atomic64_read(&pqueue->pending_count) > PENDING_THOLD) { in process_request()
503 spin_lock_bh(&pqueue->lock); in process_request()
504 pentry = get_free_pending_entry(pqueue, cptvf->pqinfo.qlen); in process_request()
506 spin_unlock_bh(&pqueue->lock); in process_request()
514 queue, pqueue->rear, pqueue->front); in process_request()
525 atomic64_inc(&pqueue->pending_count); in process_request()
544 spin_unlock_bh(&pqueue->lock); in process_request()