|
@@ -45,6 +45,11 @@ public:
|
|
|
virtual void nodeIsOnline(const uint64_t networkId,const uint64_t memberId);
|
|
|
|
|
|
protected:
|
|
|
+ struct _PairHasher
|
|
|
+ {
|
|
|
+ inline std::size_t operator()(const std::pair<uint64_t,uint64_t> &p) const { return (std::size_t)(p.first ^ p.second); }
|
|
|
+ };
|
|
|
+
|
|
|
std::string _host;
|
|
|
std::string _db;
|
|
|
std::string _auth;
|
|
@@ -58,7 +63,7 @@ protected:
|
|
|
BlockingQueue< nlohmann::json * > _commitQueue;
|
|
|
std::thread _commitThread[ZT_CONTROLLER_RETHINKDB_COMMIT_THREADS];
|
|
|
|
|
|
- std::unordered_map< std::pair<uint64_t,uint64_t>,int64_t > _lastOnline;
|
|
|
+ std::unordered_map< std::pair<uint64_t,uint64_t>,int64_t,_PairHasher > _lastOnline;
|
|
|
mutable std::mutex _lastOnline_l;
|
|
|
std::thread _onlineNotificationThread;
|
|
|
|