Home
last modified time | relevance | path

Searched refs:reply (Results 1 – 25 of 78) sorted by relevance

1234

/f-stack/app/redis-5.0.5/deps/hiredis/examples/
H A Dexample.c10 redisReply *reply; in main() local
27 reply = redisCommand(c,"PING"); in main()
29 freeReplyObject(reply); in main()
34 freeReplyObject(reply); in main()
39 freeReplyObject(reply); in main()
44 freeReplyObject(reply); in main()
48 freeReplyObject(reply); in main()
52 freeReplyObject(reply); in main()
56 freeReplyObject(reply); in main()
62 freeReplyObject(reply); in main()
[all …]
H A Dexample-ivykis.c11 redisReply *reply = r; in getCallback() local
12 if (reply == NULL) return; in getCallback()
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-libev.c11 redisReply *reply = r; in getCallback() local
12 if (reply == NULL) return; in getCallback()
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-qt.cpp11 redisReply * reply = static_cast<redisReply *>(r); in getCallback() local
13 if (reply == nullptr || ex == nullptr) return; in getCallback()
15 cout << "key: " << reply->str << endl; in getCallback()
H A Dexample-libevent.c11 redisReply *reply = r; in getCallback() local
12 if (reply == NULL) return; in getCallback()
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-libuv.c11 redisReply *reply = r; in getCallback() local
12 if (reply == NULL) return; in getCallback()
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
/f-stack/app/redis-5.0.5/deps/hiredis/
H A Dtest.c55 redisReply *reply; in select_database() local
59 assert(reply != NULL); in select_database()
64 assert(reply != NULL); in select_database()
65 if (reply->type == REDIS_REPLY_INTEGER && reply->integer == 0) { in select_database()
77 redisReply *reply; in disconnect() local
247 redisReply *reply; in test_append_formatted_commands() local
269 void *reply; in test_reply_reader() local
431 test_cond(reply->type == REDIS_REPLY_INTEGER && reply->integer == 1) in test_blocking_connection()
479 …test_cond(reply != NULL && reply->type == REDIS_REPLY_STRING && memcmp(reply->str, "fast", 4) == 0… in test_blocking_connection_timeouts()
496 … test_cond(reply != NULL && reply->type == REDIS_REPLY_STATUS && strcmp(reply->str, "PONG") == 0); in test_blocking_connection_timeouts()
[all …]
H A DREADME.md47 void freeReplyObject(void *reply);
128 * A bulk (string) reply. The value of the reply can be accessed using `reply->str`.
132 * A multi bulk reply. The number of elements in the multi bulk reply is stored in
205 redisReply *reply;
208 redisGetReply(context,&reply); // reply for SET
209 freeReplyObject(reply);
210 redisGetReply(context,&reply); // reply for GET
211 freeReplyObject(reply);
216 freeReplyObject(reply);
219 freeReplyObject(reply);
[all …]
H A Dasync.c269 cb->fn(ac,reply,cb->privdata); in __redisRunCallback()
374 if (reply->type == REDIS_REPLY_ARRAY) { in __redisGetSubscribeCallback()
375 assert(reply->elements >= 2); in __redisGetSubscribeCallback()
377 stype = reply->element[0]->str; in __redisGetSubscribeCallback()
387 sname = sdsnewlen(reply->element[1]->str,reply->element[1]->len); in __redisGetSubscribeCallback()
414 void *reply = NULL; in redisProcessCallbacks() local
418 if (reply == NULL) { in redisProcessCallbacks()
458 c->reader->fn->freeObject(reply); in redisProcessCallbacks()
469 __redisRunCallback(ac,&cb,reply); in redisProcessCallbacks()
470 c->reader->fn->freeObject(reply); in redisProcessCallbacks()
[all …]
H A Dread.c50 r->fn->freeObject(r->reply); in __redisReaderSetError()
51 r->reply = NULL; in __redisReaderSetError()
241 if (r->ridx == 0) r->reply = obj; in processLineItem()
293 if (r->ridx == 0) r->reply = obj; in processBulkItem()
360 if (root) r->reply = obj; in processMultiBulkItem()
439 r->fn->freeObject(r->reply); in redisReaderFree()
479 if (reply != NULL) in redisReaderGetReply()
480 *reply = NULL; in redisReaderGetReply()
520 if (reply != NULL) in redisReaderGetReply()
521 *reply = r->reply; in redisReaderGetReply()
[all …]
/f-stack/dpdk/lib/librte_eal/linux/
H A Deal_vfio_mp_sync.c30 struct rte_mp_msg reply; in vfio_mp_primary() local
40 memset(&reply, 0, sizeof(reply)); in vfio_mp_primary()
55 reply.num_fds = 1; in vfio_mp_primary()
56 reply.fds[0] = fd; in vfio_mp_primary()
66 reply.num_fds = 1; in vfio_mp_primary()
67 reply.fds[0] = fd; in vfio_mp_primary()
77 reply.num_fds = 1; in vfio_mp_primary()
78 reply.fds[0] = fd; in vfio_mp_primary()
102 strcpy(reply.name, EAL_VFIO_MP); in vfio_mp_primary()
103 reply.len_param = sizeof(*r); in vfio_mp_primary()
[all …]
/f-stack/app/redis-5.0.5/tests/unit/type/
H A Dstream-cgroups.tcl29 set reply [
41 set reply [
160 set reply [
166 set reply [
180 set reply [
191 set reply [
208 set reply [
214 set reply [
220 set reply [
228 set reply [
[all …]
/f-stack/app/redis-5.0.5/src/modules/
H A Dtestmodule.c40 int TestMatchReply(RedisModuleCallReply *reply, char *str) { in TestMatchReply() argument
42 mystr = RedisModule_CreateStringFromCallReply(reply); in TestMatchReply()
56 RedisModuleCallReply *reply; in TestCall() local
62 long long items = RedisModule_CallReplyLength(reply); in TestCall()
67 item0 = RedisModule_CallReplyArrayElement(reply,0); in TestCall()
68 item1 = RedisModule_CallReplyArrayElement(reply,1); in TestCall()
315 RedisModule_CallReplyType(reply)); in TestAssertStringReply()
336 RedisModule_CallReplyType(reply)); in TestAssertIntegerReply()
339 long long val = RedisModule_CallReplyInteger(reply); in TestAssertIntegerReply()
361 RedisModuleCallReply *reply; in TestIt() local
[all …]
H A Dhelloworld.c84 RedisModuleCallReply *reply; in HelloPushCall_RedisCommand() local
86 reply = RedisModule_Call(ctx,"RPUSH","ss",argv[1],argv[2]); in HelloPushCall_RedisCommand()
87 long long len = RedisModule_CallReplyInteger(reply); in HelloPushCall_RedisCommand()
88 RedisModule_FreeCallReply(reply); in HelloPushCall_RedisCommand()
100 RedisModuleCallReply *reply; in HelloPushCall2_RedisCommand() local
102 reply = RedisModule_Call(ctx,"RPUSH","ss",argv[1],argv[2]); in HelloPushCall2_RedisCommand()
103 RedisModule_ReplyWithCallReply(ctx,reply); in HelloPushCall2_RedisCommand()
104 RedisModule_FreeCallReply(reply); in HelloPushCall2_RedisCommand()
115 RedisModuleCallReply *reply; in HelloListSumLen_RedisCommand() local
119 size_t items = RedisModule_CallReplyLength(reply); in HelloListSumLen_RedisCommand()
[all …]
/f-stack/dpdk/lib/librte_eal/common/
H A Deal_common_proc.c430 msg = sr->reply; in process_async_request()
454 reply->nb_sent--; in process_async_request()
462 free(sr->reply); in process_async_request()
926 reply->nb_sent++; in mp_request_sync()
946 reply->nb_sent--; in mp_request_sync()
950 tmp = realloc(reply->msgs, sizeof(msg) * (reply->nb_received + 1)); in mp_request_sync()
958 reply->msgs = tmp; in mp_request_sync()
977 reply->nb_sent = 0; in rte_mp_request_sync()
979 reply->msgs = NULL; in rte_mp_request_sync()
1054 free(reply->msgs); in rte_mp_request_sync()
[all …]
H A Dmalloc_mp.c34 const struct rte_mp_reply *reply);
149 struct rte_mp_msg reply; in handle_sync() local
161 memset(&reply, 0, sizeof(reply)); in handle_sync()
163 reply.num_fds = 0; in handle_sync()
164 strlcpy(reply.name, msg->name, sizeof(reply.name)); in handle_sync()
173 rte_mp_reply(&reply, peer); in handle_sync()
365 if (reply->nb_received != reply->nb_sent) in handle_sync_response()
574 struct rte_mp_reply reply; in request_sync() local
580 memset(&reply, 0, sizeof(reply)); in request_sync()
608 if (reply.nb_received != reply.nb_sent) { in request_sync()
[all …]
/f-stack/app/redis-5.0.5/src/
H A Dredis-cli.c1850 if (reply) freeReplyObject(reply); in evalMode()
2222 if (reply) freeReplyObject(reply); in clusterManagerStartTransaction()
2252 if (reply) freeReplyObject(reply); in clusterManagerExecTransaction()
2783 if (reply != NULL) freeReplyObject(reply); in clusterManagerAddSlots()
2815 if (reply) freeReplyObject(reply); in clusterManagerClearSlotStatus()
2833 if (reply) freeReplyObject(reply); in clusterManagerDelSlot()
2841 if (reply) freeReplyObject(reply); in clusterManagerAddSlot()
2853 if (reply) freeReplyObject(reply); in clusterManagerCountKeysInSlot()
2860 if (reply) freeReplyObject(reply); in clusterManagerBumpEpoch()
3338 if (reply) freeReplyObject(reply); in clusterManagerNodeLoadInfo()
[all …]
H A Dscripting.c144 string2ll(reply+1,p-reply-1,&value); in redisProtocolToLuaType_Int()
153 string2ll(reply+1,p-reply-1,&bulklen); in redisProtocolToLuaType_Bulk()
168 lua_pushlstring(lua,reply+1,p-reply-1); in redisProtocolToLuaType_Status()
178 lua_pushlstring(lua,reply+1,p-reply-1); in redisProtocolToLuaType_Error()
188 string2ll(reply+1,p-reply-1,&mbulklen); in redisProtocolToLuaType_MultiBulk()
609 (reply[0] == '*' && reply[1] != '-')) { in luaRedisGenericCommand()
612 if (reply != c->buf) sdsfree(reply); in luaRedisGenericCommand()
2046 *o = sdscatlen(*o,reply+1,p-reply-1); in ldbRedisProtocolToHuman_Int()
2054 string2ll(reply+1,p-reply-1,&bulklen); in ldbRedisProtocolToHuman_Bulk()
2067 *o = sdscatrepr(*o,reply,p-reply); in ldbRedisProtocolToHuman_Status()
[all …]
H A Dmodule.c1274 sds proto = sdsnewlen(reply->proto, reply->protolen); in RM_ReplyWithCallReply()
2454 RedisModuleCallReply *reply = zmalloc(sizeof(*reply)); in moduleCreateCallReplyFromProto() local
2455 reply->ctx = ctx; in moduleCreateCallReplyFromProto()
2469 return reply; in moduleCreateCallReplyFromProto()
2581 if (reply->proto) sdsfree(reply->proto); in RM_FreeCallReply_Rec()
2582 zfree(reply); in RM_FreeCallReply_Rec()
2599 return reply->type; in RM_CallReplyType()
2647 return RM_CreateString(reply->ctx,reply->val.str,reply->len); in RM_CreateStringFromCallReply()
2823 listDelNode(c->reply,listFirst(c->reply)); in RM_Call()
2831 return reply; in RM_Call()
[all …]
/f-stack/app/redis-5.0.5/tests/modules/
H A Dcommandfilter.c31 RedisModuleCallReply *reply = RedisModule_Call(ctx, "ping", "c", "@log"); in CommandFilter_PingCommand() local
32 if (reply) { in CommandFilter_PingCommand()
33 RedisModule_ReplyWithCallReply(ctx, reply); in CommandFilter_PingCommand()
34 RedisModule_FreeCallReply(reply); in CommandFilter_PingCommand()
64 RedisModuleCallReply *reply = RedisModule_Call(ctx, cmdname, "v", &argv[2], argc - 2); in CommandFilter_LogCommand() local
65 if (reply) { in CommandFilter_LogCommand()
66 RedisModule_ReplyWithCallReply(ctx, reply); in CommandFilter_LogCommand()
67 RedisModule_FreeCallReply(reply); in CommandFilter_LogCommand()
/f-stack/tools/libnetgraph/
H A Dmsg.c118 struct ng_mesg *reply, *binary, *ascii; in NgSendAsciiMsg() local
164 if (NgAllocRecvMsg(cs, &reply, NULL) < 0) in NgSendAsciiMsg()
168 binary = (struct ng_mesg *)reply->data; in NgSendAsciiMsg()
173 free(reply); in NgSendAsciiMsg()
177 free(reply); in NgSendAsciiMsg()
358 bufSize = 2 * sizeof(*reply) + replen; in NgRecvAsciiMsg()
367 memcpy(reply, msg, sizeof(*msg)); in NgRecvAsciiMsg()
385 strncpy(reply->data, ascii->data, ascii->header.arglen); in NgRecvAsciiMsg()
408 (*reply = malloc(len)) == NULL) in NgAllocRecvAsciiMsg()
410 if ((len = NgRecvAsciiMsg(cs, *reply, len, path)) < 0) in NgAllocRecvAsciiMsg()
[all …]
/f-stack/app/redis-5.0.5/tests/unit/
H A Dobuf-limits.tcl7 set reply [$rd1 read]
8 assert {$reply eq "subscribe foo 1"}
27 set reply [$rd1 read]
28 assert {$reply eq "subscribe foo 1"}
53 set reply [$rd1 read]
54 assert {$reply eq "subscribe foo 1"}
/f-stack/freebsd/net/
H A Dif_spppfr.c408 struct arp_req *reply; in sppp_fr_arp() local
486 reply = (struct arp_req*) (h + 10); in sppp_fr_arp()
498 reply->htype = htons (ARPHRD_FRELAY); in sppp_fr_arp()
499 reply->ptype = htons (ETHERTYPE_IP); in sppp_fr_arp()
500 reply->halen = 2; in sppp_fr_arp()
501 reply->palen = 4; in sppp_fr_arp()
502 reply->op = htons (ARPOP_INVREPLY); in sppp_fr_arp()
503 reply->hsource = htons (my_hardware_address); in sppp_fr_arp()
504 reply->psource1 = htonl (my_ip_address); in sppp_fr_arp()
505 reply->psource2 = htonl (my_ip_address) >> 16; in sppp_fr_arp()
[all …]
/f-stack/dpdk/drivers/net/bnx2x/
H A Dbnx2x_vfpf.c381 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_init()
512 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_setup_queue()
556 struct vf_common_reply_tlv *reply; in bnx2x_vf_set_mac() local
581 reply = &sc->vf2pf_mbox->resp.common_reply; in bnx2x_vf_set_mac()
596 if (BNX2X_VF_STATUS_SUCCESS != reply->status) { in bnx2x_vf_set_mac()
598 reply->status); in bnx2x_vf_set_mac()
638 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_config_rss()
696 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vf_set_rx_mode()
713 struct vf_common_reply_tlv *reply = in bnx2x_vfpf_set_mcast() local
753 if (reply->status != BNX2X_VF_STATUS_SUCCESS) { in bnx2x_vfpf_set_mcast()
[all …]
/f-stack/app/redis-5.0.5/tests/support/
H A Dredis.tcl221 set ::redis::state($id) [dict create buf {} mbulk -1 bulk -1 reply {}]
225 proc ::redis::redis_call_callback {id type reply} { argument
244 + {redis_call_callback $id reply [string range $line 1 end-1]}
260 redis_call_callback $id reply {}
279 redis_call_callback $id reply \
283 lappend reply [string range $buf 0 end-2]
288 redis_call_callback $id reply \
289 [dict get $::redis::state($id) reply]

1234