Merge pull request #144 from ggggggggg/issue142

make send faster by calling get_events less often
JuliaInterop · Sep 1, 2017 · b1ed616 · b1ed616
2 parents cde187a + b5bc8bb
commit b1ed616
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/ZMQ.jl b/src/ZMQ.jl
@@ -450,7 +450,10 @@ function send(socket::Socket, zmsg::Message, SNDMORE::Bool=false)
                 wait(socket)
             end
         else
-            get_events(socket) != 0 && notify(socket)
+            notify_is_expensive = !isempty(socket.pollfd.notify.waitq)
+            if notify_is_expensive
+                get_events(socket) != 0 && notify(socket)
+            end
             break
         end
     end
@@ -482,7 +485,10 @@ function recv(socket::Socket)
                 wait(socket)
             end
         else
-            get_events(socket) != 0 && notify(socket)
+            notify_is_expensive = !isempty(socket.pollfd.notify.waitq)
+            if notify_is_expensive
+                get_events(socket) != 0 && notify(socket)
+            end
             break
         end
     end