Zmq.hpp

chronolaw · chronolaw · commit a8751a05a65c · 2020-04-10T21:19:04.000+08:00
diff --git a/section5/SpinLock.hpp b/section5/SpinLock.hpp
@@ -7,6 +7,7 @@
 
 BEGIN_NAMESPACE(cpp_study)
 
+// atomic spinlock with TAS
 class SpinLock final
 {
 public:
@@ -43,6 +44,8 @@ class SpinLock final
     atomic_type m_lock {false};
 };
 
+// RAII for lock
+// you can change it to a template class
 class SpinLockGuard final
 {
 public:
diff --git a/section5/Zmq.hpp b/section5/Zmq.hpp
@@ -32,23 +32,23 @@ class ZmqContext final
     }
 public:
     static
-    zmq_socket_type recv_sock(int hwm = 1000)
+    zmq_socket_type recv_sock(int hwm = 1000, int linger = 10)
     {
         zmq_socket_type sock(context(), ZMQ_PULL);
 
         sock.setsockopt(ZMQ_RCVHWM, hwm);
-        sock.setsockopt(ZMQ_LINGER, 10);    // wait for 10ms
+        sock.setsockopt(ZMQ_LINGER, linger);    // wait for 10ms
 
         return sock;
     }
 
     static
-    zmq_socket_type send_sock(int hwm = 1000)
+    zmq_socket_type send_sock(int hwm = 1000, int linger = 10)
     {
         zmq_socket_type sock(context(), ZMQ_PUSH);
 
         sock.setsockopt(ZMQ_SNDHWM, hwm);
-        sock.setsockopt(ZMQ_LINGER, 10);    // wait for 10ms
+        sock.setsockopt(ZMQ_LINGER, linger);    // wait for 10ms
 
         return sock;
     }

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@`
`7`	`7`
`8`	`8`	`BEGIN_NAMESPACE(cpp_study)`
`9`	`9`
	`10`	`+// atomic spinlock with TAS`
`10`	`11`	`class SpinLock final`
`11`	`12`	`{`
`12`	`13`	`public:`
`@@ -43,6 +44,8 @@ class SpinLock final`
`43`	`44`	`atomic_type m_lock {false};`
`44`	`45`	`};`
`45`	`46`
	`47`	`+// RAII for lock`
	`48`	`+// you can change it to a template class`
`46`	`49`	`class SpinLockGuard final`
`47`	`50`	`{`
`48`	`51`	`public:`
Original file line number	Diff line number	Diff line change
`@@ -32,23 +32,23 @@ class ZmqContext final`
`32`	`32`	`}`
`33`	`33`	`public:`
`34`	`34`	`static`
`35`		`- zmq_socket_type recv_sock(int hwm = 1000)`
	`35`	`+ zmq_socket_type recv_sock(int hwm = 1000, int linger = 10)`
`36`	`36`	`{`
`37`	`37`	`zmq_socket_type sock(context(), ZMQ_PULL);`
`38`	`38`
`39`	`39`	`sock.setsockopt(ZMQ_RCVHWM, hwm);`
`40`		`- sock.setsockopt(ZMQ_LINGER, 10); // wait for 10ms`
	`40`	`+ sock.setsockopt(ZMQ_LINGER, linger); // wait for 10ms`
`41`	`41`
`42`	`42`	`return sock;`
`43`	`43`	`}`
`44`	`44`
`45`	`45`	`static`
`46`		`- zmq_socket_type send_sock(int hwm = 1000)`
	`46`	`+ zmq_socket_type send_sock(int hwm = 1000, int linger = 10)`
`47`	`47`	`{`
`48`	`48`	`zmq_socket_type sock(context(), ZMQ_PUSH);`
`49`	`49`
`50`	`50`	`sock.setsockopt(ZMQ_SNDHWM, hwm);`
`51`		`- sock.setsockopt(ZMQ_LINGER, 10); // wait for 10ms`
	`51`	`+ sock.setsockopt(ZMQ_LINGER, linger); // wait for 10ms`
`52`	`52`
`53`	`53`	`return sock;`
`54`	`54`	`}`