Home
last modified time | relevance | path

Searched refs:de (Results 1 – 23 of 23) sorted by relevance

/redis-3.2.3/src/
H A Dpubsub.c59 dictEntry *de; in pubsubSubscribeChannel() local
69 if (de == NULL) { in pubsubSubscribeChannel()
74 clients = dictGetVal(de); in pubsubSubscribeChannel()
89 dictEntry *de; in pubsubUnsubscribeChannel() local
102 clients = dictGetVal(de); in pubsubUnsubscribeChannel()
180 dictEntry *de; in pubsubUnsubscribeAllChannels() local
184 robj *channel = dictGetKey(de); in pubsubUnsubscribeAllChannels()
227 dictEntry *de; in pubsubPublishMessage() local
233 if (de) { in pubsubPublishMessage()
234 list *list = dictGetVal(de); in pubsubPublishMessage()
[all …]
H A Ddict.c261 while(de) { in dictRehash()
264 nextde = de->next; in dictRehash()
271 de = nextde; in dictRehash()
858 const dictEntry *de; in dictScan() local
869 while (de) { in dictScan()
870 fn(privdata, de); in dictScan()
871 de = de->next; in dictScan()
889 while (de) { in dictScan()
891 de = de->next; in dictScan()
899 while (de) { in dictScan()
[all …]
H A Dlatency.c136 dictEntry *de; in latencyResetEvent() local
140 while((de = dictNext(di)) != NULL) { in latencyResetEvent()
141 char *event = dictGetKey(de); in latencyResetEvent()
248 dictEntry *de; in createLatencyReport() local
252 while((de = dictNext(di)) != NULL) { in createLatencyReport()
253 char *event = dictGetKey(de); in createLatencyReport()
497 dictEntry *de; in latencyCommandReplyWithLatestEvents() local
502 char *event = dictGetKey(de); in latencyCommandReplyWithLatestEvents()
581 dictEntry *de; in latencyCommand() local
586 ts = dictGetVal(de); in latencyCommand()
[all …]
H A Dsentinel.c645 dictEntry *de; in sentinelGenerateInitialMonitorEvents() local
1021 dictEntry *de; in sentinelTryConnectionSharing() local
1057 dictEntry *de; in sentinelUpdateSentinelAddressInAllMasters() local
1302 dictEntry *de; in removeMatchingSentinelFromMaster() local
1328 dictEntry *de; in getSentinelRedisInstanceByAddrAndRunID() local
1362 dictEntry *de; in sentinelAddFlagsToDictOfRedisInstances() local
1376 dictEntry *de; in sentinelDelFlagsToDictOfRedisInstances() local
1435 dictEntry *de; in sentinelResetMastersByPattern() local
1465 dictEntry *de; in sentinelResetMasterAndChangeAddress() local
1550 dictEntry *de; in sentinelPropagateDownAfterPeriod() local
[all …]
H A Ddb.c49 if (de) { in lookupKey()
204 dictEntry *de; in dbRandomKey() local
213 key = dictGetKey(de); in dbRandomKey()
405 dictEntry *de; in keysCommand() local
442 key = dictGetKey(de); in scanCallback()
445 key = dictGetKey(de); in scanCallback()
447 val = dictGetVal(de); in scanCallback()
848 dictEntry *kde, *de; in setExpire() local
860 dictEntry *de; in getExpire() local
1036 dictEntry *de; in persistCommand() local
[all …]
H A Dcluster.c491 dictEntry *de; in clusterReset() local
866 dictEntry *de; in clusterDelNode() local
895 dictEntry *de; in clusterLookupNode() local
929 dictEntry *de; in clusterGetMaxEpoch() local
1085 dictEntry *de; in clusterBlacklistCleanup() local
1099 dictEntry *de; in clusterBlacklistAddNode() local
1217 dictEntry *de; in clusterHandshakeInProgress() local
2100 dictEntry *de; in clusterBroadcastMessage() local
2311 dictEntry *de; in clusterBroadcastPong() local
2902 dictEntry *de; in clusterHandleSlaveMigration() local
[all …]
H A Ddebug.c117 dictEntry *de; in computeDatasetDigest() local
141 key = dictGetKey(de); in computeDatasetDigest()
146 o = dictGetVal(de); in computeDatasetDigest()
208 dictEntry *de; in computeDatasetDigest() local
357 dictEntry *de; in debugCommand() local
365 val = dictGetVal(de); in debugCommand()
409 dictEntry *de; in debugCommand() local
417 val = dictGetVal(de); in debugCommand()
418 key = dictGetKey(de); in debugCommand()
895 dictEntry *de; in logCurrentClient() local
[all …]
H A Dt_zset.c1338 dictEntry *de; in zaddGenericCommand() local
1343 if (de != NULL) { in zaddGenericCommand()
1435 dictEntry *de; in zremCommand() local
1440 if (de != NULL) { in zremCommand()
1603 dictEntry *de; member
1761 if (it->ht.de == NULL) in zuiNext()
1896 dictEntry *de; in zuiFind() local
2078 dictEntry *de; in zunionInterGenericCommand() local
2101 if (de == NULL) { in zunionInterGenericCommand()
2894 dictEntry *de; in zrankGenericCommand() local
[all …]
H A Dt_set.c158 dictEntry *de = dictNext(si->di); in setTypeNext() local
159 if (de == NULL) return -1; in setTypeNext()
160 *objele = dictGetKey(de); in setTypeNext()
217 dictEntry *de = dictGetRandomKey(setobj->ptr); in setTypeRandomElement() local
218 *objele = dictGetKey(de); in setTypeRandomElement()
709 dictEntry *de; in srandmemberWithCountCommand() local
711 de = dictGetRandomKey(d); in srandmemberWithCountCommand()
712 dictDelete(d,dictGetKey(de)); in srandmemberWithCountCommand()
744 dictEntry *de; in srandmemberWithCountCommand() local
748 while((de = dictNext(di)) != NULL) in srandmemberWithCountCommand()
[all …]
H A Dt_list.c617 dictEntry *de; in blockForKeys() local
632 de = dictFind(c->db->blocking_keys,keys[j]); in blockForKeys()
633 if (de == NULL) { in blockForKeys()
642 l = dictGetVal(de); in blockForKeys()
652 dictEntry *de; in unblockClientWaitingData() local
659 while((de = dictNext(di)) != NULL) { in unblockClientWaitingData()
660 robj *key = dictGetKey(de); in unblockClientWaitingData()
812 dictEntry *de; in handleClientsBlockedOnLists() local
816 de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnLists()
817 if (de) { in handleClientsBlockedOnLists()
[all …]
H A Drdb.c606 dictEntry *de; in rdbSaveObject() local
612 robj *eleobj = dictGetKey(de); in rdbSaveObject()
635 dictEntry *de; in rdbSaveObject() local
641 robj *eleobj = dictGetKey(de); in rdbSaveObject()
663 dictEntry *de; in rdbSaveObject() local
669 robj *key = dictGetKey(de); in rdbSaveObject()
670 robj *val = dictGetVal(de); in rdbSaveObject()
764 dictEntry *de; in rdbSaveRio() local
803 while((de = dictNext(di)) != NULL) { in rdbSaveRio()
804 sds keystr = dictGetKey(de); in rdbSaveRio()
[all …]
H A Daof.c843 dictEntry *de; in rewriteSetObject() local
845 while((de = dictNext(di)) != NULL) { in rewriteSetObject()
846 robj *eleobj = dictGetKey(de); in rewriteSetObject()
909 dictEntry *de; in rewriteSortedSetObject() local
911 while((de = dictNext(di)) != NULL) { in rewriteSortedSetObject()
912 robj *eleobj = dictGetKey(de); in rewriteSortedSetObject()
913 double *score = dictGetVal(de); in rewriteSortedSetObject()
1017 dictEntry *de; in rewriteAppendOnlyFile() local
1055 while((de = dictNext(di)) != NULL) { in rewriteAppendOnlyFile()
1060 keystr = dictGetKey(de); in rewriteAppendOnlyFile()
[all …]
H A Dt_hash.c102 dictEntry *de; in hashTypeGetFromHashTable() local
106 de = dictFind(o->ptr, field); in hashTypeGetFromHashTable()
107 if (de == NULL) return -1; in hashTypeGetFromHashTable()
108 *value = dictGetVal(de); in hashTypeGetFromHashTable()
353 if ((hi->de = dictNext(hi->di)) == NULL) return C_ERR; in hashTypeNext()
386 *dst = dictGetKey(hi->de); in hashTypeCurrentFromHashTable()
388 *dst = dictGetVal(hi->de); in hashTypeCurrentFromHashTable()
H A Dserver.c728 long long t = dictGetSignedIntegerVal(de); in activeExpireCycleTryExpire()
730 sds key = dictGetKey(de); in activeExpireCycleTryExpire()
848 dictEntry *de; in activeExpireCycle() local
2759 dictEntry *de; in commandCommand() local
3401 dictEntry *de; in evictionPoolPopulate() local
3403 de = samples[j]; in evictionPoolPopulate()
3404 key = dictGetKey(de); in evictionPoolPopulate()
3409 o = dictGetVal(de); in evictionPoolPopulate()
3491 dictEntry *de; in freeMemoryIfNeeded() local
3509 bestkey = dictGetKey(de); in freeMemoryIfNeeded()
[all …]
H A Dobject.c695 dictEntry *de; in objectCommandLookup() local
697 if ((de = dictFind(c->db->dict,key->ptr)) == NULL) return NULL; in objectCommandLookup()
698 return (robj*) dictGetVal(de); in objectCommandLookup()
H A Ddict.h97 typedef void (dictScanFunction)(void *privdata, const dictEntry *de);
H A Dconfig.c1678 dictEntry *de; local
1680 while((de = dictNext(di)) != NULL) {
1681 list *l = dictGetVal(de);
1682 sds option = dictGetKey(de);
H A Dserver.h1056 dictEntry *de; member
/redis-3.2.3/deps/hiredis/
H A Ddict.c184 dictEntry *de, *prevde; in dictDelete() local
189 de = ht->table[h]; in dictDelete()
192 while(de) { in dictDelete()
193 if (dictCompareHashKeys(ht,key,de->key)) { in dictDelete()
196 prevde->next = de->next; in dictDelete()
198 ht->table[h] = de->next; in dictDelete()
200 dictFreeEntryKey(ht,de); in dictDelete()
201 dictFreeEntryVal(ht,de); in dictDelete()
202 free(de); in dictDelete()
206 prevde = de; in dictDelete()
[all …]
H A Dasync.c268 dictEntry *de; in __redisAsyncFree() local
280 while ((de = dictNext(it)) != NULL) in __redisAsyncFree()
281 __redisRunCallback(ac,dictGetEntryVal(de),NULL); in __redisAsyncFree()
286 while ((de = dictNext(it)) != NULL) in __redisAsyncFree()
287 __redisRunCallback(ac,dictGetEntryVal(de),NULL); in __redisAsyncFree()
356 dictEntry *de; in __redisGetSubscribeCallback() local
377 de = dictFind(callbacks,sname); in __redisGetSubscribeCallback()
378 if (de != NULL) { in __redisGetSubscribeCallback()
379 memcpy(dstcb,dictGetEntryVal(de),sizeof(*dstcb)); in __redisGetSubscribeCallback()
H A DREADME.md229 Examples are bundled that show using Hiredis with [libev](http://software.schmorp.de/pkg/libev.html)
/redis-3.2.3/deps/lua/
H A DREADME33 Science of PUC-Rio (the Pontifical Catholic University of Rio de Janeiro
/redis-3.2.3/deps/jemalloc/
H A DChangeLog623 - Fix a cpp logic regression (due to the "thread.{de,}allocatedp" mallctl fix
631 - Fix "thread.{de,}allocatedp" mallctl for OS X.
650 - Add the "thread.[de]allocatedp" mallctl's.