mirror of
https://github.com/fluencelabs/redis
synced 2025-03-18 08:30:51 +00:00
Cluster: always use safe iteartors to iterate server.cluster->nodes.
This commit is contained in:
parent
43fe2d0d97
commit
e5d5da6f7c
@ -545,7 +545,7 @@ void clusterDelNode(clusterNode *delnode) {
|
||||
}
|
||||
|
||||
/* 2) Remove failure reports. */
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
|
||||
@ -1234,7 +1234,7 @@ void clusterBroadcastMessage(void *buf, size_t len) {
|
||||
dictIterator *di;
|
||||
dictEntry *de;
|
||||
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
|
||||
@ -1346,7 +1346,7 @@ void clusterBroadcastPong(void) {
|
||||
dictIterator *di;
|
||||
dictEntry *de;
|
||||
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
|
||||
@ -1647,7 +1647,7 @@ void clusterCron(void) {
|
||||
}
|
||||
|
||||
/* Iterate nodes to check if we need to flag something as failing */
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
time_t now = time(NULL);
|
||||
@ -1849,7 +1849,7 @@ void clusterUpdateState(void) {
|
||||
dictEntry *de;
|
||||
|
||||
server.cluster->size = 0;
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
|
||||
@ -1978,7 +1978,7 @@ sds clusterGenNodesDescription(void) {
|
||||
dictEntry *de;
|
||||
int j, start;
|
||||
|
||||
di = dictGetIterator(server.cluster->nodes);
|
||||
di = dictGetSafeIterator(server.cluster->nodes);
|
||||
while((de = dictNext(di)) != NULL) {
|
||||
clusterNode *node = dictGetVal(de);
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user