Lines Matching defs:queue
26 struct xnvme_queue *queue;
192 struct xnvme_cmd_ctx *ctx = xnvme_queue_get_cmd_ctx(xnvme_ch->queue);
219 xnvme_queue_put_cmd_ctx(xnvme_ch->queue, ctx);
227 xnvme_queue_put_cmd_ctx(xnvme_ch->queue, ctx);
246 /* Submission failed: queue is full or no memory => Queue the I/O in bdev layer */
250 SPDK_WARNLOG("Start to queue I/O for xnvme bdev\n");
252 xnvme_queue_put_cmd_ctx(xnvme_ch->queue, ctx);
256 /* Submission failed: unexpected error, put the command-context back in the queue */
260 xnvme_queue_put_cmd_ctx(xnvme_ch->queue, ctx);
272 xnvme_queue_put_cmd_ctx(xnvme_ch->queue, xnvme_queue_get_cmd_ctx(xnvme_ch->queue));
342 /* Completed: Put the command- context back in the queue */
343 xnvme_queue_put_cmd_ctx(ctx->async.queue, ctx);
352 rc = xnvme_queue_poke(ch->queue, 0);
358 return xnvme_queue_get_outstanding(ch->queue) ? SPDK_POLLER_BUSY : SPDK_POLLER_IDLE;
369 rc = xnvme_queue_init(xnvme->dev, qd, 0, &ch->queue);
375 xnvme_queue_set_cb(ch->queue, bdev_xnvme_cmd_cb, ch);
389 xnvme_queue_term(ch->queue);