#include "php.h"

#include "php_ini.h"

#ifndef REDIS_COMMON_H

#define REDIS_COMMON_H

#define PHPREDIS_NOTUSED(v) ((void)v)

#include "zend_llist.h"

#include <ext/standard/php_var.h>

#include <ext/standard/php_math.h>

#include <zend_smart_str.h>

#include <ext/standard/php_smart_string.h>

#define PHPREDIS_GET_OBJECT(class_entry, o) (class_entry *)((char *)o - XtOffsetOf(class_entry, std))

#define PHPREDIS_ZVAL_GET_OBJECT(class_entry, z) PHPREDIS_GET_OBJECT(class_entry, Z_OBJ_P(z))

/* NULL check so Eclipse doesn't go crazy */

#ifndef NULL

#define NULL ((void *) 0)

#endif

typedef enum {

REDIS_SOCK_STATUS_FAILED = -1,

REDIS_SOCK_STATUS_DISCONNECTED,

REDIS_SOCK_STATUS_CONNECTED,

REDIS_SOCK_STATUS_READY

} redis_sock_status;

#define _NL "\r\n"

/* properties */

#define REDIS_NOT_FOUND 0

#define REDIS_STRING 1

#define REDIS_SET 2

#define REDIS_LIST 3

#define REDIS_ZSET 4

#define REDIS_HASH 5

#define REDIS_STREAM 6

#ifdef PHP_WIN32

#define PHP_REDIS_API __declspec(dllexport)

#define phpredis_atoi64(p) _atoi64((p))

#else

#define PHP_REDIS_API

#define phpredis_atoi64(p) atoll((p))

#endif

/* reply types */

typedef enum _REDIS_REPLY_TYPE {

TYPE_EOF = -1,

TYPE_LINE = '+',

TYPE_INT = ':',

TYPE_ERR = '-',

TYPE_BULK = '$',

TYPE_MULTIBULK = '*'

} REDIS_REPLY_TYPE;

/* SCAN variants */

typedef enum _REDIS_SCAN_TYPE {

TYPE_SCAN,

TYPE_SSCAN,

TYPE_HSCAN,

TYPE_ZSCAN

} REDIS_SCAN_TYPE;

/* PUBSUB subcommands */

typedef enum _PUBSUB_TYPE {

PUBSUB_CHANNELS,

PUBSUB_NUMSUB,

PUBSUB_NUMPAT

} PUBSUB_TYPE;

/* options */

#define REDIS_OPT_SERIALIZER 1

#define REDIS_OPT_PREFIX 2

#define REDIS_OPT_READ_TIMEOUT 3

#define REDIS_OPT_SCAN 4

#define REDIS_OPT_FAILOVER 5

#define REDIS_OPT_TCP_KEEPALIVE 6

#define REDIS_OPT_COMPRESSION 7

#define REDIS_OPT_REPLY_LITERAL 8

#define REDIS_OPT_COMPRESSION_LEVEL 9

#define REDIS_OPT_NULL_MBULK_AS_NULL 10

/* cluster options */

#define REDIS_FAILOVER_NONE 0

#define REDIS_FAILOVER_ERROR 1

#define REDIS_FAILOVER_DISTRIBUTE 2

#define REDIS_FAILOVER_DISTRIBUTE_SLAVES 3

/* serializers */

typedef enum {

REDIS_SERIALIZER_NONE,

REDIS_SERIALIZER_PHP,

REDIS_SERIALIZER_IGBINARY,

REDIS_SERIALIZER_MSGPACK,

REDIS_SERIALIZER_JSON

} redis_serializer;

/* compression */

#define REDIS_COMPRESSION_NONE 0

#define REDIS_COMPRESSION_LZF 1

#define REDIS_COMPRESSION_ZSTD 2

#define REDIS_COMPRESSION_LZ4 3

/* SCAN options */

#define REDIS_SCAN_NORETRY 0

#define REDIS_SCAN_RETRY 1

#define REDIS_SCAN_PREFIX 2

#define REDIS_SCAN_NOPREFIX 3

/* GETBIT/SETBIT offset range limits */

#define BITOP_MIN_OFFSET 0

#define BITOP_MAX_OFFSET 4294967295U

/* Transaction modes */

#define ATOMIC 0

#define MULTI 1

#define PIPELINE 2

#define IS_ATOMIC(redis_sock) (redis_sock->mode == ATOMIC)

#define IS_MULTI(redis_sock) (redis_sock->mode & MULTI)

#define IS_PIPELINE(redis_sock) (redis_sock->mode & PIPELINE)

#define PIPELINE_ENQUEUE_COMMAND(cmd, cmd_len) do { \

if (redis_sock->pipeline_cmd == NULL) { \

redis_sock->pipeline_cmd = zend_string_init(cmd, cmd_len, 0); \

} else { \

size_t pipeline_len = ZSTR_LEN(redis_sock->pipeline_cmd); \

redis_sock->pipeline_cmd = zend_string_realloc(redis_sock->pipeline_cmd, pipeline_len + cmd_len, 0); \

memcpy(&ZSTR_VAL(redis_sock->pipeline_cmd)[pipeline_len], cmd, cmd_len); \

} \

} while (0)

#define SOCKET_WRITE_COMMAND(redis_sock, cmd, cmd_len) \

if(redis_sock_write(redis_sock, cmd, cmd_len) < 0) { \

efree(cmd); \

RETURN_FALSE; \

}

#define REDIS_SAVE_CALLBACK(callback, closure_context) do { \

fold_item *fi = malloc(sizeof(fold_item)); \

fi->fun = callback; \

fi->ctx = closure_context; \

fi->next = NULL; \

if (redis_sock->current) { \

redis_sock->current->next = fi; \

} \

redis_sock->current = fi; \

if (NULL == redis_sock->head) { \

redis_sock->head = redis_sock->current; \

} \

} while (0)

#define REDIS_PROCESS_REQUEST(redis_sock, cmd, cmd_len) \

if (IS_PIPELINE(redis_sock)) { \

PIPELINE_ENQUEUE_COMMAND(cmd, cmd_len); \

} else { \

SOCKET_WRITE_COMMAND(redis_sock, cmd, cmd_len); \

} \

efree(cmd);

#define REDIS_PROCESS_RESPONSE_CLOSURE(function, closure_context) \

if (!IS_PIPELINE(redis_sock)) { \

if (redis_response_enqueued(redis_sock) != SUCCESS) { \

RETURN_FALSE; \

} \

} \

REDIS_SAVE_CALLBACK(function, closure_context); \

RETURN_ZVAL(getThis(), 1, 0); \

#define REDIS_PROCESS_RESPONSE(function) else { \

REDIS_PROCESS_RESPONSE_CLOSURE(function, NULL) \

}

/* Clear redirection info */

#define REDIS_MOVED_CLEAR(redis_sock) \

redis_sock->redir_slot = 0; \

redis_sock->redir_port = 0; \

redis_sock->redir_type = MOVED_NONE; \

/* Process a command assuming our command where our command building

* function is redis_<cmdname>_cmd */

#define REDIS_PROCESS_CMD(cmdname, resp_func) \

RedisSock *redis_sock; char *cmd; int cmd_len; void *ctx=NULL; \

if ((redis_sock = redis_sock_get(getThis(), 0)) == NULL || \

redis_##cmdname##_cmd(INTERNAL_FUNCTION_PARAM_PASSTHRU,redis_sock, \

&cmd, &cmd_len, NULL, &ctx)==FAILURE) { \

RETURN_FALSE; \

} \

REDIS_PROCESS_REQUEST(redis_sock, cmd, cmd_len); \

if (IS_ATOMIC(redis_sock)) { \

resp_func(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, NULL, ctx); \

} else { \

REDIS_PROCESS_RESPONSE_CLOSURE(resp_func, ctx) \

}

/* Process a command but with a specific command building function

* and keyword which is passed to us*/

#define REDIS_PROCESS_KW_CMD(kw, cmdfunc, resp_func) \

RedisSock *redis_sock; char *cmd; int cmd_len; void *ctx=NULL; \

if ((redis_sock = redis_sock_get(getThis(), 0)) == NULL || \

cmdfunc(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, kw, &cmd, \

&cmd_len, NULL, &ctx)==FAILURE) { \

RETURN_FALSE; \

} \

REDIS_PROCESS_REQUEST(redis_sock, cmd, cmd_len); \

if (IS_ATOMIC(redis_sock)) { \

resp_func(INTERNAL_FUNCTION_PARAM_PASSTHRU, redis_sock, NULL, ctx); \

} else { \

REDIS_PROCESS_RESPONSE_CLOSURE(resp_func, ctx) \

}

/* Case sensitive compare against compile-time static string */

#define REDIS_STRCMP_STATIC(s, len, sstr) \

(len == sizeof(sstr) - 1 && !strncmp(s, sstr, len))

/* Case insensitive compare against compile-time static string */

#define REDIS_STRICMP_STATIC(s, len, sstr) \

(len == sizeof(sstr) - 1 && !strncasecmp(s, sstr, len))

/* Test if a zval is a string and (case insensitive) matches a static string */

#define ZVAL_STRICMP_STATIC(zv, sstr) \

REDIS_STRICMP_STATIC(Z_STRVAL_P(zv), Z_STRLEN_P(zv), sstr)

/* Case insensitive compare of a zend_string to a static string */

#define ZSTR_STRICMP_STATIC(zs, sstr) \

REDIS_STRICMP_STATIC(ZSTR_VAL(zs), ZSTR_LEN(zs), sstr)

/* Extended SET argument detection */

#define ZSTR_IS_EX_ARG(zs) ZSTR_STRICMP_STATIC(zs, "EX")

#define ZSTR_IS_PX_ARG(zs) ZSTR_STRICMP_STATIC(zs, "PX")

#define ZSTR_IS_NX_ARG(zs) ZSTR_STRICMP_STATIC(zs, "NX")

#define ZSTR_IS_XX_ARG(zs) ZSTR_STRICMP_STATIC(zs, "XX")

#define ZVAL_IS_NX_XX_ARG(zv) (ZVAL_STRICMP_STATIC(zv, "NX") || ZVAL_STRICMP_STATIC(zv, "XX"))

#define ZSTR_IS_EX_PX_ARG(a) (ZSTR_IS_EX_ARG(a) || ZSTR_IS_PX_ARG(a))

/* Given a string and length, validate a zRangeByLex argument. The semantics

* here are that the argument must start with '(' or '[' or be just the char

* '+' or '-' */

#define IS_LEX_ARG(s,l) \

(l>0 && (*s=='(' || *s=='[' || (l==1 && (*s=='+' || *s=='-'))))

#define REDIS_ENABLE_MODE(redis_sock, m) (redis_sock->mode |= m)

#define REDIS_DISABLE_MODE(redis_sock, m) (redis_sock->mode &= ~m)

/* HOST_NAME_MAX doesn't exist everywhere */

#ifndef HOST_NAME_MAX

#if defined(_POSIX_HOST_NAME_MAX)

#define HOST_NAME_MAX _POSIX_HOST_NAME_MAX

#elif defined(MAXHOSTNAMELEN)

#define HOST_NAME_MAX MAXHOSTNAMELEN

#else

#define HOST_NAME_MAX 255

#endif

#endif

/* {{{ struct RedisSock */

typedef struct {

php_stream *stream;

php_stream_context *stream_ctx;

zend_string *host;

int port;

zend_string *user;

zend_string *pass;

double timeout;

double read_timeout;

long retry_interval;

redis_sock_status status;

int persistent;

int watching;

zend_string *persistent_id;

redis_serializer serializer;

int compression;

int compression_level;

long dbNumber;

zend_string *prefix;

short mode;

struct fold_item *head;

struct fold_item *current;

zend_string *pipeline_cmd;

zend_string *err;

int scan;

int readonly;

int reply_literal;

int null_mbulk_as_null;

int tcp_keepalive;

} RedisSock;

/* }}} */

/* Redis response handler function callback prototype */

typedef void (*ResultCallback)(INTERNAL_FUNCTION_PARAMETERS, RedisSock *redis_sock, zval *z_tab, void *ctx);

typedef int (*FailableResultCallback)(INTERNAL_FUNCTION_PARAMETERS, RedisSock*, zval*, void*);

typedef struct fold_item {

FailableResultCallback fun;

void *ctx;

struct fold_item *next;

} fold_item;

typedef struct {

zend_llist list;

int nb_active;

} ConnectionPool;

typedef struct {

RedisSock *sock;

zend_object std;

} redis_object;

/** Argument info for any function expecting 0 args */

ZEND_BEGIN_ARG_INFO_EX(arginfo_void, 0, 0, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key, 0, 0, 1)

ZEND_ARG_INFO(0, key)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_value, 0, 0, 1)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_value, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_expire_value, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, expire)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_newkey, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, newkey)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pairs, 0, 0, 1)

ZEND_ARG_ARRAY_INFO(0, pairs, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_nkeys, 0, 0, 1)

ZEND_ARG_INFO(0, key)

ZEND_ARG_VARIADIC_INFO(0, other_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_dst_nkeys, 0, 0, 2)

ZEND_ARG_INFO(0, dst)

ZEND_ARG_INFO(0, key)

ZEND_ARG_VARIADIC_INFO(0, other_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_min_max, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, min)

ZEND_ARG_INFO(0, max)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_member, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, member)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_member_value, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, member)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_members, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, member)

ZEND_ARG_VARIADIC_INFO(0, other_members)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_timestamp, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, timestamp)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_offset, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, offset)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_offset_value, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, offset)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_swapdb, 0, 0, 2)

ZEND_ARG_INFO(0, srcdb)

ZEND_ARG_INFO(0, dstdb)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_key_start_end, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, start)

ZEND_ARG_INFO(0, end)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_echo, 0, 0, 1)

ZEND_ARG_INFO(0, msg)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_expire, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, timeout)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_set, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, value)

ZEND_ARG_INFO(0, opts)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_lset, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, index)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_blrpop, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, timeout_or_key)

ZEND_ARG_VARIADIC_INFO(0, extra_args)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_linsert, 0, 0, 4)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, position)

ZEND_ARG_INFO(0, pivot)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_lindex, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, index)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_brpoplpush, 0, 0, 3)

ZEND_ARG_INFO(0, src)

ZEND_ARG_INFO(0, dst)

ZEND_ARG_INFO(0, timeout)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_rpoplpush, 0, 0, 2)

ZEND_ARG_INFO(0, src)

ZEND_ARG_INFO(0, dst)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_sadd_array, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, options, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_srand_member, 0, 0, 1)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, count)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zadd, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, score)

ZEND_ARG_INFO(0, value)

ZEND_ARG_VARIADIC_INFO(0, extra_args)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zpop, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, count)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zincrby, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, value)

ZEND_ARG_INFO(0, member)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_hmget, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, keys, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_hmset, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, pairs, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_bitop, 0, 0, 3)

ZEND_ARG_INFO(0, operation)

ZEND_ARG_INFO(0, ret_key)

ZEND_ARG_INFO(0, key)

ZEND_ARG_VARIADIC_INFO(0, other_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_bitpos, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, bit)

ZEND_ARG_INFO(0, start)

ZEND_ARG_INFO(0, end)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_ltrim, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, start)

ZEND_ARG_INFO(0, stop)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_publish, 0, 0, 2)

ZEND_ARG_INFO(0, channel)

ZEND_ARG_INFO(0, message)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pfadd, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, elements, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_pfmerge, 0, 0, 2)

ZEND_ARG_INFO(0, dstkey)

ZEND_ARG_ARRAY_INFO(0, keys, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_restore, 0, 0, 3)

ZEND_ARG_INFO(0, ttl)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_smove, 0, 0, 3)

ZEND_ARG_INFO(0, src)

ZEND_ARG_INFO(0, dst)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zrange, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, start)

ZEND_ARG_INFO(0, end)

ZEND_ARG_INFO(0, scores)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zrangebyscore, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, start)

ZEND_ARG_INFO(0, end)

ZEND_ARG_ARRAY_INFO(0, options, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zrangebylex, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, min)

ZEND_ARG_INFO(0, max)

ZEND_ARG_INFO(0, offset)

ZEND_ARG_INFO(0, limit)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_zstore, 0, 0, 2)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, keys, 0)

ZEND_ARG_ARRAY_INFO(0, weights, 1)

ZEND_ARG_INFO(0, aggregate)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_sort, 0, 0, 1)

ZEND_ARG_INFO(0, key)

ZEND_ARG_ARRAY_INFO(0, options, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_object, 0, 0, 2)

ZEND_ARG_INFO(0, field)

ZEND_ARG_INFO(0, key)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_subscribe, 0, 0, 2)

ZEND_ARG_ARRAY_INFO(0, channels, 0)

ZEND_ARG_INFO(0, callback)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_psubscribe, 0, 0, 2)

ZEND_ARG_ARRAY_INFO(0, patterns, 0)

ZEND_ARG_INFO(0, callback)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_unsubscribe, 0, 0, 1)

ZEND_ARG_INFO(0, channel)

ZEND_ARG_VARIADIC_INFO(0, other_channels)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_punsubscribe, 0, 0, 1)

ZEND_ARG_INFO(0, pattern)

ZEND_ARG_VARIADIC_INFO(0, other_patterns)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_eval, 0, 0, 1)

ZEND_ARG_INFO(0, script)

ZEND_ARG_INFO(0, args)

ZEND_ARG_INFO(0, num_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_evalsha, 0, 0, 1)

ZEND_ARG_INFO(0, script_sha)

ZEND_ARG_INFO(0, args)

ZEND_ARG_INFO(0, num_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_getoption, 0, 0, 1)

ZEND_ARG_INFO(0, option)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_setoption, 0, 0, 2)

ZEND_ARG_INFO(0, option)

ZEND_ARG_INFO(0, value)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_watch, 0, 0, 1)

ZEND_ARG_INFO(0, key)

ZEND_ARG_VARIADIC_INFO(0, other_keys)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_command, 0, 0, 0)

ZEND_ARG_VARIADIC_INFO(0, args)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_rawcommand, 0, 0, 1)

ZEND_ARG_INFO(0, cmd)

ZEND_ARG_VARIADIC_INFO(0, args)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_geoadd, 0, 0, 4)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, lng)

ZEND_ARG_INFO(0, lat)

ZEND_ARG_INFO(0, member)

ZEND_ARG_VARIADIC_INFO(0, other_triples)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_geodist, 0, 0, 3)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, src)

ZEND_ARG_INFO(0, dst)

ZEND_ARG_INFO(0, unit)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_georadius, 0, 0, 5)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, lng)

ZEND_ARG_INFO(0, lan)

ZEND_ARG_INFO(0, radius)

ZEND_ARG_INFO(0, unit)

ZEND_ARG_ARRAY_INFO(0, opts, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_georadiusbymember, 0, 0, 4)

ZEND_ARG_INFO(0, key)

ZEND_ARG_INFO(0, member)

ZEND_ARG_INFO(0, radius)

ZEND_ARG_INFO(0, unit)

ZEND_ARG_ARRAY_INFO(0, opts, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xadd, 0, 0, 3)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_id)

ZEND_ARG_ARRAY_INFO(0, arr_fields, 0)

ZEND_ARG_INFO(0, i_maxlen)

ZEND_ARG_INFO(0, boo_approximate)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xpending, 0, 0, 2)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_group)

ZEND_ARG_INFO(0, str_start)

ZEND_ARG_INFO(0, str_end)

ZEND_ARG_INFO(0, i_count)

ZEND_ARG_INFO(0, str_consumer)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xrange, 0, 0, 3)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_start)

ZEND_ARG_INFO(0, str_end)

ZEND_ARG_INFO(0, i_count)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xread, 0, 0, 1)

ZEND_ARG_ARRAY_INFO(0, arr_streams, 0)

ZEND_ARG_INFO(0, i_count)

ZEND_ARG_INFO(0, i_block)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xreadgroup, 0, 0, 3)

ZEND_ARG_INFO(0, str_group)

ZEND_ARG_INFO(0, str_consumer)

ZEND_ARG_ARRAY_INFO(0, arr_streams, 0)

ZEND_ARG_INFO(0, i_count)

ZEND_ARG_INFO(0, i_block)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xack, 0, 0, 3)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_group)

ZEND_ARG_ARRAY_INFO(0, arr_ids, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xclaim, 0, 0, 5)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_group)

ZEND_ARG_INFO(0, str_consumer)

ZEND_ARG_INFO(0, i_min_idle)

ZEND_ARG_ARRAY_INFO(0, arr_ids, 0)

ZEND_ARG_ARRAY_INFO(0, arr_opts, 0)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xgroup, 0, 0, 1)

ZEND_ARG_INFO(0, str_operation)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_arg1)

ZEND_ARG_INFO(0, str_arg2)

ZEND_ARG_INFO(0, str_arg3)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xinfo, 0, 0, 1)

ZEND_ARG_INFO(0, str_cmd)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, str_group)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xtrim, 0, 0, 2)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_INFO(0, i_maxlen)

ZEND_ARG_INFO(0, boo_approximate)

ZEND_END_ARG_INFO()

ZEND_BEGIN_ARG_INFO_EX(arginfo_xdel, 0, 0, 2)

ZEND_ARG_INFO(0, str_key)

ZEND_ARG_ARRAY_INFO(0, arr_ids, 0)

ZEND_END_ARG_INFO()

#endif