Commit 91d7d20c authored by Ben Walker's avatar Ben Walker Committed by Daniel Verkamp
Browse files

event: add a reactor benchmark tool 



Change-Id: I57c7ed3475b19ffb8d00354eabb23ba86294164b
Signed-off-by: default avatarDaniel Verkamp <daniel.verkamp@intel.com>
Signed-off-by: default avatarBen Walker <benjamin.walker@intel.com>
parent 6a939460

test/lib/event/Makefile

+1 −1
Original line number Diff line number Diff line
@@ -34,7 +34,7 @@ 
SPDK_ROOT_DIR := $(abspath $(CURDIR)/../../..)

include $(SPDK_ROOT_DIR)/mk/spdk.common.mk



DIRS-y = event_perf reactor subsystem

DIRS-y = event_perf reactor reactor_perf subsystem



.PHONY: all clean $(DIRS-y)

test/lib/event/event.sh

+1 −0
Original line number Diff line number Diff line
@@ -7,5 +7,6 @@ source $rootdir/scripts/autotest_common.sh 
timing_enter event

$testdir/event_perf/event_perf -m 0xF -t 5

$testdir/reactor/reactor -t 1

$testdir/reactor_perf/reactor_perf -t 5

$testdir/subsystem/subsystem_ut

timing_exit event

test/lib/event/reactor_perf/.gitignore

0 → 100644
+1 −0
Original line number Diff line number Diff line 
reactor_perf

test/lib/event/reactor_perf/Makefile

0 → 100644
+54 −0
Original line number Diff line number Diff line 
#

#  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.

#



SPDK_ROOT_DIR := $(abspath $(CURDIR)/../../../..)

include $(SPDK_ROOT_DIR)/mk/spdk.app.mk

include $(SPDK_ROOT_DIR)/mk/spdk.common.mk



CFLAGS += $(ENV_CFLAGS)

APP = reactor_perf

C_SRCS := reactor_perf.c



SPDK_LIB_LIST = event trace conf util log



LIBS += $(SPDK_LIB_LINKER_ARGS) $(ENV_LINKER_ARGS)



all : $(APP)



$(APP) : $(OBJS) $(SPDK_LIB_FILES) $(ENV_LIBS)

	$(LINK_C)



clean :

	$(CLEAN_C) $(APP)



include $(SPDK_ROOT_DIR)/mk/spdk.deps.mk

test/lib/event/reactor_perf/reactor_perf.c

0 → 100644
+148 −0
Original line number Diff line number Diff line 
/*-

 *   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 <inttypes.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>



#include "spdk/event.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 void

__test_end(void *arg)

{

	printf("test_end\n");

	spdk_app_stop(0);

}



static void

__submit_next(void *arg1, void *arg2)

{

	struct spdk_event *event;



	g_call_count++;



	event = spdk_event_allocate(spdk_app_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. */

	spdk_poller_register(&test_end_poller, __test_end, NULL,

			     spdk_app_get_current_core(),

			     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, NULL);

	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;



	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);

	}



	optind = 1;



	opts.shutdown_cb = test_cleanup;



	spdk_app_init(&opts);



	spdk_app_start(test_start, NULL, NULL);



	spdk_app_fini();



	printf("Performance: %8ju events per second\n", g_call_count / g_time_in_sec);



	return 0;

}