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

event: Attempt to respect cpumask when scheduling threads

Browse Source 
Individual threads can have their own CPU mask. Attempt to
respect that in the scheduler.

Change-Id: I2bd08d4249bdae32a459ed8770b88090346be5dc
Signed-off-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/452258
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
This commit is contained in:
Ben Walker 2019-04-26 12:58:21 -07:00 committed by Jim Harris
parent 835d21a2d0
commit 67234b6ad4
1 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
lib/event/reactor.c
View File

@ -405,21 +405,37 @@ spdk_reactor_schedule_thread(struct spdk_thread *thread)
{ {
uint32_t core; uint32_t core;
struct spdk_lw_thread *lw_thread; struct spdk_lw_thread *lw_thread;
struct spdk_event *evt; struct spdk_event *evt = NULL;
struct spdk_cpuset *cpumask;
uint32_t i;
cpumask = spdk_thread_get_cpumask(thread);
lw_thread = spdk_thread_get_ctx(thread); lw_thread = spdk_thread_get_ctx(thread);
assert(lw_thread != NULL); assert(lw_thread != NULL);
memset(lw_thread, 0, sizeof(*lw_thread)); memset(lw_thread, 0, sizeof(*lw_thread));
pthread_mutex_lock(&g_scheduler_mtx); pthread_mutex_lock(&g_scheduler_mtx);
if (g_next_core > spdk_env_get_last_core()) { for (i = 0; i < spdk_env_get_core_count(); i++) {
g_next_core = spdk_env_get_first_core(); if (g_next_core > spdk_env_get_last_core()) {
g_next_core = spdk_env_get_first_core();
}
core = g_next_core;
g_next_core = spdk_env_get_next_core(g_next_core);
if (spdk_cpuset_get_cpu(cpumask, core)) {
evt = spdk_event_allocate(core, _schedule_thread, lw_thread, NULL);
break;
}
} }
core = g_next_core;
g_next_core = spdk_env_get_next_core(g_next_core);
pthread_mutex_unlock(&g_scheduler_mtx); pthread_mutex_unlock(&g_scheduler_mtx);
evt = spdk_event_allocate(core, _schedule_thread, lw_thread, NULL); assert(evt != NULL);
if (evt == NULL) {
SPDK_ERRLOG("Unable to schedule thread on requested core mask.\n");
return -1;
}
spdk_event_call(evt); spdk_event_call(evt);
return 0; return 0;