X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fserver.hpp;h=2719294f9cf3d4fd626b1fcda9ec14d6292ae8c0;hb=7ab3500b376928c4a621cfa29289aa1eaeecd60d;hp=5d718949eaf5406d3496495422b834c6c5329f22;hpb=5dcbf2e84a46ee8e5c520a6bf2b35b643425f172;p=awesomized%2Flibmemcached diff --git a/libmemcached/server.hpp b/libmemcached/server.hpp index 5d718949..2719294f 100644 --- a/libmemcached/server.hpp +++ b/libmemcached/server.hpp @@ -44,15 +44,12 @@ #include memcached_server_st *__server_create_with(memcached_st *memc, - memcached_server_write_instance_st host, + memcached_server_st* self, const memcached_string_t& hostname, const in_port_t port, - uint32_t weight, + uint32_t weight, const memcached_connection_t type); -memcached_server_st *memcached_server_clone(memcached_server_st *destination, - memcached_server_st *source); - memcached_return_t memcached_server_add_parsed(memcached_st *ptr, const char *hostname, size_t hostname_length, @@ -63,38 +60,14 @@ void __server_free(memcached_server_st *); static inline bool memcached_is_valid_servername(const memcached_string_t& arg) { - return arg.size > 0 or arg.size < NI_MAXHOST; -} - -static inline void memcached_mark_server_as_clean(memcached_server_write_instance_st server) -{ - server->server_failure_counter= 0; - server->next_retry= 0; + return arg.size < NI_MAXHOST; } +void memcached_instance_free(org::libmemcached::Instance *); -static inline void set_last_disconnected_host(memcached_server_write_instance_st self) -{ - assert(self->root); - if (self->root == NULL) - { - return; - } - - if (self->root->last_disconnected_server and self->root->last_disconnected_server->version == self->version) - { - return; - } - - // const_cast - memcached_st *root= (memcached_st *)self->root; - - memcached_server_free(root->last_disconnected_server); - root->last_disconnected_server= memcached_server_clone(NULL, self); - root->last_disconnected_server->version= self->version; -} +void set_last_disconnected_host(org::libmemcached::Instance* self); -static inline void memcached_mark_server_for_timeout(memcached_server_write_instance_st server) +static inline void memcached_mark_server_for_timeout(org::libmemcached::Instance* server) { if (server->state != MEMCACHED_SERVER_STATE_IN_TIMEOUT) {