diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-07-26 17:39:00 -0700 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2019-07-26 17:39:00 -0700 |
| commit | f6b080b8a2c071266270de23c7b99722b2cef21a (patch) | |
| tree | 1fbfdc4d07b1061a58b1eb64a6baa47082d0acc2 /controller/PostgreSQL.hpp | |
| parent | c8c33db1d12359e38dbe0cae80143963ea0b8c8a (diff) | |
| download | infinitytier-f6b080b8a2c071266270de23c7b99722b2cef21a.tar.gz infinitytier-f6b080b8a2c071266270de23c7b99722b2cef21a.zip | |
Abstract out change listener from controller itself to permit DBs to shadow changes from other DBs.
Diffstat (limited to 'controller/PostgreSQL.hpp')
| -rw-r--r-- | controller/PostgreSQL.hpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/controller/PostgreSQL.hpp b/controller/PostgreSQL.hpp index 779d47bd..f35f89fc 100644 --- a/controller/PostgreSQL.hpp +++ b/controller/PostgreSQL.hpp @@ -51,7 +51,7 @@ struct MQConfig; class PostgreSQL : public DB { public: - PostgreSQL(EmbeddedNetworkController *const nc, const Identity &myId, const char *path, int listenPort, MQConfig *mqc = NULL); + PostgreSQL(const Identity &myId, const char *path, int listenPort, MQConfig *mqc = NULL); virtual ~PostgreSQL(); virtual bool waitForReady(); @@ -78,7 +78,6 @@ private: void _networksWatcher_Postgres(PGconn *conn); void _networksWatcher_RabbitMQ(); - void commitThread(); void onlineNotificationThread(); @@ -93,7 +92,6 @@ private: BlockingQueue<nlohmann::json *> _commitQueue; - std::thread _heartbeatThread; std::thread _membersDbWatcher; std::thread _networksDbWatcher; @@ -116,4 +114,4 @@ private: #endif // ZT_CONTROLLER_LIBPQ_HPP -#endif // ZT_CONTROLLER_USE_LIBPQ
\ No newline at end of file +#endif // ZT_CONTROLLER_USE_LIBPQ |