X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached_server.c;h=b7dd8a94700eb309b8d54dcbf385ea2b5ec8b722;hb=a7cf02c028bde895f4e49b176443578956001060;hp=87f2ddc9c70fb9042d20795927d013ed65b3a070;hpb=27bc5952905705b7113b338c9d805825dab3075c;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached_server.c b/libmemcached/memcached_server.c index 87f2ddc9..b7dd8a94 100644 --- a/libmemcached/memcached_server.c +++ b/libmemcached/memcached_server.c @@ -13,12 +13,10 @@ memcached_server_st *memcached_server_create(memcached_st *memc, memcached_serve return NULL; /* MEMCACHED_MEMORY_ALLOCATION_FAILURE */ memset(ptr, 0, sizeof(memcached_server_st)); - ptr->is_allocated= MEMCACHED_ALLOCATED; + ptr->is_allocated= true; } else - { memset(ptr, 0, sizeof(memcached_server_st)); - } ptr->root= memc; @@ -34,7 +32,6 @@ memcached_server_st *memcached_server_create_with(memcached_st *memc, memcached_ if (host == NULL) return NULL; - memset(host, 0, sizeof(memcached_server_st)); strncpy(host->hostname, hostname, MEMCACHED_MAX_HOST_LENGTH - 1); host->root= memc ? memc : NULL; host->port= port; @@ -44,15 +41,12 @@ memcached_server_st *memcached_server_create_with(memcached_st *memc, memcached_ host->read_ptr= host->read_buffer; if (memc) host->next_retry= memc->retry_timeout; - host->sockaddr_inited= MEMCACHED_NOT_ALLOCATED; return host; } void memcached_server_free(memcached_server_st *ptr) { - WATCHPOINT_ASSERT(ptr->is_allocated != MEMCACHED_NOT_ALLOCATED); - memcached_quit_server(ptr, 0); if (ptr->address_info) @@ -61,7 +55,7 @@ void memcached_server_free(memcached_server_st *ptr) ptr->address_info= NULL; } - if (ptr->is_allocated == MEMCACHED_ALLOCATED) + if (ptr->is_allocated) { if (ptr->root && ptr->root->call_free) ptr->root->call_free(ptr->root, ptr); @@ -69,7 +63,7 @@ void memcached_server_free(memcached_server_st *ptr) free(ptr); } else - ptr->is_allocated= MEMCACHED_USED; + memset(ptr, 0, sizeof(memcached_server_st)); } /* @@ -77,31 +71,14 @@ void memcached_server_free(memcached_server_st *ptr) */ memcached_server_st *memcached_server_clone(memcached_server_st *clone, memcached_server_st *ptr) { - memcached_server_st *new_clone; - /* We just do a normal create if ptr is missing */ if (ptr == NULL) return NULL; - if (clone && clone->is_allocated == MEMCACHED_USED) - { - WATCHPOINT_ASSERT(0); - return NULL; - } - - new_clone= memcached_server_create(ptr->root, clone); - - if (new_clone == NULL) - return NULL; - - new_clone->root= ptr->root; - /* TODO We should check return type */ - memcached_server_create_with(new_clone->root, new_clone, - ptr->hostname, ptr->port, ptr->weight, - ptr->type); - - return new_clone; + return memcached_server_create_with(ptr->root, clone, + ptr->hostname, ptr->port, ptr->weight, + ptr->type); } memcached_return memcached_server_cursor(memcached_st *ptr, @@ -133,11 +110,10 @@ memcached_server_st *memcached_server_by_key(memcached_st *ptr, const char *key { uint32_t server_key; - unlikely (key_length == 0) - { - *error= MEMCACHED_NO_KEY_PROVIDED; + *error= memcached_validate_key_length(key_length, + ptr->flags & MEM_BINARY_PROTOCOL); + unlikely (*error != MEMCACHED_SUCCESS) return NULL; - } unlikely (ptr->number_of_hosts == 0) {