Home
last modified time | relevance | path

Searched refs:redisAsyncContext (Results 1 – 12 of 12) sorted by relevance

/redis-3.2.3/deps/hiredis/
H A Dasync.h40 struct redisAsyncContext; /* need forward declaration of redisAsyncContext */
44 typedef void (redisCallbackFn)(struct redisAsyncContext*, void*, void*);
58 typedef void (redisConnectCallback)(const struct redisAsyncContext*, int status);
61 typedef struct redisAsyncContext { struct
101 } redisAsyncContext; argument
104 redisAsyncContext *redisAsyncConnect(const char *ip, int port);
106 redisAsyncContext *redisAsyncConnectUnix(const char *path);
109 void redisAsyncDisconnect(redisAsyncContext *ac);
110 void redisAsyncFree(redisAsyncContext *ac);
113 void redisAsyncHandleRead(redisAsyncContext *ac);
[all …]
H A Dasync.c106 redisAsyncContext *ac; in redisAsyncInitialize()
108 ac = realloc(c,sizeof(redisAsyncContext)); in redisAsyncInitialize()
152 redisAsyncContext *ac; in redisAsyncConnect()
171 redisAsyncContext *ac = redisAsyncInitialize(c); in redisAsyncConnectBind()
178 redisAsyncContext *ac; in redisAsyncConnectUnix()
264 static void __redisAsyncFree(redisAsyncContext *ac) { in __redisAsyncFree()
312 void redisAsyncFree(redisAsyncContext *ac) { in redisAsyncFree()
346 void redisAsyncDisconnect(redisAsyncContext *ac) { in redisAsyncDisconnect()
400 void redisProcessCallbacks(redisAsyncContext *ac) { in redisProcessCallbacks()
504 void redisAsyncHandleRead(redisAsyncContext *ac) { in redisAsyncHandleRead()
[all …]
H A DREADME.md235 Redis. It returns a pointer to the newly created `redisAsyncContext` struct. The `err` field
240 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379);
250 void(const redisAsyncContext *c, int status);
262 int redisAsyncSetDisconnectCallback(redisAsyncContext *ac, redisDisconnectCallback *fn);
271 void(redisAsyncContext *c, void *reply, void *privdata);
279 redisAsyncContext *ac, redisCallbackFn *fn, void *privdata,
282 redisAsyncContext *ac, redisCallbackFn *fn, void *privdata,
300 void redisAsyncDisconnect(redisAsyncContext *ac);
/redis-3.2.3/deps/hiredis/examples/
H A Dexample-libev.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
38 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main()
H A Dexample-libevent.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
39 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main()
H A Dexample-libuv.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
19 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
27 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
39 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main()
H A Dexample-ae.c13 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback()
22 void connectCallback(const redisAsyncContext *c, int status) { in connectCallback()
32 void disconnectCallback(const redisAsyncContext *c, int status) { in disconnectCallback()
46 redisAsyncContext *c = redisAsyncConnect("127.0.0.1", 6379); in main()
/redis-3.2.3/deps/hiredis/adapters/
H A Dlibuv.h9 redisAsyncContext* context;
14 int redisLibuvAttach(redisAsyncContext*, uv_loop_t*);
90 static int redisLibuvAttach(redisAsyncContext* ac, uv_loop_t* loop) { in redisLibuvAttach()
H A Dlibevent.h38 redisAsyncContext *context;
81 static int redisLibeventAttach(redisAsyncContext *ac, struct event_base *base) { in redisLibeventAttach()
H A Dae.h39 redisAsyncContext *context;
102 static int redisAeAttach(aeEventLoop *loop, redisAsyncContext *ac) { in redisAeAttach()
H A Dlibev.h40 redisAsyncContext *context;
113 static int redisLibevAttach(EV_P_ redisAsyncContext *ac) { in redisLibevAttach()
/redis-3.2.3/src/
H A Dsentinel.c140 redisAsyncContext *cc; /* Hiredis context for commands. */
141 redisAsyncContext *pc; /* Hiredis context for Pub / Sub. */
265 redisAsyncContext *context;
328 static int redisAeAttach(aeEventLoop *loop, redisAsyncContext *ac) { in redisAeAttach()
356 void sentinelLinkEstablishedCallback(const redisAsyncContext *c, int status);
357 void sentinelDisconnectCallback(const redisAsyncContext *c, int status);
363 void instanceLinkConnectionError(const redisAsyncContext *c);
953 void instanceLinkCloseConnection(instanceLink *link, redisAsyncContext *c) { in instanceLinkCloseConnection()
1096 void instanceLinkConnectionError(const redisAsyncContext *c) { in instanceLinkConnectionError()
1112 void sentinelLinkEstablishedCallback(const redisAsyncContext *c, int status) { in sentinelLinkEstablishedCallback()
[all …]