X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fflush.cc;fp=libmemcached%2Fflush.cc;h=ef79092287ead37bc1a0fa3b1edb3b0fdfa0a890;hb=999006a8904a0f08293f1df7bda81bff914b091a;hp=989555e2f968625f2a47600ead8099eeda26273a;hpb=89577febff3909fe3498c40699aae8f933c122c0;p=m6w6%2Flibmemcached diff --git a/libmemcached/flush.cc b/libmemcached/flush.cc index 989555e2..ef790922 100644 --- a/libmemcached/flush.cc +++ b/libmemcached/flush.cc @@ -42,7 +42,6 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, { protocol_binary_request_flush request= {}; - request.message.header.request.magic= (uint8_t)PROTOCOL_BINARY_REQ; request.message.header.request.opcode= PROTOCOL_BINARY_CMD_FLUSH; request.message.header.request.extlen= 4; request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES; @@ -54,6 +53,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); + initialize_binary_request(instance, request.message.header); if (reply) { @@ -86,7 +86,7 @@ static memcached_return_t memcached_flush_binary(memcached_st *ptr, { memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, x); - if (memcached_server_response_count(instance) > 0) + if (memcached_instance_response_count(instance) > 0) { (void)memcached_response(instance, NULL, 0, NULL); }