src/daemon/common_test.c

   1 /**
   2  * collectd - src/tests/test_common.c
   3  * Copyright (C) 2013       Florian octo Forster
   4  *
   5  * Permission is hereby granted, free of charge, to any person obtaining a
   6  * copy of this software and associated documentation files (the "Software"),
   7  * to deal in the Software without restriction, including without limitation
   8  * the rights to use, copy, modify, merge, publish, distribute, sublicense,
   9  * and/or sell copies of the Software, and to permit persons to whom the
  10  * Software is furnished to do so, subject to the following conditions:
  11  *
  12  * The above copyright notice and this permission notice shall be included in
  13  * all copies or substantial portions of the Software.
  14  *
  15  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  16  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  17  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  18  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  19  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  20  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
  21  * DEALINGS IN THE SOFTWARE.
  22  *
  23  * Authors:
  24  *   Florian octo Forster <octo at collectd.org>
  25  */
  26
  27 #include "common.h"
  28 #include "testing.h"
  29
  30 #if HAVE_LIBKSTAT
  31 kstat_ctl_t *kc;
  32 #endif /* HAVE_LIBKSTAT */
  33
  34 DEF_TEST(sstrncpy)
  35 {
  36   char buffer[16] = "";
  37   char *ptr = &buffer[4];
  38   char *ret;
  39
  40   buffer[0] = buffer[1] = buffer[2] = buffer[3] = 0xff;
  41   buffer[12] = buffer[13] = buffer[14] = buffer[15] = 0xff;
  42
  43   ret = sstrncpy (ptr, "foobar", 8);
  44   OK(ret == ptr);
  45   EXPECT_EQ_STR ("foobar", ptr);
  46   OK(buffer[3] == buffer[12]);
  47
  48   ret = sstrncpy (ptr, "abc", 8);
  49   OK(ret == ptr);
  50   EXPECT_EQ_STR ("abc", ptr);
  51   OK(buffer[3] == buffer[12]);
  52
  53   ret = sstrncpy (ptr, "collectd", 8);
  54   OK(ret == ptr);
  55   OK(ptr[7] == 0);
  56   EXPECT_EQ_STR ("collect", ptr);
  57   OK(buffer[3] == buffer[12]);
  58
  59   return (0);
  60 }
  61
  62 DEF_TEST(ssnprintf)
  63 {
  64   char buffer[16] = "";
  65   char *ptr = &buffer[4];
  66   int status;
  67
  68   buffer[0] = buffer[1] = buffer[2] = buffer[3] = 0xff;
  69   buffer[12] = buffer[13] = buffer[14] = buffer[15] = 0xff;
  70
  71   status = ssnprintf (ptr, 8, "%i", 1337);
  72   OK(status == 4);
  73   EXPECT_EQ_STR ("1337", ptr);
  74
  75   status = ssnprintf (ptr, 8, "%s", "collectd");
  76   OK(status == 8);
  77   OK(ptr[7] == 0);
  78   EXPECT_EQ_STR ("collect", ptr);
  79   OK(buffer[3] == buffer[12]);
  80
  81   return (0);
  82 }
  83
  84 DEF_TEST(sstrdup)
  85 {
  86   char *ptr;
  87
  88   ptr = sstrdup ("collectd");
  89   OK(ptr != NULL);
  90   EXPECT_EQ_STR ("collectd", ptr);
  91
  92   sfree(ptr);
  93
  94   ptr = sstrdup (NULL);
  95   OK(ptr == NULL);
  96
  97   return (0);
  98 }
  99
 100 DEF_TEST(strsplit)
 101 {
 102   char buffer[32];
 103   char *fields[8];
 104   int status;
 105
 106   strncpy (buffer, "foo bar", sizeof (buffer));
 107   status = strsplit (buffer, fields, 8);
 108   OK(status == 2);
 109   EXPECT_EQ_STR ("foo", fields[0]);
 110   EXPECT_EQ_STR ("bar", fields[1]);
 111
 112   strncpy (buffer, "foo \t bar", sizeof (buffer));
 113   status = strsplit (buffer, fields, 8);
 114   OK(status == 2);
 115   EXPECT_EQ_STR ("foo", fields[0]);
 116   EXPECT_EQ_STR ("bar", fields[1]);
 117
 118   strncpy (buffer, "one two\tthree\rfour\nfive", sizeof (buffer));
 119   status = strsplit (buffer, fields, 8);
 120   OK(status == 5);
 121   EXPECT_EQ_STR ("one", fields[0]);
 122   EXPECT_EQ_STR ("two", fields[1]);
 123   EXPECT_EQ_STR ("three", fields[2]);
 124   EXPECT_EQ_STR ("four", fields[3]);
 125   EXPECT_EQ_STR ("five", fields[4]);
 126
 127   strncpy (buffer, "\twith trailing\n", sizeof (buffer));
 128   status = strsplit (buffer, fields, 8);
 129   OK(status == 2);
 130   EXPECT_EQ_STR ("with", fields[0]);
 131   EXPECT_EQ_STR ("trailing", fields[1]);
 132
 133   strncpy (buffer, "1 2 3 4 5 6 7 8 9 10 11 12 13", sizeof (buffer));
 134   status = strsplit (buffer, fields, 8);
 135   OK(status == 8);
 136   EXPECT_EQ_STR ("7", fields[6]);
 137   EXPECT_EQ_STR ("8", fields[7]);
 138
 139   strncpy (buffer, "single", sizeof (buffer));
 140   status = strsplit (buffer, fields, 8);
 141   OK(status == 1);
 142   EXPECT_EQ_STR ("single", fields[0]);
 143
 144   strncpy (buffer, "", sizeof (buffer));
 145   status = strsplit (buffer, fields, 8);
 146   OK(status == 0);
 147
 148   return (0);
 149 }
 150
 151 DEF_TEST(strjoin)
 152 {
 153   char buffer[16];
 154   char *fields[4];
 155   int status;
 156
 157   fields[0] = "foo";
 158   fields[1] = "bar";
 159   fields[2] = "baz";
 160   fields[3] = "qux";
 161
 162   status = strjoin (buffer, sizeof (buffer), fields, 2, "!");
 163   OK(status == 7);
 164   EXPECT_EQ_STR ("foo!bar", buffer);
 165
 166   status = strjoin (buffer, sizeof (buffer), fields, 1, "!");
 167   OK(status == 3);
 168   EXPECT_EQ_STR ("foo", buffer);
 169
 170   status = strjoin (buffer, sizeof (buffer), fields, 0, "!");
 171   OK(status < 0);
 172
 173   status = strjoin (buffer, sizeof (buffer), fields, 2, "rcht");
 174   OK(status == 10);
 175   EXPECT_EQ_STR ("foorchtbar", buffer);
 176
 177   status = strjoin (buffer, sizeof (buffer), fields, 4, "");
 178   OK(status == 12);
 179   EXPECT_EQ_STR ("foobarbazqux", buffer);
 180
 181   status = strjoin (buffer, sizeof (buffer), fields, 4, "!");
 182   OK(status == 15);
 183   EXPECT_EQ_STR ("foo!bar!baz!qux", buffer);
 184
 185   fields[0] = "0123";
 186   fields[1] = "4567";
 187   fields[2] = "8901";
 188   fields[3] = "2345";
 189   status = strjoin (buffer, sizeof (buffer), fields, 4, "-");
 190   OK(status < 0);
 191
 192   return (0);
 193 }
 194
 195 DEF_TEST(escape_slashes)
 196 {
 197   struct {
 198     char *str;
 199     char *want;
 200   } cases[] = {
 201     {"foo/bar/baz", "foo_bar_baz"},
 202     {"/like/a/path", "like_a_path"},
 203     {"trailing/slash/", "trailing_slash_"},
 204     {"foo//bar", "foo__bar"},
 205   };
 206
 207   for (size_t i = 0; i < STATIC_ARRAY_SIZE (cases); i++) {
 208     char buffer[32];
 209
 210     strncpy (buffer, cases[i].str, sizeof (buffer));
 211     OK(escape_slashes (buffer, sizeof (buffer)) == 0);
 212     EXPECT_EQ_STR(cases[i].want, buffer);
 213   }
 214
 215   return 0;
 216 }
 217
 218 DEF_TEST(escape_string)
 219 {
 220   struct {
 221     char *str;
 222     char *want;
 223   } cases[] = {
 224     {"foobar", "foobar"},
 225     {"f00bar", "f00bar"},
 226     {"foo bar", "\"foo bar\""},
 227     {"foo \"bar\"", "\"foo \\\"bar\\\"\""},
 228     {"012345678901234", "012345678901234"},
 229     {"012345 78901234", "\"012345 789012\""},
 230     {"012345 78901\"34", "\"012345 78901\""},
 231   };
 232
 233   for (size_t i = 0; i < STATIC_ARRAY_SIZE (cases); i++) {
 234     char buffer[16];
 235
 236     strncpy (buffer, cases[i].str, sizeof (buffer));
 237     OK(escape_string (buffer, sizeof (buffer)) == 0);
 238     EXPECT_EQ_STR(cases[i].want, buffer);
 239   }
 240
 241   return 0;
 242 }
 243
 244 DEF_TEST(strunescape)
 245 {
 246   char buffer[16];
 247   int status;
 248
 249   strncpy (buffer, "foo\\tbar", sizeof (buffer));
 250   status = strunescape (buffer, sizeof (buffer));
 251   OK(status == 0);
 252   EXPECT_EQ_STR ("foo\tbar", buffer);
 253
 254   strncpy (buffer, "\\tfoo\\r\\n", sizeof (buffer));
 255   status = strunescape (buffer, sizeof (buffer));
 256   OK(status == 0);
 257   EXPECT_EQ_STR ("\tfoo\r\n", buffer);
 258
 259   strncpy (buffer, "With \\\"quotes\\\"", sizeof (buffer));
 260   status = strunescape (buffer, sizeof (buffer));
 261   OK(status == 0);
 262   EXPECT_EQ_STR ("With \"quotes\"", buffer);
 263
 264   /* Backslash before null byte */
 265   strncpy (buffer, "\\tbackslash end\\", sizeof (buffer));
 266   status = strunescape (buffer, sizeof (buffer));
 267   OK(status != 0);
 268   EXPECT_EQ_STR ("\tbackslash end", buffer);
 269   return (0);
 270
 271   /* Backslash at buffer end */
 272   strncpy (buffer, "\\t3\\56", sizeof (buffer));
 273   status = strunescape (buffer, 4);
 274   OK(status != 0);
 275   OK(buffer[0] == '\t');
 276   OK(buffer[1] == '3');
 277   OK(buffer[2] == 0);
 278   OK(buffer[3] == 0);
 279   OK(buffer[4] == '5');
 280   OK(buffer[5] == '6');
 281   OK(buffer[6] == '7');
 282
 283   return (0);
 284 }
 285
 286 DEF_TEST(parse_values)
 287 {
 288   struct {
 289     char buffer[64];
 290     int status;
 291     gauge_t value;
 292   } cases[] = {
 293     {"1435044576:42",     0, 42.0},
 294     {"1435044576:42:23", -1,  NAN},
 295     {"1435044576:U",      0,  NAN},
 296     {"N:12.3",            0, 12.3},
 297     {"N:42.0:23",        -1,  NAN},
 298     {"N:U",               0,  NAN},
 299     {"T:42.0",           -1,  NAN},
 300   };
 301
 302   for (size_t i = 0; i < STATIC_ARRAY_SIZE (cases); i++)
 303   {
 304     data_source_t dsrc = {
 305       .name = "value",
 306       .type = DS_TYPE_GAUGE,
 307       .min = 0.0,
 308       .max = NAN,
 309     };
 310     data_set_t ds = {
 311       .type = "example",
 312       .ds_num = 1,
 313       .ds = &dsrc,
 314     };
 315
 316     value_t v = {
 317       .gauge = NAN,
 318     };
 319     value_list_t vl = {
 320       .values = &v,
 321       .values_len = 1,
 322       .time = 0,
 323       .interval = 0,
 324       .host = "example.com",
 325       .plugin = "common_test",
 326       .type = "example",
 327       .meta = NULL,
 328     };
 329
 330     int status = parse_values (cases[i].buffer, &vl, &ds);
 331     EXPECT_EQ_INT (cases[i].status, status);
 332     if (status != 0)
 333       continue;
 334
 335     EXPECT_EQ_DOUBLE (cases[i].value, vl.values[0].gauge);
 336   }
 337
 338   return (0);
 339 }
 340
 341 DEF_TEST(value_to_rate)
 342 {
 343   struct {
 344     time_t t0;
 345     time_t t1;
 346     int ds_type;
 347     value_t v0;
 348     value_t v1;
 349     gauge_t want;
 350   } cases[] = {
 351     { 0, 10, DS_TYPE_DERIVE,  {.derive  =    0}, {.derive = 1000},   NAN},
 352     {10, 20, DS_TYPE_DERIVE,  {.derive  = 1000}, {.derive = 2000}, 100.0},
 353     {20, 30, DS_TYPE_DERIVE,  {.derive  = 2000}, {.derive = 1800}, -20.0},
 354     { 0, 10, DS_TYPE_COUNTER, {.counter =    0}, {.counter = 1000},   NAN},
 355     {10, 20, DS_TYPE_COUNTER, {.counter = 1000}, {.counter = 5000}, 400.0},
 356     /* 32bit wrap-around. */
 357     {20, 30, DS_TYPE_COUNTER, {.counter = 4294967238ULL}, {.counter =   42}, 10.0},
 358     /* 64bit wrap-around. */
 359     {30, 40, DS_TYPE_COUNTER, {.counter = 18446744073709551558ULL}, {.counter =   42}, 10.0},
 360   };
 361
 362   for (size_t i = 0; i < STATIC_ARRAY_SIZE (cases); i++) {
 363     value_to_rate_state_t state = { cases[i].v0, TIME_T_TO_CDTIME_T (cases[i].t0) };
 364     gauge_t got;
 365
 366     if (cases[i].t0 == 0) {
 367       OK(value_to_rate (&got, cases[i].v1, cases[i].ds_type, TIME_T_TO_CDTIME_T(cases[i].t1), &state) == EAGAIN);
 368       continue;
 369     }
 370
 371     OK(value_to_rate (&got, cases[i].v1, cases[i].ds_type, TIME_T_TO_CDTIME_T(cases[i].t1), &state) == 0);
 372     EXPECT_EQ_DOUBLE(cases[i].want, got);
 373   }
 374
 375   return 0;
 376 }
 377
 378 int main (void)
 379 {
 380   RUN_TEST(sstrncpy);
 381   RUN_TEST(ssnprintf);
 382   RUN_TEST(sstrdup);
 383   RUN_TEST(strsplit);
 384   RUN_TEST(strjoin);
 385   RUN_TEST(escape_slashes);
 386   RUN_TEST(escape_string);
 387   RUN_TEST(strunescape);
 388   RUN_TEST(parse_values);
 389   RUN_TEST(value_to_rate);
 390
 391   END_TEST;
 392 }
 393
 394 /* vim: set sw=2 sts=2 et : */