X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fflush_buffers.c;h=649db983ec65295033058e81871126959bc53ac6;hb=3dee67d04099cc5e2986ed94aa612f429f54d6fb;hp=c037cb7b26657d552be83b14c6e77f8aab4f5ee7;hpb=e42302e08fa4d04cb21eaf7493f5f92b11169c03;p=m6w6%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; + } } }