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

accel_perf: add shutdown callback

Browse Source 
Otherwise, it's impossible to stop the app before its run time expires,
because the accel library waits until its IO channels are released which
would only happen at the end.

Signed-off-by: Konrad Sztyber <konrad.sztyber@intel.com>
Change-Id: I7438b474f4f6d6bcb4bf6aad02ccae9f511f1b51
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/17768
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
This commit is contained in:
Konrad Sztyber 2023-04-25 15:13:30 +02:00 committed by David Ko
parent 4a47f1f926
commit 483520322a
1 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
examples/accel/perf/accel_perf.c
View File

@ -1115,6 +1115,26 @@ error_end:
spdk_app_stop(rc);
}
static void
worker_shutdown(void *ctx)
{
_worker_stop(ctx);
}
static void
shutdown_cb(void)
{
struct worker_thread *worker;
pthread_mutex_lock(&g_workers_lock);
worker = g_workers;
while (worker) {
spdk_thread_send_msg(worker->thread, worker_shutdown, worker);
worker = worker->next;
}
pthread_mutex_unlock(&g_workers_lock);
}
int
main(int argc, char **argv)
{
@ -1124,6 +1144,7 @@ main(int argc, char **argv)
spdk_app_opts_init(&g_opts, sizeof(g_opts));
g_opts.name = "accel_perf";
g_opts.reactor_mask = "0x1";
g_opts.shutdown_cb = shutdown_cb;
if (spdk_app_parse_args(argc, argv, &g_opts, "a:C:o:q:t:yw:P:f:T:l:x:", NULL, parse_args,
usage) != SPDK_APP_PARSE_ARGS_SUCCESS) {
g_rc = -1;