Lines Matching defs:group_ch
36 struct bdev_uring_group_channel *group_ch;
181 struct bdev_uring_group_channel *group_ch = uring_ch->group_ch;
184 sqe = io_uring_get_sqe(&group_ch->uring);
198 group_ch->io_pending++;
208 struct bdev_uring_group_channel *group_ch = uring_ch->group_ch;
211 sqe = io_uring_get_sqe(&group_ch->uring);
225 group_ch->io_pending++;
271 uring_task->ch->group_ch->io_inflight--;
283 struct bdev_uring_group_channel *group_ch = arg;
287 to_submit = group_ch->io_pending;
292 ret = io_uring_submit(&group_ch->uring);
297 group_ch->io_pending = 0;
298 group_ch->io_inflight += to_submit;
301 to_complete = group_ch->io_inflight;
304 count = bdev_uring_reap(&group_ch->uring, to_complete);
664 ch->group_ch = spdk_io_channel_get_ctx(spdk_get_io_channel(&uring_if));
674 spdk_put_io_channel(spdk_io_channel_from_ctx(ch->group_ch));