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   char key[10];
 517   char randomstuff[6 * 1024];
 518   memcached_return rc;
 519
 520   memset(randomstuff, 0, 6 * 1024);
 521
 522   /* We just keep looking at the same values over and over */
 523   srandom(10);
 524
 525   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &setter);
 526   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &setter);
 527
 528
 529   /* add key */
 530   for (x= 0 ; total < 20 * 1024576 ; x++ )
 531   {
 532     unsigned int j= 0;
 533
 534     size= (rand() % ( 5 * 1024 ) ) + 400;
 535     memset(randomstuff, 0, 6 * 1024);
 536     assert(size < 6 * 1024); /* Being safe here */
 537
 538     for (j= 0 ; j < size ;j++)
 539       randomstuff[j] = (char) (rand() % 26) + 97;
 540
 541     total += size;
 542     sprintf(key, "%d", x);
 543     rc = memcached_set(memc, key, strlen(key),
 544                        randomstuff, strlen(randomstuff), 10, 0);
 545     /* If we fail, lets try again */
 546     if (rc != MEMCACHED_SUCCESS)
 547       rc = memcached_set(memc, key, strlen(key),
 548                          randomstuff, strlen(randomstuff), 10, 0);
 549     assert(rc == MEMCACHED_SUCCESS);
 550   }
 551 }
 552
 553 /* Test case provided by Cal Haldenbrand */
 554 void user_supplied_bug2(memcached_st *memc)
 555 {
 556   int errors;
 557   unsigned int setter;
 558   unsigned int x;
 559   unsigned long long total;
 560
 561   setter= 1;
 562   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, &setter);
 563   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, &setter);
 564 #ifdef NOT_YET
 565   setter = 20 * 1024576;
 566   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE, &setter);
 567   setter = 20 * 1024576;
 568   memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE, &setter);
 569   getter = memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE);
 570   getter = memcached_behavior_get(memc, MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE);
 571 #endif
 572
 573   for (x= 0, errors= 0, total= 0 ; total < 20 * 1024576 ; x++)
 574   {
 575     memcached_return rc;
 576     char buffer[SMALL_STRING_LEN];
 577     uint16_t flags;
 578     size_t val_len;
 579     char *getval;
 580
 581     snprintf(buffer, SMALL_STRING_LEN, "%u", x);
 582     getval= memcached_get(memc, buffer, strlen(buffer),
 583                            &val_len, &flags, &rc);
 584     if (rc != MEMCACHED_SUCCESS)
 585     {
 586       WATCHPOINT_ERROR(rc);
 587       errors++;
 588       if ( errors == 10 )
 589       {
 590         fprintf(stderr, "last: %s:  len %zu  flags: %u\n", buffer, val_len, flags);
 591         assert(0);
 592       }
 593       continue;
 594     }
 595     total+= val_len;
 596     errors= 0;
 597     free(getval);
 598   }
 599 }
 600
 601 void add_host_test1(memcached_st *memc)
 602 {
 603   unsigned int x;
 604   memcached_return rc;
 605   char servername[]= "0.example.com";
 606   memcached_server_st *servers;
 607
 608   servers= memcached_server_list_append(NULL, servername, 400, &rc);
 609   assert(servers);
 610   assert(1 == memcached_server_list_count(servers));
 611
 612   for (x= 2; x < 20; x++)
 613   {
 614     char buffer[SMALL_STRING_LEN];
 615
 616     snprintf(buffer, SMALL_STRING_LEN, "%u.example.com", 400+x);
 617     servers= memcached_server_list_append(servers, buffer, 401,
 618                                      &rc);
 619     assert(rc == MEMCACHED_SUCCESS);
 620     assert(x == memcached_server_list_count(servers));
 621   }
 622
 623   rc= memcached_server_push(memc, servers);
 624   assert(rc == MEMCACHED_SUCCESS);
 625   rc= memcached_server_push(memc, servers);
 626   assert(rc == MEMCACHED_SUCCESS);
 627
 628   memcached_server_list_free(servers);
 629 }
 630
 631 typedef struct test_st test_st;
 632
 633 struct test_st {
 634   char *function_name;
 635   unsigned int requires_flush;
 636   void (*function)(memcached_st *memc);
 637 };
 638
 639 int main(int argc, char *argv[])
 640 {
 641   unsigned int x;
 642   char *server_list;
 643   char *test_to_run= NULL;
 644   char *wildcard= NULL;
 645   memcached_server_st *servers;
 646
 647   if (argc > 2)
 648     test_to_run= argv[1];
 649
 650   if (argc == 3)
 651     wildcard= argv[2];
 652
 653   if (!(server_list= getenv("MEMCACHED_SERVERS")))
 654     server_list= "localhost";
 655
 656   printf("servers %s\n", server_list);
 657   srandom(time(NULL));
 658
 659   servers= memcached_servers_parse(server_list);
 660   assert(servers);
 661
 662   for (x= 0; x < memcached_server_list_count(servers); x++)
 663   {
 664     printf("\t%s : %u\n", servers[x].hostname, servers[x].port);
 665     assert(servers[x].stack_responses == 0);
 666     assert(servers[x].fd == -1);
 667     assert(servers[x].cursor_active == 0);
 668   }
 669
 670   printf("\n");
 671
 672   /* Clean the server before beginning testing */
 673   test_st tests[] ={
 674     {"flush", 0, flush_test },
 675     {"init", 0, init_test },
 676     {"allocation", 0, allocation_test },
 677     {"error", 0, error_test },
 678     {"set", 0, set_test },
 679     {"set2", 0, set_test2 },
 680     {"set3", 0, set_test3 },
 681     {"add", 0, add_test },
 682     {"replace", 0, replace_test },
 683     {"delete", 1, delete_test },
 684     {"get", 0, get_test },
 685     {"get2", 0, get_test2 },
 686     {"get3", 0, get_test3 },
 687     {"get4", 0, get_test4 },
 688     {"stats_servername", 0, stats_servername_test },
 689     {"increment", 0, increment_test },
 690     {"decrement", 0, decrement_test },
 691     {"quit", 0, quit_test },
 692     {"mget", 0, mget_test },
 693     {"get_stats", 0, get_stats },
 694     {"add_host_test", 0, add_host_test },
 695     {"get_stats_keys", 0, get_stats_keys },
 696     {"behavior_test", 0, get_stats_keys },
 697     {0, 0, 0}
 698   };
 699
 700   test_st user_tests[] ={
 701     {"user_supplied_bug1", 0, user_supplied_bug1 },
 702     {"user_supplied_bug2", 0, user_supplied_bug2 },
 703     {0, 0, 0}
 704   };
 705
 706   if ((test_to_run && !strcmp(test_to_run, "block")) || !test_to_run)
 707   {
 708     fprintf(stderr, "\nBlock tests\n\n");
 709     for (x= 0; tests[x].function_name; x++)
 710     {
 711       if (wildcard)
 712         if (strcmp(wildcard, tests[x].function_name))
 713           continue;
 714
 715       memcached_st *memc;
 716       memcached_return rc;
 717       struct timeval start_time, end_time;
 718
 719       memc= memcached_create(NULL);
 720       assert(memc);
 721
 722       rc= memcached_server_push(memc, servers);
 723       assert(rc == MEMCACHED_SUCCESS);
 724
 725       unsigned int loop;
 726       for (loop= 0; loop < memcached_server_list_count(servers); loop++)
 727       {
 728         assert(memc->hosts[loop].stack_responses == 0);
 729         assert(memc->hosts[loop].fd == -1);
 730         assert(memc->hosts[loop].cursor_active == 0);
 731       }
 732
 733       fprintf(stderr, "Testing %s", tests[x].function_name);
 734       gettimeofday(&start_time, NULL);
 735       tests[x].function(memc);
 736       gettimeofday(&end_time, NULL);
 737       long int load_time= timedif(end_time, start_time);
 738       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 739               load_time % 1000);
 740       assert(memc);
 741       memcached_free(memc);
 742     }
 743   }
 744
 745   if ((test_to_run && !strcmp(test_to_run, "nonblock")) || !test_to_run)
 746   {
 747     fprintf(stderr, "\nNonblock tests\n\n");
 748     for (x= 0; tests[x].function_name; x++)
 749     {
 750       if (wildcard)
 751         if (strcmp(wildcard, tests[x].function_name))
 752           continue;
 753
 754       memcached_st *memc;
 755       memcached_return rc;
 756       struct timeval start_time, end_time;
 757
 758       memc= memcached_create(NULL);
 759       assert(memc);
 760
 761       rc= memcached_server_push(memc, servers);
 762       assert(rc == MEMCACHED_SUCCESS);
 763
 764       fprintf(stderr, "Testing %s", tests[x].function_name);
 765       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
 766       gettimeofday(&start_time, NULL);
 767       tests[x].function(memc);
 768       gettimeofday(&end_time, NULL);
 769       long int load_time= timedif(end_time, start_time);
 770       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 771               load_time % 1000);
 772       assert(memc);
 773       memcached_free(memc);
 774     }
 775   }
 776
 777   if ((test_to_run && !strcmp(test_to_run, "nodelay")) || !test_to_run)
 778   {
 779     fprintf(stderr, "\nTCP Nodelay tests\n\n");
 780     for (x= 0; tests[x].function_name; x++)
 781     {
 782       if (wildcard)
 783         if (strcmp(wildcard, tests[x].function_name))
 784           continue;
 785
 786       memcached_st *memc;
 787       memcached_return rc;
 788       struct timeval start_time, end_time;
 789
 790       memc= memcached_create(NULL);
 791       assert(memc);
 792
 793       rc= memcached_server_push(memc, servers);
 794       assert(rc == MEMCACHED_SUCCESS);
 795
 796       fprintf(stderr, "Testing %s", tests[x].function_name);
 797       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
 798       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, NULL);
 799       gettimeofday(&start_time, NULL);
 800       tests[x].function(memc);
 801       gettimeofday(&end_time, NULL);
 802       long int load_time= timedif(end_time, start_time);
 803       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 804               load_time % 1000);
 805       assert(memc);
 806       memcached_free(memc);
 807     }
 808   }
 809
 810   if ((test_to_run && !strcmp(test_to_run, "md5")) || !test_to_run)
 811   {
 812     fprintf(stderr, "\nMD5 Hashing\n\n");
 813     for (x= 0; tests[x].function_name; x++)
 814     {
 815       if (wildcard)
 816         if (strcmp(wildcard, tests[x].function_name))
 817           continue;
 818
 819       memcached_st *memc;
 820       memcached_return rc;
 821       struct timeval start_time, end_time;
 822
 823       memc= memcached_create(NULL);
 824       assert(memc);
 825
 826       rc= memcached_server_push(memc, servers);
 827       assert(rc == MEMCACHED_SUCCESS);
 828
 829       fprintf(stderr, "Testing %s", tests[x].function_name);
 830       memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_MD5_HASHING, NULL);
 831       gettimeofday(&start_time, NULL);
 832       tests[x].function(memc);
 833       gettimeofday(&end_time, NULL);
 834       long int load_time= timedif(end_time, start_time);
 835       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 836               load_time % 1000);
 837       assert(memc);
 838       memcached_free(memc);
 839     }
 840   }
 841
 842   if ((test_to_run && !strcmp(test_to_run, "user")) || !test_to_run)
 843   {
 844     fprintf(stderr, "\nUser Supplied tests\n\n");
 845     for (x= 0; user_tests[x].function_name; x++)
 846     {
 847       if (wildcard)
 848         if (strcmp(wildcard, tests[x].function_name))
 849           continue;
 850
 851       memcached_st *memc;
 852       memcached_return rc;
 853       struct timeval start_time, end_time;
 854
 855       memc= memcached_create(NULL);
 856       assert(memc);
 857
 858       rc= memcached_server_push(memc, servers);
 859       assert(rc == MEMCACHED_SUCCESS);
 860
 861       fprintf(stderr, "Testing %s", user_tests[x].function_name);
 862       gettimeofday(&start_time, NULL);
 863       user_tests[x].function(memc);
 864       gettimeofday(&end_time, NULL);
 865       long int load_time= timedif(end_time, start_time);
 866       fprintf(stderr, "\t\t\t\t\t %ld.%03ld [ ok ]\n", load_time / 1000,
 867               load_time % 1000);
 868       assert(memc);
 869       memcached_free(memc);
 870     }
 871   }
 872
 873   /* Clean up whatever we might have left */
 874   {
 875     memcached_st *memc;
 876     memc= memcached_create(NULL);
 877     assert(memc);
 878     flush_test(memc);
 879     memcached_free(memc);
 880   }
 881
 882   fprintf(stderr, "All tests completed successfully\n\n");
 883
 884   memcached_server_list_free(servers);
 885
 886   return 0;
 887 }