X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fmemcached.c;h=3a4e4c4a78d8edc6c1a18020e7b388d469f67c95;hb=f0d3a824ed9acb9f6e3080683abe2bcc8b0cd6bd;hp=81895afab67b19102b9e4418ee1890663cf4128c;hpb=4209d822c35fea2ca1c5879e18bc6c063dba4c41;p=awesomized%2Flibmemcached diff --git a/libmemcached/memcached.c b/libmemcached/memcached.c index 81895afa..3a4e4c4a 100644 --- a/libmemcached/memcached.c +++ b/libmemcached/memcached.c @@ -34,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 + } }; @@ -95,9 +97,42 @@ static inline bool _memcached_init(memcached_st *self) self->sasl.callbacks= NULL; self->sasl.is_allocated= false; + self->error_messages= NULL; + return true; } +static void _free(memcached_st *ptr, bool release_st) +{ + /* If we have anything open, lets close it now */ + memcached_quit(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); + + memcached_error_free(ptr); + + if (ptr->sasl.callbacks) + { +#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT + memcached_destroy_sasl_auth_data(ptr); +#endif + } + + if (memcached_is_allocated(ptr) && release_st) + { + libmemcached_free(ptr, ptr); + } +} + memcached_st *memcached_create(memcached_st *ptr) { if (ptr == NULL) @@ -138,6 +173,18 @@ memcached_st *memcached_create(memcached_st *ptr) return ptr; } +void memcached_reset(memcached_st *ptr) +{ + WATCHPOINT_ASSERT(ptr); + if (! ptr) + return; + + bool stored_is_allocated= memcached_is_allocated(ptr); + _free(ptr, false); + memcached_create(ptr); + memcached_set_allocated(ptr, stored_is_allocated); +} + void memcached_servers_reset(memcached_st *ptr) { memcached_server_list_free(memcached_server_list(ptr)); @@ -163,31 +210,7 @@ void memcached_reset_last_disconnected_server(memcached_st *ptr) void memcached_free(memcached_st *ptr) { - /* If we have anything open, lets close it now */ - memcached_quit(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); - - if (ptr->sasl.callbacks) - { -#ifdef LIBMEMCACHED_WITH_SASL_SUPPORT - memcached_destroy_sasl_auth_data(ptr); -#endif - } - - if (memcached_is_allocated(ptr)) - { - libmemcached_free(ptr, ptr); - } + _free(ptr, true); } /*