X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fflush_buffers.c;h=649db983ec65295033058e81871126959bc53ac6;hb=5978e22206f36565d27a4d513962832f92955652;hp=c037cb7b26657d552be83b14c6e77f8aab4f5ee7;hpb=3928e14fbe1ed17cefe9bdbbb282fb7ecf053e7a;p=awesomized%2Flibmemcached diff --git a/libmemcached/flush_buffers.c b/libmemcached/flush_buffers.c index c037cb7b..649db983 100644 --- a/libmemcached/flush_buffers.c +++ b/libmemcached/flush_buffers.c @@ -6,7 +6,7 @@ memcached_return_t memcached_flush_buffers(memcached_st *memc) for (uint32_t x= 0; x < memcached_server_count(memc); ++x) { - memcached_server_instance_st *instance= + memcached_server_write_instance_st instance= memcached_server_instance_fetch(memc, x); if (instance->write_buffer_offset != 0) @@ -17,8 +17,11 @@ memcached_return_t memcached_flush_buffers(memcached_st *memc) WATCHPOINT_ERROR(ret); return ret; } - if (memcached_io_write(instance, NULL, 0, 1) == -1) + + if (memcached_io_write(instance, NULL, 0, true) == -1) + { ret= MEMCACHED_SOME_ERRORS; + } } }