Lines Matching defs:queue
84 struct pending_queue *queue;
86 for_each_pending_queue(pqinfo, queue, i) {
87 if (!queue->head)
90 /* free single queue */
91 kfree_sensitive((queue->head));
93 queue->front = 0;
94 queue->rear = 0;
109 struct pending_queue *queue = NULL;
116 for_each_pending_queue(pqinfo, queue, i) {
117 queue->head = kzalloc((size), GFP_KERNEL);
118 if (!queue->head) {
123 queue->front = 0;
124 queue->rear = 0;
125 atomic64_set((&queue->pending_count), (0));
127 /* init queue spin lock */
128 spin_lock_init(&queue->lock);
164 dev_info(&pdev->dev, "Cleaning VQ pending queue (%u)\n",
173 struct command_queue *queue = NULL;
178 /* clean up for each queue */
180 queue = &cqinfo->queue[i];
181 if (hlist_empty(&cqinfo->queue[i].chead))
184 hlist_for_each_entry_safe(chunk, node, &cqinfo->queue[i].chead,
195 queue->nchunks = 0;
196 queue->idx = 0;
209 struct command_queue *queue = NULL;
220 /* per queue initialization */
227 queue = &cqinfo->queue[i];
228 INIT_HLIST_HEAD(&cqinfo->queue[i].chead);
242 i, queue->nchunks);
248 if (queue->nchunks == 0) {
250 &cqinfo->queue[i].chead);
257 queue->nchunks++;
265 /* Make the queue circular */
269 queue->qhead = curr;
270 spin_lock_init(&queue->lock);
303 dev_info(&pdev->dev, "Cleaning VQ command queue (%u)\n",
652 /* TODO: for now only one queue, so hard coded */
653 base_addr = (u64)(cptvf->cqinfo.queue[0].qhead->dma_addr);