X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.c;h=329e170dacc174679ad92e5b8dad0157d7a5ec92;hb=7c986323bd4eece0d805f4df17eb03ea094f84f6;hp=a363c2498351435a0f639911e35478144f5a211f;hpb=b4de8d3fd063b9017797dd9809ab3acb8a537606;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached.c b/libmemcached/memcached.c index a363c249..329e170d 100644 --- a/libmemcached/memcached.c +++ b/libmemcached/memcached.c @@ -5,8 +5,6 @@ memcached_st *memcached_create(memcached_st *ptr) { - memcached_result_st *result_ptr; - if (ptr == NULL) { ptr= (memcached_st *)calloc(1, sizeof(memcached_st)); @@ -27,8 +25,11 @@ memcached_st *memcached_create(memcached_st *ptr) memcached_set_memory_allocators(ptr, NULL, NULL, NULL, NULL); - result_ptr= memcached_result_create(ptr, &ptr->result); - WATCHPOINT_ASSERT(result_ptr); + if (! memcached_result_create(ptr, &ptr->result)) + { + memcached_free(ptr); + return NULL; + } ptr->poll_timeout= MEMCACHED_DEFAULT_TIMEOUT; ptr->connect_timeout= MEMCACHED_DEFAULT_TIMEOUT; ptr->retry_timeout= 0; @@ -39,7 +40,6 @@ memcached_st *memcached_create(memcached_st *ptr) ptr->io_bytes_watermark= 65 * 1024; WATCHPOINT_ASSERT_INITIALIZED(&ptr->result); - WATCHPOINT_ASSERT_INITIALIZED(&ptr->hashkit); return ptr; } @@ -98,7 +98,7 @@ memcached_st *memcached_clone(memcached_st *clone, memcached_st *source) new_clone->retry_timeout= source->retry_timeout; new_clone->distribution= source->distribution; new_clone->hash= source->hash; - new_clone->hash_continuum= source->hash_continuum; + new_clone->distribution_hash= source->distribution_hash; new_clone->user_data= source->user_data; new_clone->snd_timeout= source->snd_timeout; @@ -136,6 +136,7 @@ memcached_st *memcached_clone(memcached_st *clone, memcached_st *source) } rc= run_distribution(new_clone); + if (rc != MEMCACHED_SUCCESS) { memcached_free(new_clone); @@ -148,6 +149,7 @@ memcached_st *memcached_clone(memcached_st *clone, memcached_st *source) return new_clone; } + void *memcached_get_user_data(memcached_st *ptr) { return ptr->user_data; @@ -157,5 +159,6 @@ void *memcached_set_user_data(memcached_st *ptr, void *data) { void *ret= ptr->user_data; ptr->user_data= data; + return ret; }