Lines Matching refs:di
490 dictIterator *di; in clusterReset() local
509 di = dictGetSafeIterator(server.cluster->nodes); in clusterReset()
510 while((de = dictNext(di)) != NULL) { in clusterReset()
516 dictReleaseIterator(di); in clusterReset()
865 dictIterator *di; in clusterDelNode() local
879 di = dictGetSafeIterator(server.cluster->nodes); in clusterDelNode()
880 while((de = dictNext(di)) != NULL) { in clusterDelNode()
886 dictReleaseIterator(di); in clusterDelNode()
928 dictIterator *di; in clusterGetMaxEpoch() local
931 di = dictGetSafeIterator(server.cluster->nodes); in clusterGetMaxEpoch()
932 while((de = dictNext(di)) != NULL) { in clusterGetMaxEpoch()
936 dictReleaseIterator(di); in clusterGetMaxEpoch()
1084 dictIterator *di; in clusterBlacklistCleanup() local
1087 di = dictGetSafeIterator(server.cluster->nodes_black_list); in clusterBlacklistCleanup()
1088 while((de = dictNext(di)) != NULL) { in clusterBlacklistCleanup()
1094 dictReleaseIterator(di); in clusterBlacklistCleanup()
1216 dictIterator *di; in clusterHandshakeInProgress() local
1219 di = dictGetSafeIterator(server.cluster->nodes); in clusterHandshakeInProgress()
1220 while((de = dictNext(di)) != NULL) { in clusterHandshakeInProgress()
1226 dictReleaseIterator(di); in clusterHandshakeInProgress()
2099 dictIterator *di; in clusterBroadcastMessage() local
2102 di = dictGetSafeIterator(server.cluster->nodes); in clusterBroadcastMessage()
2103 while((de = dictNext(di)) != NULL) { in clusterBroadcastMessage()
2111 dictReleaseIterator(di); in clusterBroadcastMessage()
2310 dictIterator *di; in clusterBroadcastPong() local
2313 di = dictGetSafeIterator(server.cluster->nodes); in clusterBroadcastPong()
2314 while((de = dictNext(di)) != NULL) { in clusterBroadcastPong()
2327 dictReleaseIterator(di); in clusterBroadcastPong()
2901 dictIterator *di; in clusterHandleSlaveMigration() local
2926 di = dictGetSafeIterator(server.cluster->nodes); in clusterHandleSlaveMigration()
2927 while((de = dictNext(di)) != NULL) { in clusterHandleSlaveMigration()
2966 dictReleaseIterator(di); in clusterHandleSlaveMigration()
3063 dictIterator *di; in clusterCron() local
3084 di = dictGetSafeIterator(server.cluster->nodes); in clusterCron()
3085 while((de = dictNext(di)) != NULL) { in clusterCron()
3148 dictReleaseIterator(di); in clusterCron()
3185 di = dictGetSafeIterator(server.cluster->nodes); in clusterCron()
3186 while((de = dictNext(di)) != NULL) { in clusterCron()
3270 dictReleaseIterator(di); in clusterCron()
3363 dictIterator *di = dictGetSafeIterator(server.cluster->nodes); in clusterMastersHaveSlaves() local
3366 while((de = dictNext(di)) != NULL) { in clusterMastersHaveSlaves()
3372 dictReleaseIterator(di); in clusterMastersHaveSlaves()
3511 dictIterator *di; in clusterUpdateState() local
3515 di = dictGetSafeIterator(server.cluster->nodes); in clusterUpdateState()
3516 while((de = dictNext(di)) != NULL) { in clusterUpdateState()
3525 dictReleaseIterator(di); in clusterUpdateState()
3773 dictIterator *di; in clusterGenNodesDescription() local
3776 di = dictGetSafeIterator(server.cluster->nodes); in clusterGenNodesDescription()
3777 while((de = dictNext(di)) != NULL) { in clusterGenNodesDescription()
3786 dictReleaseIterator(di); in clusterGenNodesDescription()
3822 dictIterator *di = dictGetSafeIterator(server.cluster->nodes); in clusterReplyMultiBulkSlots() local
3823 while((de = dictNext(di)) != NULL) { in clusterReplyMultiBulkSlots()
3876 dictReleaseIterator(di); in clusterReplyMultiBulkSlots()
4630 dictIterator *di = dictGetSafeIterator(server.migrate_cached_sockets); in migrateCloseTimedoutSockets() local
4633 while((de = dictNext(di)) != NULL) { in migrateCloseTimedoutSockets()
4642 dictReleaseIterator(di); in migrateCloseTimedoutSockets()
5182 dictIterator *di; in clusterRedirectBlockedClientIfNeeded() local
5190 di = dictGetIterator(c->bpop.keys); in clusterRedirectBlockedClientIfNeeded()
5191 while((de = dictNext(di)) != NULL) { in clusterRedirectBlockedClientIfNeeded()
5212 dictReleaseIterator(di); in clusterRedirectBlockedClientIfNeeded()