X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=lib%2Fmemcached_hash.c;h=9906f5d9be30f5dcd6dde919f36497bbd58b59b3;hb=acca3c7ad60716bf073ae8de0652517542cdd224;hp=33c1055bbfd70ffd60aa1e902739367136b08705;hpb=131622cdc2710ecd9ad554ce7d08c6003fbdcf6e;p=m6w6%2Flibmemcached diff --git a/lib/memcached_hash.c b/lib/memcached_hash.c index 33c1055b..9906f5d9 100644 --- a/lib/memcached_hash.c +++ b/lib/memcached_hash.c @@ -29,6 +29,8 @@ unsigned int memcached_generate_hash(memcached_st *ptr, char *key, size_t key_le break; case MEMCACHED_HASH_CRC: hash= ((hash_crc32(key, key_length) >> 16) & 0x7fff); + if (hash == 0) + hash= 1; break; /* FNV hash'es lifted from Dustin Sallings work */ case MEMCACHED_HASH_FNV1_64: @@ -77,16 +79,27 @@ unsigned int memcached_generate_hash(memcached_st *ptr, char *key, size_t key_le hash= internal_generate_ketama_md5(key, key_length); break; } + case MEMCACHED_HASH_HSIEH: + { + hash= hsieh_hash(key, key_length); + break; + } } WATCHPOINT_ASSERT(hash); - if (ptr->flags & MEM_USE_KETAMA) + + if (ptr->distribution == MEMCACHED_DISTRIBUTION_MODULA) { - WATCHPOINT_ASSERT(0); - return 0; + return hash % ptr->number_of_hosts; } else - return hash % ptr->number_of_hosts; + { + unsigned int server_key; + + server_key= hash % MEMCACHED_WHEEL_SIZE; + + return ptr->wheel[server_key]; + } } static uint64_t internal_generate_hash(char *key, size_t key_length)