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

lib/event: add assert check after call spdk_reactor_get

Browse Source 
Signed-off-by: Weifeng Su <suweifeng1@huawei.com>
Signed-off-by: Shihao Sun <sunshihao@huawei.com>
Change-Id: Ib2012fd57071c89743477eba26047f127e68ce4f
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/5074
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Aleksey Marchuk <alexeymar@mellanox.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
This commit is contained in:
Weifeng Su 2020-11-11 02:35:53 -05:00 committed by Tomasz Zawadzki
parent ced16bcd35
commit 5e01bdb41d
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/event/reactor.c
View File

@ -515,6 +515,7 @@ _reactors_scheduler_fini(void *arg1, void *arg2)
SPDK_ENV_FOREACH_CORE(i) { SPDK_ENV_FOREACH_CORE(i) {
reactor = spdk_reactor_get(i); reactor = spdk_reactor_get(i);
assert(reactor != NULL);
reactor->flags.is_scheduling = false; reactor->flags.is_scheduling = false;
} }
} }
@ -528,6 +529,7 @@ _reactors_scheduler_cancel(void *arg1, void *arg2)
SPDK_ENV_FOREACH_CORE(i) { SPDK_ENV_FOREACH_CORE(i) {
reactor = spdk_reactor_get(i); reactor = spdk_reactor_get(i);
assert(reactor != NULL);
reactor->flags.is_scheduling = false; reactor->flags.is_scheduling = false;
} }
} }
@ -544,6 +546,7 @@ _reactors_scheduler_gather_metrics(void *arg1, void *arg2)
uint32_t i; uint32_t i;
reactor = spdk_reactor_get(spdk_env_get_current_core()); reactor = spdk_reactor_get(spdk_env_get_current_core());
assert(reactor != NULL);
reactor->flags.is_scheduling = true; reactor->flags.is_scheduling = true;
core_info = &g_core_infos[reactor->lcore]; core_info = &g_core_infos[reactor->lcore];
core_info->lcore = reactor->lcore; core_info->lcore = reactor->lcore;
@ -845,7 +848,7 @@ spdk_reactors_stop(void *arg1)
if (spdk_interrupt_mode_is_enabled()) { if (spdk_interrupt_mode_is_enabled()) {
SPDK_ENV_FOREACH_CORE(i) { SPDK_ENV_FOREACH_CORE(i) {
reactor = spdk_reactor_get(i); reactor = spdk_reactor_get(i);
assert(reactor != NULL);
rc = write(reactor->events_fd, &notify, sizeof(notify)); rc = write(reactor->events_fd, &notify, sizeof(notify));
if (rc < 0) { if (rc < 0) {
SPDK_ERRLOG("failed to notify event queue for reactor(%u): %s.\n", i, spdk_strerror(errno)); SPDK_ERRLOG("failed to notify event queue for reactor(%u): %s.\n", i, spdk_strerror(errno));