X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fflush.c;h=c8428f7015f979deec1f3e2eca63d18143079fdd;hb=d70dd7ca2db0a4f7d7c63367466567cc1efe9f68;hp=cb044b0c6e1216015311d137915cc852fa2a71dc;hpb=3928e14fbe1ed17cefe9bdbbb282fb7ecf053e7a;p=m6w6%2Flibmemcached diff --git a/libmemcached/flush.c b/libmemcached/flush.c index cb044b0c..c8428f70 100644 --- a/libmemcached/flush.c +++ b/libmemcached/flush.c @@ -32,7 +32,7 @@ static memcached_return_t memcached_flush_textual(memcached_st *ptr, for (x= 0; x < memcached_server_count(ptr); x++) { bool no_reply= ptr->flags.no_reply; - memcached_server_instance_st *instance= + memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); if (expiration) @@ -43,7 +43,7 @@ static memcached_return_t memcached_flush_textual(memcached_st *ptr, send_length= (size_t) snprintf(buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, "flush_all%s\r\n", no_reply ? " noreply" : ""); - rc= memcached_do(instance, buffer, send_length, 1); + rc= memcached_do(instance, buffer, send_length, true); if (rc == MEMCACHED_SUCCESS && !no_reply) (void)memcached_response(instance, buffer, MEMCACHED_DEFAULT_COMMAND_SIZE, NULL); @@ -70,7 +70,7 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, for (x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_instance_st *instance= + memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); if (ptr->flags.no_reply) @@ -83,7 +83,7 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, } if (memcached_do(instance, request.bytes, - sizeof(request.bytes), 1) != MEMCACHED_SUCCESS) + sizeof(request.bytes), true) != MEMCACHED_SUCCESS) { memcached_io_reset(instance); return MEMCACHED_WRITE_FAILURE; @@ -92,7 +92,7 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, for (x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_instance_st *instance= + memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); if (memcached_server_response_count(instance) > 0)