c3bc40a6ef
This will be used to track time used in pollers - each poller can now indicate if it found any work to do or not. For cases where it was obvious and the infrastructure was already in place, existing pollers have been modified to return 0 or a positive value to indicate whether work was done. Other pollers have been modified to return -1 by default, indicating that the poller isn't indicating anything about whether work was performed. This will allow us to find un-annotated pollers easily in the future and fix them incrementally. Change-Id: Ifebfa56604a38434fac5c76ba7263267574ff199 Signed-off-by: Roman Sudarikov <roman.sudarikov@intel.com> Signed-off-by: Daniel Verkamp <daniel.verkamp@intel.com> Reviewed-on: https://review.gerrithub.io/391042 Tested-by: SPDK Automated Test System <sys_sgsw@intel.com> Reviewed-by: Jim Harris <james.r.harris@intel.com> Reviewed-by: Changpeng Liu <changpeng.liu@intel.com> Reviewed-by: Shuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
145 lines
3.6 KiB
C
145 lines
3.6 KiB
C
/*-
|
|
* BSD LICENSE
|
|
*
|
|
* Copyright (c) Intel Corporation.
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
*
|
|
* * Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in
|
|
* the documentation and/or other materials provided with the
|
|
* distribution.
|
|
* * Neither the name of Intel Corporation nor the names of its
|
|
* contributors may be used to endorse or promote products derived
|
|
* from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#include "spdk/stdinc.h"
|
|
|
|
#include "spdk/env.h"
|
|
#include "spdk/event.h"
|
|
#include "spdk/io_channel.h"
|
|
|
|
static int g_time_in_sec;
|
|
static int g_queue_depth;
|
|
static struct spdk_poller *test_end_poller;
|
|
static uint64_t g_call_count = 0;
|
|
|
|
static int
|
|
__test_end(void *arg)
|
|
{
|
|
printf("test_end\n");
|
|
spdk_app_stop(0);
|
|
return -1;
|
|
}
|
|
|
|
static void
|
|
__submit_next(void *arg1, void *arg2)
|
|
{
|
|
struct spdk_event *event;
|
|
|
|
g_call_count++;
|
|
|
|
event = spdk_event_allocate(spdk_env_get_current_core(),
|
|
__submit_next, NULL, NULL);
|
|
spdk_event_call(event);
|
|
}
|
|
|
|
static void
|
|
test_start(void *arg1, void *arg2)
|
|
{
|
|
int i;
|
|
|
|
printf("test_start\n");
|
|
|
|
/* Register a poller that will stop the test after the time has elapsed. */
|
|
test_end_poller = spdk_poller_register(__test_end, NULL,
|
|
g_time_in_sec * 1000000ULL);
|
|
|
|
for (i = 0; i < g_queue_depth; i++) {
|
|
__submit_next(NULL, NULL);
|
|
}
|
|
}
|
|
|
|
static void
|
|
test_cleanup(void)
|
|
{
|
|
printf("test_abort\n");
|
|
|
|
spdk_poller_unregister(&test_end_poller);
|
|
spdk_app_stop(0);
|
|
}
|
|
|
|
static void
|
|
usage(const char *program_name)
|
|
{
|
|
printf("%s options\n", program_name);
|
|
printf("\t[-d Allowed delay when passing messages between cores in microseconds]\n");
|
|
printf("\t[-q Queue depth (default: 1)]\n");
|
|
printf("\t[-t time in seconds]\n");
|
|
}
|
|
|
|
int
|
|
main(int argc, char **argv)
|
|
{
|
|
struct spdk_app_opts opts;
|
|
int op;
|
|
int rc;
|
|
|
|
spdk_app_opts_init(&opts);
|
|
opts.name = "reactor_perf";
|
|
opts.max_delay_us = 1000;
|
|
|
|
g_time_in_sec = 0;
|
|
g_queue_depth = 1;
|
|
|
|
while ((op = getopt(argc, argv, "d:q:t:")) != -1) {
|
|
switch (op) {
|
|
case 'd':
|
|
opts.max_delay_us = atoi(optarg);
|
|
break;
|
|
case 'q':
|
|
g_queue_depth = atoi(optarg);
|
|
break;
|
|
case 't':
|
|
g_time_in_sec = atoi(optarg);
|
|
break;
|
|
default:
|
|
usage(argv[0]);
|
|
exit(1);
|
|
}
|
|
}
|
|
|
|
if (!g_time_in_sec) {
|
|
usage(argv[0]);
|
|
exit(1);
|
|
}
|
|
|
|
opts.shutdown_cb = test_cleanup;
|
|
|
|
rc = spdk_app_start(&opts, test_start, NULL, NULL);
|
|
|
|
spdk_app_fini();
|
|
|
|
printf("Performance: %8ju events per second\n", g_call_count / g_time_in_sec);
|
|
|
|
return rc;
|
|
}
|