d/numam-spdk
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

bdev_aio: add set interrupt mode to poller

Browse Source 
Change-Id: I089241bbb42c047e8ae4f206f2dad72c4a69f1d9
Signed-off-by: Liu Xiaodong <xiaodong.liu@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/5789
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
This commit is contained in:
Liu Xiaodong 2021-01-02 15:54:04 -05:00 committed by Tomasz Zawadzki
parent 924d4bf32d
commit 2d36f6f11c
1 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
module/bdev/aio/bdev_aio.c
View File

@ -658,20 +658,31 @@ bdev_aio_unregister_interrupt(struct bdev_aio_group_channel *ch)
ch->efd = -1; ch->efd = -1;
} }
static void
bdev_aio_poller_set_interrupt_mode(struct spdk_poller *poller, void *cb_arg, bool interrupt_mode)
{
return;
}
static int static int
bdev_aio_group_create_cb(void *io_device, void *ctx_buf) 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;
int rc;
TAILQ_INIT(&ch->io_ch_head); TAILQ_INIT(&ch->io_ch_head);
/* Initialize ch->efd to be invalid and unused. */ /* Initialize ch->efd to be invalid and unused. */
ch->efd = -1; ch->efd = -1;
if (spdk_interrupt_mode_is_enabled()) { if (spdk_interrupt_mode_is_enabled()) {
return bdev_aio_register_interrupt(ch); rc = bdev_aio_register_interrupt(ch);
if (rc < 0) {
SPDK_ERRLOG("Failed to prepare intr resource to bdev_aio\n");
return rc;
}
} }
ch->poller = SPDK_POLLER_REGISTER(bdev_aio_group_poll, ch, 0); ch->poller = SPDK_POLLER_REGISTER(bdev_aio_group_poll, ch, 0);
spdk_poller_register_interrupt(ch->poller, bdev_aio_poller_set_interrupt_mode, NULL);
return 0; return 0;
} }
@ -685,12 +696,10 @@ bdev_aio_group_destroy_cb(void *io_device, void *ctx_buf)
SPDK_ERRLOG("Group channel of bdev aio has uncleared io channel\n"); SPDK_ERRLOG("Group channel of bdev aio has uncleared io channel\n");
} }
if (ch->intr) {
bdev_aio_unregister_interrupt(ch);
return;
}
spdk_poller_unregister(&ch->poller); spdk_poller_unregister(&ch->poller);
if (spdk_interrupt_mode_is_enabled()) {
bdev_aio_unregister_interrupt(ch);
}
} }
int int