Home
last modified time | relevance | path

Searched refs:redisReply (Results 1 – 25 of 302) sorted by relevance

12345678910>>...13

/dports/net/zerotier/ZeroTierOne-1.8.3/ext/redis-plus-plus-1.1.1/install/centos8/include/sw/redis++/
H A Dreply.h49 inline T parse(redisReply &reply) { in parse()
73 T parse(ParseTag<T>, redisReply &reply);
76 T parse(ParseTag<T>, redisReply &reply);
81 inline bool is_error(redisReply &reply) { in is_error()
85 inline bool is_nil(redisReply &reply) { in is_nil()
89 inline bool is_string(redisReply &reply) { in is_string()
93 inline bool is_status(redisReply &reply) { in is_status()
101 inline bool is_array(redisReply &reply) { in is_array()
105 std::string to_status(redisReply &reply);
111 void rewrite_set_reply(redisReply &reply);
[all …]
/dports/net/zerotier/ZeroTierOne-1.8.3/ext/redis-plus-plus-1.1.1/install/macos/include/sw/redis++/
H A Dreply.h49 inline T parse(redisReply &reply) { in parse()
73 T parse(ParseTag<T>, redisReply &reply);
76 T parse(ParseTag<T>, redisReply &reply);
81 inline bool is_error(redisReply &reply) { in is_error()
85 inline bool is_nil(redisReply &reply) { in is_nil()
89 inline bool is_string(redisReply &reply) { in is_string()
93 inline bool is_status(redisReply &reply) { in is_status()
101 inline bool is_array(redisReply &reply) { in is_array()
105 std::string to_status(redisReply &reply);
111 void rewrite_set_reply(redisReply &reply);
[all …]
/dports/net/zerotier/ZeroTierOne-1.8.3/ext/redis-plus-plus-1.1.1/src/sw/redis++/
H A Dreply.h49 inline T parse(redisReply &reply) { in parse()
73 T parse(ParseTag<T>, redisReply &reply);
76 T parse(ParseTag<T>, redisReply &reply);
81 inline bool is_error(redisReply &reply) { in is_error()
85 inline bool is_nil(redisReply &reply) { in is_nil()
89 inline bool is_string(redisReply &reply) { in is_string()
93 inline bool is_status(redisReply &reply) { in is_status()
101 inline bool is_array(redisReply &reply) { in is_array()
105 std::string to_status(redisReply &reply);
111 void rewrite_set_reply(redisReply &reply);
[all …]
H A Dreply.cpp25 std::string to_status(redisReply &reply) { in to_status()
39 std::string parse(ParseTag<std::string>, redisReply &reply) { in parse()
53 long long parse(ParseTag<long long>, redisReply &reply) { in parse()
61 double parse(ParseTag<double>, redisReply &reply) { in parse()
65 bool parse(ParseTag<bool>, redisReply &reply) { in parse()
77 void parse(ParseTag<void>, redisReply &reply) { in parse()
96 void rewrite_set_reply(redisReply &reply) { in rewrite_set_reply()
117 void rewrite_georadius_reply(redisReply &reply) { in rewrite_georadius_reply()
126 bool is_flat_array(redisReply &reply) { in is_flat_array()
/dports/games/minetest/minetest-5.4.1/src/database/
H A Ddatabase-redis.cpp58 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, "AUTH %s", tmp.c_str())); in Database_Redis()
76 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, "MULTI")); in beginSave()
85 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, "EXEC")); in endSave()
97 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, "HSET %s %s %b", in saveBlock()
120 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, in loadBlock()
163 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, in deleteBlock()
181 redisReply *reply = static_cast<redisReply *>(redisCommand(ctx, "HKEYS %s", hash.c_str())); in listAllLoadableBlocks()
/dports/games/freeminer/freeminer-0.4.10.4/src/
H A Ddatabase-redis.cpp68 redisReply *reply; in beginSave()
69 reply = (redisReply*) redisCommand(ctx, "MULTI"); in beginSave()
76 redisReply *reply; in endSave()
77 reply = (redisReply*) redisCommand(ctx, "EXEC"); in endSave()
87 redisReply *reply = (redisReply *)redisCommand(ctx, "HSET %s %s %b", in saveBlock()
110 redisReply *reply; in loadBlock()
111 reply = (redisReply*) redisCommand(ctx, "HGET %s %s", hash.c_str(), tmp.c_str()); in loadBlock()
126 redisReply *reply; in listAllLoadableBlocks()
127 reply = (redisReply*) redisCommand(ctx, "HKEYS %s", hash.c_str()); in listAllLoadableBlocks()
/dports/databases/webdis/webdis-0.1.18/src/formats/
H A Djson.c17 redisReply *reply = r; in json_reply()
92 json_expand_array(const redisReply *r);
144 json_expand_array(const redisReply *r) { in json_expand_array()
148 const redisReply *e; in json_expand_array()
184 const redisReply *id, *msg; in json_singlestream_list()
185 const redisReply *e; in json_singlestream_list()
218 const redisReply *sid, *msglist; in json_xreadstream_list()
219 const redisReply *e; in json_xreadstream_list()
250 const redisReply *own, *msgs; in json_xpending_list()
251 const redisReply *e; in json_xpending_list()
[all …]
H A Draw.c12 raw_wrap(const redisReply *r, size_t *sz);
17 redisReply *reply = r; in raw_reply()
43 redisReply *reply = NULL; in raw_ws_extract()
68 redisReply *ri = reply->element[i]; in raw_ws_extract()
103 raw_array(const redisReply *r, size_t *sz) { in raw_array()
112 redisReply *e = r->element[i]; in raw_array()
132 redisReply *e = r->element[i]; in raw_array()
154 raw_wrap(const redisReply *r, size_t *sz) { in raw_wrap()
H A Dcustom-type.c11 custom_array(struct cmd *cmd, const redisReply *r, size_t *sz);
16 redisReply *reply = r; in custom_type_reply()
76 custom_array(struct cmd *cmd, const redisReply *r, size_t *sz) { in custom_array()
88 redisReply *e = r->element[i]; in custom_array()
104 redisReply *e = r->element[i]; in custom_array()
H A Dmsgpack.c29 msgpack_wrap_redis_reply(const struct cmd *cmd, struct msg_out *, const redisReply *r);
34 redisReply *reply = r; in msgpack_reply()
137 msg_hgetall_reply(msgpack_packer* pk, const redisReply *r) { in msg_hgetall_reply()
149 redisReply *k = r->element[i], *v = r->element[i+1]; in msg_hgetall_reply()
167 msgpack_wrap_redis_reply(const struct cmd *cmd, struct msg_out *out, const redisReply *r) { in msgpack_wrap_redis_reply()
225 redisReply *e = r->element[i]; in msgpack_wrap_redis_reply()
/dports/security/gvm-libs/gvm-libs-21.4.3/util/
H A Dkb.c77 static redisReply *
89 redisReply *rep; in try_database_index()
228 redisReply *rep; in redis_release_db()
309 redisReply *rep; in redis_test_connection()
399 redisReply *rep; in redis_memory_purge()
467 redisReply *rep; in redis_direct_conn()
707 redisReply *rep; in redis_cmd()
757 redisReply *rep; in redis_get_single()
844 redisReply *rep; in redis_pop_str()
897 redisReply *rep; in redis_get_nvt()
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/modules/cnxcc/
H A Dcnxcc_redis.c293 redisReply *rpl = NULL; in redis_incr_by_double()
328 redisReply *rpl = NULL; in redis_incr_by_int()
346 redisReply *rpl = NULL; in redis_get_int()
371 redisReply *rpl = NULL; in redis_get_str()
417 redisReply *rpl = NULL; in redis_remove_credit_data()
434 redisReply *rpl = NULL; in redis_append_kill_list_member()
451 redisReply *rpl = NULL; in redis_remove_kill_list_member()
469 redisReply *rpl = NULL; in redis_insert_str_value()
497 redisReply *rpl = NULL; in redis_insert_int_value()
515 redisReply *rpl = NULL; in redis_insert_double_value()
[all …]
/dports/databases/redis-devel/redis-0e5b813/deps/hiredis/
H A Dtest.c93 redisReply *reply; in get_redis_version()
128 redisReply *reply; in select_database()
151 redisReply *reply; in send_hello()
162 redisReply *reply; in send_client_tracking()
170 redisReply *reply; in disconnect()
367 redisReply *reply; in test_append_formatted_commands()
729 redisReply *reply; in test_resp3_push_handler()
854 redisReply *reply; in test_blocking_connection()
961 redisReply *reply; in test_blocking_connection_timeouts()
1018 redisReply *reply; in test_blocking_io_errors()
[all …]
/dports/net/turnserver/coturn-4.5.2/src/apps/relay/dbdrivers/
H A Ddbd_redis.c372 redisReply *rget = NULL; in set_redis_realm_opt()
434 redisReply *rget = (redisReply *)redisCommand(rc, s); in redis_get_user_key()
465 redisReply *reply = (redisReply *)redisCommand(rc, s); in redis_get_oauth_key()
569 redisReply *reply = NULL; in redis_list_users()
709 redisReply *reply = NULL; in redis_list_secrets()
738 redisReply *rget = (redisReply *) redisCommand(rc, s); in redis_list_secrets()
1054 redisReply *reply = (redisReply*) redisCommand(rc, statement); in redis_get_ip_list()
1080 redisReply *rget = (redisReply *) redisCommand(rc, s); in redis_get_ip_list()
1124 redisReply *reply = (redisReply*) redisCommand(rc, "keys turn/origin/*"); in redis_reread_realms()
1154 redisReply *rget = (redisReply *) redisCommand(rc, s); in redis_reread_realms()
[all …]
/dports/databases/webdis/webdis-0.1.18/src/hiredis/
H A Dtest.c88 redisReply *reply; in get_redis_version()
123 redisReply *reply; in select_database()
146 redisReply *reply; in send_hello()
157 redisReply *reply; in send_client_tracking()
165 redisReply *reply; in disconnect()
362 redisReply *reply; in test_append_formatted_commands()
709 redisReply *reply; in test_resp3_push_handler()
830 redisReply *reply; in test_blocking_connection()
937 redisReply *reply; in test_blocking_connection_timeouts()
994 redisReply *reply; in test_blocking_io_errors()
[all …]
/dports/databases/p5-Redis-Fast/Redis-Fast-0.31/deps/hiredis/
H A Dtest.c88 redisReply *reply; in get_redis_version()
123 redisReply *reply; in select_database()
146 redisReply *reply; in send_hello()
157 redisReply *reply; in send_client_tracking()
165 redisReply *reply; in disconnect()
362 redisReply *reply; in test_append_formatted_commands()
695 redisReply *reply; in test_resp3_push_handler()
816 redisReply *reply; in test_blocking_connection()
923 redisReply *reply; in test_blocking_connection_timeouts()
980 redisReply *reply; in test_blocking_io_errors()
[all …]
/dports/www/nginx-full/nchan-1.2.12/src/store/redis/hiredis/
H A Dtest.c88 redisReply *reply; in get_redis_version()
123 redisReply *reply; in select_database()
146 redisReply *reply; in send_hello()
157 redisReply *reply; in send_client_tracking()
165 redisReply *reply; in disconnect()
362 redisReply *reply; in test_append_formatted_commands()
695 redisReply *reply; in test_resp3_push_handler()
816 redisReply *reply; in test_blocking_connection()
923 redisReply *reply; in test_blocking_connection_timeouts()
980 redisReply *reply; in test_blocking_io_errors()
[all …]
/dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/ssl_session_reuse/src/
H A Dpublish.cc150 …redisReply *reply = static_cast<redisReply *>(redisCommand(my_context.get(), "AUTH %s", redis_pass… in setup_connection()
173 ::redisReply *
182 ::redisReply *current_reply(nullptr); in send_publish()
196 …current_reply = static_cast<redisReply *>(::redisCommand(ctx.get(), "PUBLISH %s %s", msg.channel.c… in send_publish()
216 RedisPublisher::clear_reply(::redisReply *reply) in clear_reply()
237 ::redisReply *current_reply(nullptr); in runWorker()
369 redisReply *reply = nullptr; in get_session()
375 reply = static_cast<redisReply *>(redisCommand(conn->c_ptr(), "GET %s", channel.c_str())); in get_session()
395 redisReply *
404 redisReply *reply = nullptr; in set_session()
[all …]
/dports/databases/p5-Redis-hiredis/Redis-hiredis-0.11.0/
H A DRedis-hiredis.xs20 SV * _read_reply (Redis__hiredis self, redisReply *reply);
21 SV * _read_multi_bulk_reply (Redis__hiredis self, redisReply *reply);
22 SV * _read_bulk_reply (Redis__hiredis self, redisReply *reply);
24 SV * _read_reply (Redis__hiredis self, redisReply *reply) { in _read_reply()
35 SV * _read_multi_bulk_reply (Redis__hiredis self, redisReply *reply) { in _read_multi_bulk_reply()
46 SV * _read_bulk_reply (Redis__hiredis self, redisReply *reply) { in _read_bulk_reply()
125 redisReply *reply;
179 redisReply *reply;
/dports/devel/gearmand/gearmand-1.0.6/libgearman-server/plugins/queue/redis/
H A Dqueue.cc204 …redisReply *reply= (redisReply*)redisCommand(queue->redis(), "SET %b %b", &key[0], key.size(), dat… in _hiredis_add()
233 redisReply *reply= (redisReply*)redisCommand(queue->redis(), "DELETE %.*s", key.size(), &key[0]); in _hiredis_done()
252 …redisReply *reply= (redisReply*)redisCommand(queue->redis(), "KEYS %s", GEARMAN_QUEUE_GEARMAND_DEF… in _hiredis_replay()
284 …redisReply *get_reply= (redisReply*)redisCommand(queue->redis(), "GET %s", reply->element[x]->str); in _hiredis_replay()
/dports/net/zmap/zmap-2.1.1/lib/
H A Dredis.c125 static int chkerr(redisContext *rctx, redisReply *reply) in chkerr()
142 redisReply *reply = redisCommand(rctx, "FLUSHDB"); in redis_flush()
153 redisReply *reply = redisCommand(rctx, "EXISTS %s", name); in redis_existconf()
165 redisReply *reply = redisCommand(rctx, "DEL %s", name); in redis_delconf()
176 redisReply *reply = redisCommand(rctx, "SET %s %s", name, value); in redis_setconf()
187 redisReply *reply = redisCommand(rctx, "GET %s", name); in redis_getconf()
217 redisReply *reply = redisCommand(rctx, "%s %s", cmd, name); in redis_get_sizeof()
247 redisReply *reply = NULL; in redis_pull()
293 redisReply *reply = redisCommand(rctx, "%s %s", cmd, queuename); in redis_pull_one()
333 redisReply *reply = NULL; in redis_push()
[all …]
/dports/dns/unbound/unbound-1.14.0/cachedb/
H A Dredis.c62 static redisReply* redis_command(struct module_env*, struct cachedb_env*,
121 redisReply* rep = NULL; in redis_init()
184 static redisReply*
189 redisReply* rep; in redis_command()
212 rep = (redisReply*)redisCommand(ctx, command, data, data_len); in redis_command()
236 redisReply* rep; in redis_lookup()
284 redisReply* rep; in redis_store()
/dports/databases/redisdesktopmanager/RedisDesktopManager-2021.8/3rdparty/qredisclient/3rdparty/hiredis/
H A Dtest.c55 redisReply *reply; in select_database()
77 redisReply *reply; in disconnect()
247 redisReply *reply; in test_append_formatted_commands()
417 ((redisReply*)reply)->elements == 0); in test_reply_reader()
464 redisReply *reply; in test_blocking_connection()
542 redisReply *reply; in test_blocking_connection_timeouts()
588 redisReply *reply; in test_blocking_io_errors()
663 redisReply **replies; in test_throughput()
672 replies = malloc(sizeof(redisReply*)*num); in test_throughput()
683 replies = malloc(sizeof(redisReply*)*num); in test_throughput()
[all …]
/dports/net/zerotier/ZeroTierOne-1.8.3/ext/hiredis-0.14.1/
H A Dtest.c55 redisReply *reply; in select_database()
77 redisReply *reply; in disconnect()
247 redisReply *reply; in test_append_formatted_commands()
417 ((redisReply*)reply)->elements == 0); in test_reply_reader()
464 redisReply *reply; in test_blocking_connection()
542 redisReply *reply; in test_blocking_connection_timeouts()
588 redisReply *reply; in test_blocking_io_errors()
663 redisReply **replies; in test_throughput()
672 replies = malloc(sizeof(redisReply*)*num); in test_throughput()
683 replies = malloc(sizeof(redisReply*)*num); in test_throughput()
[all …]
/dports/net/sems/sems-f89581a/apps/dsm/mods/mod_redis/
H A DDRedisConnection.h34 int handle_redis_reply(redisReply *reply, const char* _cmd);
45 int exec_cmd(const char* cmd, redisReply*& reply);
47 int get_reply(redisReply*& reply);

12345678910>>...13