X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fserver.c;h=97b0b27c865ccdd2faf1f5728507c75a8b5dfd98;hb=3660438b520db321ad916f585e418575dabb733f;hp=0461c3c7a40816710854eaaae384e7c476c97401;hpb=ea260e7bce23c9a41c3c60fd68f55b33608714a9;p=awesomized%2Flibmemcached diff --git a/libmemcached/server.c b/libmemcached/server.c index 0461c3c7..97b0b27c 100644 --- a/libmemcached/server.c +++ b/libmemcached/server.c @@ -32,9 +32,9 @@ static inline void _server_init(memcached_server_st *self, const memcached_st *r self->state.is_dead= false; WATCHPOINT_SET(self->io_wait_count.read= 0); WATCHPOINT_SET(self->io_wait_count.write= 0); - self->major_version= 0; - self->micro_version= 0; - self->minor_version= 0; + self->major_version= UINT8_MAX; + self->micro_version= UINT8_MAX; + self->minor_version= UINT8_MAX; self->type= type; self->read_ptr= self->read_buffer; self->cached_server_error= NULL; @@ -115,7 +115,14 @@ void memcached_server_free(memcached_server_st *self) if (memcached_is_allocated(self)) { - libmemcached_free(self->root, self); + if (self->root) + { + libmemcached_free(self->root, self); + } + else + { + free(self); + } } else { @@ -172,6 +179,26 @@ memcached_return_t memcached_server_cursor(const memcached_st *ptr, return MEMCACHED_SUCCESS; } +memcached_return_t memcached_server_execute(memcached_st *ptr, + memcached_server_execute_fn callback, + void *context) +{ + for (uint32_t x= 0; x < memcached_server_count(ptr); x++) + { + memcached_server_write_instance_st instance= + memcached_server_instance_fetch(ptr, x); + + unsigned int iferror; + + iferror= (*callback)(ptr, instance, context); + + if (iferror) + continue; + } + + return MEMCACHED_SUCCESS; +} + memcached_server_instance_st memcached_server_by_key(const memcached_st *ptr, const char *key, size_t key_length,