ivampiresp/Spdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bdev/aio: Remove list of channels on channel group

Browse Source 
This was only temporarily required for polling. With
a per-group aio ctx, it isn't needed anymore.

Change-Id: Ie59b50a4700f0f99dea470f857d187ac656dd229
Signed-off-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-on: https://review.gerrithub.io/c/443467
Reviewed-by: Darek Stojaczyk <dariusz.stojaczyk@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
This commit is contained in:
Ben Walker 2019-02-05 11:36:29 -07:00 committed by Jim Harris
parent 6bb59dff48
commit 4ea3e63291
1 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
lib/bdev/aio/bdev_aio.c
View File

@ -51,15 +51,11 @@
struct bdev_aio_io_channel { struct bdev_aio_io_channel {
uint64_t io_inflight; uint64_t io_inflight;
struct bdev_aio_group_channel *group_ch; struct bdev_aio_group_channel *group_ch;
TAILQ_ENTRY(bdev_aio_io_channel) link;
}; };
struct bdev_aio_group_channel { struct bdev_aio_group_channel {
struct spdk_poller *poller; struct spdk_poller *poller;
io_context_t io_ctx; io_context_t io_ctx;
TAILQ_HEAD(, bdev_aio_io_channel) channels;
}; };
struct bdev_aio_task { struct bdev_aio_task {
@ -404,8 +400,6 @@ bdev_aio_create_cb(void *io_device, void *ctx_buf)
ch->group_ch = spdk_io_channel_get_ctx(spdk_get_io_channel(&aio_if)); ch->group_ch = spdk_io_channel_get_ctx(spdk_get_io_channel(&aio_if));
TAILQ_INSERT_TAIL(&ch->group_ch->channels, ch, link);
return 0; return 0;
} }
@ -414,7 +408,6 @@ bdev_aio_destroy_cb(void *io_device, void *ctx_buf)
{ {
struct bdev_aio_io_channel *ch = ctx_buf; struct bdev_aio_io_channel *ch = ctx_buf;
TAILQ_REMOVE(&ch->group_ch->channels, ch, link);
spdk_put_io_channel(spdk_io_channel_from_ctx(ch->group_ch)); spdk_put_io_channel(spdk_io_channel_from_ctx(ch->group_ch));
} }
@ -485,8 +478,6 @@ bdev_aio_group_create_cb(void *io_device, void *ctx_buf)
{ {
struct bdev_aio_group_channel *ch = ctx_buf; struct bdev_aio_group_channel *ch = ctx_buf;
TAILQ_INIT(&ch->channels);
if (io_setup(SPDK_AIO_QUEUE_DEPTH, &ch->io_ctx) < 0) { if (io_setup(SPDK_AIO_QUEUE_DEPTH, &ch->io_ctx) < 0) {
SPDK_ERRLOG("async I/O context setup failure\n"); SPDK_ERRLOG("async I/O context setup failure\n");
return -1; return -1;