*/
#include "libmemcached/common.h"
+#include "p9y/socket.hpp"
memcached_return_t memcached_flush_buffers(memcached_st *shell) {
Memcached *memc = memcached2Memcached(shell);
for (uint32_t x = 0; x < memcached_server_count(memc); ++x) {
memcached_instance_st *instance = memcached_instance_fetch(memc, x);
- if (instance->write_buffer_offset != 0) {
+ if (instance->write_buffer_offset) {
if (instance->fd == INVALID_SOCKET
and (ret = memcached_connect(instance)) != MEMCACHED_SUCCESS) {
WATCHPOINT_ERROR(ret);