Index: uspace/app/perf/Makefile =================================================================== --- uspace/app/perf/Makefile (revision d230358b547cc23fcfa8731fb956099b3ccc73f0) +++ uspace/app/perf/Makefile (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -35,4 +35,5 @@ SOURCES = \ perf.c \ + ipc/ns_ping.c \ ipc/ping_pong.c Index: uspace/app/perf/ipc/ns_ping.c =================================================================== --- uspace/app/perf/ipc/ns_ping.c (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) +++ uspace/app/perf/ipc/ns_ping.c (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -0,0 +1,135 @@ +/* + * Copyright (c) 2018 Jiri Svoboda + * 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. + * - The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``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 AUTHOR 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 +#include +#include +#include +#include +#include +#include +#include "../perf.h" + +#define MIN_DURATION_SECS 10 +#define NUM_SAMPLES 10 + +static errno_t ping_pong_measure(uint64_t niter, uint64_t *rduration) +{ + struct timespec start; + uint64_t count; + + getuptime(&start); + + for (count = 0; count < niter; count++) { + errno_t retval = ns_ping(); + + if (retval != EOK) { + printf("Error sending ping message.\n"); + return EIO; + } + } + + struct timespec now; + getuptime(&now); + + *rduration = ts_sub_diff(&now, &start) / 1000; + return EOK; +} + +static void ping_pong_report(uint64_t niter, uint64_t duration) +{ + printf("Completed %" PRIu64 " round trips in %" PRIu64 " us", + niter, duration); + + if (duration > 0) { + printf(", %" PRIu64 " rt/s.\n", niter * 1000 * 1000 / duration); + } else { + printf(".\n"); + } +} + +const char *bench_ns_ping(void) +{ + errno_t rc; + uint64_t duration; + uint64_t dsmp[NUM_SAMPLES]; + + printf("Benchmark ns server ping time\n"); + printf("Warm up and determine work size...\n"); + + struct timespec start; + getuptime(&start); + + uint64_t niter = 1; + + while (true) { + rc = ping_pong_measure(niter, &duration); + if (rc != EOK) + return "Failed."; + + ping_pong_report(niter, duration); + + if (duration >= MIN_DURATION_SECS * 1000000) + break; + + niter *= 2; + } + + printf("Measure %d samples...\n", NUM_SAMPLES); + + int i; + + for (i = 0; i < NUM_SAMPLES; i++) { + rc = ping_pong_measure(niter, &dsmp[i]); + if (rc != EOK) + return "Failed."; + + ping_pong_report(niter, dsmp[i]); + } + + double sum = 0.0; + + for (i = 0; i < NUM_SAMPLES; i++) + sum += (double)niter / ((double)dsmp[i] / 1000000.0l); + + double avg = sum / NUM_SAMPLES; + + double qd = 0.0; + double d; + for (i = 0; i < NUM_SAMPLES; i++) { + d = (double)niter / ((double)dsmp[i] / 1000000.0l) - avg; + qd += d * d; + } + + double stddev = qd / (NUM_SAMPLES - 1); // XXX sqrt + + printf("Average: %.0f rt/s Std.dev^2: %.0f rt/s Samples: %d\n", + avg, stddev, NUM_SAMPLES); + + return NULL; +} Index: uspace/app/perf/ipc/ns_ping.def =================================================================== --- uspace/app/perf/ipc/ns_ping.def (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) +++ uspace/app/perf/ipc/ns_ping.def (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -0,0 +1,5 @@ +{ + "ns_ping", + "Name service IPC ping-pong benchmark", + &bench_ns_ping +}, Index: uspace/app/perf/ipc/ping_pong.c =================================================================== --- uspace/app/perf/ipc/ping_pong.c (revision d230358b547cc23fcfa8731fb956099b3ccc73f0) +++ uspace/app/perf/ipc/ping_pong.c (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -31,5 +31,5 @@ #include #include -#include +#include #include #include @@ -39,5 +39,6 @@ #define NUM_SAMPLES 10 -static errno_t ping_pong_measure(uint64_t niter, uint64_t *rduration) +static errno_t ping_pong_measure(ipc_test_t *test, uint64_t niter, + uint64_t *rduration) { struct timespec start; @@ -47,5 +48,5 @@ for (count = 0; count < niter; count++) { - errno_t retval = ns_ping(); + errno_t retval = ipc_test_ping(test); if (retval != EOK) { @@ -79,6 +80,12 @@ uint64_t duration; uint64_t dsmp[NUM_SAMPLES]; + ipc_test_t *test; + const char *msg; - printf("Benchmark ns server ping time\n"); + printf("Benchmark IPC test server ping time\n"); + rc = ipc_test_create(&test); + if (rc != EOK) + return "Failed contacting IPC test server."; + printf("Warm up and determine work size...\n"); @@ -89,7 +96,9 @@ while (true) { - rc = ping_pong_measure(niter, &duration); - if (rc != EOK) - return "Failed."; + rc = ping_pong_measure(test, niter, &duration); + if (rc != EOK) { + msg = "Failed."; + goto error; + } ping_pong_report(niter, duration); @@ -106,7 +115,9 @@ for (i = 0; i < NUM_SAMPLES; i++) { - rc = ping_pong_measure(niter, &dsmp[i]); - if (rc != EOK) - return "Failed."; + rc = ping_pong_measure(test, niter, &dsmp[i]); + if (rc != EOK) { + msg = "Failed."; + goto error; + } ping_pong_report(niter, dsmp[i]); @@ -132,4 +143,8 @@ avg, stddev, NUM_SAMPLES); + ipc_test_destroy(test); return NULL; +error: + ipc_test_destroy(test); + return msg; } Index: uspace/app/perf/perf.c =================================================================== --- uspace/app/perf/perf.c (revision d230358b547cc23fcfa8731fb956099b3ccc73f0) +++ uspace/app/perf/perf.c (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -42,4 +42,5 @@ benchmark_t benchmarks[] = { #include "ipc/ping_pong.def" +#include "ipc/ns_ping.def" { NULL, NULL, NULL } }; Index: uspace/app/perf/perf.h =================================================================== --- uspace/app/perf/perf.h (revision d230358b547cc23fcfa8731fb956099b3ccc73f0) +++ uspace/app/perf/perf.h (revision 1edd6d0c4201fd549dcce1ac7154c0ee7d6ab4c9) @@ -46,4 +46,5 @@ } benchmark_t; +extern const char *bench_ns_ping(void); extern const char *bench_ping_pong(void);