/*

+----------------------------------------------------------------------+

| Copyright (c) 1997-2009 The PHP Group |

+----------------------------------------------------------------------+

| This source file is subject to version 3.01 of the PHP license, |

| that is bundled with this package in the file LICENSE, and is |

| available through the world-wide-web at the following url: |

| http://www.php.net/license/3_01.txt |

| If you did not receive a copy of the PHP license and are unable to |

| obtain it through the world-wide-web, please send a note to |

| license@php.net so we can mail you a copy immediately. |

+----------------------------------------------------------------------+

| Author: Nicolas Favre-Felix <n.favre-felix@owlient.eu> |

| Maintainer: Michael Grunder <michael.grunder@gmail.com> |

+----------------------------------------------------------------------+

*/

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include "common.h"

#include "library.h"

#include "redis_array.h"

#include "redis_array_impl.h"

#include <ext/standard/info.h>

#include <zend_exceptions.h>

/* Simple macro to detect failure in a RedisArray call */

#define RA_CALL_FAILED(rv, cmd) ( \

(Z_TYPE_P(rv) == IS_FALSE) || \

(Z_TYPE_P(rv) == IS_ARRAY && zend_hash_num_elements(Z_ARRVAL_P(rv)) == 0) || \

(Z_TYPE_P(rv) == IS_LONG && Z_LVAL_P(rv) == 0 && !strcasecmp(cmd, "TYPE")) \

)

extern zend_class_entry *redis_ce;

zend_class_entry *redis_array_ce;

#if PHP_VERSION_ID < 80000

#include "redis_array_legacy_arginfo.h"

#else

#include "redis_array_arginfo.h"

#endif

extern const zend_function_entry *redis_array_get_methods(void)

{

return class_RedisArray_methods;

}

static void

redis_array_free(RedisArray *ra)

{

int i;

/* continuum */

if (ra->continuum) {

efree(ra->continuum->points);

efree(ra->continuum);

}

/* Redis objects */

for(i = 0; i< ra->count; i++) {

zval_dtor(&ra->redis[i]);

zend_string_release(ra->hosts[i]);

}

efree(ra->redis);

efree(ra->hosts);

/* delete hash function */

zval_dtor(&ra->z_fun);

/* Distributor */

zval_dtor(&ra->z_dist);

/* Hashing algorithm */

if (ra->algorithm) zend_string_release(ra->algorithm);

/* Delete pur commands */

zend_hash_destroy(ra->pure_cmds);

FREE_HASHTABLE(ra->pure_cmds);

/* Free structure itself */

efree(ra);

}

typedef struct {

RedisArray *ra;

zend_object std;

} redis_array_object;

zend_object_handlers redis_array_object_handlers;

void

free_redis_array_object(zend_object *object)

{

redis_array_object *obj = PHPREDIS_GET_OBJECT(redis_array_object, object);

if (obj->ra) {

if (obj->ra->prev) redis_array_free(obj->ra->prev);

redis_array_free(obj->ra);

}

zend_object_std_dtor(&obj->std);

}

zend_object *

create_redis_array_object(zend_class_entry *ce)

{

redis_array_object *obj = ecalloc(1, sizeof(redis_array_object) + zend_object_properties_size(ce));

obj->ra = NULL;

zend_object_std_init(&obj->std, ce);

object_properties_init(&obj->std, ce);

memcpy(&redis_array_object_handlers, zend_get_std_object_handlers(), sizeof(redis_array_object_handlers));

redis_array_object_handlers.offset = XtOffsetOf(redis_array_object, std);

redis_array_object_handlers.free_obj = free_redis_array_object;

obj->std.handlers = &redis_array_object_handlers;

return &obj->std;

}

/**

* redis_array_get

*/

PHP_REDIS_API RedisArray *

redis_array_get(zval *id)

{

redis_array_object *obj;

if (Z_TYPE_P(id) == IS_OBJECT) {

obj = PHPREDIS_ZVAL_GET_OBJECT(redis_array_object, id);

return obj->ra;

}

return NULL;

}

/* {{{ proto RedisArray RedisArray::__construct()

Public constructor */

PHP_METHOD(RedisArray, __construct)

{

zval *z0, z_fun, z_dist, *zpData, *z_opts = NULL;

RedisArray *ra = NULL;

zend_bool b_index = 0, b_autorehash = 0, b_pconnect = 0, consistent = 0;

HashTable *hPrev = NULL, *hOpts = NULL;

zend_long l_retry_interval = 0;

zend_bool b_lazy_connect = 0;

double d_connect_timeout = 0, read_timeout = 0.0;

zend_string *algorithm = NULL, *user = NULL, *pass = NULL;

redis_array_object *obj;

if (zend_parse_parameters(ZEND_NUM_ARGS(), "z|a", &z0, &z_opts) == FAILURE) {

RETURN_FALSE;

}

/* Bail if z0 isn't a string or an array.

* Note: WRONG_PARAM_COUNT seems wrong but this is what we have been doing

* for ages so we can't really change it until the next major version.

*/

if (Z_TYPE_P(z0) != IS_ARRAY && Z_TYPE_P(z0) != IS_STRING) {

#if PHP_VERSION_ID < 80000

WRONG_PARAM_COUNT;

#else

zend_argument_type_error(1, "must be of type string|array, %s given", zend_zval_type_name(z0));

RETURN_THROWS();

#endif

}

/* If it's a string we want to load the array from ini information */

if (Z_TYPE_P(z0) == IS_STRING) {

ra = ra_load_array(Z_STRVAL_P(z0));

goto finish;

}

ZVAL_NULL(&z_fun);

ZVAL_NULL(&z_dist);

/* extract options */

if(z_opts) {

hOpts = Z_ARRVAL_P(z_opts);

/* extract previous ring. */

zpData = REDIS_HASH_STR_FIND_STATIC(hOpts, "previous");

if (zpData && Z_TYPE_P(zpData) == IS_ARRAY && zend_hash_num_elements(Z_ARRVAL_P(zpData)) > 0) {

hPrev = Z_ARRVAL_P(zpData);

}

REDIS_CONF_AUTH_STATIC(hOpts, "auth", &user, &pass);

REDIS_CONF_ZVAL_STATIC(hOpts, "function", &z_fun, 1, 0);

REDIS_CONF_ZVAL_STATIC(hOpts, "distributor", &z_dist, 1, 0);

REDIS_CONF_STRING_STATIC(hOpts, "algorithm", &algorithm);

REDIS_CONF_ZEND_BOOL_STATIC(hOpts, "index", &b_index);

REDIS_CONF_ZEND_BOOL_STATIC(hOpts, "autorehash", &b_autorehash);

REDIS_CONF_ZEND_BOOL_STATIC(hOpts, "pconnect", &b_pconnect);

REDIS_CONF_LONG_STATIC(hOpts, "retry_interval", &l_retry_interval);

REDIS_CONF_ZEND_BOOL_STATIC(hOpts, "lazy_connect", &b_lazy_connect);

REDIS_CONF_ZEND_BOOL_STATIC(hOpts, "consistent", &consistent);

REDIS_CONF_DOUBLE_STATIC(hOpts, "connect_timeout", &d_connect_timeout);

REDIS_CONF_DOUBLE_STATIC(hOpts, "read_timeout", &read_timeout);

}

ra = ra_make_array(Z_ARRVAL_P(z0), &z_fun, &z_dist, hPrev, b_index,

b_pconnect, l_retry_interval, b_lazy_connect,

d_connect_timeout, read_timeout, consistent,

algorithm, user, pass);

if (algorithm) zend_string_release(algorithm);

if (user) zend_string_release(user);

if (pass) zend_string_release(pass);

zval_dtor(&z_dist);

zval_dtor(&z_fun);

finish:

if(ra) {

ra->auto_rehash = b_autorehash;

ra->connect_timeout = d_connect_timeout;

if(ra->prev) ra->prev->auto_rehash = b_autorehash;

obj = PHPREDIS_ZVAL_GET_OBJECT(redis_array_object, getThis());

obj->ra = ra;

}

}

static void

ra_forward_call(INTERNAL_FUNCTION_PARAMETERS, RedisArray *ra, const char *cmd,

int cmd_len, zval *z_args, zval *z_new_target)

{

zval z_fun, *redis_inst, *z_callargs, *zp_tmp;

char *key = NULL; /* set to avoid "unused-but-set-variable" */

int i, key_len = 0, argc;

HashTable *h_args;

zend_bool b_write_cmd = 0;

h_args = Z_ARRVAL_P(z_args);

if ((argc = zend_hash_num_elements(h_args)) == 0) {

RETURN_FALSE;

}

if(ra->z_multi_exec) {

redis_inst = ra->z_multi_exec; /* we already have the instance */

} else {

/* extract key and hash it. */

if ((zp_tmp = zend_hash_index_find(h_args, 0)) == NULL || Z_TYPE_P(zp_tmp) != IS_STRING) {

php_error_docref(NULL, E_ERROR, "Could not find key");

RETURN_FALSE;

}

key = Z_STRVAL_P(zp_tmp);

key_len = Z_STRLEN_P(zp_tmp);

/* find node */

redis_inst = ra_find_node(ra, key, key_len, NULL);

if(!redis_inst) {

php_error_docref(NULL, E_ERROR, "Could not find any redis servers for this key.");

RETURN_FALSE;

}

}

/* pass call through */

ZVAL_STRINGL(&z_fun, cmd, cmd_len); /* method name */

z_callargs = ecalloc(argc, sizeof(*z_callargs));

/* copy args to array */

i = 0;

ZEND_HASH_FOREACH_VAL(h_args, zp_tmp) {

ZVAL_ZVAL(&z_callargs[i], zp_tmp, 1, 0);

i++;

} ZEND_HASH_FOREACH_END();

/* multi/exec */

if(ra->z_multi_exec) {

call_user_function(&redis_ce->function_table, ra->z_multi_exec, &z_fun, return_value, argc, z_callargs);

zval_dtor(return_value);

zval_dtor(&z_fun);

for (i = 0; i < argc; ++i) {

zval_dtor(&z_callargs[i]);

}

efree(z_callargs);

RETURN_ZVAL(getThis(), 1, 0);

}

/* check if write cmd */

b_write_cmd = ra_is_write_cmd(ra, cmd, cmd_len);

/* CALL! */

if(ra->index && b_write_cmd) {

/* add MULTI + SADD */

ra_index_multi(redis_inst, MULTI);

/* call using discarded temp value and extract exec results after. */

call_user_function(&redis_ce->function_table, redis_inst, &z_fun, return_value, argc, z_callargs);

zval_dtor(return_value);

/* add keys to index. */

ra_index_key(key, key_len, redis_inst);

/* call EXEC */

ra_index_exec(redis_inst, return_value, 0);

} else { /* call directly through. */

call_user_function(&redis_ce->function_table, redis_inst, &z_fun, return_value, argc, z_callargs);

if (!b_write_cmd) {

/* check if we have an error. */

if (ra->prev && RA_CALL_FAILED(return_value, cmd)) { /* there was an error reading, try with prev ring. */

/* Free previous return value */

zval_dtor(return_value);

/* ERROR, FALLBACK TO PREVIOUS RING and forward a reference to the first redis instance we were looking at. */

ra_forward_call(INTERNAL_FUNCTION_PARAM_PASSTHRU, ra->prev, cmd, cmd_len, z_args, z_new_target ? z_new_target : redis_inst);

}

/* Autorehash if the key was found on the previous node if this is a read command and auto rehashing is on */

if (ra->auto_rehash && z_new_target && !RA_CALL_FAILED(return_value, cmd)) { /* move key from old ring to new ring */

ra_move_key(key, key_len, redis_inst, z_new_target);

}

}

}

/* cleanup */

zval_dtor(&z_fun);

for (i = 0; i < argc; ++i) {

zval_dtor(&z_callargs[i]);

}

efree(z_callargs);

}

PHP_METHOD(RedisArray, __call)

{

zval *object;

RedisArray *ra;

zval *z_args;

char *cmd;

size_t cmd_len;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Osa",

&object, redis_array_ce, &cmd, &cmd_len, &z_args) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

ra_forward_call(INTERNAL_FUNCTION_PARAM_PASSTHRU, ra, cmd, cmd_len, z_args, NULL);

}

PHP_METHOD(RedisArray, _hosts)

{

zval *object;

int i;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",

&object, redis_array_ce) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

array_init(return_value);

for(i = 0; i < ra->count; ++i) {

add_next_index_stringl(return_value, ZSTR_VAL(ra->hosts[i]), ZSTR_LEN(ra->hosts[i]));

}

}

PHP_METHOD(RedisArray, _target)

{

zval *object;

RedisArray *ra;

char *key;

size_t key_len;

zval *redis_inst;

int i;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os",

&object, redis_array_ce, &key, &key_len) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

redis_inst = ra_find_node(ra, key, key_len, &i);

if(redis_inst) {

RETURN_STRINGL(ZSTR_VAL(ra->hosts[i]), ZSTR_LEN(ra->hosts[i]));

} else {

RETURN_NULL();

}

}

PHP_METHOD(RedisArray, _instance)

{

zval *object;

RedisArray *ra;

zend_string *host;

zval *z_redis;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "OS",

&object, redis_array_ce, &host) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

if ((z_redis = ra_find_node_by_name(ra, host)) == NULL) {

RETURN_NULL();

}

RETURN_ZVAL(z_redis, 1, 0);

}

PHP_METHOD(RedisArray, _function)

{

zval *object;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",

&object, redis_array_ce) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

RETURN_ZVAL(&ra->z_fun, 1, 0);

}

PHP_METHOD(RedisArray, _distributor)

{

zval *object;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",

&object, redis_array_ce) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

RETURN_ZVAL(&ra->z_dist, 1, 0);

}

PHP_METHOD(RedisArray, _rehash)

{

zval *object;

RedisArray *ra;

zend_fcall_info z_cb = {0};

zend_fcall_info_cache z_cb_cache = {0};

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O|f",

&object, redis_array_ce, &z_cb, &z_cb_cache) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

if (ZEND_NUM_ARGS() == 0) {

ra_rehash(ra, NULL, NULL);

} else {

ra_rehash(ra, &z_cb, &z_cb_cache);

}

}

PHP_METHOD(RedisArray, _continuum)

{

int i;

zval *object, z_ret;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",

&object, redis_array_ce) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

array_init(return_value);

if (ra->continuum) {

for (i = 0; i < ra->continuum->nb_points; ++i) {

array_init(&z_ret);

add_assoc_long(&z_ret, "index", ra->continuum->points[i].index);

add_assoc_long(&z_ret, "value", ra->continuum->points[i].value);

add_next_index_zval(return_value, &z_ret);

}

}

}

static void

multihost_distribute_call(RedisArray *ra, zval *return_value, zval *z_fun, int argc, zval *argv)

{

zval z_tmp;

int i;

/* Init our array return */

array_init(return_value);

/* Iterate our RedisArray nodes */

for (i = 0; i < ra->count; ++i) {

/* Call each node in turn */

call_user_function(&redis_array_ce->function_table, &ra->redis[i], z_fun, &z_tmp, argc, argv);

/* Add the result for this host */

add_assoc_zval_ex(return_value, ZSTR_VAL(ra->hosts[i]), ZSTR_LEN(ra->hosts[i]), &z_tmp);

}

}

static void

multihost_distribute(INTERNAL_FUNCTION_PARAMETERS, const char *method_name)

{

zval *object, z_fun;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O",

&object, redis_array_ce) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* prepare call */

ZVAL_STRING(&z_fun, method_name);

multihost_distribute_call(ra, return_value, &z_fun, 0, NULL);

zval_dtor(&z_fun);

}

static void

multihost_distribute_flush(INTERNAL_FUNCTION_PARAMETERS, const char *method_name)

{

zval *object, z_fun, z_args[1];

zend_bool async = 0;

RedisArray *ra;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O|b",

&object, redis_array_ce, &async) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* prepare call */

ZVAL_STRING(&z_fun, method_name);

ZVAL_BOOL(&z_args[0], async);

multihost_distribute_call(ra, return_value, &z_fun, 1, z_args);

zval_dtor(&z_fun);

}

PHP_METHOD(RedisArray, info)

{

multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "INFO");

}

PHP_METHOD(RedisArray, ping)

{

multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "PING");

}

PHP_METHOD(RedisArray, flushdb)

{

multihost_distribute_flush(INTERNAL_FUNCTION_PARAM_PASSTHRU, "FLUSHDB");

}

PHP_METHOD(RedisArray, flushall)

{

multihost_distribute_flush(INTERNAL_FUNCTION_PARAM_PASSTHRU, "FLUSHALL");

}

PHP_METHOD(RedisArray, save)

{

multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "SAVE");

}

PHP_METHOD(RedisArray, bgsave)

{

multihost_distribute(INTERNAL_FUNCTION_PARAM_PASSTHRU, "BGSAVE");

}

PHP_METHOD(RedisArray, keys)

{

zval *object, z_fun, z_args[1];

RedisArray *ra;

char *pattern;

size_t pattern_len;

/* Make sure the prototype is correct */

if(zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Os",

&object, redis_array_ce, &pattern, &pattern_len) == FAILURE)

{

RETURN_FALSE;

}

/* Make sure we can grab our RedisArray object */

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* Set up our function call (KEYS) */

ZVAL_STRINGL(&z_fun, "KEYS", 4);

/* We will be passing with one string argument (the pattern) */

ZVAL_STRINGL(z_args, pattern, pattern_len);

multihost_distribute_call(ra, return_value, &z_fun, 1, z_args);

zval_dtor(&z_args[0]);

zval_dtor(&z_fun);

}

PHP_METHOD(RedisArray, getOption)

{

zval *object, z_fun, z_args[1];

RedisArray *ra;

zend_long opt;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Ol",

&object, redis_array_ce, &opt) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* prepare call */

ZVAL_STRINGL(&z_fun, "getOption", 9);

/* copy arg */

ZVAL_LONG(&z_args[0], opt);

multihost_distribute_call(ra, return_value, &z_fun, 1, z_args);

zval_dtor(&z_fun);

}

PHP_METHOD(RedisArray, setOption)

{

zval *object, z_fun, z_args[2];

RedisArray *ra;

zend_long opt;

char *val_str;

size_t val_len;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Ols",

&object, redis_array_ce, &opt, &val_str, &val_len) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* prepare call */

ZVAL_STRINGL(&z_fun, "setOption", 9);

/* copy args */

ZVAL_LONG(&z_args[0], opt);

ZVAL_STRINGL(&z_args[1], val_str, val_len);

multihost_distribute_call(ra, return_value, &z_fun, 2, z_args);

zval_dtor(&z_args[1]);

zval_dtor(&z_fun);

}

PHP_METHOD(RedisArray, select)

{

zval *object, z_fun, z_args[1];

RedisArray *ra;

zend_long opt;

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Ol",

&object, redis_array_ce, &opt) == FAILURE) {

RETURN_FALSE;

}

if ((ra = redis_array_get(object)) == NULL) {

RETURN_FALSE;

}

/* prepare call */

ZVAL_STRINGL(&z_fun, "select", 6);

/* copy args */

ZVAL_LONG(&z_args[0], opt);

multihost_distribute_call(ra, return_value, &z_fun, 1, z_args);

zval_dtor(&z_fun);

}

#define HANDLE_MULTI_EXEC(ra, cmd, cmdlen) do { \

if (ra && ra->z_multi_exec) { \

int i, num_varargs; \

zval *varargs = NULL, z_arg_array; \

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "O*", \

&object, redis_array_ce, &varargs, &num_varargs) == FAILURE) { \

RETURN_FALSE;\

} \

/* copy all args into a zval hash table */\

array_init(&z_arg_array); \

for (i = 0; i < num_varargs; i++) { \

zval z_tmp; \

ZVAL_ZVAL(&z_tmp, &varargs[i], 1, 0); \

add_next_index_zval(&z_arg_array, &z_tmp); \

} \

/* call */\

ra_forward_call(INTERNAL_FUNCTION_PARAM_PASSTHRU, ra, cmd, cmdlen, &z_arg_array, NULL); \

zval_dtor(&z_arg_array); \

return; \

} \

} while(0)

/* MGET will distribute the call to several nodes and regroup the values. */

PHP_METHOD(RedisArray, mget)

{

zval *object, *z_keys, *data, z_ret, *z_cur, z_tmp_array, z_fun, z_arg, **argv;

int i, j, n, *pos, argc, *argc_each;

HashTable *h_keys;

RedisArray *ra;

if ((ra = redis_array_get(getThis())) == NULL) {

RETURN_FALSE;

}

/* Multi/exec support */

HANDLE_MULTI_EXEC(ra, "MGET", sizeof("MGET") - 1);

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Oa",

&object, redis_array_ce, &z_keys) == FAILURE) {

RETURN_FALSE;

}

/* init data structures */

h_keys = Z_ARRVAL_P(z_keys);

if ((argc = zend_hash_num_elements(h_keys)) == 0) {

RETURN_FALSE;

}

argv = ecalloc(argc, sizeof(*argv));

pos = ecalloc(argc, sizeof(*pos));

argc_each = ecalloc(ra->count, sizeof(*argc_each));

/* associate each key to a redis node */

i = 0;

ZEND_HASH_FOREACH_VAL(h_keys, data) {

/* If we need to represent a long key as a string */

unsigned int key_len;

char kbuf[40], *key_lookup;

/* Handle the possibility that we're a reference */

ZVAL_DEREF(data);

/* Convert to a string for hash lookup if it isn't one */

if (Z_TYPE_P(data) == IS_STRING) {

key_len = Z_STRLEN_P(data);

key_lookup = Z_STRVAL_P(data);

} else if (Z_TYPE_P(data) == IS_LONG) {

key_len = snprintf(kbuf, sizeof(kbuf), ZEND_LONG_FMT, Z_LVAL_P(data));

key_lookup = (char*)kbuf;

} else {

/* phpredis proper can only use string or long keys, so restrict to that here */

php_error_docref(NULL, E_ERROR, "MGET: all keys must be strings or longs");

RETVAL_FALSE;

goto cleanup;

}

/* Find our node */

if (ra_find_node(ra, key_lookup, key_len, &pos[i]) == NULL) {

RETVAL_FALSE;

goto cleanup;

}

argc_each[pos[i]]++; /* count number of keys per node */

argv[i++] = data;

} ZEND_HASH_FOREACH_END();

/* prepare call */

array_init(&z_tmp_array);

ZVAL_STRINGL(&z_fun, "MGET", sizeof("MGET") - 1);

/* calls */

for(n = 0; n < ra->count; ++n) { /* for each node */

/* We don't even need to make a call to this node if no keys go there */

if(!argc_each[n]) continue;

/* copy args for MGET call on node. */

array_init(&z_arg);

for(i = 0; i < argc; ++i) {

if (pos[i] == n) {

ZVAL_ZVAL(&z_ret, argv[i], 1, 0);

add_next_index_zval(&z_arg, &z_ret);

}

}

/* call MGET on the node */

call_user_function(&redis_ce->function_table, &ra->redis[n], &z_fun, &z_ret, 1, &z_arg);

/* cleanup args array */

zval_dtor(&z_arg);

/* Error out if we didn't get a proper response */

if (Z_TYPE(z_ret) != IS_ARRAY) {

/* cleanup */

zval_dtor(&z_ret);

zval_dtor(&z_tmp_array);

RETVAL_FALSE;

goto cleanup;

}

for(i = 0, j = 0; i < argc; ++i) {

if (pos[i] != n || (z_cur = zend_hash_index_find(Z_ARRVAL(z_ret), j++)) == NULL) continue;

ZVAL_ZVAL(&z_arg, z_cur, 1, 0);

add_index_zval(&z_tmp_array, i, &z_arg);

}

zval_dtor(&z_ret);

}

zval_dtor(&z_fun);

array_init(return_value);

/* copy temp array in the right order to return_value */

for(i = 0; i < argc; ++i) {

if ((z_cur = zend_hash_index_find(Z_ARRVAL(z_tmp_array), i)) == NULL) continue;

ZVAL_ZVAL(&z_arg, z_cur, 1, 0);

add_next_index_zval(return_value, &z_arg);

}

/* cleanup */

zval_dtor(&z_tmp_array);

cleanup:

efree(argv);

efree(pos);

efree(argc_each);

}

/* MSET will distribute the call to several nodes and regroup the values. */

PHP_METHOD(RedisArray, mset)

{

zval *object, *z_keys, z_argarray, *data, z_fun, z_ret, **argv;

int i = 0, n, *pos, argc, *argc_each, key_len;

RedisArray *ra;

HashTable *h_keys;

char *key, kbuf[40];

zend_string **keys, *zkey;

zend_ulong idx;

if ((ra = redis_array_get(getThis())) == NULL) {

RETURN_FALSE;

}

/* Multi/exec support */

HANDLE_MULTI_EXEC(ra, "MSET", sizeof("MSET") - 1);

if (zend_parse_method_parameters(ZEND_NUM_ARGS(), getThis(), "Oa",

&object, redis_array_ce, &z_keys) == FAILURE)

{

RETURN_FALSE;

}

/* init data structures */

h_keys = Z_ARRVAL_P(z_keys);

if ((argc = zend_hash_num_elements(h_keys)) == 0) {

RETURN_FALSE;

}

argv = ecalloc(argc, sizeof(*argv));

pos = ecalloc(argc, sizeof(*pos));

keys = ecalloc(argc, sizeof(*keys));

argc_each = ecalloc(ra->count, sizeof(*argc_each));

/* associate each key to a redis node */

ZEND_HASH_FOREACH_KEY_VAL(h_keys, idx, zkey, data) {

/* If the key isn't a string, make a string representation of it */

if (zkey) {

key_len = ZSTR_LEN(zkey);

key = ZSTR_VAL(zkey);

} else {

key_len = snprintf(kbuf, sizeof(kbuf), ZEND_ULONG_FMT, idx);

key = kbuf;

}

if (ra_find_node(ra, key, (int)key_len, &pos[i]) == NULL) {

for (n = 0; n < i; ++n) {

zend_string_release(keys[n]);

}

efree(keys);

efree(argv);

efree(pos);

efree(argc_each);

RETURN_FALSE;

}

argc_each[pos[i]]++; /* count number of keys per node */

keys[i] = zkey ? zend_string_copy(zkey) : zend_string_init(key, key_len, 0);

argv[i] = data;

i++;

} ZEND_HASH_FOREACH_END();

/* prepare call */

ZVAL_STRINGL(&z_fun, "MSET", sizeof("MSET") - 1);

/* calls */

for (n = 0; n < ra->count; ++n) { /* for each node */

/* We don't even need to make a call to this node if no keys go there */

if(!argc_each[n]) continue;

int found = 0;

/* copy args */

array_init(&z_argarray);

for(i = 0; i < argc; ++i) {

if(pos[i] != n) continue;

if (argv[i] == NULL) {

ZVAL_NULL(&z_ret);

} else {

ZVAL_ZVAL(&z_ret, argv[i], 1, 0);

}

add_assoc_zval_ex(&z_argarray, ZSTR_VAL(keys[i]), ZSTR_LEN(keys[i]), &z_ret);

found++;

}

if(!found) {

zval_dtor(&z_argarray);

continue; /* don't run empty MSETs */

}

if(ra->index) { /* add MULTI */

ra_index_multi(&ra->redis[n], MULTI);

call_user_function(&redis_ce->function_table, &ra->redis[n], &z_fun, &z_ret, 1, &z_argarray);

ra_index_keys(&z_argarray, &ra->redis[n]); /* use SADD to add keys to node index */

ra_index_exec(&ra->redis[n], NULL, 0); /* run EXEC */

} else {

call_user_function(&redis_ce->function_table, &ra->redis[n], &z_fun, &z_ret, 1, &z_argarray);

}

zval_dtor(&z_argarray);

zval_dtor(&z_ret);

}

zval_dtor(&z_fun);

/* Free any keys that we needed to allocate memory for, because they weren't strings */

for(i = 0; i < argc; i++) {

zend_string_release(keys[i]);

}

/* cleanup */

efree(keys);

efree(argv);

efree(pos);

efree(argc_each);

RETURN_TRUE;

}

/* Generic handler for DEL or UNLINK which behave identically to phpredis */

static void

ra_generic_del(INTERNAL_FUNCTION_PARAMETERS, char *kw, int kw_len)

{

zval *object, z_keys, z_fun, *data, z_ret, *z_args, **argv;

int i, n, *pos, argc = ZEND_NUM_ARGS(), *argc_each, free_zkeys = 0;

HashTable *h_keys;

RedisArray *ra;

long total = 0;

if ((ra = redis_array_get(getThis())) == NULL) {

RETURN_FALSE;

}

/* Multi/exec support */

HANDLE_MULTI_EXEC(ra, kw, kw_len);