diff options
Diffstat (limited to 'src/lib/tests')
| -rw-r--r-- | src/lib/tests/CMakeLists.txt | 7 | ||||
| -rw-r--r-- | src/lib/tests/rib_test.c | 3 | ||||
| -rw-r--r-- | src/lib/tests/timerwheel_test.c | 104 | 
3 files changed, 113 insertions, 1 deletions
diff --git a/src/lib/tests/CMakeLists.txt b/src/lib/tests/CMakeLists.txt index 41c2074a..0223262a 100644 --- a/src/lib/tests/CMakeLists.txt +++ b/src/lib/tests/CMakeLists.txt @@ -1,6 +1,12 @@  get_filename_component(PARENT_PATH ${CMAKE_CURRENT_SOURCE_DIR} DIRECTORY)  get_filename_component(PARENT_DIR ${PARENT_PATH} NAME) +if (NOT (APPLE OR GNU)) +  set(TIMERWHEEL_TEST "timerwheel_test.c") +else () +  set(TIMERWHEEL_TEST "") +endif () +  create_test_sourcelist(${PARENT_DIR}_tests test_suite.c    # Add new tests here    bitmap_test.c @@ -11,6 +17,7 @@ create_test_sourcelist(${PARENT_DIR}_tests test_suite.c    rib_test.c    sha3_test.c    time_utils_test.c +  ${TIMERWHEEL_TEST}    )  add_executable(${PARENT_DIR}_test EXCLUDE_FROM_ALL ${${PARENT_DIR}_tests}) diff --git a/src/lib/tests/rib_test.c b/src/lib/tests/rib_test.c index e1fa427d..6a2446b9 100644 --- a/src/lib/tests/rib_test.c +++ b/src/lib/tests/rib_test.c @@ -20,7 +20,8 @@   * Foundation, Inc., http://www.fsf.org/about/contact/.   */ -#include <ouroboros/config.h> +#define _POSIX_C_SOURCE 199309L +  #include <ouroboros/time_utils.h>  #include <ouroboros/rib.h>  #include <ouroboros/rqueue.h> diff --git a/src/lib/tests/timerwheel_test.c b/src/lib/tests/timerwheel_test.c new file mode 100644 index 00000000..d7478487 --- /dev/null +++ b/src/lib/tests/timerwheel_test.c @@ -0,0 +1,104 @@ +/* + * Ouroboros - Copyright (C) 2016 - 2017 + * + * Test of the timer wheel + * + *    Dimitri Staessens <dimitri.staessens@ugent.be> + *    Sander Vrijders   <sander.vrijders@ugent.be> + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., http://www.fsf.org/about/contact/. + */ + +#include "timerwheel.c" + +#include <pthread.h> +#include <time.h> +#include <stdlib.h> +#include <stdio.h> + +#define MAX_ELEMENTS   100 +#define MAX_RESOLUTION 10  /* ms */ +#define MAX_ADDITIONS  1000 + +int total; + +int add(void * o) +{ +        total += *((int *) o); +        return 0; +} + +int timerwheel_test(int argc, char ** argv) +{ +        struct timerwheel * tw; +        long resolution; +        long elements; +        struct timespec wait; + +        int additions; + +        int check_total = 0; + +        int i; +        int var = 5; + +        struct tw_f * f; + +        (void) argc; +        (void) argv; + +        total = 0; + +        srand(time(NULL)); + +        resolution = rand() % (MAX_RESOLUTION - 1) + 1; +        elements = rand() % (MAX_ELEMENTS - 10) + 10; + +        tw = timerwheel_create(resolution, resolution * elements); +        if (tw == NULL) { +                printf("Failed to create timerwheel.\n"); +                return -1; +        } + +        wait.tv_sec = (resolution * elements) / 1000; +        wait.tv_nsec = ((resolution * elements) % 1000) * MILLION; + +        additions = rand() % MAX_ADDITIONS + 1000; + +        for (i = 0; i < additions; ++i) { +                int delay = rand() % (resolution * elements); +                check_total += var; +                f = timerwheel_start(tw, +                                     (void (*)(void *)) add, +                                     (void *) &var, +                                     delay); +                if (f == NULL) { +                        printf("Failed to add function."); +                        return -1; +                } +        } + +        nanosleep(&wait, NULL); + +        timerwheel_move(tw); + +        timerwheel_destroy(tw); + +        if (total != check_total) { +                printf("Totals do not match: %d and %d.\n", total, check_total); +                return -1; +        } + +        return 0; +}  | 
