X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Ftouch.cc;h=a638bf9f7e3265f9f01927cf315215143bb709a7;hb=9973d386ac8476cd09cc4d9cf7bd2234a42740c7;hp=757ddfdfa1426f92d9d6da92f59a61afb3988673;hpb=999006a8904a0f08293f1df7bda81bff914b091a;p=awesomized%2Flibmemcached diff --git a/libmemcached/touch.cc b/libmemcached/touch.cc index 757ddfdf..a638bf9f 100644 --- a/libmemcached/touch.cc +++ b/libmemcached/touch.cc @@ -38,7 +38,7 @@ #include #include -static memcached_return_t ascii_touch(memcached_server_write_instance_st instance, +static memcached_return_t ascii_touch(memcached_instance_st* instance, const char *key, size_t key_length, time_t expiration) { @@ -63,14 +63,13 @@ static memcached_return_t ascii_touch(memcached_server_write_instance_st instanc memcached_return_t rc; if (memcached_failed(rc= memcached_vdo(instance, vector, 6, true))) { - memcached_io_reset(instance); return memcached_set_error(*instance, MEMCACHED_WRITE_FAILURE, MEMCACHED_AT); } return rc; } -static memcached_return_t binary_touch(memcached_server_write_instance_st instance, +static memcached_return_t binary_touch(memcached_instance_st* instance, const char *key, size_t key_length, time_t expiration) { @@ -96,7 +95,6 @@ static memcached_return_t binary_touch(memcached_server_write_instance_st instan memcached_return_t rc; if (memcached_failed(rc= memcached_vdo(instance, vector, 4, true))) { - memcached_io_reset(instance); return memcached_set_error(*instance, MEMCACHED_WRITE_FAILURE, MEMCACHED_AT); } @@ -110,11 +108,12 @@ memcached_return_t memcached_touch(memcached_st *ptr, return memcached_touch_by_key(ptr, key, key_length, key, key_length, expiration); } -memcached_return_t memcached_touch_by_key(memcached_st *ptr, +memcached_return_t memcached_touch_by_key(memcached_st *shell, const char *group_key, size_t group_key_length, const char *key, size_t key_length, time_t expiration) { + Memcached* ptr= memcached2Memcached(shell); LIBMEMCACHED_MEMCACHED_TOUCH_START(); memcached_return_t rc; @@ -123,13 +122,13 @@ memcached_return_t memcached_touch_by_key(memcached_st *ptr, return rc; } - if (memcached_failed(rc= memcached_validate_key_length(key_length, ptr->flags.binary_protocol))) + if (memcached_failed(rc= memcached_key_test(*ptr, (const char **)&key, &key_length, 1))) { - return rc; + return memcached_set_error(*ptr, rc, MEMCACHED_AT); } uint32_t server_key= memcached_generate_hash_with_redistribution(ptr, group_key, group_key_length); - memcached_server_write_instance_st instance= memcached_server_instance_fetch(ptr, server_key); + memcached_instance_st* instance= memcached_instance_fetch(ptr, server_key); if (ptr->flags.binary_protocol) {