SKALE-4586 Added concurrentqueue

acbb854d · kladko · 70c496f4 · acbb854d · acbb854d
Unverified Commit acbb854d authored Sep 09, 2021 by kladko
Hide whitespace changes
Inline Side-by-side

Showing with 3957 additions and 1 deletion

concurrentqueue.h third_party/concurrentqueue.h +3955 -0

ZMQServer.h zmq_src/ZMQServer.h +2 -1

No files found.
--- a/third_party/concurrentqueue.h
+++ b/third_party/concurrentqueue.h
--- a/zmq_src/ZMQServer.h
+++ b/zmq_src/ZMQServer.h
@@ -27,6 +27,7 @@


 #include "third_party/readerwriterqueue.h"
+#include "third_party/concurrentqueue.h"


 #include <zmq.hpp>
@@ -50,7 +51,7 @@ class ZMQServer : public Agent{
    string caCertFile;
    string caCert;

-    BlockingReaderWriterQueue<pair<Json::Value, shared_ptr<zmq::message_t>>> outgoingQueue;
+    ConcurrentQueue<pair<Json::Value, shared_ptr<zmq::message_t>>> outgoingQueue;

    vector<BlockingReaderWriterQueue<pair<shared_ptr<ZMQMessage>, shared_ptr<zmq::message_t>>>> incomingQueue;