Lines Matching defs:queue
11 * get_free_pending_entry - get free entry from pending queue
12 * @q: pending queue
13 * @qlen: queue length
37 struct pending_queue *queue = &pqinfo->queue[qno];
39 queue->front++;
40 if (unlikely(queue->front == pqinfo->qlen))
41 queue->front = 0;
228 struct command_queue *queue;
234 dev_err(&pdev->dev, "Invalid queue (qno: %d, nr_queues: %d)\n",
240 queue = &qinfo->queue[qno];
241 /* lock commad queue */
242 spin_lock(&queue->lock);
243 ent = &queue->qhead->head[queue->idx * qinfo->cmd_size];
246 if (++queue->idx >= queue->qhead->size / 64) {
247 hlist_for_each_entry(chunk, &queue->chead, nextchunk) {
248 if (chunk == queue->qhead) {
251 queue->qhead = chunk;
255 queue->idx = 0;
260 /* unlock command queue */
261 spin_unlock(&queue->lock);
329 struct pending_queue *pqueue = &pqinfo->queue[qno];
408 int ret = 0, clear = 0, queue = 0;
474 /* Always queue 0, because 1 queue per VF */
475 queue = 0;
476 pqueue = &cptvf->pqinfo.queue[queue];
480 process_pending_queue(cptvf, &cptvf->pqinfo, queue);
489 process_pending_queue(cptvf, &cptvf->pqinfo, queue);
494 dev_err(&pdev->dev, "queue: %d, rear: %d, front: %d\n",
495 queue, pqueue->rear, pqueue->front);
524 ret = send_cpt_command(cptvf, &cptinst, queue);
546 dev_err(&pdev->dev, "Request for post processing on invalid pending queue: %u\n",