X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fserver.cc;h=20db52b8344ca79c74fefb07db81c739ac262f8d;hb=7ab3500b376928c4a621cfa29289aa1eaeecd60d;hp=8d9e9bbd175e87aeab2db814edf35a8f1c2e8c0c;hpb=ca663a567bc8d3facb22b035bcad19349e42a9b1;p=awesomized%2Flibmemcached diff --git a/libmemcached/server.cc b/libmemcached/server.cc index 8d9e9bbd..20db52b8 100644 --- a/libmemcached/server.cc +++ b/libmemcached/server.cc @@ -50,7 +50,6 @@ static inline void _server_init(memcached_server_st *self, memcached_st *root, self->number_of_hosts= 0; self->cursor_active= 0; self->port= port; - self->fd= INVALID_SOCKET; self->io_bytes_sent= 0; self->request_id= 0; self->server_failure_counter= 0; @@ -65,12 +64,6 @@ static inline void _server_init(memcached_server_st *self, memcached_st *root, self->minor_version= UINT8_MAX; self->type= type; self->error_messages= NULL; - self->read_ptr= self->read_buffer; - self->read_buffer_length= 0; - self->read_data_length= 0; - self->write_buffer_offset= 0; - self->address_info= NULL; - self->address_info_next= NULL; self->state= MEMCACHED_SERVER_STATE_NEW; self->next_retry= 0; @@ -113,7 +106,7 @@ static memcached_server_st *_server_create(memcached_server_st *self, const memc } memcached_server_st *__server_create_with(memcached_st *memc, - memcached_server_st* self, + memcached_server_st* allocated_instance, const memcached_string_t& hostname, const in_port_t port, uint32_t weight, @@ -125,16 +118,16 @@ memcached_server_st *__server_create_with(memcached_st *memc, return NULL; } - self= _server_create(self, memc); + allocated_instance= _server_create(allocated_instance, memc); - if (self == NULL) + if (allocated_instance == NULL) { return NULL; } - _server_init(self, const_cast(memc), hostname, port, weight, type); + _server_init(allocated_instance, const_cast(memc), hostname, port, weight, type); - return self; + return allocated_instance; } void __server_free(memcached_server_st *self) @@ -201,10 +194,12 @@ uint32_t memcached_server_count(const memcached_st *self) const char *memcached_server_name(const memcached_server_instance_st self) { WATCHPOINT_ASSERT(self); - if (self == NULL) - return NULL; + if (self) + { + return self->hostname; + } - return self->hostname; + return NULL; } in_port_t memcached_server_port(const memcached_server_instance_st self) @@ -215,7 +210,7 @@ in_port_t memcached_server_port(const memcached_server_instance_st self) return 0; } - return self->port; + return self->port(); } uint32_t memcached_server_response_count(const memcached_server_instance_st self) @@ -226,7 +221,7 @@ uint32_t memcached_server_response_count(const memcached_server_instance_st self return 0; } - return self->cursor_active; + return self->cursor_active_; } const char *memcached_server_type(const memcached_server_instance_st ptr)