Repository navigation
Expand file tree
/
Copy pathredis_cmd.h
More file actions
103 lines (77 loc) · 3.24 KB
/
Copy pathredis_cmd.h
File metadata and controls
103 lines (77 loc) · 3.24 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
#ifndef REDIS_CMD_H
#define REDIS_CMD_H
#include "php.h"
#include <zend_smart_string.h>
#include "common.h"
typedef struct RedisCmd {
RedisSock *redis_sock;
short slot;
smart_string s;
RedisCmdCtx ctx;
uint32_t argc;
char *head;
} RedisCmd;
#define redis_cmd_create_literal(redis_sock, kw) \
redis_cmd_create(redis_sock, kw, sizeof(kw) - 1)
#define redis_cmd_cat_literal(cmd, lit) \
redis_cmd_cat_str(cmd, lit, sizeof(lit) - 1)
#define redis_cmd_cat_literal_if(cmd, opt, lit) do { \
if (opt) \
redis_cmd_cat_str(cmd, lit, sizeof(lit) - 1); \
} while (0)
#define redis_cmd_cat_zstr_if(cmd, opt, zstr) do { \
if (opt) \
redis_cmd_cat_zstr(cmd, zstr); \
} while (0)
RedisCmd *redis_cmd_create(RedisSock *redis_sock, const char *kw, size_t kwlen);
void redis_cmd_reset(RedisCmd *cmd, const char *kw, size_t kwlen);
void redis_cmd_free_ex(RedisCmd *cmd, int free_ctx);
void redis_cmd_free_ctx(RedisCmd *cmd);
static inline RedisCmdCtx redis_cmd_pop_ctx(RedisCmd *cmd) {
RedisCmdCtx ctx = cmd->ctx;
memset(&cmd->ctx, 0, sizeof(RedisCmdCtx));
return ctx;
}
static inline void redis_cmd_free(RedisCmd *cmd) {
redis_cmd_free_ex(cmd, 0);
}
void redis_cmd_cat_zstr(RedisCmd *cmd, zend_string *str);
void redis_cmd_cat_str(RedisCmd *cmd, const char *str, size_t len);
void redis_cmd_cat_long(RedisCmd *cmd, zend_long lval);
void redis_cmd_cat_ulong(RedisCmd *cmd, zend_ulong ulval);
void redis_cmd_cat_u64(RedisCmd *cmd, uint64_t u64);
void redis_cmd_cat_double(RedisCmd *cmd, double dval);
zend_bool redis_cmd_cat_key_zval(RedisCmd *cmd, zval *zv);
zend_bool redis_cmd_cat_key_zstr(RedisCmd *cmd, zend_string *key);
zend_bool redis_cmd_cat_key_long(RedisCmd *cmd, zend_long key);
zend_bool redis_cmd_cat_key_str(RedisCmd *cmd, const char *key, size_t len);
zend_bool redis_cmd_cat_key_arrkey(RedisCmd *cmd, zend_string *str, zend_ulong idx);
void redis_cmd_cat_zval(RedisCmd *cmd, zval *zv);
void redis_cmd_cat_zval_zstr(RedisCmd *cmd, zval *zv);
void redis_cmd_cat_arrkey(RedisCmd *cmd, zend_string *str, zend_ulong idx);
void redis_cmd_set_ctx_ex(RedisCmd *cmd, void *ptr, RedisCmdCtxDtor *dtor);
static zend_always_inline void redis_cmd_set_ctx(RedisCmd *cmd, void *ptr) {
redis_cmd_set_ctx_ex(cmd, ptr, NULL);
}
static zend_always_inline void
redis_cmd_set_ctx_mode(RedisCmd *cmd, RedisCtxMode mode) {
cmd->ctx.mode = mode;
cmd->ctx.dtor = NULL;
}
void redis_cmd_randslot(RedisCmd *cmd);
static inline void redis_cmd_ctx_efree(void *ptr) {
if (ptr) efree(ptr);
}
RedisCmd *redis_cmd_fmt(RedisSock *redis_sock, const char *kw, const char *fmt, ...);
RedisCmd *redis_cmd_fmt_ex(RedisSock *redis_sock, const char *kw, size_t kw_len,
const char *fmt, ...);
const char *redis_cmd_str(RedisCmd *cmd);
size_t redis_cmd_len(RedisCmd *cmd);
/* Specialized thin wrapper around smart_str for the times we want to construct
* one buffer with 1-N commands */
void resp_str_cat_str(smart_str *s, const char *str, zend_ulong len);
void resp_str_cat_cmd(smart_str *s, zend_ulong argc, const char *kw, size_t len);
void resp_str_cat_zstr(smart_str *s, zend_string *str);
#define resp_str_cat_cmd_literal(s_, kw_, argc_) \
resp_str_cat_cmd(s_, argc_, kw_, sizeof(kw_) - 1)
#endif // REDIS_CMD_H