diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 31573705d..2a512bbc2 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -1483,8 +1483,10 @@ void PostgreSQL::commitThread() std::string key = "networks:{" + controllerId + "}"; if (_rc->clusterMode) { _cluster->srem(key, id); + _cluster->del("network-nodes-online:{"+controllerId+"}:"+id); } else { _redis->srem(key, id); + _redis->del("network-nodes-online:{"+controllerId+"}:"+id); } } catch (sw::redis::Error &e) { fprintf(stderr, "ERROR: Error adding network to Redis: %s\n", e.what()); @@ -1525,8 +1527,10 @@ void PostgreSQL::commitThread() std::string key = "network-nodes-all:{" + controllerId + "}:" + networkId; if (_rc->clusterMode) { _cluster->srem(key, memberId); + _cluster->del("member:{"+controllerId+"}:"+networkId+":"+memberId); } else { _redis->srem(key, memberId); + _redis->del("member:{"+controllerId+"}:"+networkId+":"+memberId); } } catch (sw::redis::Error &e) { fprintf(stderr, "ERROR: Error deleting member from Redis: %s\n", e.what());