Lines Matching refs:nodes

407     server.cluster->nodes = dictCreate(&clusterNodesDictType,NULL);  in clusterInit()
509 di = dictGetSafeIterator(server.cluster->nodes); in clusterReset()
530 dictDelete(server.cluster->nodes,oldname); in clusterReset()
833 serverAssert(dictDelete(server.cluster->nodes,nodename) == DICT_OK); in freeClusterNode()
847 retval = dictAdd(server.cluster->nodes, in clusterAddNode()
879 di = dictGetSafeIterator(server.cluster->nodes); in clusterDelNode()
897 de = dictFind(server.cluster->nodes,s); in clusterLookupNode()
913 retval = dictDelete(server.cluster->nodes, s); in clusterRenameNode()
931 di = dictGetSafeIterator(server.cluster->nodes); in clusterGetMaxEpoch()
1219 di = dictGetSafeIterator(server.cluster->nodes); in clusterHandshakeInProgress()
2102 di = dictGetSafeIterator(server.cluster->nodes); in clusterBroadcastMessage()
2185 int freshnodes = dictSize(server.cluster->nodes)-2; in clusterSendPing()
2213 wanted = floor(dictSize(server.cluster->nodes)/10); in clusterSendPing()
2236 dictEntry *de = dictGetRandomKey(server.cluster->nodes); in clusterSendPing()
2313 di = dictGetSafeIterator(server.cluster->nodes); in clusterBroadcastPong()
2926 di = dictGetSafeIterator(server.cluster->nodes); in clusterHandleSlaveMigration()
3084 di = dictGetSafeIterator(server.cluster->nodes); in clusterCron()
3158 de = dictGetRandomKey(server.cluster->nodes); in clusterCron()
3185 di = dictGetSafeIterator(server.cluster->nodes); in clusterCron()
3363 dictIterator *di = dictGetSafeIterator(server.cluster->nodes); in clusterMastersHaveSlaves()
3515 di = dictGetSafeIterator(server.cluster->nodes); in clusterUpdateState()
3776 di = dictGetSafeIterator(server.cluster->nodes); in clusterGenNodesDescription()
3822 dictIterator *di = dictGetSafeIterator(server.cluster->nodes); in clusterReplyMultiBulkSlots()
4121 dictSize(server.cluster->nodes), in clusterCommand()
4338 } else if (dictSize(server.cluster->nodes) > 1) { in clusterCommand()