X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=tests%2Ftest.c;h=8da111b316d627e7627ee8ff202c80ec8ed64236;hb=d3ef73cd144dfdbcaff41d3373e4458fb351f7af;hp=dabb00f4779ac23b6d0bb7e7ac84b7de4b54a8b5;hpb=806525899ce3dff894b829416307a4290cd882e2;p=m6w6%2Flibmemcached

diff --git a/tests/test.c b/tests/test.c
index dabb00f4..8da111b3 100644
--- a/tests/test.c
+++ b/tests/test.c
@@ -7,117 +7,82 @@
 #include <stdlib.h>
 #include <string.h>
 
-void init_test(void)
+void init_test(memcached_st *not_used)
 {
   memcached_st memc;
 
-  (void)memcached_init(&memc);
-  memcached_deinit(&memc);
+  (void)memcached_create(&memc);
+  memcached_free(&memc);
 }
 
-void allocation_test(void)
+void allocation_test(memcached_st *not_used)
 {
   memcached_st *memc;
-  memc= memcached_init(NULL);
+  memc= memcached_create(NULL);
   assert(memc);
-  memcached_deinit(memc);
+  memcached_free(memc);
 }
 
-void connection_test(void)
+void connection_test(memcached_st *memc)
 {
   memcached_return rc;
-  memcached_st *memc;
-  memc= memcached_init(NULL);
-  assert(memc);
+
   rc= memcached_server_add(memc, "localhost", 0);
   assert(rc == MEMCACHED_SUCCESS);
-  assert(memc);
-  memcached_deinit(memc);
 }
 
-void error_test(void)
+void error_test(memcached_st *memc)
 {
-  memcached_st *memc;
-  memc= memcached_init(NULL);
   memcached_return rc;
 
   for (rc= MEMCACHED_SUCCESS; rc < MEMCACHED_MAXIMUM_RETURN; rc++)
   {
     printf("Error %d -> %s\n", rc, memcached_strerror(memc, rc));
   }
-
-  assert(memc);
-  memcached_deinit(memc);
 }
 
-void set_test(void)
+void set_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value= "when we sanitize";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
   assert(rc == MEMCACHED_SUCCESS);
-  
-  memcached_deinit(memc);
 }
 
-void add_test(void)
+void add_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value= "when we sanitize";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
   rc= memcached_add(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
   assert(rc == MEMCACHED_NOTSTORED);
-  
-  memcached_deinit(memc);
 }
 
-void replace_test(void)
+void replace_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value= "when we sanitize";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
   rc= memcached_replace(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
   assert(rc == MEMCACHED_SUCCESS);
-  
-  memcached_deinit(memc);
 }
 
-void delete_test(void)
+void delete_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value= "when we sanitize";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
@@ -125,52 +90,34 @@ void delete_test(void)
 
   rc= memcached_delete(memc, key, strlen(key), (time_t)0);
   assert(rc == MEMCACHED_SUCCESS);
-  
-  memcached_deinit(memc);
 }
 
-void flush_test(void)
+void flush_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
   rc= memcached_flush(memc, 0);
   assert(rc == MEMCACHED_SUCCESS);
-
-  memcached_deinit(memc);
 }
 
-void get_test(void)
+void get_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *string;
   size_t string_length;
   uint16_t flags;
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-  
   string= memcached_get(memc, key, strlen(key),
                         &string_length, &flags, &rc);
 
   assert(rc == MEMCACHED_NOTFOUND);
   assert(string_length ==  0);
   assert(!string);
-
-  memcached_deinit(memc);
 }
 
-void get_test2(void)
+void get_test2(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value= "when we sanitize";
@@ -178,11 +125,6 @@ void get_test2(void)
   size_t string_length;
   uint16_t flags;
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
@@ -197,13 +139,52 @@ void get_test2(void)
   assert(!memcmp(string, value, string_length));
 
   free(string);
+}
+
+void set_test2(memcached_st *memc)
+{
+  memcached_return rc;
+  char *key= "foo";
+  char *value= "train in the brain";
+  size_t value_length= strlen(value);
+  unsigned int x;
 
-  memcached_deinit(memc);
+  for (x= 0; x < 10; x++)
+  {
+    rc= memcached_set(memc, key, strlen(key), 
+                      value, value_length,
+                      (time_t)0, (uint16_t)0);
+    assert(rc == MEMCACHED_SUCCESS);
+  }
 }
 
-void get_test3(void)
+void set_test3(memcached_st *memc)
+{
+  memcached_return rc;
+  char *key= "foo";
+  char *value;
+  size_t value_length= 8191;
+  unsigned int x;
+
+  value = (char*)malloc(value_length);
+  assert(value);
+
+  for (x= 0; x < value_length; x++)
+    value[x] = (char) (x % 127);
+
+  for (x= 0; x < 1; x++)
+  {
+    rc= memcached_set(memc, key, strlen(key), 
+                      value, value_length,
+                      (time_t)0, (uint16_t)0);
+    assert(rc == MEMCACHED_SUCCESS);
+  }
+
+  free(value);
+}
+
+void get_test3(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "foo";
   char *value;
@@ -211,16 +192,13 @@ void get_test3(void)
   char *string;
   size_t string_length;
   uint16_t flags;
-  int i;
+  int x;
 
-  value = (char*) malloc(value_length);
-  for (i=0; i<value_length; i++)
-    value[i] = (char) (i % 127);
+  value = (char*)malloc(value_length);
+  assert(value);
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
+  for (x= 0; x < value_length; x++)
+    value[x] = (char) (x % 127);
 
   rc= memcached_set(memc, key, strlen(key), 
                     value, value_length,
@@ -230,16 +208,53 @@ void get_test3(void)
   string= memcached_get(memc, key, strlen(key),
                         &string_length, &flags, &rc);
 
+  assert(rc == MEMCACHED_SUCCESS);
+  assert(string);
   assert(string_length == value_length);
   assert(!memcmp(string, value, string_length));
 
   free(string);
   free(value);
+}
 
-  memcached_deinit(memc);
+void get_test4(memcached_st *memc)
+{
+  memcached_return rc;
+  char *key= "foo";
+  char *value;
+  size_t value_length= 8191;
+  char *string;
+  size_t string_length;
+  uint16_t flags;
+  int x;
+
+  value = (char*)malloc(value_length);
+  assert(value);
+
+  for (x= 0; x < value_length; x++)
+    value[x] = (char) (x % 127);
+
+  rc= memcached_set(memc, key, strlen(key), 
+                    value, value_length,
+                    (time_t)0, (uint16_t)0);
+  assert(rc == MEMCACHED_SUCCESS);
+
+  for (x= 0; x < 10; x++)
+  {
+    string= memcached_get(memc, key, strlen(key),
+                          &string_length, &flags, &rc);
+
+    assert(rc == MEMCACHED_SUCCESS);
+    assert(string);
+    assert(string_length == value_length);
+    assert(!memcmp(string, value, string_length));
+    free(string);
+  }
+
+  free(value);
 }
 
-void stats_servername_test(void)
+void stats_servername_test(memcached_st *memc)
 {
   memcached_return rc;
   memcached_stat_st stat;
@@ -248,19 +263,13 @@ void stats_servername_test(void)
                                  MEMCACHED_DEFAULT_PORT);
 }
 
-void increment_test(void)
+void increment_test(memcached_st *memc)
 {
-  memcached_st *memc;
   unsigned int new_number;
   memcached_return rc;
   char *key= "number";
   char *value= "0";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
@@ -275,23 +284,15 @@ void increment_test(void)
                           1, &new_number);
   assert(rc == MEMCACHED_SUCCESS);
   assert(new_number == 2);
-
-  memcached_deinit(memc);
 }
 
-void decrement_test(void)
+void decrement_test(memcached_st *memc)
 {
-  memcached_st *memc;
   unsigned int new_number;
   memcached_return rc;
   char *key= "number";
   char *value= "3";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)0, (uint16_t)0);
@@ -306,22 +307,14 @@ void decrement_test(void)
                           1, &new_number);
   assert(rc == MEMCACHED_SUCCESS);
   assert(new_number == 1);
-
-  memcached_deinit(memc);
 }
 
-void quit_test(void)
+void quit_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *key= "fudge";
   char *value= "sanford and sun";
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-
   rc= memcached_set(memc, key, strlen(key), 
                     value, strlen(value),
                     (time_t)10, (uint16_t)3);
@@ -332,13 +325,10 @@ void quit_test(void)
                     value, strlen(value),
                     (time_t)50, (uint16_t)9);
   assert(rc == MEMCACHED_SUCCESS);
-  
-  memcached_deinit(memc);
 }
 
-void mget_test(void)
+void mget_test(memcached_st *memc)
 {
-  memcached_st *memc;
   memcached_return rc;
   char *keys[]= {"fudge", "son", "food"};
   size_t key_length[]= {5, 3, 4};
@@ -350,11 +340,6 @@ void mget_test(void)
   char *return_value;
   size_t return_value_length;
 
-  memc= memcached_init(NULL);
-  assert(memc);
-  rc= memcached_server_add(memc, "localhost", 0);
-  assert(rc == MEMCACHED_SUCCESS);
-
   /* We need to empty the server before continueing test */
   rc= memcached_flush(memc, 0);
   assert(rc == MEMCACHED_SUCCESS);
@@ -383,54 +368,41 @@ void mget_test(void)
   assert(rc == MEMCACHED_SUCCESS);
 
   x= 0;
-  while (return_value= memcached_fetch(memc, return_key, &return_key_length, 
-                      &return_value_length, &flags, &rc))
+  while ((return_value= memcached_fetch(memc, return_key, &return_key_length, 
+                                        &return_value_length, &flags, &rc)))
   {
     assert(return_value);
     assert(rc == MEMCACHED_SUCCESS);
-    assert(key_length[x] == return_value_length);
-    assert(!memcmp(return_value, keys[x], return_value_length));
+    assert(return_key_length == return_value_length);
+    assert(!memcmp(return_value, return_key, return_value_length));
     free(return_value);
     x++;
   }
-
-  memcached_deinit(memc);
 }
 
-void get_stats_keys(void)
+void get_stats_keys(memcached_st *memc)
 {
  char **list;
  char **ptr;
- memcached_st *memc;
  memcached_stat_st stat;
  memcached_return rc;
 
- memc= memcached_init(NULL);
- assert(memc);
-
  list= memcached_stat_get_keys(memc, &stat, &rc);
  assert(rc == MEMCACHED_SUCCESS);
  for (ptr= list; *ptr; ptr++)
    printf("Found key %s\n", *ptr);
 
  free(list);
- memcached_deinit(memc);
 }
 
-void get_stats(void)
+void get_stats(memcached_st *memc)
 {
  unsigned int x;
  char **list;
  char **ptr;
  memcached_return rc;
- memcached_st *memc;
  memcached_stat_st *stat;
 
- memc= memcached_init(NULL);
- assert(memc);
- rc= memcached_server_add(memc, "localhost", 0);
- assert(rc == MEMCACHED_SUCCESS);
-
  stat= memcached_stat(memc, NULL, &rc);
  assert(rc == MEMCACHED_SUCCESS);
 
@@ -448,79 +420,200 @@ void get_stats(void)
  }
 
  free(stat);
- memcached_deinit(memc);
 }
 
-void get_stats_multiple(void)
+void add_host_test(memcached_st *memc)
 {
- unsigned int x;
- char **list;
- char **ptr;
- memcached_return rc;
- memcached_st *memc;
- memcached_stat_st *stat;
+  unsigned int x;
+  memcached_server_st *servers;
+  memcached_return rc;
+  char servername[]= "0.example.com";
 
- memc= memcached_init(NULL);
- assert(memc);
- rc= memcached_server_add(memc, "localhost", 0);
- assert(rc == MEMCACHED_SUCCESS);
- rc= memcached_server_add(memc, "localhost", 5555);
- assert(rc == MEMCACHED_SUCCESS);
+  servers= memcached_server_list_append(NULL, servername, 400, &rc);
+  assert(servers);
+  assert(1 == memcached_server_list_count(servers));
 
- stat= memcached_stat(memc, NULL, &rc);
- assert(rc == MEMCACHED_SUCCESS);
+  for (x= 2; x < 20; x++)
+  {
+    char buffer[SMALL_STRING_LEN];
 
- assert(rc == MEMCACHED_SUCCESS);
- assert(stat);
+    snprintf(buffer, SMALL_STRING_LEN, "%u.example.com", 400+x);
+    servers= memcached_server_list_append(servers, buffer, 401, 
+                                     &rc);
+    assert(rc == MEMCACHED_SUCCESS);
+    assert(x == memcached_server_list_count(servers));
+  }
 
- for (x= 0; x < memcached_server_count(memc); x++)
- {
-   list= memcached_stat_get_keys(memc, &stat[x], &rc);
-   assert(rc == MEMCACHED_SUCCESS);
-   for (ptr= list; *ptr; ptr++)
-     printf("Found key %s\n", *ptr);
+  rc= memcached_server_push(memc, servers);
+  assert(rc == MEMCACHED_SUCCESS);
+  rc= memcached_server_push(memc, servers);
+  assert(rc == MEMCACHED_SUCCESS);
 
-   free(list);
- }
+  memcached_server_list_free(servers);
+}
 
- free(stat);
- memcached_deinit(memc);
+void add_host_test1(memcached_st *memc)
+{
+  unsigned int x;
+  memcached_return rc;
+  char servername[]= "0.example.com";
+  memcached_server_st *servers;
+
+  servers= memcached_server_list_append(NULL, servername, 400, &rc);
+  assert(servers);
+  assert(1 == memcached_server_list_count(servers));
+
+  for (x= 2; x < 20; x++)
+  {
+    char buffer[SMALL_STRING_LEN];
+
+    snprintf(buffer, SMALL_STRING_LEN, "%u.example.com", 400+x);
+    servers= memcached_server_list_append(servers, buffer, 401, 
+                                     &rc);
+    assert(rc == MEMCACHED_SUCCESS);
+    assert(x == memcached_server_list_count(servers));
+  }
+
+  rc= memcached_server_push(memc, servers);
+  assert(rc == MEMCACHED_SUCCESS);
+  rc= memcached_server_push(memc, servers);
+  assert(rc == MEMCACHED_SUCCESS);
+
+  memcached_server_list_free(servers);
 }
 
+typedef struct test_st test_st;
 
-int main(int argc, char argvp[])
+struct test_st {
+  char *function_name;
+  unsigned int requires_flush;
+  void (*function)(memcached_st *memc);
+};
+
+int main(int argc, char *argv[])
 {
+  unsigned int x;
+  char *server_list;
+  memcached_server_st *servers;
+
+  if (!(server_list= getenv("MEMCACHED_SERVERS")))
+    server_list= "localhost";
+
+  printf("servers %s\n", server_list);
+
+  servers= memcached_servers_parse(server_list);
+  assert(servers);
+
   /* Clean the server before beginning testing */
-  flush_test();
-  init_test();
-  allocation_test();
-  connection_test();
-  error_test();
-  set_test();
-  add_test();
-  replace_test();
-  flush_test();
-  delete_test();
-  flush_test();
-  get_test();
-  get_test2();
-  get_test3();
-  stats_servername_test();
-
-  increment_test();
-  decrement_test();
-  quit_test();
-  mget_test();
-  get_stats();
-
-  /* The multiple tests */
-  if (argc == 2)
+  test_st tests[] ={
+    {"flush", 0, flush_test },
+    {"init", 0, init_test },
+    {"allocation", 0, allocation_test },
+    {"error", 0, error_test },
+    {"set", 0, set_test },
+    {"set2", 0, set_test2 },
+    {"set3", 0, set_test3 },
+    {"add", 0, add_test },
+    {"replace", 0, replace_test },
+    {"delete", 1, delete_test },
+    {"get", 0, get_test },
+    {"get2", 0, get_test2 },
+    {"get3", 0, get_test3 },
+    {"get4", 0, get_test4 },
+    {"stats_servername", 0, stats_servername_test },
+    {"increment", 0, increment_test },
+    {"decrement", 0, decrement_test },
+    {"quit", 0, quit_test },
+    {"mget", 0, mget_test },
+    {"get_stats", 0, get_stats },
+    {"add_host_test", 0, add_host_test },
+    {"get_stats_keys", 0, get_stats_keys },
+    {0, 0, 0}
+  };
+
+  fprintf(stderr, "\nBlock tests\n\n");
+  for (x= 0; tests[x].function_name; x++)
   {
-    get_stats_multiple();
+    memcached_st *memc;
+    memcached_return rc;
+    memc= memcached_create(NULL);
+    assert(memc);
+
+    rc= memcached_server_push(memc, servers);
+    assert(rc == MEMCACHED_SUCCESS);
+
+    fprintf(stderr, "Testing %s", tests[x].function_name);
+    tests[x].function(memc);
+    fprintf(stderr, "\t\t\t\t\t[ ok ]\n");
+    assert(memc);
+    memcached_free(memc);
+  }
+
+  fprintf(stderr, "\nNonblock tests\n\n");
+  for (x= 0; tests[x].function_name; x++)
+  {
+    memcached_st *memc;
+    memcached_return rc;
+    memc= memcached_create(NULL);
+    assert(memc);
+
+    rc= memcached_server_push(memc, servers);
+    assert(rc == MEMCACHED_SUCCESS);
+
+    fprintf(stderr, "Testing %s", tests[x].function_name);
+    memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
+    tests[x].function(memc);
+    fprintf(stderr, "\t\t\t\t\t[ ok ]\n");
+    assert(memc);
+    memcached_free(memc);
+  }
+
+  fprintf(stderr, "\nTCP Nodelay tests\n\n");
+  for (x= 0; tests[x].function_name; x++)
+  {
+    memcached_st *memc;
+    memcached_return rc;
+    memc= memcached_create(NULL);
+    assert(memc);
+
+    rc= memcached_server_push(memc, servers);
+    assert(rc == MEMCACHED_SUCCESS);
+
+    fprintf(stderr, "Testing %s", tests[x].function_name);
+    memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_NO_BLOCK, NULL);
+    memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_TCP_NODELAY, NULL);
+    tests[x].function(memc);
+    fprintf(stderr, "\t\t\t\t\t[ ok ]\n");
+    assert(memc);
+    memcached_free(memc);
+  }
+
+  fprintf(stderr, "\nMD5 Hashing\n\n");
+  for (x= 0; tests[x].function_name; x++)
+  {
+    memcached_st *memc;
+    memcached_return rc;
+    memc= memcached_create(NULL);
+    assert(memc);
+
+    rc= memcached_server_push(memc, servers);
+    assert(rc == MEMCACHED_SUCCESS);
+
+    fprintf(stderr, "Testing %s", tests[x].function_name);
+    memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_MD5_HASHING, NULL);
+    tests[x].function(memc);
+    fprintf(stderr, "\t\t\t\t\t[ ok ]\n");
+    assert(memc);
+    memcached_free(memc);
   }
-  get_stats_keys();
 
   /* Clean up whatever we might have left */
-  flush_test();
+  {
+    memcached_st *memc;
+    memc= memcached_create(NULL);
+    assert(memc);
+    flush_test(memc);
+    memcached_free(memc);
+  }
   return 0;
 }