Make sure the streams clean up after themselves
This commit is contained in:
@@ -761,6 +761,11 @@ void PostgreSQL::_membersWatcher_Redis() {
|
|||||||
fprintf(stderr, "json parse error in networkWatcher_Redis\n");
|
fprintf(stderr, "json parse error in networkWatcher_Redis\n");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (_rc->clusterMode) {
|
||||||
|
_cluster->xdel(key, id);
|
||||||
|
} else {
|
||||||
|
_redis->xdel(key, id);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -873,6 +878,11 @@ void PostgreSQL::_networksWatcher_Redis() {
|
|||||||
fprintf(stderr, "json parse error in networkWatcher_Redis\n");
|
fprintf(stderr, "json parse error in networkWatcher_Redis\n");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if (_rc->clusterMode) {
|
||||||
|
_cluster->xdel(key, id);
|
||||||
|
} else {
|
||||||
|
_redis->xdel(key, id);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user