{
char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
protocol_binary_request_stats request= {}; // = {.bytes= {0}};
+ memcached_return_t rc;
initialize_binary_request(instance, request.message.header);
{ args, args_length }
};
- if (memcached_vdo(instance, vector, 2, true) != MEMCACHED_SUCCESS)
+ if (memcached_failed(rc = memcached_vdo(instance, vector, 2, true)))
{
- memcached_io_reset(instance);
- return MEMCACHED_WRITE_FAILURE;
+ return rc;
}
}
else
{ request.bytes, sizeof(request.bytes) }
};
- if (memcached_vdo(instance, vector, 1, true) != MEMCACHED_SUCCESS)
+ if (memcached_failed(rc = memcached_vdo(instance, vector, 1, true)))
{
- memcached_io_reset(instance);
- return MEMCACHED_WRITE_FAILURE;
+ return rc;
}
}
memcached_server_response_decrement(instance);
while (1)
{
- memcached_return_t rc= memcached_response(instance, buffer, sizeof(buffer), NULL);
+ rc= memcached_response(instance, buffer, sizeof(buffer), NULL);
if (rc == MEMCACHED_END)
{
if (rc != MEMCACHED_SUCCESS)
{
- memcached_io_reset(instance);
return rc;
}