diff options
Diffstat (limited to 'src/tools/perf')
| -rw-r--r-- | src/tools/perf/perf.c | 23 | ||||
| -rw-r--r-- | src/tools/perf/pubdrop.c | 15 |
2 files changed, 18 insertions, 20 deletions
diff --git a/src/tools/perf/perf.c b/src/tools/perf/perf.c index 46d91cd8..2801ce51 100644 --- a/src/tools/perf/perf.c +++ b/src/tools/perf/perf.c @@ -1,5 +1,5 @@ // -// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // // This software is supplied under the terms of the MIT License, a @@ -17,7 +17,6 @@ #include <nng/nng.h> #include <nng/supplemental/util/options.h> -#include <nng/supplemental/util/platform.h> static void die(const char *, ...); static int @@ -328,13 +327,13 @@ do_inproc(void *args) void do_inproc_lat(int argc, char **argv) { - nng_thread * thr; + nng_thread *thr; struct inproc_args ia; int rv; int val; int optidx; - char * arg; - char * addr; + char *arg; + char *addr; addr = "inproc://latency_test"; @@ -392,13 +391,13 @@ do_inproc_lat(int argc, char **argv) void do_inproc_thr(int argc, char **argv) { - nng_thread * thr; + nng_thread *thr; struct inproc_args ia; int rv; int optidx; int val; - char * arg; - char * addr = "inproc://throughput-test"; + char *arg; + char *addr = "inproc://throughput-test"; optidx = 0; while ((rv = nng_opts_parse(argc, argv, opts, &val, &arg, &optidx)) == @@ -461,7 +460,7 @@ void latency_client(const char *addr, size_t msgsize, int trips) { nng_socket s; - nng_msg * msg; + nng_msg *msg; nng_time start, end; int rv; int i; @@ -511,7 +510,7 @@ void latency_server(const char *addr, size_t msgsize, int trips) { nng_socket s; - nng_msg * msg; + nng_msg *msg; int rv; int i; @@ -553,7 +552,7 @@ void throughput_server(const char *addr, size_t msgsize, int count) { nng_socket s; - nng_msg * msg; + nng_msg *msg; int rv; int i; uint64_t start, end; @@ -611,7 +610,7 @@ void throughput_client(const char *addr, size_t msgsize, int count) { nng_socket s; - nng_msg * msg; + nng_msg *msg; int rv; int i; diff --git a/src/tools/perf/pubdrop.c b/src/tools/perf/pubdrop.c index f7e1dbfd..bc067d76 100644 --- a/src/tools/perf/pubdrop.c +++ b/src/tools/perf/pubdrop.c @@ -1,5 +1,5 @@ // -// Copyright 2019 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> // // This software is supplied under the terms of the MIT License, a // copy of which should be located in the distribution where this @@ -15,7 +15,6 @@ #include <string.h> #include <nng/nng.h> -#include <nng/supplemental/util/platform.h> // pubdrop - this is a simple testing utility that lets us measure PUB/SUB // performance, including dropped messages, delivery across multiple threads, @@ -117,7 +116,7 @@ parse_int(const char *arg, const char *what) } struct pubdrop_args { - const char * addr; + const char *addr; bool start; unsigned long long msgsize; unsigned long long count; @@ -128,8 +127,8 @@ struct pubdrop_args { unsigned long long recvs; nng_time beg; nng_time end; - nng_mtx * mtx; - nng_cv * cv; + nng_mtx *mtx; + nng_cv *cv; }; static void @@ -138,7 +137,7 @@ pub_server(void *arg) struct pubdrop_args *pa = arg; nng_socket sock; int rv; - nng_msg * msg; + nng_msg *msg; nng_time start; nng_time end; @@ -191,7 +190,7 @@ sub_client(void *arg) struct pubdrop_args *pa = arg; nng_socket sock; int rv; - nng_msg * msg; + nng_msg *msg; unsigned long long recvs; unsigned long long drops; unsigned long long gaps; @@ -255,7 +254,7 @@ sub_client(void *arg) static void do_pubdrop(int argc, char **argv) { - nng_thread ** thrs; + nng_thread **thrs; struct pubdrop_args pa; int rv; int nsubs; |