diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 05d2de7b1..28db4a867 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -1540,15 +1540,15 @@ void PostgreSQL::onlineNotification_Redis() std::lock_guard l(_lastOnline_l); lastOnline.swap(_lastOnline); } - - if (_rc->clusterMode) { - auto tx = _cluster->redis(controllerId).transaction(true); - _doRedisUpdate(tx, controllerId, lastOnline); - } else { - auto tx = _redis->transaction(true); - _doRedisUpdate(tx, controllerId, lastOnline); - } - + if (!lastOnline.empty()) { + if (_rc->clusterMode) { + auto tx = _cluster->redis(controllerId).transaction(true); + _doRedisUpdate(tx, controllerId, lastOnline); + } else { + auto tx = _redis->transaction(true); + _doRedisUpdate(tx, controllerId, lastOnline); + } + } std::this_thread::sleep_for(std::chrono::milliseconds(10)); } } @@ -1557,6 +1557,7 @@ void PostgreSQL::_doRedisUpdate(sw::redis::Transaction &tx, std::string &control std::unordered_map< std::pair,std::pair,_PairHasher > &lastOnline) { + fprintf(stderr, "Redis Update\n"); nlohmann::json jtmp1, jtmp2; for (auto i=lastOnline.begin(); i != lastOnline.end(); ++i) { uint64_t nwid_i = i->first.first;