From c6518afa7a611a59b00fe941cd53055066a02e41 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Tue, 12 May 2020 12:37:05 -0700 Subject: [PATCH] Make sure the streams clean up after themselves --- controller/PostgreSQL.cpp | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 31d5b9118..e3d513a06 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -761,6 +761,11 @@ void PostgreSQL::_membersWatcher_Redis() { 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"); } } + if (_rc->clusterMode) { + _cluster->xdel(key, id); + } else { + _redis->xdel(key, id); + } } } }