memcached_behavior() causes commands to be buffered until they are flushed to
[awesomized/libmemcached] / tests / function.c
index 54bbceaabc409d355841f034d631834aa92e9bd7..46005ce7988022e3c81ae5d4b0225cae647d25ac 100644 (file)
@@ -1686,6 +1686,17 @@ uint8_t generate_data(memcached_st *memc)
   return 0;
 }
 
+uint8_t generate_buffer_data(memcached_st *memc)
+{
+  int latch= 0;
+
+  latch= 1;
+  memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_BUFFER_REQUESTS, &latch);
+  generate_data(memc);
+
+  return 0;
+}
+
 #ifdef NOT_DONE
 uint8_t mset_data(memcached_st *memc)
 {
@@ -1809,6 +1820,22 @@ uint8_t delete_generate(memcached_st *memc)
   return 0;
 }
 
+uint8_t delete_buffer_generate(memcached_st *memc)
+{
+  int latch= 0;
+  unsigned int x;
+
+  latch= 1;
+  memcached_behavior_set(memc, MEMCACHED_BEHAVIOR_BUFFER_REQUESTS, &latch);
+
+  for (x= 0; x < GLOBAL_COUNT; x++)
+  {
+    (void)memcached_delete(memc, global_keys[x], global_keys_length[x], (time_t)0);
+  }
+
+  return 0;
+}
+
 uint8_t mdelete_generate(memcached_st *memc)
 {
   memcached_return rc;
@@ -2115,6 +2142,8 @@ test_st generate_tests[] ={
   {"generate_data", 0, generate_data },
   {"get_read", 0, get_read },
   {"delete_generate", 0, delete_generate },
+  {"generate_buffer_data", 0, generate_buffer_data },
+  {"delete_buffer", 0, delete_buffer_generate},
   {"generate_data", 0, generate_data },
   {"mget_read", 0, mget_read },
   {"mget_read_result", 0, mget_read_result },