X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fhosts.c;h=c861a6d9361ede3ff48c7aa5bc3cfccaaa321f9c;hb=d9752c25d2f723d27e355d0c7090b65b0445c4a4;hp=ec12c92f9813e048d9aacf887611945b7497f7ce;hpb=b175c6025c67cb8fa756750d53fb96fd888076de;p=m6w6%2Flibmemcached diff --git a/libmemcached/hosts.c b/libmemcached/hosts.c index ec12c92f..c861a6d9 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) @@ -92,9 +93,9 @@ static int continuum_item_cmp(const void *t1, const void *t2) /* Why 153? Hmmm... */ WATCHPOINT_ASSERT(ct1->value != 153); if (ct1->value == ct2->value) - return 0; + return EXIT_SUCCESS; else if (ct1->value > ct2->value) - return 1; + return EXIT_FAILURE; else return -1; } @@ -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); +}