mirror of
https://github.com/phpredis/phpredis.git
synced 2026-06-19 07:35:31 +00:00
michael-grunder
2c5ef19257
* Introduce a new `RedisCmd` struct to dynamically append RESP arguments such that we don't have to precalculate the number of arguments the command will have up front. Additionally the new `RedisCmd allows both a `void *` context pointer but also can attach a `void (*ctx_dtor)(void*)` destructor so we are still able to clean up any allocated context when commands fail. This moves the context cleanup out of every individual reply handler and into the generic processing wrappers. * Create a small group of `resp_str` helper functions for lower level concatination of RESP protocol data over the wire. * Lots of small modernization of the codebase such as using `zend_string*` instead of (`char *`, `size_t`) pairs. * Greatly simplify `crosslot` handling logic
68 lines
2.0 KiB
C
68 lines
2.0 KiB
C
#include "sentinel_library.h"
|
|
|
|
static zend_object_handlers redis_sentinel_object_handlers;
|
|
|
|
static void
|
|
free_redis_sentinel_object(zend_object *object)
|
|
{
|
|
redis_sentinel_object *obj = PHPREDIS_GET_OBJECT(redis_sentinel_object, object);
|
|
|
|
if (obj->sock) {
|
|
redis_sock_disconnect(obj->sock, 0, 1);
|
|
redis_free_socket(obj->sock);
|
|
}
|
|
zend_object_std_dtor(&obj->std);
|
|
}
|
|
|
|
zend_object *
|
|
create_sentinel_object(zend_class_entry *ce)
|
|
{
|
|
redis_sentinel_object *obj = ecalloc(1, sizeof(*obj) + zend_object_properties_size(ce));
|
|
|
|
zend_object_std_init(&obj->std, ce);
|
|
object_properties_init(&obj->std, ce);
|
|
|
|
memcpy(&redis_sentinel_object_handlers, zend_get_std_object_handlers(), sizeof(redis_sentinel_object_handlers));
|
|
redis_sentinel_object_handlers.offset = XtOffsetOf(redis_sentinel_object, std);
|
|
redis_sentinel_object_handlers.free_obj = free_redis_sentinel_object;
|
|
obj->std.handlers = &redis_sentinel_object_handlers;
|
|
|
|
return &obj->std;
|
|
}
|
|
|
|
PHP_REDIS_API int
|
|
sentinel_mbulk_reply_zipped_assoc(INTERNAL_FUNCTION_PARAMETERS, RedisSock *redis_sock,
|
|
zval *z_tab, RedisCmdCtx ctx)
|
|
{
|
|
char inbuf[4096];
|
|
int i, nelem;
|
|
size_t len;
|
|
zval z_ret;
|
|
|
|
/* Throws exception on failure */
|
|
if (redis_sock_gets(redis_sock, inbuf, sizeof(inbuf) - 1, &len) < 0) {
|
|
RETVAL_FALSE;
|
|
return FAILURE;
|
|
}
|
|
|
|
if (*inbuf != TYPE_MULTIBULK) {
|
|
if (*inbuf == TYPE_ERR) {
|
|
redis_sock_set_err(redis_sock, inbuf + 1, len - 1);
|
|
}
|
|
|
|
RETVAL_FALSE;
|
|
return FAILURE;
|
|
}
|
|
array_init(&z_ret);
|
|
nelem = atoi(inbuf + 1);
|
|
for (i = 0; i < nelem; ++i) {
|
|
/* redis_mbulk_reply_zipped_raw calls redis_mbulk_reply_zipped
|
|
* which puts result into return_value via RETVAL_ZVAL */
|
|
redis_mbulk_reply_zipped_raw(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, z_tab, ctx);
|
|
add_next_index_zval(&z_ret, return_value);
|
|
}
|
|
|
|
RETVAL_ZVAL(&z_ret, 0, 1);
|
|
return SUCCESS;
|
|
}
|