Updated comments in code.
authorBrian Aker <brian@gaz>
Sun, 10 Jan 2010 06:11:32 +0000 (22:11 -0800)
committerBrian Aker <brian@gaz>
Sun, 10 Jan 2010 06:11:32 +0000 (22:11 -0800)
libmemcached/hosts.c
libmemcached/memcached.h

index e81807205d9ada5372e2154cc589e5004baf992f..683b08435681855398e8a1a9d7bf1e24ac276fdf 100644 (file)
@@ -129,7 +129,9 @@ static memcached_return_t update_continuum(memcached_st *ptr)
     }
   }
   else
+  {
     live_servers= memcached_server_count(ptr);
+  }
 
   is_ketama_weighted= memcached_behavior_get(ptr, MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED);
   points_per_server= (uint32_t) (is_ketama_weighted ? MEMCACHED_POINTS_PER_SERVER_KETAMA : MEMCACHED_POINTS_PER_SERVER);
index d67a213706f28a11ca8b7c96482a4c7071de123f..9244057945bbf899407e89a4e2e0cdb274f2a6e7 100644 (file)
@@ -52,7 +52,7 @@ struct memcached_st {
   } options;
   memcached_server_distribution_t distribution;
   memcached_hash_t hash;
-  uint32_t continuum_points_counter;
+  uint32_t continuum_points_counter; // Ketama
   memcached_server_st *hosts;
   memcached_server_st *last_disconnected_server;
   int32_t snd_timeout;
@@ -83,16 +83,16 @@ struct memcached_st {
   int32_t poll_timeout;
   int32_t connect_timeout;
   int32_t retry_timeout;
-  uint32_t continuum_count;
+  uint32_t continuum_count; // Ketama
   int send_size;
   int recv_size;
   void *user_data;
-  time_t next_distribution_rebuild;
+  time_t next_distribution_rebuild; // Ketama
   size_t prefix_key_length;
   uint32_t number_of_replicas;
   memcached_hash_t distribution_hash;
   memcached_result_st result;
-  memcached_continuum_item_st *continuum;
+  memcached_continuum_item_st *continuum; // Ketama
   memcached_clone_fn on_clone;
   memcached_cleanup_fn on_cleanup;
   memcached_free_fn call_free;