X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fflush.cc;h=7a102eab2cb96bbdf4c3d141e2213226c905f867;hb=56a083d9a9b9887fc48890526d323fbc44e487b5;hp=6afcce9af73d5e886c266df30a6e8d1033bff824;hpb=ca663a567bc8d3facb22b035bcad19349e42a9b1;p=awesomized%2Flibmemcached diff --git a/libmemcached/flush.cc b/libmemcached/flush.cc index 6afcce9a..7a102eab 100644 --- a/libmemcached/flush.cc +++ b/libmemcached/flush.cc @@ -52,7 +52,7 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, for (uint32_t x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, x); initialize_binary_request(instance, request.message.header); if (reply) @@ -84,9 +84,9 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, for (uint32_t x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, x); - if (memcached_instance_response_count(instance) > 0) + if (instance->response_count() > 0) { (void)memcached_response(instance, NULL, 0, NULL); } @@ -115,13 +115,13 @@ static memcached_return_t memcached_flush_textual(memcached_st *ptr, memcached_return_t rc= MEMCACHED_SUCCESS; for (uint32_t x= 0; x < memcached_server_count(ptr); x++) { - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); + org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, x); libmemcached_io_vector_st vector[]= { { NULL, 0 }, { memcached_literal_param("flush_all ") }, - { buffer, send_length }, + { buffer, size_t(send_length) }, { " noreply", reply ? 0 : memcached_literal_param_size(" noreply") }, { memcached_literal_param("\r\n") } };