diff options
| author | Grant Limberg <[email protected]> | 2022-04-28 13:10:07 -0700 |
|---|---|---|
| committer | Grant Limberg <[email protected]> | 2022-04-28 13:10:07 -0700 |
| commit | 59151fbf860cff44d3c39639e1ac4bed60b9c781 (patch) | |
| tree | 227ce4584194e2440c0d0387f03f47d82b7dd549 /controller/PostgreSQL.cpp | |
| parent | 1c700b7b41c570e2a5498d11a3ee7f448875b2bc (diff) | |
remove max count for xread
Diffstat (limited to 'controller/PostgreSQL.cpp')
| -rw-r--r-- | controller/PostgreSQL.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 05dcc148..23064c59 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -944,9 +944,9 @@ void PostgreSQL::_membersWatcher_Redis() { json tmp; std::unordered_map<std::string, ItemStream> 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) { |