summaryrefslogtreecommitdiff
path: root/controller/EmbeddedNetworkController.hpp
diff options
context:
space:
mode:
authorAdam Ierymenko <adam.ierymenko@gmail.com>2018-11-11 22:35:15 -0800
committerAdam Ierymenko <adam.ierymenko@gmail.com>2018-11-11 22:35:15 -0800
commitc9c17eaddd6380724a3b0360e8a2e5ae8f84a69c (patch)
treeeeded5f75c4e05ac7305d9706a541c4e76fc5f1e /controller/EmbeddedNetworkController.hpp
parent296e4616ccb6a78b5b52fc23e54b4a09d6805883 (diff)
downloadinfinitytier-c9c17eaddd6380724a3b0360e8a2e5ae8f84a69c.tar.gz
infinitytier-c9c17eaddd6380724a3b0360e8a2e5ae8f84a69c.zip
Retire RethinkDB, simple receive path multithreading.
Diffstat (limited to 'controller/EmbeddedNetworkController.hpp')
-rw-r--r--controller/EmbeddedNetworkController.hpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/controller/EmbeddedNetworkController.hpp b/controller/EmbeddedNetworkController.hpp
index df6d4a7b..c3f121c5 100644
--- a/controller/EmbeddedNetworkController.hpp
+++ b/controller/EmbeddedNetworkController.hpp
@@ -146,10 +146,13 @@ private:
Identity _signingId;
std::string _signingIdAddressString;
NetworkController::Sender *_sender;
+
std::unique_ptr<DB> _db;
BlockingQueue< _RQEntry * > _queue;
+
std::vector<std::thread> _threads;
std::mutex _threads_l;
+
std::unordered_map< _MemberStatusKey,_MemberStatus,_MemberStatusHash > _memberStatus;
std::mutex _memberStatus_l;
};