X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fhosts.c;h=992bd763d0b98e1afe59aa32f9d88740e840a897;hb=8ddd817cd74d85db3f945920fb02f4cc4daa8050;hp=ec12c92f9813e048d9aacf887611945b7497f7ce;hpb=44bc9cfbcf0794de92da28d9aaaa46d62945ce4e;p=awesomized%2Flibmemcached diff --git a/libmemcached/hosts.c b/libmemcached/hosts.c index ec12c92f..992bd763 100644 --- a/libmemcached/hosts.c +++ b/libmemcached/hosts.c @@ -17,6 +17,7 @@ static memcached_return_t server_add(memcached_st *ptr, const char *hostname, in_port_t port, uint32_t weight, memcached_connection_t type); + static memcached_return_t update_continuum(memcached_st *ptr); static int compare_servers(const void *p1, const void *p2) @@ -337,7 +338,9 @@ memcached_return_t memcached_server_push(memcached_st *ptr, const memcached_serv if ((ptr->flags.use_udp && list[x].type != MEMCACHED_CONNECTION_UDP) || ((list[x].type == MEMCACHED_CONNECTION_UDP) && ! (ptr->flags.use_udp)) ) + { return MEMCACHED_INVALID_HOST_PROTOCOL; + } WATCHPOINT_ASSERT(list[x].hostname[0] != 0); @@ -447,3 +450,20 @@ static memcached_return_t server_add(memcached_st *ptr, const char *hostname, return run_distribution(ptr); } + +memcached_return_t memcached_server_add_parsed(memcached_st *ptr, + const char *hostname, + size_t hostname_length, + in_port_t port, + uint32_t weight) +{ + char buffer[NI_MAXHOST]; + + memcpy(buffer, hostname, hostname_length); + buffer[hostname_length]= 0; + + return server_add(ptr, buffer, + port, + weight, + MEMCACHED_CONNECTION_TCP); +}