Home
last modified time | relevance | path

Searched refs:privdata (Results 1 – 25 of 29) sorted by relevance

12

/redis-3.2.3/deps/hiredis/adapters/
H A Dae.h48 redisAeEvents *e = (redisAeEvents*)privdata; in redisAeReadEvent()
55 redisAeEvents *e = (redisAeEvents*)privdata; in redisAeWriteEvent()
59 static void redisAeAddRead(void *privdata) { in redisAeAddRead() argument
60 redisAeEvents *e = (redisAeEvents*)privdata; in redisAeAddRead()
68 static void redisAeDelRead(void *privdata) { in redisAeDelRead() argument
69 redisAeEvents *e = (redisAeEvents*)privdata; in redisAeDelRead()
77 static void redisAeAddWrite(void *privdata) { in redisAeAddWrite() argument
86 static void redisAeDelWrite(void *privdata) { in redisAeDelWrite() argument
95 static void redisAeCleanup(void *privdata) { in redisAeCleanup() argument
97 redisAeDelRead(privdata); in redisAeCleanup()
[all …]
H A Dlibev.h66 static void redisLibevAddRead(void *privdata) { in redisLibevAddRead() argument
67 redisLibevEvents *e = (redisLibevEvents*)privdata; in redisLibevAddRead()
76 static void redisLibevDelRead(void *privdata) { in redisLibevDelRead() argument
77 redisLibevEvents *e = (redisLibevEvents*)privdata; in redisLibevDelRead()
86 static void redisLibevAddWrite(void *privdata) { in redisLibevAddWrite() argument
87 redisLibevEvents *e = (redisLibevEvents*)privdata; in redisLibevAddWrite()
96 static void redisLibevDelWrite(void *privdata) { in redisLibevDelWrite() argument
97 redisLibevEvents *e = (redisLibevEvents*)privdata; in redisLibevDelWrite()
106 static void redisLibevCleanup(void *privdata) { in redisLibevCleanup() argument
108 redisLibevDelRead(privdata); in redisLibevCleanup()
[all …]
H A Dlibevent.h54 static void redisLibeventAddRead(void *privdata) { in redisLibeventAddRead() argument
55 redisLibeventEvents *e = (redisLibeventEvents*)privdata; in redisLibeventAddRead()
59 static void redisLibeventDelRead(void *privdata) { in redisLibeventDelRead() argument
60 redisLibeventEvents *e = (redisLibeventEvents*)privdata; in redisLibeventDelRead()
64 static void redisLibeventAddWrite(void *privdata) { in redisLibeventAddWrite() argument
65 redisLibeventEvents *e = (redisLibeventEvents*)privdata; in redisLibeventAddWrite()
69 static void redisLibeventDelWrite(void *privdata) { in redisLibeventDelWrite() argument
70 redisLibeventEvents *e = (redisLibeventEvents*)privdata; in redisLibeventDelWrite()
74 static void redisLibeventCleanup(void *privdata) { in redisLibeventCleanup() argument
75 redisLibeventEvents *e = (redisLibeventEvents*)privdata; in redisLibeventCleanup()
H A Dlibuv.h32 static void redisLibuvAddRead(void *privdata) { in redisLibuvAddRead() argument
33 redisLibuvEvents* p = (redisLibuvEvents*)privdata; in redisLibuvAddRead()
41 static void redisLibuvDelRead(void *privdata) { in redisLibuvDelRead() argument
42 redisLibuvEvents* p = (redisLibuvEvents*)privdata; in redisLibuvDelRead()
54 static void redisLibuvAddWrite(void *privdata) { in redisLibuvAddWrite() argument
55 redisLibuvEvents* p = (redisLibuvEvents*)privdata; in redisLibuvAddWrite()
63 static void redisLibuvDelWrite(void *privdata) { in redisLibuvDelWrite() argument
64 redisLibuvEvents* p = (redisLibuvEvents*)privdata; in redisLibuvDelWrite()
83 static void redisLibuvCleanup(void *privdata) { in redisLibuvCleanup() argument
84 redisLibuvEvents* p = (redisLibuvEvents*)privdata; in redisLibuvCleanup()
/redis-3.2.3/deps/hiredis/
H A Dasync.h48 void *privdata; member
78 void (*addRead)(void *privdata);
79 void (*delRead)(void *privdata);
80 void (*addWrite)(void *privdata);
81 void (*delWrite)(void *privdata);
82 void (*cleanup)(void *privdata);
118 int redisvAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, const char *form…
119 int redisAsyncCommand(redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, const char *forma…
120 int redisAsyncCommandArgv(redisAsyncContext *ac, redisCallbackFn *fn, void *privdata, int argc, con…
H A Ddict.h53 void *(*keyDup)(void *privdata, const void *key);
54 void *(*valDup)(void *privdata, const void *obj);
55 int (*keyCompare)(void *privdata, const void *key1, const void *key2);
56 void (*keyDestructor)(void *privdata, void *key);
57 void (*valDestructor)(void *privdata, void *obj);
66 void *privdata; member
81 (ht)->type->valDestructor((ht)->privdata, (entry)->val)
85 entry->val = (ht)->type->valDup((ht)->privdata, _val_); \
92 (ht)->type->keyDestructor((ht)->privdata, (entry)->key)
96 entry->key = (ht)->type->keyDup((ht)->privdata, _key_); \
[all …]
H A Dasync.c69 static void *callbackValDup(void *privdata, const void *src) { in callbackValDup() argument
70 ((void) privdata); in callbackValDup()
78 ((void) privdata); in callbackKeyCompare()
86 static void callbackKeyDestructor(void *privdata, void *key) { in callbackKeyDestructor() argument
87 ((void) privdata); in callbackKeyDestructor()
92 ((void) privdata); in callbackValDestructor()
258 cb->fn(ac,reply,cb->privdata); in __redisRunCallback()
585 cb.privdata = privdata; in __redisAsyncCommand()
640 status = __redisAsyncCommand(ac,fn,privdata,cmd,len); in redisvAsyncCommand()
649 status = redisvAsyncCommand(ac,fn,privdata,format,ap); in redisAsyncCommand()
[all …]
H A Dhiredis.h113 void *privdata; /* user-settable arbitrary field */ member
139 void *privdata; member
153 #define redisReplyReaderSetPrivdata(_r, _p) (int)(((redisReader*)(_r))->privdata = (_p))
H A Ddict.c83 ht->privdata = privDataPtr; in _dictInit()
97 _dictInit(&n, ht->type, ht->privdata); in dictExpand()
/redis-3.2.3/src/
H A Ddict.h60 void *(*keyDup)(void *privdata, const void *key);
61 void *(*valDup)(void *privdata, const void *obj);
63 void (*keyDestructor)(void *privdata, void *key);
64 void (*valDestructor)(void *privdata, void *obj);
78 void *privdata; member
97 typedef void (dictScanFunction)(void *privdata, const dictEntry *de);
105 (d)->type->valDestructor((d)->privdata, (entry)->v.val)
109 entry->v.val = (d)->type->valDup((d)->privdata, _val_); \
125 (d)->type->keyDestructor((d)->privdata, (entry)->key)
129 entry->key = (d)->type->keyDup((d)->privdata, _key_); \
[all …]
H A Dsentinel.c285 static void redisAeAddRead(void *privdata) { in redisAeAddRead() argument
294 static void redisAeDelRead(void *privdata) { in redisAeDelRead() argument
323 redisAeDelRead(privdata); in redisAeCleanup()
324 redisAeDelWrite(privdata); in redisAeCleanup()
387 UNUSED(privdata); in dictInstancesValDestructor()
990 if (cb->privdata == ri) { in releaseInstanceLink()
2241 sentinelRedisInstance *ri = privdata; in sentinelInfoReplyCallback()
2258 UNUSED(privdata); in sentinelDiscardReplyCallback()
2264 sentinelRedisInstance *ri = privdata; in sentinelPingReplyCallback()
2303 sentinelRedisInstance *ri = privdata; in sentinelPublishReplyCallback()
[all …]
H A Ddict.c184 d->privdata = privDataPtr; in _dictInit()
465 if (callback && (i & 65535) == 0) callback(d->privdata); in _dictClear()
855 void *privdata) in dictScan() argument
870 fn(privdata, de); in dictScan()
890 fn(privdata, de); in dictScan()
900 fn(privdata, de); in dictScan()
H A Dredis-benchmark.c101 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask);
189 static void readHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in readHandler() argument
190 client c = privdata; in readHandler()
258 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in writeHandler() argument
259 client c = privdata; in writeHandler()
H A Dlatency.c39 int dictStringKeyCompare(void *privdata, const void *key1, const void *key2) { in dictStringKeyCompare() argument
40 UNUSED(privdata); in dictStringKeyCompare()
48 void dictVanillaFree(void *privdata, void *val);
H A Dserver.c425 void dictVanillaFree(void *privdata, void *val) in dictVanillaFree() argument
427 DICT_NOTUSED(privdata); in dictVanillaFree()
431 void dictListDestructor(void *privdata, void *val) in dictListDestructor() argument
433 DICT_NOTUSED(privdata); in dictListDestructor()
441 DICT_NOTUSED(privdata); in dictSdsKeyCompare()
454 DICT_NOTUSED(privdata); in dictSdsKeyCaseCompare()
459 void dictObjectDestructor(void *privdata, void *val) in dictObjectDestructor() argument
461 DICT_NOTUSED(privdata); in dictObjectDestructor()
467 void dictSdsDestructor(void *privdata, void *val) in dictSdsDestructor() argument
469 DICT_NOTUSED(privdata); in dictSdsDestructor()
[all …]
H A Ddb.c432 void scanCallback(void *privdata, const dictEntry *de) { in scanCallback() argument
433 void **pd = (void**) privdata; in scanCallback()
563 void *privdata[2]; in scanGenericCommand() local
573 privdata[0] = keys; in scanGenericCommand()
574 privdata[1] = o; in scanGenericCommand()
576 cursor = dictScan(ht, cursor, scanCallback, privdata); in scanGenericCommand()
H A Dnetworking.c686 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler() argument
691 UNUSED(privdata); in acceptTcpHandler()
706 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptUnixHandler() argument
710 UNUSED(privdata); in acceptUnixHandler()
988 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) { in sendReplyToClient() argument
991 writeToClient(fd,privdata,1); in sendReplyToClient()
1307 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { in readQueryFromClient() argument
1308 client *c = (client*) privdata; in readQueryFromClient()
H A Dreplication.c798 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave() argument
799 client *slave = privdata; in sendBulkToSlave()
960 void replicationEmptyDbCallback(void *privdata) { in replicationEmptyDbCallback() argument
961 UNUSED(privdata); in replicationEmptyDbCallback()
984 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload() argument
989 UNUSED(privdata); in readSyncBulkPayload()
1386 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster() argument
1392 UNUSED(privdata); in syncWithMaster()
H A Dserver.h1097 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask);
1101 void acceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1102 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1103 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1104 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask);
H A Daof.c95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData() argument
101 UNUSED(privdata); in aofChildWriteDiffData()
1180 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable() argument
1183 UNUSED(privdata); in aofChildPipeReadable()
/redis-3.2.3/deps/hiredis/examples/
H A Dexample-libev.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-libevent.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-libuv.c10 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
13 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
H A Dexample-ae.c13 void getCallback(redisAsyncContext *c, void *r, void *privdata) { in getCallback() argument
16 printf("argv[%s]: %s\n", (char*)privdata, reply->str); in getCallback()
/redis-3.2.3/utils/hashtable/
H A Drehashing.c21 int dictKeyCompare(void *privdata, const void *key1, const void *key2) { in dictKeyCompare() argument

12