X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached_connect.c;h=2b392fb6138528361abb5836f9e3d628fcface76;hb=1af835409ff66c8a2860d2d95aa72d7a7a817358;hp=f2549dc75157877fb23a8e79244a7e2b465298e4;hpb=b34c702fa781b33f8a1f7751385929122c3e6bae;p=m6w6%2Flibmemcached diff --git a/libmemcached/memcached_connect.c b/libmemcached/memcached_connect.c index f2549dc7..2b392fb6 100644 --- a/libmemcached/memcached_connect.c +++ b/libmemcached/memcached_connect.c @@ -1,4 +1,5 @@ #include "common.h" +#include #include #include @@ -13,7 +14,7 @@ static memcached_return set_hostinfo(memcached_server_st *server) memset(&hints, 0, sizeof(hints)); - hints.ai_family= AF_INET; + // hints.ai_family= AF_INET; if (server->type == MEMCACHED_CONNECTION_UDP) { hints.ai_protocol= IPPROTO_UDP; @@ -34,7 +35,10 @@ static memcached_return set_hostinfo(memcached_server_st *server) } if (server->address_info) + { freeaddrinfo(server->address_info); + server->address_info= NULL; + } server->address_info= ai; return MEMCACHED_SUCCESS; @@ -172,9 +176,12 @@ static memcached_return network_connect(memcached_server_st *ptr) { struct addrinfo *use; - if(ptr->root->server_failure_limit != 0) { - if(ptr->server_failure_counter >= ptr->root->server_failure_limit) { - server_remove(ptr); + if (ptr->root->server_failure_limit != 0) + { + if (ptr->server_failure_counter >= ptr->root->server_failure_limit) + { + memcached_server_remove(ptr); + return MEMCACHED_FAILURE; } } /* Old connection junk still is in the structure */ @@ -242,13 +249,13 @@ test_connect: ptr->address_info= NULL; } - if (ptr->root->retry_timeout) - { - struct timeval next_time; + if (ptr->root->retry_timeout) + { + struct timeval next_time; - gettimeofday(&next_time, NULL); - ptr->next_retry= next_time.tv_sec + ptr->root->retry_timeout; - } + gettimeofday(&next_time, NULL); + ptr->next_retry= next_time.tv_sec + ptr->root->retry_timeout; + } ptr->server_failure_counter+= 1; return MEMCACHED_ERRNO; }