Zmq.hpp

chronolaw · chronolaw · commit 42baac719ef0 · 2020-04-10T10:57:25.000+08:00
diff --git a/section5/SalesData.hpp b/section5/SalesData.hpp
@@ -58,6 +58,16 @@ class SalesData final
     uint_type   m_sold      = 0;
     uint_type   m_revenue   = 0;
 
+public:
+    void inc_sold(uint_type s) noexcept
+    {
+        m_sold += s;
+    }
+
+    void inc_revenue(currency_type r) noexcept
+    {
+        m_revenue += r;
+    }
 public:
     string_view_type id() const noexcept
     {
diff --git a/section5/Zmq.hpp b/section5/Zmq.hpp
@@ -9,13 +9,19 @@
 
 BEGIN_NAMESPACE(cpp_study)
 
+using zmq_context_type  = zmq::context_t;
+using zmq_socket_type   = zmq::socket_t;
+using zmq_message_type  = zmq::message_t;
+
 template<int thread_num = 1>
 class ZmqContext final
 {
+#if 0
 public:
     using zmq_context_type  = zmq::context_t;
     using zmq_socket_type   = zmq::socket_t;
     using zmq_message_type  = zmq::message_t;
+#endif
 public:
     static
     zmq_context_type& context()
@@ -24,9 +30,15 @@ class ZmqContext final
         return ctx;
     }
 public:
-    zmq_socket_type socket(int mode) const
+    zmq_socket_type socket(int mode, size_t hwm = 1000) const
     {
-        return zmq_socket_type(context(), mode);
+        zmq_socket_type sock(context(), mode);
+
+        sock.setsockopt(
+            mode == ZMQ_PULL ? ZMQ_RCVHWM : ZMQ_SNDHWM,
+            hwm);
+
+        return sock;
     }
 };
 
diff --git a/section5/srv.cpp b/section5/srv.cpp
@@ -9,6 +9,7 @@
 #include "cpplang.hpp"
 #include "SalesData.hpp"
 #include "SpinLock.hpp"
+#include "Zmq.hpp"
 
 int main()
 {

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@`
`9`	`9`	`#include "cpplang.hpp"`
`10`	`10`	`#include "SalesData.hpp"`
`11`	`11`	`#include "SpinLock.hpp"`
	`12`	`+#include "Zmq.hpp"`
`12`	`13`
`13`	`14`	`int main()`
`14`	`15`	`{`