X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fconnect.c;h=f3832faed079d8b771ee18e61b1237b7a8283c5e;hb=77688f0ea4e99869438e0e639d19881aee14d5dd;hp=b599977fab77ab4799297b1dcb5a9e1197c17f54;hpb=a4456cc10079f2e6f648befc91657f2723c825e5;p=m6w6%2Flibmemcached diff --git a/libmemcached/connect.c b/libmemcached/connect.c index b599977f..f3832fae 100644 --- a/libmemcached/connect.c +++ b/libmemcached/connect.c @@ -282,6 +282,20 @@ static memcached_return_t network_connect(memcached_server_st *ptr) } } +#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT + if (ptr->fd != -1 && ptr->root->sasl.callbacks != NULL) + { + memcached_return rc= memcached_sasl_authenticate_connection(ptr); + if (rc != MEMCACHED_SUCCESS) + { + (void)close(ptr->fd); + ptr->fd= -1; + return rc; + } + } +#endif + + if (ptr->fd != -1) { ptr->server_failure_counter= 0; @@ -313,7 +327,7 @@ static memcached_return_t network_connect(memcached_server_st *ptr) } -memcached_return_t memcached_connect(memcached_server_st *ptr) +memcached_return_t memcached_connect(memcached_server_write_instance_st ptr) { memcached_return_t rc= MEMCACHED_NO_SERVERS; LIBMEMCACHED_MEMCACHED_CONNECT_START(); @@ -368,7 +382,7 @@ memcached_return_t memcached_connect(memcached_server_st *ptr) WATCHPOINT_ASSERT(0); } - unlikely ( rc != MEMCACHED_SUCCESS) + unlikely ( rc != MEMCACHED_SUCCESS) { //@todo create interface around last_discontected_server memcached_st *root= (memcached_st *)ptr->root;