git.m6w6.name Git - awesomized/libmemcached/blob - tests/test.c

   1 /*
   2   Sample test application.
   3 */
   4 #include <assert.h>
   5 #include <memcached.h>
   6 #include <stdio.h>
   7 #include <stdlib.h>
   8 #include <string.h>
   9 #include <sys/time.h>
  10 #include <time.h>
  11
  12 long int timedif(struct timeval a, struct timeval b)
  13 {
  14   register int us, s;
  15
  16   us = a.tv_usec - b.tv_usec;
  17   us /= 1000;
  18   s = a.tv_sec - b.tv_sec;
  19   s *= 1000;
  20   return s + us;
  21 }
  22
  23 void init_test(memcached_st *not_used)
  24 {
  25   memcached_st memc;
  26
  27   (void)memcached_create(&memc);
  28   memcached_free(&memc);
  29 }
  30
  31 void allocation_test(memcached_st *not_used)
  32 {
  33   memcached_st *memc;
  34   memc= memcached_create(NULL);
  35   assert(memc);
  36   memcached_free(memc);
  37 }
  38
  39 void connection_test(memcached_st *memc)
  40 {
  41   memcached_return rc;
  42
  43   rc= memcached_server_add(memc, "localhost", 0);
  44   assert(rc == MEMCACHED_SUCCESS);
  45 }
  46
  47 void error_test(memcached_st *memc)
  48 {
  49   memcached_return rc;
  50
  51   for (rc= MEMCACHED_SUCCESS; rc < MEMCACHED_MAXIMUM_RETURN; rc++)
  52   {
  53     printf("Error %d -> %s\n", rc, memcached_strerror(memc, rc));
  54   }
  55 }
  56
  57 void set_test(memcached_st *memc)
  58 {
  59   memcached_return rc;
  60   char *key= "foo";
  61   char *value= "when we sanitize";
  62
  63   rc= memcached_set(memc, key, strlen(key),
  64                     value, strlen(value),
  65                     (time_t)0, (uint16_t)0);
  66   assert(rc == MEMCACHED_SUCCESS);
  67 }
  68
  69 void add_test(memcached_st *memc)
  70 {
  71   memcached_return rc;
  72   char *key= "foo";
  73   char *value= "when we sanitize";
  74
  75   rc= memcached_add(memc, key, strlen(key),
  76                     value, strlen(value),
  77                     (time_t)0, (uint16_t)0);
  78   assert(rc == MEMCACHED_NOTSTORED);
  79 }
  80
  81 void replace_test(memcached_st *memc)
  82 {
  83   memcached_return rc;
  84   char *key= "foo";
  85   char *value= "when we sanitize";
  86
  87   rc= memcached_replace(memc, key, strlen(key),
  88                     value, strlen(value),
  89                     (time_t)0, (uint16_t)0);
  90   assert(rc == MEMCACHED_SUCCESS);
  91 }
  92
  93 void delete_test(memcached_st *memc)
  94 {
  95   memcached_return rc;
  96   char *key= "foo";
  97   char *value= "when we sanitize";
  98
  99   rc= memcached_set(memc, key, strlen(key),
 100                     value, strlen(value),
 101                     (time_t)0, (uint16_t)0);
 102   assert(rc == MEMCACHED_SUCCESS);
 103
 104   rc= memcached_delete(memc, key, strlen(key), (time_t)0);
 105   assert(rc == MEMCACHED_SUCCESS);
 106 }
 107
 108 void flush_test(memcached_st *memc)
 109 {
 110   memcached_return rc;
 111
 112   rc= memcached_flush(memc, 0);
 113   assert(rc == MEMCACHED_SUCCESS);
 114 }
 115
 116 void get_test(memcached_st *memc)
 117 {
 118   memcached_return rc;
 119   char *key= "foo";
 120   char *string;
 121   size_t string_length;
 122   uint16_t flags;
 123
 124   string= memcached_get(memc, key, strlen(key),
 125                         &string_length, &flags, &rc);
 126
 127   assert(rc == MEMCACHED_NOTFOUND);
 128   assert(string_length ==  0);
 129   assert(!string);
 130 }
 131
 132 void get_test2(memcached_st *memc)
 133 {
 134   memcached_return rc;
 135   char *key= "foo";
 136   char *value= "when we sanitize";
 137   char *string;
 138   size_t string_length;
 139   uint16_t flags;
 140
 141   rc= memcached_set(memc, key, strlen(key),
 142                     value, strlen(value),
 143                     (time_t)0, (uint16_t)0);
 144   assert(rc == MEMCACHED_SUCCESS);
 145
 146   string= memcached_get(memc, key, strlen(key),
 147                         &string_length, &flags, &rc);
 148
 149   assert(string);
 150   assert(rc == MEMCACHED_SUCCESS);
 151   assert(string_length == strlen(value));
 152   assert(!memcmp(string, value, string_length));
 153
 154   free(string);
 155 }
 156
 157 void set_test2(memcached_st *memc)
 158 {
 159   memcached_return rc;
 160   char *key= "foo";
 161   char *value= "train in the brain";
 162   size_t value_length= strlen(value);
 163   unsigned int x;
 164
 165   for (x= 0; x < 10; x++)
 166   {
 167     rc= memcached_set(memc, key, strlen(key),
 168                       value, value_length,
 169                       (time_t)0, (uint16_t)0);
 170     assert(rc == MEMCACHED_SUCCESS);
 171   }
 172 }
 173
 174 void set_test3(memcached_st *memc)
 175 {
 176   memcached_return rc;
 177   char *key= "foo";
 178   char *value;
 179   size_t value_length= 8191;
 180   unsigned int x;
 181
 182   value = (char*)malloc(value_length);
 183   assert(value);
 184
 185   for (x= 0; x < value_length; x++)
 186     value[x] = (char) (x % 127);
 187
 188   for (x= 0; x < 1; x++)
 189   {
 190     rc= memcached_set(memc, key, strlen(key),
 191                       value, value_length,
 192                       (time_t)0, (uint16_t)0);
 193     assert(rc == MEMCACHED_SUCCESS);
 194   }
 195
 196   free(value);
 197 }
 198
 199 void get_test3(memcached_st *memc)
 200 {
 201   memcached_return rc;
 202   char *key= "foo";
 203   char *value;
 204   size_t value_length= 8191;
 205   char *string;
 206   size_t string_length;
 207   uint16_t flags;
 208   int x;
 209
 210   value = (char*)malloc(value_length);
 211   assert(value);
 212
 213   for (x= 0; x < value_length; x++)
 214     value[x] = (char) (x % 127);
 215
 216   rc= memcached_set(memc, key, strlen(key),
 217                     value, value_length,
 218                     (time_t)0, (uint16_t)0);
 219   assert(rc == MEMCACHED_SUCCESS);
 220
 221   string= memcached_get(memc, key, strlen(key),
 222                         &string_length, &flags, &rc);
 223
 224   assert(rc == MEMCACHED_SUCCESS);
 225   assert(string);
 226   assert(string_length == value_length);
 227   assert(!memcmp(string, value, string_length));
 228
 229   free(string);
 230   free(value);
 231 }
 232
 233 void get_test4(memcached_st *memc)
 234 {
 235   memcached_return rc;
 236   char *key= "foo";
 237   char *value;
 238   size_t value_length= 8191;
 239   char *string;
 240   size_t string_length;
 241   uint16_t flags;
 242   int x;
 243
 244   value = (char*)malloc(value_length);
 245   assert(value);
 246
 247   for (x= 0; x < value_length; x++)
 248     value[x] = (char) (x % 127);
 249
 250   rc= memcached_set(memc, key, strlen(key),
 251                     value, value_length,
 252                     (time_t)0, (uint16_t)0);
 253   assert(rc == MEMCACHED_SUCCESS);
 254
 255   for (x= 0; x < 10; x++)
 256   {
 257     string= memcached_get(memc, key, strlen(key),
 258                           &string_length, &flags, &rc);
 259
 260     assert(rc == MEMCACHED_SUCCESS);
 261     assert(string);
 262     assert(string_length == value_length);
 263     assert(!memcmp(string, value, string_length));
 264     free(string);
 265   }
 266
 267   free(value);
 268 }
 269
 270 void stats_servername_test(memcached_st *memc)
 271 {
 272   memcached_return rc;
 273   memcached_stat_st stat;
 274   rc= memcached_stat_servername(&stat, NULL,
 275                                  "localhost",
 276                                  MEMCACHED_DEFAULT_PORT);
 277 }
 278
 279 void increment_test(memcached_st *memc)
 280 {
 281   unsigned int new_number;
 282   memcached_return rc;
 283   char *key= "number";
 284   char *value= "0";
 285
 286   rc= memcached_set(memc, key, strlen(key),
 287                     value, strlen(value),
 288                     (time_t)0, (uint16_t)0);
 289   assert(rc == MEMCACHED_SUCCESS);
 290
 291   rc= memcached_increment(memc, key, strlen(key),
 292                           1, &new_number);
 293   assert(rc == MEMCACHED_SUCCESS);
 294   assert(new_number == 1);
 295
 296   rc= memcached_increment(memc, key, strlen(key),
 297                           1, &new_number);
 298   assert(rc == MEMCACHED_SUCCESS);
 299   assert(new_number == 2);
 300 }
 301
 302 void decrement_test(memcached_st *memc)
 303 {
 304   unsigned int new_number;
 305   memcached_return rc;
 306   char *key= "number";
 307   char *value= "3";
 308
 309   rc= memcached_set(memc, key, strlen(key),
 310                     value, strlen(value),
 311                     (time_t)0, (uint16_t)0);
 312   assert(rc == MEMCACHED_SUCCESS);
 313
 314   rc= memcached_decrement(memc, key, strlen(key),
 315                           1, &new_number);
 316   assert(rc == MEMCACHED_SUCCESS);
 317   assert(new_number == 2);
 318
 319   rc= memcached_decrement(memc, key, strlen(key),
 320                           1, &new_number);
 321   assert(rc == MEMCACHED_SUCCESS);
 322   assert(new_number == 1);
 323 }
 324
 325 void quit_test(memcached_st *memc)
 326 {
 327   memcached_return rc;
 328   char *key= "fudge";
 329   char *value= "sanford and sun";
 330
 331   rc= memcached_set(memc, key, strlen(key),
 332                     value, strlen(value),
 333                     (time_t)10, (uint16_t)3);
 334   assert(rc == MEMCACHED_SUCCESS);
 335   memcached_quit(memc);
 336
 337   rc= memcached_set(memc, key, strlen(key),
 338                     value, strlen(value),
 339                     (time_t)50, (uint16_t)9);
 340   assert(rc == MEMCACHED_SUCCESS);
 341 }
 342
 343 void mget_test(memcached_st *memc)
 344 {
 345   memcached_return rc;
 346   char *keys[]= {"fudge", "son", "food"};
 347   size_t key_length[]= {5, 3, 4};
 348   unsigned int x;
 349   uint16_t flags;
 350
 351   char return_key[MEMCACHED_MAX_KEY];
 352   size_t return_key_length;
 353   char *return_value;
 354   size_t return_value_length;
 355
 356   /* We need to empty the server before continueing test */
 357   rc= memcached_flush(memc, 0);
 358   assert(rc == MEMCACHED_SUCCESS);
 359
 360   rc= memcached_mget(memc, keys, key_length, 3);
 361   assert(rc == MEMCACHED_SUCCESS);
 362
 363   while ((return_value= memcached_fetch(memc, return_key, &return_key_length,
 364                       &return_value_length, &flags, &rc)) != NULL)
 365   {
 366     assert(return_value);
 367   }
 368   assert(!return_value);
 369   assert(return_value_length == 0);
 370   assert(rc == MEMCACHED_NOTFOUND);
 371
 372   for (x= 0; x < 3; x++)
 373   {
 374     rc= memcached_set(memc, keys[x], key_length[x],
 375                       keys[x], key_length[x],
 376                       (time_t)50, (uint16_t)9);
 377     assert(rc == MEMCACHED_SUCCESS);
 378   }
 379
 380   rc= memcached_mget(memc, keys, key_length, 3);
 381   assert(rc == MEMCACHED_SUCCESS);
 382
 383   x= 0;
 384   while ((return_value= memcached_fetch(memc, return_key, &return_key_length,
 385                                         &return_value_length, &flags, &rc)))
 386   {
 387     assert(return_value);
 388     assert(rc == MEMCACHED_SUCCESS);
 389     assert(return_key_length == return_value_length);
 390     assert(!memcmp(return_value, return_key, return_value_length));
 391     free(return_value);
 392     x++;
 393   }
 394 }
 395
 396 void get_stats_keys(memcached_st *memc)
 397 {
 398  char **list;
 399  char **ptr;
 400  memcached_stat_st stat;
 401  memcached_return rc;
 402
 403  list= memcached_stat_get_keys(memc, &stat, &rc);
 404  assert(rc == MEMCACHED_SUCCESS);
 405  for (ptr= list; *ptr; ptr++)
 406    printf("Found key %s\n", *ptr);
 407  fflush(stdout);
 408
 409  free(list);
 410 }
 411
 412 void get_stats(memcached_st *memc)
 413 {
 414  unsigned int x;
 415  char **list;
 416  char **ptr;
 417  memcached_return rc;
 418  memcached_stat_st *stat;
 419
 420  stat= memcached_stat(memc, NULL, &rc);
 421  assert(rc == MEMCACHED_SUCCESS);
 422
 423  assert(rc == MEMCACHED_SUCCESS);
 424  assert(stat);
 425
 426  for (x= 0; x < memcached_server_count(memc); x++)
 427  {
 428    list= memcached_stat_get_keys(memc, &stat[x], &rc);
 429    assert(rc == MEMCACHED_SUCCESS);
 430    for (ptr= list; *ptr; ptr++)
 431      printf("Found key %s\n", *ptr);
 432
 433    free(list);
 434  }
 435
 436  free(stat);
 437 }
 438
 439 void add_host_test(memcached_st *memc)
 440 {
 441   unsigned int x;
 442   memcached_server_st *servers;
 443   memcached_return rc;
 444   char servername[]= "0.example.com";
 445
 446   servers= memcached_server_list_append(NULL, servername, 400, &rc);
 447   assert(servers);
 448   assert(1 == memcached_server_list_count(servers));
 449
 450   for (x= 2; x < 20; x++)
 451   {
 452     char buffer[SMALL_STRING_LEN];
 453
 454     snprintf(buffer, SMALL_STRING_LEN, "%u.example.com", 400+x);
 455     servers= memcached_server_list_append(servers, buffer, 401,
 456                                      &rc);
 457     assert(rc == MEMCACHED_SUCCESS);
 458     assert(x == memcached_server_list_count(servers));
 459   }
 460
 461   rc= memcached_server_push(memc, servers);
 462   assert(rc == MEMCACHED_SUCCESS);
 463   rc= memcached_server_push(memc, servers);
 464   assert(rc == MEMCACHED_SUCCESS);
 465
 466   memcached_server_list_free(servers);
 467 }
 468
 469 /* We don't test the behavior itself, we test the switches */
 470 void behavior_test(memcached_st *memc)
 471 {
 472   unsigned long long value;
 473   unsigned int set= 1;
 474
 475   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &set);
 476   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_NO_BLOCK);
 477   assert(value == 1);
 478
 479   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &set);
 480   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY);
 481   assert(value == 1);
 482
 483   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_MD5_HASHING, &set);
 484   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_MD5_HASHING);
 485   assert(value == 1);
 486
 487   set= 0;
 488
 489   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &set);
 490   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_NO_BLOCK);
 491   assert(value == 0);
 492
 493   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &set);
 494   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY);
 495   assert(value == 0);
 496
 497   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_MD5_HASHING, &set);
 498   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_MD5_HASHING);
 499   assert(value == 0);
 500
 501   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE);
 502   assert(value > 0);
 503
 504   value= memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE);
 505   assert(value > 0);
 506 }
 507
 508 /* Test case provided by Cal Haldenbrand */
 509 void user_supplied_bug1(memcached_st *memc)
 510 {
 511   unsigned int setter= 1;
 512   unsigned int x;
 513
 514   unsigned long long total= 0;
 515   int size= 0;
 516   srand(time(NULL));
 517   char key[10];
 518   char *randomstuff = (char *)malloc(6 * 1024);
 519   memset(randomstuff, 0, 6 * 1024);
 520
 521   memcached_return rc;
 522
 523   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &setter);
 524   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &setter);
 525
 526
 527   /* add key */
 528   for (x= 0 ; total < 20 * 1024576 ; x++ )
 529   {
 530     unsigned int j= 0;
 531
 532     size= (rand() % ( 5 * 1024 ) ) + 400;
 533     memset(randomstuff, 0, 6 * 1024);
 534     assert(size < 6 * 1024); /* Being safe here */
 535
 536     for (j= 0 ; j < size ;j++)
 537       randomstuff[j] = (char) (rand() % 26) + 97;
 538
 539     total += size;
 540     sprintf(key, "%d", x);
 541     rc = memcached_set(memc, key, strlen(key),
 542                        randomstuff, strlen(randomstuff), 10, 0);
 543     /* If we fail, lets try again */
 544     if (rc != MEMCACHED_SUCCESS)
 545       rc = memcached_set(memc, key, strlen(key),
 546                          randomstuff, strlen(randomstuff), 10, 0);
 547     assert(rc == MEMCACHED_SUCCESS);
 548   }
 549 }
 550
 551 /* Test case provided by Cal Haldenbrand */
 552 void user_supplied_bug2(memcached_st *memc)
 553 {
 554   int errors;
 555   unsigned int setter;
 556   unsigned int x;
 557   unsigned long long total;
 558
 559
 560   setter= 1;
 561   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &setter);
 562   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &setter);
 563 #ifdef NOT_YET
 564   setter = 20 * 1024576;
 565   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE, &setter);
 566   setter = 20 * 1024576;
 567   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE, &setter);
 568   getter = memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE);
 569   getter = memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE);
 570 #endif
 571
 572   for (x= 0, errors= 0, total= 0 ; total < 20 * 1024576 ; x++)
 573   {
 574     memcached_return rc;
 575     char buffer[SMALL_STRING_LEN];
 576     uint16_t flags;
 577     size_t val_len;
 578     char *getval;
 579
 580     snprintf(buffer, SMALL_STRING_LEN, "%u", x);
 581     getval= memcached_get(memc, buffer, strlen(buffer),
 582                            &val_len, &flags, &rc);
 583     if (rc != MEMCACHED_SUCCESS)
 584     {
 585       WATCHPOINT_ERROR(rc);
 586       errors++;
 587       if ( errors == 10 )
 588       {
 589         fprintf(stderr, "last: %s:  len %zu  flags: %u\n", buffer, val_len, flags);
 590         assert(0);
 591       }
 592       continue;
 593     }
 594     total+= val_len;
 595     errors= 0;
 596     free(getval);
 597   }
 598 }
 599
 600 void add_host_test1(memcached_st *memc)
 601 {
 602   unsigned int x;
 603   memcached_return rc;
 604   char servername[]= "0.example.com";
 605   memcached_server_st *servers;
 606
 607   servers= memcached_server_list_append(NULL, servername, 400, &rc);
 608   assert(servers);
 609   assert(1 == memcached_server_list_count(servers));
 610
 611   for (x= 2; x < 20; x++)
 612   {
 613     char buffer[SMALL_STRING_LEN];
 614
 615     snprintf(buffer, SMALL_STRING_LEN, "%u.example.com", 400+x);
 616     servers= memcached_server_list_append(servers, buffer, 401,
 617                                      &rc);
 618     assert(rc == MEMCACHED_SUCCESS);
 619     assert(x == memcached_server_list_count(servers));
 620   }
 621
 622   rc= memcached_server_push(memc, servers);
 623   assert(rc == MEMCACHED_SUCCESS);
 624   rc= memcached_server_push(memc, servers);
 625   assert(rc == MEMCACHED_SUCCESS);
 626
 627   memcached_server_list_free(servers);
 628 }
 629
 630 typedef struct test_st test_st;
 631
 632 struct test_st {
 633   char *function_name;
 634   unsigned int requires_flush;
 635   void (*function)(memcached_st *memc);
 636 };
 637
 638 int main(int argc, char *argv[])
 639 {
 640   unsigned int x;
 641   char *server_list;
 642   char *test_to_run= NULL;
 643   char *wildcard= NULL;
 644   memcached_server_st *servers;
 645
 646   if (argc > 2)
 647     test_to_run= argv[1];
 648
 649   if (argc == 3)
 650     wildcard= argv[2];
 651
 652   if (!(server_list= getenv("MEMCACHED_SERVERS")))
 653     server_list= "localhost";
 654
 655   printf("servers %s\n", server_list);
 656   srandom(time(NULL));
 657
 658   servers= memcached_servers_parse(server_list);
 659   assert(servers);
 660
 661   for (x= 0; x < memcached_server_list_count(servers); x++)
 662   {
 663     printf("\t%s : %u\n", servers[x].hostname, servers[x].port);
 664     assert(servers[x].stack_responses == 0);
 665     assert(servers[x].fd == -1);
 666     assert(servers[x].cursor_active == 0);
 667   }
 668
 669   printf("\n");
 670
 671   /* Clean the server before beginning testing */
 672   test_st tests[] ={
 673     {"flush", 0, flush_test },
 674     {"init", 0, init_test },
 675     {"allocation", 0, allocation_test },
 676     {"error", 0, error_test },
 677     {"set", 0, set_test },
 678     {"set2", 0, set_test2 },
 679     {"set3", 0, set_test3 },
 680     {"add", 0, add_test },
 681     {"replace", 0, replace_test },
 682     {"delete", 1, delete_test },
 683     {"get", 0, get_test },
 684     {"get2", 0, get_test2 },
 685     {"get3", 0, get_test3 },
 686     {"get4", 0, get_test4 },
 687     {"stats_servername", 0, stats_servername_test },
 688     {"increment", 0, increment_test },
 689     {"decrement", 0, decrement_test },
 690     {"quit", 0, quit_test },
 691     {"mget", 0, mget_test },
 692     {"get_stats", 0, get_stats },
 693     {"add_host_test", 0, add_host_test },
 694     {"get_stats_keys", 0, get_stats_keys },
 695     {"behavior_test", 0, get_stats_keys },
 696     {0, 0, 0}
 697   };
 698
 699   test_st user_tests[] ={
 700     {"user_supplied_bug1", 0, user_supplied_bug1 },
 701     {"user_supplied_bug2", 0, user_supplied_bug1 },
 702     {0, 0, 0}
 703   };
 704
 705   if ((test_to_run && !strcmp(test_to_run, "block")) || !test_to_run)
 706   {
 707     fprintf(stderr, "\nBlock tests\n\n");
 708     for (x= 0; tests[x].function_name; x++)
 709     {
 710       if (wildcard)
 711         if (strcmp(wildcard, tests[x].function_name))
 712           continue;
 713
 714       memcached_st *memc;
 715       memcached_return rc;
 716       struct timeval start_time, end_time;
 717
 718       memc= memcached_create(NULL);
 719       assert(memc);
 720
 721       rc= memcached_server_push(memc, servers);
 722       assert(rc == MEMCACHED_SUCCESS);
 723
 724       unsigned int loop;
 725       for (loop= 0; loop < memcached_server_list_count(servers); loop++)
 726       {
 727         assert(memc->hosts[loop].stack_responses == 0);
 728         assert(memc->hosts[loop].fd == -1);
 729         assert(memc->hosts[loop].cursor_active == 0);
 730       }
 731
 732       fprintf(stderr, "Testing %s", tests[x].function_name);
 733       gettimeofday(&start_time, NULL);
 734       tests[x].function(memc);
 735       gettimeofday(&end_time, NULL);
 736       long int load_time= timedif(end_time, start_time);
 737       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 738               load_time % 1000);
 739       assert(memc);
 740       memcached_free(memc);
 741     }
 742   }
 743
 744   if ((test_to_run && !strcmp(test_to_run, "nonblock")) || !test_to_run)
 745   {
 746     fprintf(stderr, "\nNonblock tests\n\n");
 747     for (x= 0; tests[x].function_name; x++)
 748     {
 749       if (wildcard)
 750         if (strcmp(wildcard, tests[x].function_name))
 751           continue;
 752
 753       memcached_st *memc;
 754       memcached_return rc;
 755       struct timeval start_time, end_time;
 756
 757       memc= memcached_create(NULL);
 758       assert(memc);
 759
 760       rc= memcached_server_push(memc, servers);
 761       assert(rc == MEMCACHED_SUCCESS);
 762
 763       fprintf(stderr, "Testing %s", tests[x].function_name);
 764       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
 765       gettimeofday(&start_time, NULL);
 766       tests[x].function(memc);
 767       gettimeofday(&end_time, NULL);
 768       long int load_time= timedif(end_time, start_time);
 769       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 770               load_time % 1000);
 771       assert(memc);
 772       memcached_free(memc);
 773     }
 774   }
 775
 776   if ((test_to_run && !strcmp(test_to_run, "nodelay")) || !test_to_run)
 777   {
 778     fprintf(stderr, "\nTCP Nodelay tests\n\n");
 779     for (x= 0; tests[x].function_name; x++)
 780     {
 781       if (wildcard)
 782         if (strcmp(wildcard, tests[x].function_name))
 783           continue;
 784
 785       memcached_st *memc;
 786       memcached_return rc;
 787       struct timeval start_time, end_time;
 788
 789       memc= memcached_create(NULL);
 790       assert(memc);
 791
 792       rc= memcached_server_push(memc, servers);
 793       assert(rc == MEMCACHED_SUCCESS);
 794
 795       fprintf(stderr, "Testing %s", tests[x].function_name);
 796       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
 797       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, NULL);
 798       gettimeofday(&start_time, NULL);
 799       tests[x].function(memc);
 800       gettimeofday(&end_time, NULL);
 801       long int load_time= timedif(end_time, start_time);
 802       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 803               load_time % 1000);
 804       assert(memc);
 805       memcached_free(memc);
 806     }
 807   }
 808
 809   if ((test_to_run && !strcmp(test_to_run, "md5")) || !test_to_run)
 810   {
 811     fprintf(stderr, "\nMD5 Hashing\n\n");
 812     for (x= 0; tests[x].function_name; x++)
 813     {
 814       if (wildcard)
 815         if (strcmp(wildcard, tests[x].function_name))
 816           continue;
 817
 818       memcached_st *memc;
 819       memcached_return rc;
 820       struct timeval start_time, end_time;
 821
 822       memc= memcached_create(NULL);
 823       assert(memc);
 824
 825       rc= memcached_server_push(memc, servers);
 826       assert(rc == MEMCACHED_SUCCESS);
 827
 828       fprintf(stderr, "Testing %s", tests[x].function_name);
 829       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_MD5_HASHING, NULL);
 830       gettimeofday(&start_time, NULL);
 831       tests[x].function(memc);
 832       gettimeofday(&end_time, NULL);
 833       long int load_time= timedif(end_time, start_time);
 834       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 835               load_time % 1000);
 836       assert(memc);
 837       memcached_free(memc);
 838     }
 839   }
 840
 841   if ((test_to_run && !strcmp(test_to_run, "user")) || !test_to_run)
 842   {
 843     fprintf(stderr, "\nUser Supplied tests\n\n");
 844     for (x= 0; user_tests[x].function_name; x++)
 845     {
 846       if (wildcard)
 847         if (strcmp(wildcard, tests[x].function_name))
 848           continue;
 849
 850       memcached_st *memc;
 851       memcached_return rc;
 852       struct timeval start_time, end_time;
 853
 854       memc= memcached_create(NULL);
 855       assert(memc);
 856
 857       rc= memcached_server_push(memc, servers);
 858       assert(rc == MEMCACHED_SUCCESS);
 859
 860       fprintf(stderr, "Testing %s", user_tests[x].function_name);
 861       gettimeofday(&start_time, NULL);
 862       user_tests[x].function(memc);
 863       gettimeofday(&end_time, NULL);
 864       long int load_time= timedif(end_time, start_time);
 865       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 866               load_time % 1000);
 867       assert(memc);
 868       memcached_free(memc);
 869     }
 870   }
 871
 872   /* Clean up whatever we might have left */
 873   {
 874     memcached_st *memc;
 875     memc= memcached_create(NULL);
 876     assert(memc);
 877     flush_test(memc);
 878     memcached_free(memc);
 879   }
 880
 881   fprintf(stderr, "All tests completed successfully\n\n");
 882
 883   return 0;
 884 }