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

thread: criticalmsg also indicates valid event

Browse Source 
Change-Id: I32296be76dfdde725249f43a96f5031c9c2613ae
Signed-off-by: Liu Xiaodong <xiaodong.liu@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/6721
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
This commit is contained in:
Liu Xiaodong 2021-03-05 07:45:34 -05:00 committed by Tomasz Zawadzki
parent 1bd39bb5ee
commit b8db1af4e2
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/thread/thread.c
View File

@ -626,6 +626,7 @@ thread_poll(struct spdk_thread *thread, uint32_t max_msgs, uint64_t now)
if (spdk_unlikely(critical_msg != NULL)) { if (spdk_unlikely(critical_msg != NULL)) {
critical_msg(NULL); critical_msg(NULL);
thread->critical_msg = NULL; thread->critical_msg = NULL;
rc = 1;
} }
msg_count = msg_queue_run_batch(thread, max_msgs); msg_count = msg_queue_run_batch(thread, max_msgs);
@ -1869,6 +1870,7 @@ thread_interrupt_msg_process(void *arg)
if (spdk_unlikely(critical_msg != NULL)) { if (spdk_unlikely(critical_msg != NULL)) {
critical_msg(NULL); critical_msg(NULL);
thread->critical_msg = NULL; thread->critical_msg = NULL;
rc = 1;
} }
msg_count = msg_queue_run_batch(thread, 0); msg_count = msg_queue_run_batch(thread, 0);