| /f-stack/app/redis-5.0.5/src/ |
| H A D | dict.h | 47 typedef struct dictEntry { struct 55 struct dictEntry *next; argument 56 } dictEntry; typedef 70 dictEntry **table; 92 dictEntry *entry, *nextEntry; 154 dictEntry *dictAddRaw(dict *d, void *key, dictEntry **existing); 155 dictEntry *dictAddOrFind(dict *d, void *key); 158 dictEntry *dictUnlink(dict *ht, const void *key); 161 dictEntry * dictFind(dict *d, const void *key); 166 dictEntry *dictNext(dictIterator *iter); [all …]
|
| H A D | dict.c | 193 dictEntry *de, *nextde; in dictRehash() 292 dictEntry *dictAddRaw(dict *d, void *key, dictEntry **existing) in dictAddRaw() 295 dictEntry *entry; in dictAddRaw() 366 dictEntry *he, *prevHe; in dictGenericDelete() 447 dictEntry *he, *nextHe; in _dictClear() 478 dictEntry *he; in dictFind() 498 dictEntry *he; in dictFetchValue() 612 dictEntry *he, *orighe; in dictGetRandomKey() 966 dictEntry *he; in _dictKeyIndex() 1013 dictEntry *he, **heref; in dictFindEntryRefByPtrAndHash() [all …]
|
| H A D | defrag.c | 174 dictEntry **newtable; in dictDefragTables() 273 dictEntry *de; in activeDefragSdsDict() 340 dictEntry *de; in activeDefragSdsListAndDict() 398 dictEntry *de = *deref; in replaceSateliteDictKeyPtrAndOrDefragDictEntry() 457 dictEntry *de = (dictEntry*)_de; in scanLaterZsetCallback() 474 dictEntry *de = (dictEntry*)_de; in scanLaterSetCallback() 492 dictEntry *de = (dictEntry*)_de; in scanLaterHashCallback() 533 dictEntry *de; in defragZsetSkiplist() 577 long defragSet(redisDb *db, dictEntry *kde) { in defragSet() 763 long defragKey(redisDb *db, dictEntry *de) { in defragKey() [all …]
|
| H A D | object.c | 784 struct dictEntry *de; in objectComputeSize() 859 elesize += sizeof(struct dictEntry); in objectComputeSize() 1029 mem += dictSize(server.lua_scripts) * sizeof(dictEntry) + in getMemoryOverheadData() 1030 dictSlots(server.lua_scripts) * sizeof(dictEntry*); in getMemoryOverheadData() 1049 mem = dictSize(db->dict) * sizeof(dictEntry) + in getMemoryOverheadData() 1050 dictSlots(db->dict) * sizeof(dictEntry*) + in getMemoryOverheadData() 1055 mem = dictSize(db->expires) * sizeof(dictEntry) + in getMemoryOverheadData() 1056 dictSlots(db->expires) * sizeof(dictEntry*); in getMemoryOverheadData() 1235 dictEntry *de; in objectCommandLookup() 1311 dictEntry *de; in memoryCommand() [all …]
|
| H A D | expire.c | 54 int activeExpireCycleTryExpire(redisDb *db, dictEntry *de, long long now) { in activeExpireCycleTryExpire() 190 dictEntry *de; in activeExpireCycle() 292 dictEntry *de = dictGetRandomKey(slaveKeysWithExpire); in expireSlaveKeys() 303 dictEntry *expire = dictFind(db->expires,keyname); in expireSlaveKeys() 358 dictEntry *de = dictAddOrFind(slaveKeysWithExpire,key->ptr); in rememberSlaveKeyWithExpire()
|
| H A D | pubsub.c | 59 dictEntry *de; in pubsubSubscribeChannel() 89 dictEntry *de; in pubsubUnsubscribeChannel() 180 dictEntry *de; in pubsubUnsubscribeAllChannels() 227 dictEntry *de; in pubsubPublishMessage() 342 dictEntry *de; in pubsubCommand()
|
| H A D | blocked.c | 268 dictEntry *de; in handleClientsBlockedOnKeys() 329 dictEntry *de; in handleClientsBlockedOnKeys() 376 dictEntry *de = dictFind(rl->db->blocking_keys,rl->key); in handleClientsBlockedOnKeys() 498 dictEntry *de; in blockForKeys() 544 dictEntry *de; in unblockClientWaitingData()
|
| H A D | sentinel.c | 667 dictEntry *de; in sentinelGenerateInitialMonitorEvents() 1044 dictEntry *de; in sentinelTryConnectionSharing() 1080 dictEntry *de; in sentinelUpdateSentinelAddressInAllMasters() 1327 dictEntry *de; in removeMatchingSentinelFromMaster() 1353 dictEntry *de; in getSentinelRedisInstanceByAddrAndRunID() 1387 dictEntry *de; in sentinelAddFlagsToDictOfRedisInstances() 1401 dictEntry *de; in sentinelDelFlagsToDictOfRedisInstances() 1460 dictEntry *de; in sentinelResetMastersByPattern() 1490 dictEntry *de; in sentinelResetMasterAndChangeAddress() 1575 dictEntry *de; in sentinelPropagateDownAfterPeriod() [all …]
|
| H A D | latency.c | 137 dictEntry *de; in latencyResetEvent() 249 dictEntry *de; in createLatencyReport() 498 dictEntry *de; in latencyCommandReplyWithLatestEvents() 593 dictEntry *de; in latencyCommand()
|
| H A D | db.c | 56 dictEntry *de = dictFind(db->dict,key->ptr); in lookupKey() 190 dictEntry *de = dictFind(db->dict,key->ptr); in dbOverwrite() 193 dictEntry auxentry = *de; in dbOverwrite() 236 dictEntry *de; in dbRandomKey() 538 dictEntry *de; in keysCommand() 565 void scanCallback(void *privdata, const dictEntry *de) { in scanCallback() 979 dictEntry *de; in scanDatabaseForReadyLists() 1077 dictEntry *kde, *de; in setExpire() 1093 dictEntry *de; in getExpire()
|
| H A D | evict.c | 164 dictEntry *samples[server.maxmemory_samples]; in evictionPoolPopulate() 171 dictEntry *de; in evictionPoolPopulate() 476 dictEntry *de; in freeMemoryIfNeeded()
|
| H A D | t_set.c | 56 dictEntry *de = dictAddRaw(ht,value,NULL); in setTypeAdd() 156 dictEntry *de = dictNext(si->di); in setTypeNext() 210 dictEntry *de = dictGetRandomKey(setobj->ptr); in setTypeRandomElement() 702 dictEntry *de; in srandmemberWithCountCommand() 738 dictEntry *de; in srandmemberWithCountCommand()
|
| H A D | lazyfree.c | 62 dictEntry *de = dictUnlink(db->dict,key->ptr); in dbAsyncDelete()
|
| H A D | cluster.c | 533 dictEntry *de; in clusterReset() 908 dictEntry *de; in clusterDelNode() 937 dictEntry *de; in clusterLookupNode() 971 dictEntry *de; in clusterGetMaxEpoch() 1127 dictEntry *de; in clusterBlacklistCleanup() 1141 dictEntry *de; in clusterBlacklistAddNode() 1259 dictEntry *de; in clusterHandshakeInProgress() 2231 dictEntry *de; in clusterBroadcastMessage() 2496 dictEntry *de; in clusterBroadcastPong() 3148 dictEntry *de; in clusterHandleSlaveMigration() [all …]
|
| H A D | debug.c | 183 dictEntry *de; in xorObjectDigest() 261 dictEntry *de; in computeDatasetDigest() 387 dictEntry *de; in debugCommand() 439 dictEntry *de; in debugCommand() 562 sizes = sdscatprintf(sizes,"dictentry:%d ",(int)sizeof(dictEntry)); in debugCommand() 1140 dictEntry *de; in logCurrentClient()
|
| H A D | t_hash.c | 91 dictEntry *de; in hashTypeGetFromHashTable() 240 dictEntry *de = dictFind(o->ptr,field); in hashTypeSet()
|
| H A D | module.c | 493 dictEntry *he = dictFind(server.moduleapi, funcname); in RM_GetApi() 763 dictEntry *de = dictFind(modules,modulename); in RM_IsModuleNameBusy() 2902 dictEntry *de; in moduleTypeLookupModuleByName() 2941 dictEntry *de; in moduleTypeLookupModuleByID() 4148 dictEntry *de; in RM_GetClusterNodesList() 4753 dictEntry *de = dictFind(server.sharedapi, apiname); in RM_GetSharedAPI() 4772 dictEntry *de; in moduleUnregisterSharedAPI() 5120 dictEntry *de; in moduleUnregisterCommands() 5281 dictEntry *de; in moduleCommand()
|
| H A D | t_zset.c | 1262 dictEntry *de = dictFind(zs->dict, member); in zsetScore() 1374 dictEntry *de; in zsetAdd() 1434 dictEntry *de; in zsetDel() 1507 dictEntry *de; in zsetRank() 1822 dictEntry *de; 2119 dictEntry *de; in zuiFind() 2315 dictEntry *de, *existing; in zunionInterGenericCommand()
|
| H A D | aof.c | 978 dictEntry *de; in rewriteSetObject() 1044 dictEntry *de; in rewriteSortedSetObject() 1291 dictEntry *de; in rewriteAppendOnlyFileRio()
|
| H A D | sort.c | 433 dictEntry *setele; in sortCommand()
|
| H A D | rdb.c | 790 dictEntry *de; in rdbSaveObject() 863 dictEntry *de; in rdbSaveObject() 1104 dictEntry *de; in rdbSaveRio()
|
| /f-stack/app/redis-5.0.5/deps/hiredis/ |
| H A D | dict.h | 45 typedef struct dictEntry { struct 48 struct dictEntry *next; argument 49 } dictEntry; typedef 61 dictEntry **table; 72 dictEntry *entry, *nextEntry; 121 static dictEntry * dictFind(dict *ht, const void *key); 123 static dictEntry *dictNext(dictIterator *iter);
|
| H A D | dict.c | 100 n.table = calloc(realsize,sizeof(dictEntry*)); in dictExpand() 107 dictEntry *he, *nextHe; in dictExpand() 137 dictEntry *entry; in dictAdd() 161 dictEntry *entry, auxentry; in dictReplace() 184 dictEntry *de, *prevde; in dictDelete() 218 dictEntry *he, *nextHe; in _dictClear() 243 static dictEntry *dictFind(dict *ht, const void *key) { in dictFind() 244 dictEntry *he; in dictFind() 268 static dictEntry *dictNext(dictIterator *iter) { in dictNext() 322 dictEntry *he; in _dictKeyIndex()
|
| H A D | async.c | 279 dictEntry *de; in __redisAsyncFree() 367 dictEntry *de; in __redisGetSubscribeCallback()
|
| /f-stack/app/redis-5.0.5/utils/hashtable/ |
| H A D | rehashing.c | 66 la = (long) (*((dictEntry**)a)); in sortPointers() 67 lb = (long) (*((dictEntry**)b)); in sortPointers() 74 dictEntry **des = zmalloc(sizeof(dictEntry*)*dictSize(d)); in stressGetKeys() 80 qsort(des,returned,sizeof(dictEntry*),sortPointers); in stressGetKeys()
|