X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.c;h=b0333569ec7fe8f45fe943a16d210b8d70eb502c;hb=10f3d6bf1bc11c235779ae735f30758cfb035686;hp=0c38cc69f61ce637a2a99e62bdec622d71a371c9;hpb=26c65ac524f21cd73a79f3caf45cdb76c9a41bc0;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached.c b/libmemcached/memcached.c index 0c38cc69..b0333569 100644 --- a/libmemcached/memcached.c +++ b/libmemcached/memcached.c @@ -15,6 +15,7 @@ static const memcached_st global_copy= { .state= { .is_purging= false, .is_processing_input= false, + .is_time_for_rebuild= false, }, .flags= { .auto_eject_hosts= false, @@ -33,7 +34,9 @@ static const memcached_st global_copy= { .use_sort_hosts= false, .use_udp= false, .verify_key= false, - .tcp_keepalive= false + .tcp_keepalive= false, + .load_from_file= false + } }; @@ -68,7 +71,7 @@ static inline bool _memcached_init(memcached_st *self) self->io_key_prefetch= 0; self->cached_errno= 0; self->poll_timeout= MEMCACHED_DEFAULT_TIMEOUT; - self->connect_timeout= MEMCACHED_DEFAULT_TIMEOUT; + self->connect_timeout= MEMCACHED_DEFAULT_CONNECT_TIMEOUT; self->retry_timeout= 0; self->continuum_count= 0; @@ -91,10 +94,8 @@ static inline bool _memcached_init(memcached_st *self) self->get_key_failure= NULL; self->delete_trigger= NULL; self->callbacks= NULL; -#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT self->sasl.callbacks= NULL; self->sasl.is_allocated= false; -#endif return true; } @@ -145,10 +146,23 @@ void memcached_servers_reset(memcached_st *ptr) memcached_server_list_set(ptr, NULL); ptr->number_of_hosts= 0; + if (ptr->last_disconnected_server) + { + memcached_server_free(ptr->last_disconnected_server); + } ptr->last_disconnected_server= NULL; ptr->server_failure_limit= 0; } +void memcached_reset_last_disconnected_server(memcached_st *ptr) +{ + if (ptr->last_disconnected_server) + { + memcached_server_free(ptr->last_disconnected_server); + ptr->last_disconnected_server= NULL; + } +} + void memcached_free(memcached_st *ptr) { /* If we have anything open, lets close it now */ @@ -156,18 +170,21 @@ void memcached_free(memcached_st *ptr) memcached_server_list_free(memcached_server_list(ptr)); memcached_result_free(&ptr->result); + if (ptr->last_disconnected_server) + memcached_server_free(ptr->last_disconnected_server); + if (ptr->on_cleanup) ptr->on_cleanup(ptr); if (ptr->continuum) libmemcached_free(ptr, ptr->continuum); -#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT - if (ptr->sasl.callbacks != NULL) + if (ptr->sasl.callbacks) { +#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT memcached_destroy_sasl_auth_data(ptr); - } #endif + } if (memcached_is_allocated(ptr)) {