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

schedulers: Add _get_next_target_lcore function

Browse Source 
This function will be useful in upcoming patch.

Signed-off-by: Maciej Szwed <maciej.szwed@intel.com>
Change-Id: I2a79305b8cb155a94c83b4baa3f5d7014cb602c9
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/6079
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
This commit is contained in:
Maciej Szwed 2021-01-25 16:56:31 +01:00 committed by Tomasz Zawadzki
parent e742a41456
commit 20362e5bc8
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
lib/event/scheduler_dynamic.c
View File

@ -48,6 +48,21 @@ uint64_t g_last_main_core_busy, g_last_main_core_idle;
#define SCHEDULER_THREAD_BUSY 100 #define SCHEDULER_THREAD_BUSY 100
#define SCHEDULER_LOAD_LIMIT 50 #define SCHEDULER_LOAD_LIMIT 50
static uint32_t
_get_next_target_core(void)
{
uint32_t target_lcore;
if (g_next_lcore == SPDK_ENV_LCORE_ID_ANY) {
g_next_lcore = spdk_env_get_first_core();
}
target_lcore = g_next_lcore;
g_next_lcore = spdk_env_get_next_core(g_next_lcore);
return target_lcore;
}
static uint8_t static uint8_t
_get_thread_load(struct spdk_lw_thread *lw_thread) _get_thread_load(struct spdk_lw_thread *lw_thread)
{ {
@ -160,12 +175,7 @@ balance(struct spdk_scheduler_core_info *cores_info, int cores_count,
if (i == g_main_lcore && load >= SCHEDULER_LOAD_LIMIT) { if (i == g_main_lcore && load >= SCHEDULER_LOAD_LIMIT) {
/* This thread is active and on the main core, we need to pick a core to move it to */ /* This thread is active and on the main core, we need to pick a core to move it to */
for (k = 0; k < spdk_env_get_core_count(); k++) { for (k = 0; k < spdk_env_get_core_count(); k++) {
if (g_next_lcore == SPDK_ENV_LCORE_ID_ANY) { target_lcore = _get_next_target_core();
g_next_lcore = spdk_env_get_first_core();
}
target_lcore = g_next_lcore;
g_next_lcore = spdk_env_get_next_core(g_next_lcore);
/* Do not use main core if it is too busy for new thread */ /* Do not use main core if it is too busy for new thread */
if (target_lcore == g_main_lcore && thread_busy > main_core_idle) { if (target_lcore == g_main_lcore && thread_busy > main_core_idle) {