X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached_server.c;h=2ecbe214d9fb416f60b9fca98290bb70ee37977f;hb=a7a011c2ea4a63368b3a96a332da00820ed402cb;hp=11e5988a6f7b57f7161a4753da0e3bc70e224b57;hpb=c3dd2b1a405b440095f45b6f5ad8b4d4fd0d83a2;p=m6w6%2Flibmemcached diff --git a/libmemcached/memcached_server.c b/libmemcached/memcached_server.c index 11e5988a..2ecbe214 100644 --- a/libmemcached/memcached_server.c +++ b/libmemcached/memcached_server.c @@ -16,14 +16,14 @@ memcached_server_st *memcached_server_create(memcached_st *memc, memcached_serve } else memset(ptr, 0, sizeof(memcached_server_st)); - + ptr->root= memc; return ptr; } -memcached_server_st *memcached_server_create_with(memcached_st *memc, memcached_server_st *host, - const char *hostname, unsigned int port, +memcached_server_st *memcached_server_create_with(memcached_st *memc, memcached_server_st *host, + const char *hostname, unsigned int port, uint32_t weight, memcached_connection type) { host= memcached_server_create(memc, host); @@ -53,11 +53,11 @@ void memcached_server_free(memcached_server_st *ptr) { memcached_quit_server(ptr, 0); + if (ptr->cached_server_error) + free(ptr->cached_server_error); + if (ptr->address_info) - { freeaddrinfo(ptr->address_info); - ptr->address_info= NULL; - } if (ptr->is_allocated) ptr->root->call_free(ptr->root, ptr); @@ -70,17 +70,27 @@ 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 *rv= NULL; + /* We just do a normal create if ptr is missing */ if (ptr == NULL) return NULL; - /* TODO We should check return type */ - return memcached_server_create_with(ptr->root, clone, - ptr->hostname, ptr->port, ptr->weight, - ptr->type); + rv = memcached_server_create_with(ptr->root, clone, + ptr->hostname, ptr->port, ptr->weight, + ptr->type); + if (rv != NULL) + { + rv->cached_errno= ptr->cached_errno; + if (ptr->cached_server_error) + rv->cached_server_error= strdup(ptr->cached_server_error); + } + + return rv; + } -memcached_return memcached_server_cursor(memcached_st *ptr, +memcached_return memcached_server_cursor(memcached_st *ptr, memcached_server_function *callback, void *context, unsigned int number_of_callbacks) @@ -109,7 +119,7 @@ memcached_server_st *memcached_server_by_key(memcached_st *ptr, const char *key { uint32_t server_key; - *error= memcached_validate_key_length(key_length, + *error= memcached_validate_key_length(key_length, ptr->flags & MEM_BINARY_PROTOCOL); unlikely (*error != MEMCACHED_SUCCESS) return NULL; @@ -131,3 +141,21 @@ memcached_server_st *memcached_server_by_key(memcached_st *ptr, const char *key return memcached_server_clone(NULL, &ptr->hosts[server_key]); } + +const char *memcached_server_error(memcached_server_st *ptr) +{ + if (ptr) + return ptr->cached_server_error; + else + return NULL; +} + +void memcached_server_error_reset(memcached_server_st *ptr) +{ + ptr->cached_server_error[0]= 0; +} + +memcached_server_st *memcached_server_get_last_disconnect(memcached_st *ptr) +{ + return ptr->last_disconnected_server; +}