diff options
author | Dimitri Staessens <[email protected]> | 2018-02-14 13:55:00 +0100 |
---|---|---|
committer | Sander Vrijders <[email protected]> | 2018-02-14 17:58:51 +0100 |
commit | 91012d9af758a48c4c57fc940dfcc8a581fa46ac (patch) | |
tree | 96495c10b615ddafa94ebcfa1a0977109ec0ffe8 /src/tools/cbr/cbr_client.c | |
parent | e095d0ade3035c714768266755c9c61acfc2ad0f (diff) | |
download | ouroboros-91012d9af758a48c4c57fc940dfcc8a581fa46ac.tar.gz ouroboros-91012d9af758a48c4c57fc940dfcc8a581fa46ac.zip |
build: Allow out-of-tree build of tools
This removes the dependencies for the tools on some ouroboros internal
headers (endian.h and time_utils.h) so they can be built out-of-tree.
The echo-app tool has been renamed oecho and the cbr tool has been
renamed ocbr.
Signed-off-by: Dimitri Staessens <[email protected]>
Signed-off-by: Sander Vrijders <[email protected]>
Diffstat (limited to 'src/tools/cbr/cbr_client.c')
-rw-r--r-- | src/tools/cbr/cbr_client.c | 164 |
1 files changed, 0 insertions, 164 deletions
diff --git a/src/tools/cbr/cbr_client.c b/src/tools/cbr/cbr_client.c deleted file mode 100644 index bf527317..00000000 --- a/src/tools/cbr/cbr_client.c +++ /dev/null @@ -1,164 +0,0 @@ -/* - * Ouroboros - Copyright (C) 2016 - 2018 - * - * A simple CBR generator - * - * Dimitri Staessens <[email protected]> - * Sander Vrijders <[email protected]> - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * - * 2. 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. - * - * 3. Neither the name of the copyright holder 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 HOLDER 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 <ouroboros/dev.h> -#include <ouroboros/time_utils.h> - -#include <signal.h> - -volatile bool stop; - -static void shutdown_client(int signo, siginfo_t * info, void * c) -{ - (void) info; - (void) c; - - switch(signo) { - case SIGINT: - case SIGTERM: - case SIGHUP: - stop = true; - default: - return; - } -} - -static void busy_wait_until(const struct timespec * deadline) -{ - struct timespec now; - clock_gettime(CLOCK_REALTIME, &now); - while (now.tv_sec < deadline->tv_sec) - clock_gettime(CLOCK_REALTIME, &now); - while (now.tv_sec == deadline->tv_sec - && now.tv_nsec < deadline->tv_nsec) - clock_gettime(CLOCK_REALTIME, &now); -} - -int client_main(char * server, - int duration, - int size, - long rate, - bool flood, - bool sleep) -{ - struct sigaction sig_act; - - int fd = 0; - char buf[size]; - long seqnr = 0; - long gap = size * 8.0 * (BILLION / (double) rate); - - struct timespec start; - struct timespec end; - struct timespec intv = {(gap / BILLION), gap % BILLION}; - int ms; - - stop = false; - - memset(&sig_act, 0, sizeof sig_act); - sig_act.sa_sigaction = &shutdown_client; - sig_act.sa_flags = 0; - - if (sigaction(SIGINT, &sig_act, NULL) || - sigaction(SIGTERM, &sig_act, NULL) || - sigaction(SIGHUP, &sig_act, NULL) || - sigaction(SIGPIPE, &sig_act, NULL)) { - printf("Failed to install sighandler.\n"); - return -1; - } - - printf("Client started, duration %d, rate %lu b/s, size %d B.\n", - duration, rate, size); - - fd = flow_alloc(server, NULL, NULL); - if (fd < 0) { - printf("Failed to allocate flow.\n"); - return -1; - } - - clock_gettime(CLOCK_REALTIME, &start); - if (!flood) { - while (!stop) { - clock_gettime(CLOCK_REALTIME, &end); - ts_add(&end, &intv, &end); - memcpy(buf, &seqnr, sizeof(seqnr)); - - if (flow_write(fd, buf, size) < 0) { - stop = true; - continue; - } - - if (sleep) - nanosleep(&intv, NULL); - else - busy_wait_until(&end); - - ++seqnr; - - if (ts_diff_us(&start, &end) / MILLION >= duration) - stop = true; - } - } else { /* flood */ - while (!stop) { - clock_gettime(CLOCK_REALTIME, &end); - if (flow_write(fd, buf, (size_t) size) < 0) { - stop = true; - continue; - } - - ++seqnr; - - if (ts_diff_us(&start, &end) / MILLION - >= (long) duration) - stop = true; - } - - } - - clock_gettime(CLOCK_REALTIME, &end); - - ms = ts_diff_ms(&start, &end); - - printf("sent statistics: " - "%9ld SDUs, %12ld bytes in %9d ms, %4.4f Mb/s\n", - seqnr, seqnr * size, ms, (seqnr / (ms * 1000.0)) * size * 8.0); - - flow_dealloc(fd); - - return 0; -} |