X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Ftouch.cc;h=757ddfdfa1426f92d9d6da92f59a61afb3988673;hb=999006a8904a0f08293f1df7bda81bff914b091a;hp=ba73146f2458ef169d7507531b89faa186e316bd;hpb=3c74b93b3db239f4240c907a91678ed401fa41ad;p=m6w6%2Flibmemcached diff --git a/libmemcached/touch.cc b/libmemcached/touch.cc index ba73146f..757ddfdf 100644 --- a/libmemcached/touch.cc +++ b/libmemcached/touch.cc @@ -52,15 +52,16 @@ static memcached_return_t ascii_touch(memcached_server_write_instance_st instanc libmemcached_io_vector_st vector[]= { + { NULL, 0 }, { memcached_literal_param("touch ") }, { memcached_array_string(instance->root->_namespace), memcached_array_size(instance->root->_namespace) }, { key, key_length }, - { expiration_buffer, expiration_buffer_length }, + { expiration_buffer, size_t(expiration_buffer_length) }, { memcached_literal_param("\r\n") } }; memcached_return_t rc; - if (memcached_failed(rc= memcached_vdo(instance, vector, 5, true))) + if (memcached_failed(rc= memcached_vdo(instance, vector, 6, true))) { memcached_io_reset(instance); return memcached_set_error(*instance, MEMCACHED_WRITE_FAILURE, MEMCACHED_AT); @@ -74,7 +75,9 @@ static memcached_return_t binary_touch(memcached_server_write_instance_st instan time_t expiration) { protocol_binary_request_touch request= {}; //{.bytes= {0}}; - request.message.header.request.magic= PROTOCOL_BINARY_REQ; + + initialize_binary_request(instance, request.message.header); + request.message.header.request.opcode= PROTOCOL_BINARY_CMD_TOUCH; request.message.header.request.extlen= 4; request.message.header.request.keylen= htons((uint16_t)(key_length +memcached_array_size(instance->root->_namespace))); @@ -84,13 +87,14 @@ static memcached_return_t binary_touch(memcached_server_write_instance_st instan libmemcached_io_vector_st vector[]= { + { NULL, 0 }, { request.bytes, sizeof(request.bytes) }, { memcached_array_string(instance->root->_namespace), memcached_array_size(instance->root->_namespace) }, { key, key_length } }; memcached_return_t rc; - if (memcached_failed(rc= memcached_vdo(instance, vector, 3, true))) + if (memcached_failed(rc= memcached_vdo(instance, vector, 4, true))) { memcached_io_reset(instance); return memcached_set_error(*instance, MEMCACHED_WRITE_FAILURE, MEMCACHED_AT); @@ -121,7 +125,7 @@ memcached_return_t memcached_touch_by_key(memcached_st *ptr, if (memcached_failed(rc= memcached_validate_key_length(key_length, ptr->flags.binary_protocol))) { - return memcached_set_error(*ptr, rc, MEMCACHED_AT); + return rc; } uint32_t server_key= memcached_generate_hash_with_redistribution(ptr, group_key, group_key_length);