Lines Matching refs:ch
98 struct ut_bdev_channel *ch = ctx_buf;
104 TAILQ_INIT(&ch->outstanding_io);
105 ch->outstanding_cnt = 0;
112 ch->avail_cnt = 2048;
113 ch->thread = spdk_get_thread();
115 TAILQ_INSERT_TAIL(&g_ut_channels, ch, link);
123 struct ut_bdev_channel *ch = ctx_buf;
125 TAILQ_REMOVE(&g_ut_channels, ch, link);
149 struct ut_bdev_channel *ch = ctx;
152 while (!TAILQ_EMPTY(&ch->outstanding_io)) {
153 bio = TAILQ_FIRST(&ch->outstanding_io);
154 TAILQ_REMOVE(&ch->outstanding_io, bio, link);
155 ch->outstanding_cnt--;
157 ch->avail_cnt++;
164 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch), *tmp_ch;
177 TAILQ_FOREACH(bio, &ch->outstanding_io, link) {
180 TAILQ_REMOVE(&ch->outstanding_io, bio, link);
181 ch->outstanding_cnt--;
183 ch->avail_cnt++;
194 if (ch->avail_cnt > 0) {
195 TAILQ_INSERT_TAIL(&ch->outstanding_io, (struct ut_bdev_io *)bdev_io->driver_ctx, link);
196 ch->outstanding_cnt++;
197 ch->avail_cnt--;
207 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch);
214 if (TAILQ_EMPTY(&ch->outstanding_io)) {
217 bio = TAILQ_FIRST(&ch->outstanding_io);
218 TAILQ_REMOVE(&ch->outstanding_io, bio, link);
220 ch->outstanding_cnt--;
222 ch->avail_cnt++;
413 g_ut_threads[0].ch = spdk_bdev_get_io_channel(g_desc);
414 CU_ASSERT(g_ut_threads[0].ch == NULL);
418 g_ut_threads[0].ch = spdk_bdev_get_io_channel(g_desc);
419 CU_ASSERT(g_ut_threads[0].ch == NULL);
423 g_ut_threads[0].ch = spdk_bdev_get_io_channel(g_desc);
424 CU_ASSERT(g_ut_threads[0].ch != NULL);
425 spdk_put_io_channel(g_ut_threads[0].ch);
840 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch);
845 TAILQ_FOREACH(bio, &ch->outstanding_io, link) {
1113 CU_ASSERT(bdev->internal.qos->ch == NULL);
1121 CU_ASSERT(bdev->internal.qos->ch != NULL);
1134 CU_ASSERT(bdev->internal.qos->ch == NULL);
1139 CU_ASSERT(bdev->internal.qos->ch == NULL);
1153 CU_ASSERT(bdev->internal.qos->ch == bdev_ch[1]);
1937 struct spdk_io_channel *ch[2];
1947 ch[0] = spdk_bdev_get_io_channel(g_desc);
1948 CU_ASSERT(ch[0] != NULL);
1951 ch[1] = spdk_bdev_get_io_channel(g_desc);
1952 CU_ASSERT(ch[1] != NULL);
1976 rc = spdk_bdev_write_blocks(g_desc, ch[0], &buf, 0, 1, io_during_io_done, &status);
1986 rc = spdk_bdev_read_blocks(g_desc, ch[1], &buf, 0, 1, io_during_io_done, &status);
2017 spdk_put_io_channel(ch[0]);
2019 spdk_put_io_channel(ch[1]);
2032 bdev_channel_count_submitted_io(struct spdk_bdev_channel *ch)
2037 if (!ch) {
2041 TAILQ_FOREACH(bdev_io, &ch->io_submitted, internal.ch_link) {
2070 struct spdk_io_channel *ch[3];
2080 ch[0] = spdk_bdev_get_io_channel(g_desc);
2081 CU_ASSERT(ch[0] != NULL);
2084 ch[1] = spdk_bdev_get_io_channel(g_desc);
2085 CU_ASSERT(ch[1] != NULL);
2088 ch[2] = spdk_bdev_get_io_channel(g_desc);
2089 CU_ASSERT(ch[2] != NULL);
2106 CU_ASSERT(spdk_bdev_read_blocks(g_desc, ch[0], (void *)0x2000, 0, 1, io_done, NULL) == 0);
2107 bdev_ch[0] = spdk_io_channel_get_ctx(ch[0]);
2111 CU_ASSERT(spdk_bdev_write_blocks(g_desc, ch[1], (void *)0x1000, 0, 1, io_done, NULL) == 0);
2112 bdev_ch[1] = spdk_io_channel_get_ctx(ch[1]);
2123 CU_ASSERT(spdk_bdev_read_blocks(g_desc, ch[2], (void *)0xF000, 14, 8, io_done, NULL) == 0);
2124 bdev_ch[2] = spdk_io_channel_get_ctx(ch[2]);
2168 CU_ASSERT(spdk_bdev_read_blocks(g_desc, ch[0], (void *)0x1000, 0, 1, io_done, NULL) == 0);
2170 CU_ASSERT(spdk_bdev_write_blocks(g_desc, ch[1], (void *)0x2000, 0, 2, io_done, NULL) == 0);
2172 CU_ASSERT(spdk_bdev_read_blocks(g_desc, ch[2], (void *)0x3000, 0, 3, io_done, NULL) == 0);
2182 spdk_put_io_channel(ch[0]);
2196 spdk_put_io_channel(ch[1]);
2219 spdk_put_io_channel(ch[2]);
2267 struct ut_bdev_channel *ch = spdk_io_channel_get_ctx(_ch);
2270 outstanding_cnt = ch->outstanding_cnt;