X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=libmemcached%2Fresponse.cc;h=6ee62af08ad86b67e2cf8ac2f3f4daf3bcc17197;hb=a6c3e3a3d04f379b1480c8c88a8eae17e54b1449;hp=3c996f94499e049522480b68d50495edb76f6d37;hpb=9cde1fdc1bbd49775c75a83e44c942354129f1d5;p=m6w6%2Flibmemcached diff --git a/libmemcached/response.cc b/libmemcached/response.cc index 3c996f94..6ee62af0 100644 --- a/libmemcached/response.cc +++ b/libmemcached/response.cc @@ -111,18 +111,15 @@ static memcached_return_t textual_value_fetch(memcached_server_write_instance_st char *buffer, memcached_result_st *result) { - memcached_return_t rc= MEMCACHED_SUCCESS; char *string_ptr; char *end_ptr; char *next_ptr; size_t value_length; size_t to_read; - char *value_ptr; ssize_t read_length= 0; - memcached_return_t rrc; if (ptr->root->flags.use_udp) - return memcached_set_error((memcached_st *)ptr->root, MEMCACHED_NOT_SUPPORTED); + return memcached_set_error(*ptr, MEMCACHED_NOT_SUPPORTED, MEMCACHED_AT); WATCHPOINT_ASSERT(ptr->root); end_ptr= buffer + MEMCACHED_DEFAULT_COMMAND_SIZE; @@ -197,25 +194,26 @@ static memcached_return_t textual_value_fetch(memcached_server_write_instance_st goto read_error; /* We add two bytes so that we can walk the \r\n */ - rc= memcached_string_check(&result->value, value_length+2); - if (rc != MEMCACHED_SUCCESS) + if (memcached_failed(memcached_string_check(&result->value, value_length +2))) { value_length= 0; - return memcached_set_error((memcached_st *)ptr->root, MEMCACHED_MEMORY_ALLOCATION_FAILURE); + return memcached_set_error(*ptr, MEMCACHED_MEMORY_ALLOCATION_FAILURE, MEMCACHED_AT); } - value_ptr= memcached_string_value_mutable(&result->value); - /* - We read the \r\n into the string since not doing so is more - cycles then the waster of memory to do so. - - We are null terminating through, which will most likely make - some people lazy about using the return length. - */ - to_read= (value_length) + 2; - rrc= memcached_io_read(ptr, value_ptr, to_read, &read_length); - if (rrc != MEMCACHED_SUCCESS) - return rrc; + { + char *value_ptr= memcached_string_value_mutable(&result->value); + /* + We read the \r\n into the string since not doing so is more + cycles then the waster of memory to do so. + + We are null terminating through, which will most likely make + some people lazy about using the return length. + */ + to_read= (value_length) + 2; + memcached_return_t rrc= memcached_io_read(ptr, value_ptr, to_read, &read_length); + if (memcached_failed(rrc)) + return rrc; + } if (read_length != (ssize_t)(value_length + 2)) { @@ -552,7 +550,7 @@ static memcached_return_t binary_read_one_response(memcached_server_write_instan if ((rc= memcached_safe_read(ptr, hole, nr)) != MEMCACHED_SUCCESS) { WATCHPOINT_ERROR(rc); - return memcached_set_error((memcached_st *)ptr->root, MEMCACHED_UNKNOWN_READ_FAILURE); + return memcached_set_error(*ptr, MEMCACHED_UNKNOWN_READ_FAILURE, MEMCACHED_AT); } bodylen-= (uint32_t) nr; }