Lines Matching refs:pqueue
329 struct pending_queue *pqueue = &pqinfo->queue[qno]; in process_pending_queue() local
336 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()
393 atomic64_dec((&pqueue->pending_count)); in process_pending_queue()
395 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
414 struct pending_queue *pqueue = NULL; in process_request() local
476 pqueue = &cptvf->pqinfo.queue[queue]; in process_request()
478 if (atomic64_read(&pqueue->pending_count) > PENDING_THOLD) { in process_request()
484 spin_lock_bh(&pqueue->lock); in process_request()
485 pentry = get_free_pending_entry(pqueue, cptvf->pqinfo.qlen); in process_request()
487 spin_unlock_bh(&pqueue->lock); in process_request()
495 queue, pqueue->rear, pqueue->front); in process_request()
506 atomic64_inc(&pqueue->pending_count); in process_request()
525 spin_unlock_bh(&pqueue->lock); in process_request()