Lines Matching refs:pqueue
298 struct otx_cpt_pending_queue *pqueue, in process_request() argument
324 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()
505 struct otx_cpt_pending_queue *pqueue) in process_pending_queue() argument
517 spin_lock_bh(&pqueue->lock); in process_pending_queue()
518 pentry = &pqueue->head[pqueue->front]; in process_pending_queue()
521 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
527 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
556 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
567 resume_index = modulo_inc(pqueue->front, pqueue->qlen, in process_pending_queue()
569 resume_pentry = &pqueue->head[resume_index]; in process_pending_queue()
577 spin_unlock_bh(&pqueue->lock); in process_pending_queue()
584 spin_lock_bh(&pqueue->lock); in process_pending_queue()
592 pqueue->pending_count--; in process_pending_queue()
593 pqueue->front = modulo_inc(pqueue->front, pqueue->qlen, 1); in process_pending_queue()
594 spin_unlock_bh(&pqueue->lock); in process_pending_queue()