Merge pull request #17 from alonbl/build

[netdata.git] / src / unit_test.c

diff --git a/src/unit_test.c b/src/unit_test.c
index d74cc953867f26afa942b35cf6ca5e70953a8f6b..dd69d68a90f4f512e7e176d8fab44296be45c1cd 100755 (executable)
--- a/src/unit_test.c
+++ b/src/unit_test.c
@@ -1,21 +1,29 @@
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
 #include <sys/resource.h>
 
+#include "common.h"
 #include "storage_number.h"
 #include "rrd.h"
 #include "log.h"
 #include "web_buffer.h"
 
-#define ACCURACY_LOSS 0.0000001
-
 int check_storage_number(calculated_number n, int debug) {
        char buffer[100];
+       uint32_t flags = SN_EXISTS;
 
-       storage_number s = pack_storage_number(n);
+       storage_number s = pack_storage_number(n, flags);
        calculated_number d = unpack_storage_number(s);
 
+       if(!does_storage_number_exist(s)) {
+               fprintf(stderr, "Exists flags missing for number " CALCULATED_NUMBER_FORMAT "!\n", n);
+               return 5;
+       }
+
        calculated_number ddiff = d - n;
        calculated_number dcdiff = ddiff * 100.0 / n;
 
@@ -152,7 +160,7 @@ void benchmark_storage_number(int loop, int multiplier) {
                        n *= multiplier;
                        if(n > STORAGE_NUMBER_POSITIVE_MAX) n = STORAGE_NUMBER_POSITIVE_MIN;
 
-                       s = pack_storage_number(n);
+                       s = pack_storage_number(n, 1);
                        d = unpack_storage_number(s);
                        print_calculated_number(buffer, d);
                }
@@ -177,8 +185,38 @@ void benchmark_storage_number(int loop, int multiplier) {
 
 }
 
+static int check_storage_number_exists() {
+       uint32_t flags = SN_EXISTS;
+
+
+       for(flags = 0; flags < 7 ; flags++) {
+               if(get_storage_number_flags(flags << 24) != flags << 24) {
+                       fprintf(stderr, "Flag 0x%08x is not checked correctly. It became 0x%08x\n", flags << 24, get_storage_number_flags(flags << 24));
+                       return 1;
+               }
+       }
+
+       flags = SN_EXISTS;
+       calculated_number n = 0.0;
+
+       storage_number s = pack_storage_number(n, flags);
+       calculated_number d = unpack_storage_number(s);
+       if(get_storage_number_flags(s) != flags) {
+               fprintf(stderr, "Wrong flags. Given %08x, Got %08x!\n", flags, get_storage_number_flags(s));
+               return 1;
+       }
+       if(n != d) {
+               fprintf(stderr, "Wrong number returned. Expected " CALCULATED_NUMBER_FORMAT ", returned " CALCULATED_NUMBER_FORMAT "!\n", n, d);
+               return 1;
+       }
+
+       return 0;
+}
+
 int unit_test_storage()
 {
+       if(check_storage_number_exists()) return 0;
+
        calculated_number c, a = 0;
        int i, j, g, r = 0;
 
@@ -212,32 +250,32 @@ int unit_test(long delay, long shift)
        snprintf(name, 100, "unittest-%d-%ld-%ld", repeat, delay, shift);
 
        debug_flags = 0xffffffff;
-       memory_mode = NETDATA_MEMORY_MODE_RAM;
-       update_every = 1;
+       rrd_memory_mode = RRD_MEMORY_MODE_RAM;
+       rrd_update_every = 1;
 
        int do_abs = 1;
        int do_inc = 1;
        int do_abst = 1;
        int do_absi = 1;
 
-       RRD_STATS *st = rrd_stats_create("netdata", name, name, "netdata", "Unit Testing", "a value", 1, 1, CHART_TYPE_LINE);
+       RRDSET *st = rrdset_create("netdata", name, name, "netdata", "Unit Testing", "a value", 1, 1, RRDSET_TYPE_LINE);
        st->debug = 1;
 
-       RRD_DIMENSION *rdabs = NULL;
-       RRD_DIMENSION *rdinc = NULL;
-       RRD_DIMENSION *rdabst = NULL;
-       RRD_DIMENSION *rdabsi = NULL;
+       RRDDIM *rdabs = NULL;
+       RRDDIM *rdinc = NULL;
+       RRDDIM *rdabst = NULL;
+       RRDDIM *rdabsi = NULL;
 
-       if(do_abs) rdabs = rrd_stats_dimension_add(st, "absolute", "absolute", 1, 1, RRD_DIMENSION_ABSOLUTE);
-       if(do_inc) rdinc = rrd_stats_dimension_add(st, "incremental", "incremental", 1, 1 * update_every, RRD_DIMENSION_INCREMENTAL);
-       if(do_abst) rdabst = rrd_stats_dimension_add(st, "percentage-of-absolute-row", "percentage-of-absolute-row", 1, 1, RRD_DIMENSION_PCENT_OVER_ROW_TOTAL);
-       if(do_absi) rdabsi = rrd_stats_dimension_add(st, "percentage-of-incremental-row", "percentage-of-incremental-row", 1, 1, RRD_DIMENSION_PCENT_OVER_DIFF_TOTAL);
+       if(do_abs) rdabs = rrddim_add(st, "absolute", "absolute", 1, 1, RRDDIM_ABSOLUTE);
+       if(do_inc) rdinc = rrddim_add(st, "incremental", "incremental", 1, 1 * rrd_update_every, RRDDIM_INCREMENTAL);
+       if(do_abst) rdabst = rrddim_add(st, "percentage-of-absolute-row", "percentage-of-absolute-row", 1, 1, RRDDIM_PCENT_OVER_ROW_TOTAL);
+       if(do_absi) rdabsi = rrddim_add(st, "percentage-of-incremental-row", "percentage-of-incremental-row", 1, 1, RRDDIM_PCENT_OVER_DIFF_TOTAL);
 
        long increment = 1000;
        collected_number i = 0;
 
        unsigned long c, dimensions = 0;
-       RRD_DIMENSION *rd;
+       RRDDIM *rd;
        for(rd = st->dimensions ; rd ; rd = rd->next) dimensions++;
 
        for(c = 0; c < 20 ;c++) {
@@ -245,12 +283,12 @@ int unit_test(long delay, long shift)
 
                fprintf(stderr, "\n\nLOOP = %lu, DELAY = %ld, VALUE = " COLLECTED_NUMBER_FORMAT "\n", c, delay, i);
                if(c) {
-                       rrd_stats_next_usec(st, delay);
+                       rrdset_next_usec(st, delay);
                }
-               if(do_abs) rrd_stats_dimension_set(st, "absolute", i);
-               if(do_inc) rrd_stats_dimension_set(st, "incremental", i);
-               if(do_abst) rrd_stats_dimension_set(st, "percentage-of-absolute-row", i);
-               if(do_absi) rrd_stats_dimension_set(st, "percentage-of-incremental-row", i);
+               if(do_abs) rrddim_set(st, "absolute", i);
+               if(do_inc) rrddim_set(st, "incremental", i);
+               if(do_abst) rrddim_set(st, "percentage-of-absolute-row", i);
+               if(do_absi) rrddim_set(st, "percentage-of-incremental-row", i);
 
                if(!c) {
                        gettimeofday(&st->last_collected_time, NULL);
@@ -260,7 +298,7 @@ int unit_test(long delay, long shift)
                // prevent it from deleting the dimensions
                for(rd = st->dimensions ; rd ; rd = rd->next) rd->last_collected_time.tv_sec = st->last_collected_time.tv_sec;
 
-               rrd_stats_done(st);
+               rrdset_done(st);
        }
 
        unsigned long oincrement = increment;