From 59151fbf860cff44d3c39639e1ac4bed60b9c781 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Thu, 28 Apr 2022 13:10:07 -0700 Subject: [PATCH] remove max count for xread --- controller/PostgreSQL.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 05dcc1483..23064c596 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -944,9 +944,9 @@ void PostgreSQL::_membersWatcher_Redis() { json tmp; std::unordered_map result; if (_rc->clusterMode) { - _cluster->xread(key, lastID, std::chrono::seconds(1), 10, std::inserter(result, result.end())); + _cluster->xread(key, lastID, std::chrono::seconds(1), 0, std::inserter(result, result.end())); } else { - _redis->xread(key, lastID, std::chrono::seconds(1), 10, std::inserter(result, result.end())); + _redis->xread(key, lastID, std::chrono::seconds(1), 0, std::inserter(result, result.end())); } if (!result.empty()) { for (auto element : result) {