X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=lib%2Fmemcached_connect.c;h=105e7d20d82074f89f5689c854249376e6040f92;hb=a081ca36c7fbf7c73e2a61d4f3c06ab0eff0571e;hp=1be786e1c6149d4480fdef280ee2d115ec774285;hpb=1fc4b1ae18810551553837b4c67c6075f1ad5941;p=m6w6%2Flibmemcached diff --git a/lib/memcached_connect.c b/lib/memcached_connect.c index 1be786e1..105e7d20 100644 --- a/lib/memcached_connect.c +++ b/lib/memcached_connect.c @@ -2,6 +2,9 @@ memcached_return memcached_server_add(memcached_st *ptr, char *hostname, unsigned int port) { + memcached_host_st *new_host_list; + char *new_hostname; + if (!port) port= MEMCACHED_DEFAULT_PORT; @@ -9,10 +12,24 @@ memcached_return memcached_server_add(memcached_st *ptr, char *hostname, unsigne hostname= "localhost"; - ptr->hosts= (memcached_host_st *)realloc(ptr->hosts, sizeof(memcached_host_st) * (size_t)ptr->number_of_hosts); - ptr->hosts[ptr->number_of_hosts].hostname= - (char *)malloc(sizeof(char) * strlen(hostname)); - memcpy(ptr->hosts[ptr->number_of_hosts].hostname, hostname, strlen(hostname)); + new_host_list= (memcached_host_st *)realloc(ptr->hosts, sizeof(memcached_host_st) * (ptr->number_of_hosts+1)); + if (!new_host_list) + return MEMCACHED_MEMORY_ALLOCATION_FAILURE; + memset(&new_host_list[ptr->number_of_hosts], 0, sizeof(memcached_host_st)); + + if (!new_host_list) + return MEMCACHED_MEMORY_ALLOCATION_FAILURE; + + ptr->hosts= new_host_list; + + new_hostname= + (char *)malloc(sizeof(char) * (strlen(hostname)+1)); + if (!new_hostname) + return MEMCACHED_MEMORY_ALLOCATION_FAILURE; + + memset(new_hostname, 0, strlen(hostname)+1); + memcpy(new_hostname, hostname, strlen(hostname)); + ptr->hosts[ptr->number_of_hosts].hostname= new_hostname; ptr->hosts[ptr->number_of_hosts].port= port; ptr->hosts[ptr->number_of_hosts].fd= -1; ptr->number_of_hosts++; @@ -25,7 +42,6 @@ memcached_return memcached_connect(memcached_st *ptr) unsigned int x; struct sockaddr_in localAddr, servAddr; struct hostent *h; - memcached_host_st *host_ptr; if (ptr->connected) return MEMCACHED_SUCCESS; @@ -43,10 +59,7 @@ memcached_return memcached_connect(memcached_st *ptr) for (x= 0; x < ptr->number_of_hosts; x++) { if ((h= gethostbyname(ptr->hosts[x].hostname)) == NULL) - { - fprintf(stderr, "unknown host '%s'\n", ptr->hosts[x].hostname); return MEMCACHED_HOST_LOCKUP_FAILURE; - } servAddr.sin_family= h->h_addrtype; memcpy((char *) &servAddr.sin_addr.s_addr, h->h_addr_list[0], h->h_length); @@ -54,10 +67,7 @@ memcached_return memcached_connect(memcached_st *ptr) /* Create the socket */ if ((ptr->hosts[0].fd= socket(AF_INET, SOCK_STREAM, 0)) < 0) - { - fprintf(stderr, "cannot open socket"); return MEMCACHED_CONNECTION_SOCKET_CREATE_FAILURE; - } /* bind any port number */ @@ -66,19 +76,11 @@ memcached_return memcached_connect(memcached_st *ptr) localAddr.sin_port = htons(0); if (bind(ptr->hosts[0].fd, (struct sockaddr *) &localAddr, sizeof(localAddr)) < 0) - { - fprintf(stderr, "cannot bind port TCP %u\n", ptr->hosts[x].port); return(MEMCACHED_CONNECTION_BIND_FAILURE); - } /* connect to server */ if (connect(ptr->hosts[0].fd, (struct sockaddr *) &servAddr, sizeof(servAddr)) < 0) - { - fprintf(stderr, "cannot connect to host '%s' (%u) (error: %s)\n", ptr->hosts[x].hostname, - ptr->hosts[x].port, - strerror(errno)); return MEMCACHED_HOST_LOCKUP_FAILURE; - } } ptr->connected= 1;