fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-30 22:31:03 +00:00
Code Issues Projects Releases Wiki Activity

Cluster Manager: fix memory leak in clusterManagerWaitForClusterJoin

Browse Source
This commit is contained in:
artix 2018-06-06 18:45:31 +02:00
parent 3578aabc05
commit b013d2c4db
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/redis-cli.c
View File

@ -3413,11 +3413,12 @@ static void clusterManagerWaitForClusterJoin(void) {
sleep(1); sleep(1);
if (++counter > check_after) { if (++counter > check_after) {
dict *status = clusterManagerGetLinkStatus(); dict *status = clusterManagerGetLinkStatus();
dictIterator *iter = NULL;
if (status != NULL && dictSize(status) > 0) { if (status != NULL && dictSize(status) > 0) {
printf("\n"); printf("\n");
clusterManagerLogErr("Warning: %d node(s) may " clusterManagerLogErr("Warning: %d node(s) may "
"be unreachable\n", dictSize(status)); "be unreachable\n", dictSize(status));
dictIterator *iter = dictGetIterator(status); iter = dictGetIterator(status);
dictEntry *entry; dictEntry *entry;
while ((entry = dictNext(iter)) != NULL) { while ((entry = dictNext(iter)) != NULL) {
sds nodeaddr = (sds) dictGetKey(entry); sds nodeaddr = (sds) dictGetKey(entry);
@ -3447,11 +3448,11 @@ static void clusterManagerWaitForClusterJoin(void) {
"from standard instance port.\n"); "from standard instance port.\n");
listEmpty(from); listEmpty(from);
} }
dictReleaseIterator(iter);
dictRelease(status);
} }
if (iter != NULL) dictReleaseIterator(iter);
if (status != NULL) dictRelease(status);
counter = 0; counter = 0;
} }
} }
printf("\n"); printf("\n");
} }