diff options
| author | Grant Limberg <[email protected]> | 2020-05-22 10:07:39 -0700 |
|---|---|---|
| committer | Grant Limberg <[email protected]> | 2020-05-22 10:07:39 -0700 |
| commit | fb0e8aebdb1ed168c8ff2dd7e30d110db38d6f8f (patch) | |
| tree | c7fa00647837c721f3d2afc9422a2edc01c3b9e0 /controller/PostgreSQL.cpp | |
| parent | 13929aee6f48cb201d4575a0095cc03704255ebc (diff) | |
keep list of active networks in redis
Diffstat (limited to 'controller/PostgreSQL.cpp')
| -rw-r--r-- | controller/PostgreSQL.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 4de01172..6bc2b3a4 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -1714,6 +1714,7 @@ void PostgreSQL::_doRedisUpdate(sw::redis::Transaction &tx, std::string &control }; tx.zadd("nodes-online:{"+controllerId+"}", memberId, ts) .zadd("network-nodes-online:{"+controllerId+"}:"+networkId, memberId, ts) + .zadd("active-networks:{"+controllerId+"}", networkId, ts) .sadd("network-nodes-all:{"+controllerId+"}:"+networkId, memberId) .hmset("member:{"+controllerId+"}:"+networkId+":"+memberId, record.begin(), record.end()); } @@ -1745,7 +1746,7 @@ void PostgreSQL::_doRedisUpdate(sw::redis::Transaction &tx, std::string &control } tx.zremrangebyscore("nodes-online:{"+controllerId+"}", sw::redis::RightBoundedInterval<double>(expireOld, sw::redis::BoundType::LEFT_OPEN)); - + tx.zremrangebyscore("active-networks:{"+controllerId}"}", sw::redis::RightBoundedInterval<double>(expireOld, sw::redis::BoundType::LEFT_OPEN)); for(const auto &k : keys) { tx.zremrangebyscore(k, sw::redis::RightBoundedInterval<double>(expireOld, sw::redis::BoundType::LEFT_OPEN)); } |