diff options
| author | Grant Limberg <[email protected]> | 2022-04-28 13:05:02 -0700 |
|---|---|---|
| committer | Grant Limberg <[email protected]> | 2022-04-28 13:05:02 -0700 |
| commit | 1c700b7b41c570e2a5498d11a3ee7f448875b2bc (patch) | |
| tree | e7de155baa7f57148ea834bfb190bbb88b6b0965 /controller/PostgreSQL.cpp | |
| parent | ff18bacd94d38c744173caacc3280220810b41c1 (diff) | |
Fix redis cluster usage
Diffstat (limited to 'controller/PostgreSQL.cpp')
| -rw-r--r-- | controller/PostgreSQL.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 7aefec9f..05dcc148 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -28,7 +28,7 @@ #include <chrono> -// #define ZT_TRACE 1 +// #define REDIS_TRACE 1 using json = nlohmann::json; @@ -950,18 +950,18 @@ void PostgreSQL::_membersWatcher_Redis() { } if (!result.empty()) { for (auto element : result) { - #ifdef ZT_TRACE + #ifdef REDIS_TRACE fprintf(stdout, "Received notification from: %s\n", element.first.c_str()); #endif for (auto rec : element.second) { std::string id = rec.first; auto attrs = rec.second; - #ifdef ZT_TRACE + #ifdef REDIS_TRACE fprintf(stdout, "Record ID: %s\n", id.c_str()); fprintf(stdout, "attrs len: %lu\n", attrs.size()); #endif for (auto a : attrs) { - #ifdef ZT_TRACE + #ifdef REDIS_TRACE fprintf(stdout, "key: %s\nvalue: %s\n", a.first.c_str(), a.second.c_str()); #endif try { @@ -1039,18 +1039,18 @@ void PostgreSQL::_networksWatcher_Redis() { if (!result.empty()) { for (auto element : result) { -#ifdef ZT_TRACE +#ifdef REDIS_TRACE fprintf(stdout, "Received notification from: %s\n", element.first.c_str()); #endif for (auto rec : element.second) { std::string id = rec.first; auto attrs = rec.second; -#ifdef ZT_TRACE +#ifdef REDIS_TRACE fprintf(stdout, "Record ID: %s\n", id.c_str()); fprintf(stdout, "attrs len: %lu\n", attrs.size()); #endif for (auto a : attrs) { -#ifdef ZT_TRACE +#ifdef REDIS_TRACE fprintf(stdout, "key: %s\nvalue: %s\n", a.first.c_str(), a.second.c_str()); #endif try { @@ -1515,7 +1515,7 @@ void PostgreSQL::onlineNotification_Redis() } } } catch (sw::redis::Error &e) { -#ifdef ZT_TRACE +#ifdef REDIS_TRACE fprintf(stderr, "Error in online notification thread (redis): %s\n", e.what()); #endif } |