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

reactor: update tsc records in intr mode

Browse Source 
In interrupt mode, reactor spends its valid cpu cycles
to process registered thread interrupt function. So we
can count idle_tsc and busy_tsc in it, and update
reactor's last_tsc in it.

Change-Id: I65f4ae7d3b1e5c7c5c06937d6855f5d1b5c0349f
Signed-off-by: Liu Xiaodong <xiaodong.liu@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/6716
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: Changpeng Liu <changpeng.liu@intel.com>
Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
This commit is contained in:
Liu Xiaodong 2021-03-05 07:19:56 -05:00 committed by Tomasz Zawadzki
parent 4825fce4bf
commit ee4a83360f
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lib/event/reactor.c
View File

@ -872,7 +872,7 @@ reactor_interrupt_run(struct spdk_reactor *reactor)
spdk_fd_group_wait(reactor->fgrp, block_timeout); spdk_fd_group_wait(reactor->fgrp, block_timeout);
/* TODO: add tsc records and g_framework_context_switch_monitor_enabled */ /* TODO: g_framework_context_switch_monitor_enabled */
} }
static void static void
@ -1076,8 +1076,27 @@ static int
thread_process_interrupts(void *arg) thread_process_interrupts(void *arg)
{ {
struct spdk_thread *thread = arg; struct spdk_thread *thread = arg;
struct spdk_reactor *reactor = spdk_reactor_get(spdk_env_get_current_core());
uint64_t now;
int rc;
return spdk_thread_poll(thread, 0, 0); /* Update idle_tsc between the end of last intr_fn and the start of this intr_fn. */
now = spdk_get_ticks();
reactor->idle_tsc += now - reactor->tsc_last;
reactor->tsc_last = now;
rc = spdk_thread_poll(thread, 0, now);
/* Update tsc between the start and the end of this intr_fn. */
now = spdk_thread_get_last_tsc(thread);
if (rc == 0) {
reactor->idle_tsc += now - reactor->tsc_last;
} else if (rc > 0) {
reactor->busy_tsc += now - reactor->tsc_last;
}
reactor->tsc_last = now;
return rc;
} }
static void static void