Lines Matching refs:ch
48 struct bdev_uring_io_channel *ch;
176 bdev_uring_readv(struct bdev_uring *uring, struct spdk_io_channel *ch,
180 struct bdev_uring_io_channel *uring_ch = spdk_io_channel_get_ctx(ch);
193 uring_task->ch = uring_ch;
203 bdev_uring_writev(struct bdev_uring *uring, struct spdk_io_channel *ch,
207 struct bdev_uring_io_channel *uring_ch = spdk_io_channel_get_ctx(ch);
220 uring_task->ch = uring_ch;
271 uring_task->ch->group_ch->io_inflight--;
315 bdev_uring_get_buf_cb(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io,
328 ch,
337 ch,
614 _bdev_uring_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io)
636 bdev_uring_submit_request(struct spdk_io_channel *ch, struct spdk_bdev_io *bdev_io)
638 if (_bdev_uring_submit_request(ch, bdev_io) < 0) {
662 struct bdev_uring_io_channel *ch = ctx_buf;
664 ch->group_ch = spdk_io_channel_get_ctx(spdk_get_io_channel(&uring_if));
672 struct bdev_uring_io_channel *ch = ctx_buf;
674 spdk_put_io_channel(spdk_io_channel_from_ctx(ch->group_ch));
743 struct bdev_uring_group_channel *ch = ctx_buf;
747 if (io_uring_queue_init(SPDK_URING_QUEUE_DEPTH, &ch->uring, 0) < 0) {
752 ch->poller = SPDK_POLLER_REGISTER(bdev_uring_group_poll, ch, 0);
759 struct bdev_uring_group_channel *ch = ctx_buf;
761 io_uring_queue_exit(&ch->uring);
763 spdk_poller_unregister(&ch->poller);