X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.c;h=40f8e263e7f7f478d579de9a8e74ff26503e2fbe;hb=7577cb0a57aa70d9857d42c381f13c7cb60d0056;hp=33a80bab29693982e49ae0210b3fc08f18694095;hpb=26aff973ea8db6495862e66cb287e9c000103c9e;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached.c b/libmemcached/memcached.c index 33a80bab..40f8e263 100644 --- a/libmemcached/memcached.c +++ b/libmemcached/memcached.c @@ -41,6 +41,14 @@ void memcached_free(memcached_st *ptr) if (ptr->on_cleanup) ptr->on_cleanup(ptr); + if (ptr->continuum) + { + if (ptr->call_free) + ptr->call_free(ptr, ptr->continuum); + else + free(ptr->continuum); + } + if (ptr->is_allocated == MEMCACHED_ALLOCATED) { if (ptr->call_free) @@ -95,8 +103,12 @@ memcached_st *memcached_clone(memcached_st *clone, memcached_st *ptr) new_clone->retry_timeout= ptr->retry_timeout; new_clone->distribution= ptr->distribution; new_clone->hash= ptr->hash; + new_clone->hash_continuum= ptr->hash_continuum; new_clone->user_data= ptr->user_data; + new_clone->snd_timeout= ptr->snd_timeout; + new_clone->rcv_timeout= ptr->rcv_timeout; + new_clone->on_clone= ptr->on_clone; new_clone->on_cleanup= ptr->on_cleanup; new_clone->call_free= ptr->call_free; @@ -105,6 +117,20 @@ memcached_st *memcached_clone(memcached_st *clone, memcached_st *ptr) new_clone->get_key_failure= ptr->get_key_failure; new_clone->delete_trigger= ptr->delete_trigger; + if (ptr->prefix_key[0] != 0) + { + strcpy(new_clone->prefix_key, ptr->prefix_key); + new_clone->prefix_key_length= ptr->prefix_key_length; + } + + rc= run_distribution(new_clone); + if (rc != MEMCACHED_SUCCESS) + { + memcached_free(new_clone); + + return NULL; + } + if (ptr->on_clone) ptr->on_clone(ptr, new_clone);