#include <ctime>
#include <sys/types.h>
-static bool __is_ketama(memcached_st *ptr)
+bool memcached_is_consistent_distribution(const memcached_st* memc)
{
- switch (ptr->distribution)
+ switch (memc->distribution)
{
case MEMCACHED_DISTRIBUTION_CONSISTENT:
case MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA:
return ptr->flags.verify_key;
case MEMCACHED_BEHAVIOR_KETAMA_WEIGHTED:
- if (__is_ketama(ptr))
+ if (memcached_is_consistent_distribution(ptr))
{
- return ptr->ketama.weighted;
+ return memcached_is_weighted_ketama(ptr);
}
return false;
return ptr->distribution;
case MEMCACHED_BEHAVIOR_KETAMA:
- return __is_ketama(ptr);
+ return memcached_is_consistent_distribution(ptr);
case MEMCACHED_BEHAVIOR_HASH:
return hashkit_get_function(&ptr->hashkit);
case MEMCACHED_DISTRIBUTION_CONSISTENT:
case MEMCACHED_DISTRIBUTION_CONSISTENT_KETAMA:
- ptr->ketama.weighted= false;
+ memcached_set_weighted_ketama(ptr, false);
break;
case MEMCACHED_DISTRIBUTION_RANDOM:
break;
case MEMCACHED_DISTRIBUTION_CONSISTENT_WEIGHTED:
- ptr->ketama.weighted= true;
+ memcached_set_weighted_ketama(ptr, true);
break;
case MEMCACHED_DISTRIBUTION_VIRTUAL_BUCKET: