Lines Matching refs:de
491 dictEntry *de; in clusterReset() local
510 while((de = dictNext(di)) != NULL) { in clusterReset()
511 clusterNode *node = dictGetVal(de); in clusterReset()
866 dictEntry *de; in clusterDelNode() local
880 while((de = dictNext(di)) != NULL) { in clusterDelNode()
881 clusterNode *node = dictGetVal(de); in clusterDelNode()
895 dictEntry *de; in clusterLookupNode() local
897 de = dictFind(server.cluster->nodes,s); in clusterLookupNode()
899 if (de == NULL) return NULL; in clusterLookupNode()
900 return dictGetVal(de); in clusterLookupNode()
929 dictEntry *de; in clusterGetMaxEpoch() local
932 while((de = dictNext(di)) != NULL) { in clusterGetMaxEpoch()
933 clusterNode *node = dictGetVal(de); in clusterGetMaxEpoch()
1085 dictEntry *de; in clusterBlacklistCleanup() local
1088 while((de = dictNext(di)) != NULL) { in clusterBlacklistCleanup()
1089 int64_t expire = dictGetUnsignedIntegerVal(de); in clusterBlacklistCleanup()
1092 dictDelete(server.cluster->nodes_black_list,dictGetKey(de)); in clusterBlacklistCleanup()
1099 dictEntry *de; in clusterBlacklistAddNode() local
1108 de = dictFind(server.cluster->nodes_black_list,id); in clusterBlacklistAddNode()
1109 dictSetUnsignedIntegerVal(de,time(NULL)+CLUSTER_BLACKLIST_TTL); in clusterBlacklistAddNode()
1217 dictEntry *de; in clusterHandshakeInProgress() local
1220 while((de = dictNext(di)) != NULL) { in clusterHandshakeInProgress()
1221 clusterNode *node = dictGetVal(de); in clusterHandshakeInProgress()
1227 return de != NULL; in clusterHandshakeInProgress()
2100 dictEntry *de; in clusterBroadcastMessage() local
2103 while((de = dictNext(di)) != NULL) { in clusterBroadcastMessage()
2104 clusterNode *node = dictGetVal(de); in clusterBroadcastMessage()
2236 dictEntry *de = dictGetRandomKey(server.cluster->nodes); in clusterSendPing() local
2237 clusterNode *this = dictGetVal(de); in clusterSendPing()
2311 dictEntry *de; in clusterBroadcastPong() local
2314 while((de = dictNext(di)) != NULL) { in clusterBroadcastPong()
2315 clusterNode *node = dictGetVal(de); in clusterBroadcastPong()
2902 dictEntry *de; in clusterHandleSlaveMigration() local
2927 while((de = dictNext(di)) != NULL) { in clusterHandleSlaveMigration()
2928 clusterNode *node = dictGetVal(de); in clusterHandleSlaveMigration()
3064 dictEntry *de; in clusterCron() local
3085 while((de = dictNext(di)) != NULL) { in clusterCron()
3086 clusterNode *node = dictGetVal(de); in clusterCron()
3158 de = dictGetRandomKey(server.cluster->nodes); in clusterCron()
3159 clusterNode *this = dictGetVal(de); in clusterCron()
3186 while((de = dictNext(di)) != NULL) { in clusterCron()
3187 clusterNode *node = dictGetVal(de); in clusterCron()
3364 dictEntry *de; in clusterMastersHaveSlaves() local
3366 while((de = dictNext(di)) != NULL) { in clusterMastersHaveSlaves()
3367 clusterNode *node = dictGetVal(de); in clusterMastersHaveSlaves()
3512 dictEntry *de; in clusterUpdateState() local
3516 while((de = dictNext(di)) != NULL) { in clusterUpdateState()
3517 clusterNode *node = dictGetVal(de); in clusterUpdateState()
3774 dictEntry *de; in clusterGenNodesDescription() local
3777 while((de = dictNext(di)) != NULL) { in clusterGenNodesDescription()
3778 clusterNode *node = dictGetVal(de); in clusterGenNodesDescription()
3821 dictEntry *de; in clusterReplyMultiBulkSlots() local
3823 while((de = dictNext(di)) != NULL) { in clusterReplyMultiBulkSlots()
3824 clusterNode *node = dictGetVal(de); in clusterReplyMultiBulkSlots()
4573 dictEntry *de = dictGetRandomKey(server.migrate_cached_sockets); in migrateGetSocket() local
4574 cs = dictGetVal(de); in migrateGetSocket()
4577 dictDelete(server.migrate_cached_sockets,dictGetKey(de)); in migrateGetSocket()
4631 dictEntry *de; in migrateCloseTimedoutSockets() local
4633 while((de = dictNext(di)) != NULL) { in migrateCloseTimedoutSockets()
4634 migrateCachedSocket *cs = dictGetVal(de); in migrateCloseTimedoutSockets()
4639 dictDelete(server.migrate_cached_sockets,dictGetKey(de)); in migrateCloseTimedoutSockets()
5181 dictEntry *de; in clusterRedirectBlockedClientIfNeeded() local
5191 while((de = dictNext(di)) != NULL) { in clusterRedirectBlockedClientIfNeeded()
5192 robj *key = dictGetKey(de); in clusterRedirectBlockedClientIfNeeded()