return MEMCACHED_SUCCESS;
}
-char *memcached_stat_get_value(const memcached_st *, memcached_stat_st *memc_stat,
+char *memcached_stat_get_value(const memcached_st* shell, memcached_stat_st *memc_stat,
const char *key, memcached_return_t *error)
{
memcached_return_t not_used;
}
else
{
- *error= MEMCACHED_NOTFOUND;
+ Memcached* memc= (Memcached*)memcached2Memcached(shell);
+ *error= memcached_set_error(*memc, MEMCACHED_INVALID_ARGUMENTS, MEMCACHED_AT, memcached_literal_param("Invalid key provided"));
return NULL;
}
if (length >= SMALL_STRING_LEN || length < 0)
{
- *error= MEMCACHED_FAILURE;
+ Memcached* memc= (Memcached*)memcached2Memcached(shell);
+ *error= memcached_set_error(*memc, MEMCACHED_FAILURE, MEMCACHED_AT, memcached_literal_param("Internal failure occured with buffer, please report this bug."));
return NULL;
}
{
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;
}
if (args)
{
args_length= strlen(args);
- rc= memcached_validate_key_length(args_length, self->flags.binary_protocol);
- if (memcached_failed(rc))
+ if (memcached_failed(rc= memcached_key_test(*self, (const char **)&args, &args_length, 1)))
{
*error= memcached_set_error(*self, rc, MEMCACHED_AT);
return NULL;
if (args)
{
args_length= strlen(args);
- rc= memcached_validate_key_length(args_length, memc.flags.binary_protocol);
+ rc= memcached_key_test(*memc_ptr, (const char **)&args, &args_length, 1);
}
if (memcached_success(rc))